ó H`¾Tc@sdZddlZddlmZmZmZddlmZm Z defd„ƒYZ d efd „ƒYZ d efd „ƒYZ e Z dS( s™ .. dialect:: mysql+oursql :name: OurSQL :dbapi: oursql :connectstring: mysql+oursql://:@[:]/ :url: http://packages.python.org/oursql/ Unicode ------- oursql defaults to using ``utf8`` as the connection charset, but other encodings may be used instead. Like the MySQL-Python driver, unicode support can be completely disabled:: # oursql sets the connection charset to utf8 automatically; all strings come # back as utf8 str create_engine('mysql+oursql:///mydb?use_unicode=0') To not automatically use ``utf8`` and instead use whatever the connection defaults to, there is a separate parameter:: # use the default connection charset; all strings come back as unicode create_engine('mysql+oursql:///mydb?default_charset=1') # use latin1 as the connection charset; all strings come back as unicode create_engine('mysql+oursql:///mydb?charset=latin1') iÿÿÿÿNi(tBITt MySQLDialecttMySQLExecutionContexti(ttypestutilt _oursqlBITcBseZd„ZRS(cCsdS(s'oursql already converts mysql bits, so.N(tNone(tselftdialecttcoltype((sf/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/dialects/mysql/oursql.pytresult_processor,s(t__name__t __module__R (((sf/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/dialects/mysql/oursql.pyR+stMySQLExecutionContext_oursqlcBseZed„ƒZRS(cCs|jjdtƒS(Nt_oursql_plain_query(texecution_optionstgettFalse(R((sf/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/dialects/mysql/oursql.pyt plain_query4s(R R tpropertyR(((sf/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/dialects/mysql/oursql.pyR 2stMySQLDialect_oursqlcBsreZdZejr$eZeZneZeZ eZ e Z ej ejiejej6ee6ƒZed„ƒZdd„Zd„Zd„Zd„Zd„Zeed„Zeed„Zdd „Zdd „Z dd „Z!dd „Z"dd „Z#d„Z$d„Z%ddd„Z&d„Z'd„Z(d„Z)d„Z*d„Z+dd„Z,dd„Z-dd„Z.RS(toursqlcCs tdƒS(NR(t __import__(tcls((sf/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/dialects/mysql/oursql.pytdbapiNscCs9|r%|jr%|j|dtƒn|j||ƒdS(sMProvide an implementation of *cursor.execute(statement, parameters)*.RN(RtexecutetTrue(Rtcursort statementt parameterstcontext((sf/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/dialects/mysql/oursql.pyt do_executeRscCs|jƒjddtƒdS(NtBEGINR(RRR(Rt connection((sf/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/dialects/mysql/oursql.pytdo_begin[scCsvtjr|jj|ƒ}n-|j}|jj|j|ƒƒj|ƒ}d|}|jdtƒj ||ƒdS(Ns'%s'R( Rtpy2kR!t_escape_stringt_connection_charsettencodetdecodeRRR(RR!tquerytxidtargtcharset((sf/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/dialects/mysql/oursql.pyt _xa_query^s     cCs|j|d|ƒdS(Ns XA BEGIN %s(R,(RR!R)((sf/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/dialects/mysql/oursql.pytdo_begin_twophasenscCs*|j|d|ƒ|j|d|ƒdS(Ns XA END %ss XA PREPARE %s(R,(RR!R)((sf/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/dialects/mysql/oursql.pytdo_prepare_twophaseqscCs3|s|j|d|ƒn|j|d|ƒdS(Ns XA END %ssXA ROLLBACK %s(R,(RR!R)t is_preparedtrecover((sf/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/dialects/mysql/oursql.pytdo_rollback_twophaseuscCs0|s|j||ƒn|j|d|ƒdS(Ns XA COMMIT %s(R.R,(RR!R)R/R0((sf/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/dialects/mysql/oursql.pytdo_commit_twophase{scCs(tj||jƒjdtƒ||ƒS(NR(Rt has_tabletconnectRR(RR!t table_nametschema((sf/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/dialects/mysql/oursql.pyR3ƒs cKs.tj||jƒjdtƒ|d||S(NRR6(Rtget_table_optionsR4RR(RR!R5R6tkw((sf/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/dialects/mysql/oursql.pyR7‹s cKs.tj||jƒjdtƒ|d||S(NRR6(Rt get_columnsR4RR(RR!R5R6R8((sf/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/dialects/mysql/oursql.pyR9”s cKs+tj||jƒjdtƒd||S(NRR6(Rtget_view_namesR4RR(RR!R6R8((sf/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/dialects/mysql/oursql.pyR:s cKs%tj||jƒjdtƒ|ƒS(NR(Rtget_table_namesR4RR(RR!R6R8((sf/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/dialects/mysql/oursql.pyR;¥scKs%tj||jƒjdtƒ|S(NR(Rtget_schema_namesR4RR(RR!R8((sf/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/dialects/mysql/oursql.pyR<¬scCstj||jdtƒƒS(NR(Rt initializeRR(RR!((sf/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/dialects/mysql/oursql.pyR=³scCs1tj||jdtƒjdtƒ|||ƒS(Ntclose_with_resultR(Rt_show_create_tabletcontextual_connectRR(RR!ttableR+t full_name((sf/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/dialects/mysql/oursql.pyR?¹s cCs\t||jjƒrK|jdkoJd|jdkoJ|jdjdƒS|jd kSdS( NRitclosediÖiÝiÞiýi(iÖiÝiÞiýi(t isinstanceRtProgrammingErrorterrnoRtargstendswith(RteR!R((sf/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/dialects/mysql/oursql.pyt is_disconnectÂs"cCsz|jddddddƒ}|j|jƒtj|dtƒtj|dtƒtj|d tƒtj|d tƒtj|d tƒ|jd tƒr¬d|d }y|jt|ƒƒWq1tk rn|j|ƒq1Xq1Wt|ƒS(Ns[.\-]( R!tretcompiletsplitt server_infotappendRat ValueErrorttuple(RR!t dbapi_contversiontrtn((sf/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/dialects/mysql/oursql.pyt_get_server_version_infoës  cCs|jS(N(RF(Rt exception((sf/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/dialects/mysql/oursql.pyt_extract_error_codeöscCs |jjS(s:Sniff out the character set in use for connection results.(R!R+(RR!((sf/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/dialects/mysql/oursql.pyt_detect_charsetùscCs |jƒS(s.oursql isn't super-broken like MySQLdb, yaaay.(tfetchall(RtrpR+((sf/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/dialects/mysql/oursql.pyt_compat_fetchallþscCs |jƒS(s.oursql isn't super-broken like MySQLdb, yaaay.(tfetchone(RRzR+((sf/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/dialects/mysql/oursql.pyt_compat_fetchonescCs |jƒS(N(tfirst(RRzR+((sf/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/dialects/mysql/oursql.pyt _compat_firstsN(/R R tdriverRR#Rtsupports_unicode_bindstsupports_unicode_statementstsupports_native_decimaltsupports_sane_rowcounttsupports_sane_multi_rowcountR texecution_ctx_clst update_copyRtcolspecstsqltypestTimeRRt classmethodRRRR"R,R-R.RR1R2R3R7R9R:R;R<R=R?RJRiRuRwRxR{R}R(((sf/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/dialects/mysql/oursql.pyR9sP                  "    (t__doc__RjtbaseRRRtRR‰RRR RR(((sf/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/dialects/mysql/oursql.pyt#s Ñ