/
opt
/
alt
/
python27
/
lib64
/
python2.7
/
site-packages
/
sqlalchemy
/
dialects
/
mysql
/
up file
home
� 1��fc @ s� d Z d d l 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 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+mysqldb :name: mysqlclient (maintained fork of MySQL-Python) :dbapi: mysqldb :connectstring: mysql+mysqldb://<user>:<password>@<host>[:<port>]/<dbname> :url: https://pypi.org/project/mysqlclient/ Driver Status ------------- The mysqlclient DBAPI is a maintained fork of the `MySQL-Python <https://sourceforge.net/projects/mysql-python>`_ DBAPI that is no longer maintained. `mysqlclient`_ supports Python 2 and Python 3 and is very stable. .. _mysqlclient: https://github.com/PyMySQL/mysqlclient-python .. _mysqldb_unicode: Unicode ------- Please see :ref:`mysql_unicode` for current recommendations on unicode handling. .. _mysqldb_ssl: SSL Connections ---------------- The mysqlclient and PyMySQL DBAPIs accept an additional dictionary under the key "ssl", which may be specified using the :paramref:`_sa.create_engine.connect_args` dictionary:: engine = create_engine( "mysql+mysqldb://scott:tiger@192.168.0.134/test", connect_args={ "ssl": { "ca": "/home/gord/client-ssl/ca.pem", "cert": "/home/gord/client-ssl/client-cert.pem", "key": "/home/gord/client-ssl/client-key.pem" } } ) For convenience, the following keys may also be specified inline within the URL where they will be interpreted into the "ssl" dictionary automatically: "ssl_ca", "ssl_cert", "ssl_key", "ssl_capath", "ssl_cipher", "ssl_check_hostname". An example is as follows:: connection_uri = ( "mysql+mysqldb://scott:tiger@192.168.0.134/test" "?ssl_ca=/home/gord/client-ssl/ca.pem" "&ssl_cert=/home/gord/client-ssl/client-cert.pem" "&ssl_key=/home/gord/client-ssl/client-key.pem" ) .. seealso:: :ref:`pymysql_ssl` in the PyMySQL dialect Using MySQLdb with Google Cloud SQL ----------------------------------- Google Cloud SQL now recommends use of the MySQLdb dialect. Connect using a URL like the following:: mysql+mysqldb://root@/<dbname>?unix_socket=/cloudsql/<projectid>:<instancename> Server Side Cursors ------------------- The mysqldb dialect supports server-side cursors. See :ref:`mysql_ss_cursors`. i����Ni ( t MySQLCompiler( t MySQLDialect( t MySQLExecutionContext( t MySQLIdentifierPreparer( t TEXTi ( t sql( t utilt MySQLExecutionContext_mysqldbc B s e Z e d � � Z RS( c C s$ t | d � r | j S| j j Sd S( Nt _rowcount( t hasattrR t cursort rowcount( t self( ( sT /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/dialects/mysql/mysqldb.pyR b s ( t __name__t __module__t propertyR ( ( ( sT /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/dialects/mysql/mysqldb.pyR a s t MySQLCompiler_mysqldbc B s e Z RS( ( R R ( ( ( sT /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/dialects/mysql/mysqldb.pyR j s t MySQLDialect_mysqldbc B s� e Z d Z e Z e Z e Z e Z e Z d Z e Z e Z e Z d � Z d � Z e j j d � � Z e d � � Z d � Z d � Z d � Z d d � Z d � Z d d � Z d � Z d � Z d � Z! e" d d d d d g � Z# d � Z$ RS( t mysqldbt formatc K sY t t | � j | � | j d k rL t | j d � rL | j | j j � n d | _ d S( Nt __version__i ( i i i ( t superR t __init__t dbapit NoneR t _parse_dbapi_versionR t _mysql_dbapi_version( R t kwargs( ( sT /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/dialects/mysql/mysqldb.pyR | s 6c C sC t j d | � } | r; t d � | j d d d � D� � Sd Sd S( Ns (\d+)\.(\d+)(?:\.(\d+))?c s s' | ] } | d k r t | � Vq d S( N( R t int( t .0t x( ( sT /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/dialects/mysql/mysqldb.pys <genexpr>� s i i i i ( i i i ( t ret matcht tuplet group( R t versiont m( ( sT /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/dialects/mysql/mysqldb.pyR � s #c C sB y# t d � j } | j | _ t SWn t t f k r= t SXd S( Ns MySQLdb.cursors( t __import__t cursorst SSCursort _sscursort Truet ImportErrort AttributeErrort False( R R& ( ( sT /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/dialects/mysql/mysqldb.pyt supports_server_side_cursors� s c C s t d � S( Nt MySQLdb( R% ( t cls( ( sT /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/dialects/mysql/mysqldb.pyR � s c s( t t | � j � � � f d � } | S( Nc s_ � d k r � | � n | j � } | d k r[ | j � } | j d | � | j � n d S( Ns SET NAMES %s( R t character_set_nameR t executet close( t connt charset_nameR ( t super_( sT /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/dialects/mysql/mysqldb.pyt on_connect� s ( R R R6 ( R R6 ( ( R5 sT /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/dialects/mysql/mysqldb.pyR6 � s c C s | j � S( N( t ping( R t dbapi_connection( ( sT /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/dialects/mysql/mysqldb.pyt _ping_impl� s c C sQ y | j | � Wn5 | j j k rH } | j | | d � rB t S� n Xt Sd S( N( R9 R t Errort is_disconnectR R, R) ( R R8 t err( ( sT /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/dialects/mysql/mysqldb.pyt do_ping� s c C s. | j | | � } | d k r* | | _ n d S( N( t executemanyR R ( R R t statementt parameterst contextR ( ( sT /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/dialects/mysql/mysqldb.pyt do_executemany� s c C s� | j d | j j d � | j j d � f � j � } | j d k oI | } | r� t j t j t j d � t d d � � d � g } n g } t t | � j | | � S( Ns: show collation where %s = 'utf8mb4' and %s = 'utf8mb4_bin't Charsett Collationi s 'test collated returns't charsett utf8mb4t utf8mb4_bin( i ( t exec_driver_sqlt identifier_preparert quotet scalart server_version_infoR t collatet castt literal_columnR R R t _check_unicode_returns( R t connectiont collationt has_utf8mb4_bint additional_tests( ( sT /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/dialects/mysql/mysqldb.pyRP � s c C s� | d k r* t d d d d d d � } n | j | � } | j | j � t j | d t � t j | d t � t j | d t � t j | d t � t j | d t � t j | d t � t j | d t � t j | d t � i } d t f d t f d t f d t f d t f d t f g } xS | D]K \ } } | | k r*| | | | d <t j | | d | � | | =q*q*W| r�| | d <n | j d d � } | j � } | d k r�| | O} | | d <n g | g S( Nt databaset dbt usernamet usert passwordt passwdt compresst connect_timeoutt read_timeoutt write_timeoutt client_flagt local_infilet use_unicodeRE t ssl_cat ssl_keyt ssl_certt ssl_capatht ssl_ciphert ssl_check_hostnamei t ssli ( R t dictt translate_connect_argst updatet queryR t coerce_kw_typet boolR t strt gett _found_rows_client_flag( R t urlt _translate_argst optsRh t keyst keyt kw_typeR_ t client_flag_found_rows( ( sT /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/dialects/mysql/mysqldb.pyt create_connect_args� sB c C s\ | j d k rT y t | j j d � j j } Wn t t f k rI d SX| j Sn d Sd S( Ns .constants.CLIENT( R R R% R t constantst CLIENTR+ R* t FOUND_ROWS( R t CLIENT_FLAGS( ( sT /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/dialects/mysql/mysqldb.pyRq s c C s | j d S( Ni ( t args( R t exception( ( sT /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/dialects/mysql/mysqldb.pyt _extract_error_code s c C s= y | j j } Wn t k r1 t j d � d SX| � Sd S( s: Sniff out the character set in use for connection results.s� No 'character_set_name' can be detected with this MySQL-Python version; please upgrade to a recent version of MySQL-Python. Assuming latin1.t latin1N( RQ R0 R+ R t warn( R RQ t cset_name( ( sT /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/dialects/mysql/mysqldb.pyt _detect_charset s t SERIALIZABLEs READ UNCOMMITTEDs READ COMMITTEDs REPEATABLE READt AUTOCOMMITc C sF | d k r | j t � n& | j t � t t | � j | | � d S( NR� ( t autocommitR) R, R R t _set_isolation_level( R RQ t level( ( sT /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/dialects/mysql/mysqldb.pyR� 7 s N(% R R t driverR) t supports_statement_cachet supports_unicode_statementst supports_sane_rowcountt supports_sane_multi_rowcountt supports_native_decimalt default_paramstyleR t execution_ctx_clsR t statement_compilerR t preparerR R R t langhelperst memoized_propertyR- t classmethodR R6 R9 R= R RB RP Ry Rq R� R� t sett _isolation_lookupR� ( ( ( sT /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/dialects/mysql/mysqldb.pyR n s< 3 ( t __doc__R t baseR R R R R t R R R R R t dialect( ( ( sT /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/dialects/mysql/mysqldb.pyt <module>T s �