/
opt
/
alt
/
python27
/
lib64
/
python2.7
/
site-packages
/
sqlalchemy
/
dialects
/
mysql
/
up file
home
� 1��fc @ s� d Z d d l m Z d d l m Z d d l m Z d d l m Z d d l m Z d e f d � � YZ d e f d � � YZ d e f d � � YZ e Z d S( s� .. dialect:: mysql+oursql :name: OurSQL :dbapi: oursql :connectstring: mysql+oursql://<user>:<password>@<host>[:<port>]/<dbname> :url: https://packages.python.org/oursql/ .. note:: The OurSQL MySQL dialect is legacy and is no longer supported upstream, and is **not tested as part of SQLAlchemy's continuous integration**. The recommended MySQL dialects are mysqlclient and PyMySQL. .. deprecated:: 1.4 The OurSQL DBAPI is deprecated and will be removed in a future version. Please use one of the supported DBAPIs to connect to mysql. Unicode ------- Please see :ref:`mysql_unicode` for current recommendations on unicode handling. i ( t BIT( t MySQLDialect( t MySQLExecutionContexti ( t types( t utilt _oursqlBITc B s e Z d � Z RS( c C s d S( s' oursql already converts mysql bits, so.N( t None( t selft dialectt coltype( ( sS /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/dialects/mysql/oursql.pyt result_processor, s ( t __name__t __module__R ( ( ( sS /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/dialects/mysql/oursql.pyR + s t MySQLExecutionContext_oursqlc B s e Z e d � � Z RS( c C s | j j d t � S( Nt _oursql_plain_query( t execution_optionst gett False( R ( ( sS /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/dialects/mysql/oursql.pyt plain_query3 s ( R R t propertyR ( ( ( sS /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/dialects/mysql/oursql.pyR 2 s t MySQLDialect_oursqlc B so e Z d Z e Z e j r* e Z e Z n e Z e Z e Z e Z e j e j i e j e j 6e e 6� Z e d � � Z d d � Z d � Z d � Z d � Z d � Z e e d � Z e e d � Z d d � Z d d � Z! d d � Z" d d � Z# d d � Z$ d � Z% d � Z& d d d � Z' d � Z( d � Z) d � Z* d � Z+ d d � Z, d d � Z- d d � Z. RS( t oursqlc C s t j d d d �t d � S( Ns� The OurSQL DBAPI is deprecated and will be removed in a future version. Please use one of the supported DBAPIs to connect to mysql.t versions 1.4R ( R t warn_deprecatedt __import__( t cls( ( sS /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/dialects/mysql/oursql.pyt dbapiJ s c C s9 | r% | j r% | j | d t �n | j | | � d S( sM Provide an implementation of *cursor.execute(statement, parameters)*.R N( R t executet True( R t cursort statementt parameterst context( ( sS /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/dialects/mysql/oursql.pyt do_executeT s c C s | j � j d d t �d S( Nt BEGINR ( R R R ( R t connection( ( sS /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/dialects/mysql/oursql.pyt do_begin] s c C sv t j r | j j | � } n- | j } | j j | j | � � j | � } d | } | j d t � j | | � d S( Ns '%s'R ( R t py2kR# t _escape_stringt _connection_charsett encodet decodeR R t exec_driver_sql( R R# t queryt xidt argt charset( ( sS /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/dialects/mysql/oursql.pyt _xa_query` s c C s | j | d | � d S( Ns XA BEGIN %s( R/ ( R R# R, ( ( sS /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/dialects/mysql/oursql.pyt do_begin_twophaser s c C s* | j | d | � | j | d | � d S( Ns XA END %ss XA PREPARE %s( R/ ( R R# R, ( ( sS /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/dialects/mysql/oursql.pyt do_prepare_twophaseu s c C s3 | s | j | d | � n | j | d | � d S( Ns XA END %ss XA ROLLBACK %s( R/ ( R R# R, t is_preparedt recover( ( sS /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/dialects/mysql/oursql.pyt do_rollback_twophasey s c C s0 | s | j | | � n | j | d | � d S( Ns XA COMMIT %s( R1 R/ ( R R# R, R2 R3 ( ( sS /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/dialects/mysql/oursql.pyt do_commit_twophase� s c C s( t j | | j � j d t � | | � S( NR ( R t has_tablet connectR R ( R R# t table_namet schema( ( sS /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/dialects/mysql/oursql.pyR6 � s c K s. t j | | j � j d t � | d | | �S( NR R9 ( R t get_table_optionsR7 R R ( R R# R8 R9 t kw( ( sS /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/dialects/mysql/oursql.pyR: � s c K s. t j | | j � j d t � | d | | �S( NR R9 ( R t get_columnsR7 R R ( R R# R8 R9 R; ( ( sS /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/dialects/mysql/oursql.pyR< � s c K s+ t j | | j � j d t � d | | �S( NR R9 ( R t get_view_namesR7 R R ( R R# R9 R; ( ( sS /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/dialects/mysql/oursql.pyR= � s c K s% t j | | j � j d t � | � S( NR ( R t get_table_namesR7 R R ( R R# R9 R; ( ( sS /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/dialects/mysql/oursql.pyR> � s c K s% t j | | j � j d t � | � S( NR ( R t get_schema_namesR7 R R ( R R# R; ( ( sS /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/dialects/mysql/oursql.pyR? � s c C s t j | | j d t � � S( NR ( R t initializeR R ( R R# ( ( sS /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/dialects/mysql/oursql.pyR@ � s c C s1 t j | | j d t � j d t � | | | � S( Nt close_with_resultR ( R t _show_create_tableR7 R R ( R R# t tableR. t full_name( ( sS /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/dialects/mysql/oursql.pyRB � s c C s\ t | | j j � rK | j d k oJ d | j d k oJ | j d j d � S| j d k Sd S( NR i t closedi� i� i� i� i ( i� i� i� i� i ( t isinstanceR t ProgrammingErrort errnoR t argst endswith( R t eR# R ( ( sS /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/dialects/mysql/oursql.pyt is_disconnect� s c C sz | j d d d d d d � } | j | j � t j | d t � t j | d t � t j | d t � t j | d t � t j | d t � | j d t � r� d | d <n t j | d t � | j d t � | d <t j | d t � | j d t � i } x\ d d d d d g D]E } | | k r| | | | d <t j | | d t � | | =qqW| rp| | d <n g | g S( Nt databaset dbt usernamet usert passwordt passwdt portt compresst autopingt raise_on_warningst default_charsetR. t use_unicodet found_rowst ssl_cat ssl_keyt ssl_certt ssl_capatht ssl_cipheri t ssl( t translate_connect_argst updateR+ R t coerce_kw_typet intt boolt popR R t strR R t setdefault( R t urlt optsR_ t key( ( sS /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/dialects/mysql/oursql.pyt create_connect_args� s8 c C s | j S( N( RH ( R t exception( ( sS /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/dialects/mysql/oursql.pyt _extract_error_code� s c C s | j j S( s: Sniff out the character set in use for connection results.( R# R. ( R R# ( ( sS /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/dialects/mysql/oursql.pyt _detect_charset s c C s | j � S( s. oursql isn't super-broken like MySQLdb, yaaay.( t fetchall( R t rpR. ( ( sS /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/dialects/mysql/oursql.pyt _compat_fetchall s c C s | j � S( s. oursql isn't super-broken like MySQLdb, yaaay.( t fetchone( R Rp R. ( ( sS /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/dialects/mysql/oursql.pyt _compat_fetchone s c C s | j � S( N( t first( R Rp R. ( ( sS /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/dialects/mysql/oursql.pyt _compat_first s N(/ R R t driverR t supports_statement_cacheR R% t supports_unicode_bindst supports_unicode_statementst supports_native_decimalt supports_sane_rowcountt supports_sane_multi_rowcountR t execution_ctx_clst update_copyR t colspecst sqltypest TimeR R t classmethodR R R! R$ R/ R0 R1 R R4 R5 R6 R: R< R= R> R? R@ RB RL Rk Rm Rn Rq Rs Ru ( ( ( sS /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/dialects/mysql/oursql.pyR 8 sD # ( N( t __doc__t baseR R R t R R� R R R R R ( ( ( sS /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/dialects/mysql/oursql.pyt <module>! s �