D7net
Home
Console
Upload
information
Create File
Create Folder
About
Tools
:
/
proc
/
3206095
/
root
/
lib
/
python2.7
/
site-packages
/
pymysql
/
Filename :
connections.pyo
back
Copy
� �Y:Zc @ s d d l m Z d d l m Z m Z m Z m Z m Z m Z d d l Z d d l m Z d d l Z d d l Z d d l Z d d l Z d d l Z d d l Z d d l Z d d l Z d d l m Z m Z m Z d d l m Z m Z m Z m Z m Z d d l m Z d d l m! Z! d d l" m# Z# d d l$ m% Z% m& Z& d d l m' Z' y d d l( Z( e) Z* Wn e+ k r�e, Z( e- Z* n Xy d d l. Z. e. j/ � Z0 [. Wn e+ e1 f k r�e, Z0 n Xe- Z2 e j3 d Z4 e r�nh e4 d d f k rDg e5 d � D]. Z6 e6 d k r"e7 e6 � n e7 e6 d � ^ qZ8 d � Z9 n d � Z9 e oWe rvd d l: m; Z; d � Z< n d � Z< e= e j> e j? e j@ e jA e jB e jC e jD e jE e jF g � ZG e e jH d � ZI d ZJ d ZK d ZL d ZM d ZN d ZO d d d ZP d � ZQ d ZR d! � ZS d" � ZT d# ZU d$ eV f d% � � YZW d& � ZX d' � ZY d( � ZZ d) � Z[ d* eV f d+ � � YZ\ d, e\ f d- � � YZ] d. eV f d/ � � YZ^ d0 eV f d1 � � YZ_ d2 eV f d3 � � YZ` d4 eV f d5 � � YZa d6 eV f d7 � � YZb d8 eV f d9 � � YZc d S(: i����( t print_functioni ( t PY2t range_typet text_typet str_typet JYTHONt IRONPYTHONN( t partial( t MBLENGTHt charset_by_namet charset_by_id( t CLIENTt COMMANDt CRt FIELD_TYPEt SERVER_STATUS( t converters( t Cursor( t Parser( t byte2intt int2byte( t erri i i i i� i � c C s | j d � j t � S( Nt latin1( t decodet translatet _surrogateescape_table( t s( ( s7 /usr/lib/python2.7/site-packages/pymysql/connections.pyt _fast_surrogateescape5 s c C s | j d d � S( Nt asciit surrogateescape( R ( R ( ( s7 /usr/lib/python2.7/site-packages/pymysql/connections.pyR 8 s ( t SocketIOc C s t j t | | � � S( N( t iot BufferedReaderR ( t sockt mode( ( s7 /usr/lib/python2.7/site-packages/pymysql/connections.pyt _makefileC s c C s | j | � S( N( t makefile( R! R" ( ( s7 /usr/lib/python2.7/site-packages/pymysql/connections.pyR# G s t sha1i� i� i� i� R i c sH d � � yn t d t | � � xF t d d � D]5 } t j | � } t d | | j j | j f � q/ Wt d d � Wn t k r� n Xg t d t t | � d � d � D] } | | | d !^ q� } xb | D]Z } t d j t d � | � � d d t | � d d j t � f d � | � � � q� Wt d d � t � d S( Nc S sC d t | � k o d k n r? t | t � r; t | � S| Sd S( NiA iz t .( R t isinstancet intt chr( t data( ( s7 /usr/lib/python2.7/site-packages/pymysql/connections.pyt is_asciid s " s packet length:i i s call[%d]: %s (line %d)t -iB i i i t c S s d j t | � � S( Ns {:02X}( t formatR ( t x( ( s7 /usr/lib/python2.7/site-packages/pymysql/connections.pyt <lambda>u t s i R1 c s d j � | � � S( Ns {}( R. ( R/ ( R+ ( s7 /usr/lib/python2.7/site-packages/pymysql/connections.pyR0 w R1 s ( t printt lent ranget syst _getframet f_codet co_namet f_linenot ValueErrorR t mint joint map( R* t it ft dump_datat d( ( R+ s7 /usr/lib/python2.7/site-packages/pymysql/connections.pyt dump_packetc s $ ? .'i c C s� | s d St r' t d t | � � n t | � j � } t | � j � } t � } | j | t � | j | � | j � } t | | � S( NR1 s password=( t DEBUGR2 t strt sha_newt digestt updatet SCRAMBLE_LENGTHt _my_crypt( t passwordt messaget stage1t stage2R t result( ( s7 /usr/lib/python2.7/site-packages/pymysql/connections.pyt _scramble~ s c C s� t | � } d } xj t | � D]\ } t j d | | | d !� d t j d | | | d !� d A} | t j d | � 7} q W| S( NR1 t Bi i ( R3 R t structt unpackt pack( t message1t message2t lengthRN R> R/ ( ( s7 /usr/lib/python2.7/site-packages/pymysql/connections.pyRI � s "i t RandStruct_323c B s e Z d � Z d � Z RS( c C s- d | _ | | j | _ | | j | _ d S( Ni���?( t max_valuet seed1t seed2( t selfRY RZ ( ( s7 /usr/lib/python2.7/site-packages/pymysql/connections.pyt __init__� s c C sV | j d | j | j | _ | j | j d | j | _ t | j � t | j � S( Ni i! ( RY RZ RX t float( R[ ( ( s7 /usr/lib/python2.7/site-packages/pymysql/connections.pyt my_rnd� s ( t __name__t __module__R\ R^ ( ( ( s7 /usr/lib/python2.7/site-packages/pymysql/connections.pyRW � s c C s2 t | � } t | t � } t j d | � } t j d | � } t | d | d A| d | d A� } t j � } xJ t t t t | � � � D]- } | j t t | j � d � d � � q� Wt t | j � d � � } | j � } t j � } x1 | D]) } | j t t | � t | � A� � q� W| j � S( Ns >LLi i i i@ ( t _hash_password_323t SCRAMBLE_LENGTH_323RQ RR RW R t BytesIOR R; R3 t writeR R( R^ t getvalueR ( RJ RK t hash_passt hash_messaget hash_pass_nt hash_message_nt rand_stt outbuft _t extrat outt c( ( s7 /usr/lib/python2.7/site-packages/pymysql/connections.pyt _scramble_323� s "+ 'c C s� d } d } d } xy g | D] } | d k r t | � ^ q D]L } | | d @| | | d >d @N} | | d >| Ad @} | | d @} q> W| d @} | d @} t j d | | � S( Ni5W0Pi iqV4R- s i i i? i I���� i i s >LL( R- s i i I � i���I � i���( R RQ RS ( RJ t nrt addt nr2R/ Ro t r1t r2( ( s7 /usr/lib/python2.7/site-packages/pymysql/connections.pyRa � s 2" c C s t j d | � d S( Ns <Ii ( RQ RS ( t n( ( s7 /usr/lib/python2.7/site-packages/pymysql/connections.pyt pack_int24� s c C s� | d k r t d | � � n� | d k r5 t | � S| d k rU d t j d | � S| d k ry d t j d | � d S| d k r� d t j d | � St d | d f � � d S( Ni sF Encoding %d is less than 0 - no representation in LengthEncodedIntegeri� i i s �s <Hi s �s <Ii i@ s �s <QsI Encoding %x is larger than %x - no representation in LengthEncodedIntegeri i l l ( R: R RQ RS ( R> ( ( s7 /usr/lib/python2.7/site-packages/pymysql/connections.pyt lenenc_int� s t MysqlPacketc B s e Z d Z d Z d � Z d � Z d � Z d � Z d � Z d d � Z d d � Z e ri d � Z n d � Z d � Z d � Z d � Z d � Z d � Z d � Z d � Z d � Z d � Z d � Z d � Z d � Z d � Z d � Z d � Z d � Z RS( sr Representation of a MySQL response packet. Provides an interface for reading/parsing the packet results. t _positiont _datac C s d | _ | | _ d S( Ni ( Rz R{ ( R[ R* t encoding( ( s7 /usr/lib/python2.7/site-packages/pymysql/connections.pyR\ � s c C s | j S( N( R{ ( R[ ( ( s7 /usr/lib/python2.7/site-packages/pymysql/connections.pyt get_all_data� s c C s� | j | j | j | !} t | � | k r� d | t | � | j t | j � f } t rq t | � | j � n t | � � n | j | 7_ | S( sC Read the first 'size' bytes in packet and advance cursor past them.s\ Result length not requested length: Expected=%s. Actual=%s. Position: %s. Data Length: %s( R{ Rz R3 RC R2 t dumpt AssertionError( R[ t sizeRN t error( ( s7 /usr/lib/python2.7/site-packages/pymysql/connections.pyt read� s % c C s | j | j } d | _ | S( s` Read all remaining data in the packet. (Subsequent read() will return errors.) N( R{ Rz t None( R[ RN ( ( s7 /usr/lib/python2.7/site-packages/pymysql/connections.pyt read_all� s c C sT | j | } | d k s. | t | j � k rG t d | | f � � n | | _ d S( s1 Advance the cursor in data buffer 'length' bytes.i s4 Invalid advance amount (%s) for cursor. Position=%sN( Rz R3 R{ t Exception( R[ RV t new_position( ( s7 /usr/lib/python2.7/site-packages/pymysql/connections.pyt advance� s !i c C sA | d k s! | t | j � k r4 t d | � � n | | _ d S( s9 Set the position of the data buffer cursor to 'position'.i s) Invalid position to rewind cursor to: %s.N( R3 R{ R� Rz ( R[ t position( ( s7 /usr/lib/python2.7/site-packages/pymysql/connections.pyt rewind s !i c C s | j | | | !S( s> Get 'length' bytes starting at 'position'. Position is start of payload (first four packet header bytes are not included) starting at index '0'. No error checking is done. If requesting outside end of buffer an empty string (or string shorter than 'length') may be returned! ( R{ ( R[ R� RV ( ( s7 /usr/lib/python2.7/site-packages/pymysql/connections.pyt get_bytes s c C s) t | j | j � } | j d 7_ | S( Ni ( t ordR{ Rz ( R[ RN ( ( s7 /usr/lib/python2.7/site-packages/pymysql/connections.pyt read_uint8 s c C s# | j | j } | j d 7_ | S( Ni ( R{ Rz ( R[ RN ( ( s7 /usr/lib/python2.7/site-packages/pymysql/connections.pyR� s c C s2 t j d | j | j � d } | j d 7_ | S( Ns <Hi i ( RQ t unpack_fromR{ Rz ( R[ RN ( ( s7 /usr/lib/python2.7/site-packages/pymysql/connections.pyt read_uint16" s c C s< t j d | j | j � \ } } | j d 7_ | | d >S( Ns <HBi i ( RQ R� R{ Rz ( R[ t lowt high( ( s7 /usr/lib/python2.7/site-packages/pymysql/connections.pyt read_uint24' s !c C s2 t j d | j | j � d } | j d 7_ | S( Ns <Ii i ( RQ R� R{ Rz ( R[ RN ( ( s7 /usr/lib/python2.7/site-packages/pymysql/connections.pyt read_uint32, s c C s2 t j d | j | j � d } | j d 7_ | S( Ns <Qi i ( RQ R� R{ Rz ( R[ RN ( ( s7 /usr/lib/python2.7/site-packages/pymysql/connections.pyt read_uint641 s c C sL | j j d | j � } | d k r( d S| j | j | !} | d | _ | S( Ns i i ( R{ t findRz R� ( R[ t end_posRN ( ( s7 /usr/lib/python2.7/site-packages/pymysql/connections.pyt read_string6 s c C sr | j � } | t k r d S| t k r, | S| t k rB | j � S| t k rX | j � S| t k rn | j � Sd S( s� Read a 'Length Coded Binary' number from the data buffer. Length coded numbers can be anywhere from 1 to 9 bytes depending on the value of the first byte. N( R� t NULL_COLUMNR� t UNSIGNED_CHAR_COLUMNt UNSIGNED_SHORT_COLUMNR� t UNSIGNED_INT24_COLUMNR� t UNSIGNED_INT64_COLUMNR� ( R[ Ro ( ( s7 /usr/lib/python2.7/site-packages/pymysql/connections.pyt read_length_encoded_integer> s c C s) | j � } | d k r d S| j | � S( s Read a 'Length Coded String' from the data buffer. A 'Length Coded String' consists first of a length coded (unsigned, positive) integer represented in 1-9 bytes followed by that many bytes of binary data. (For example "cat" would be "3cat".) N( R� R� R� ( R[ RV ( ( s7 /usr/lib/python2.7/site-packages/pymysql/connections.pyt read_length_coded_stringP s c C s= t j | � } | j | j | j � } | j | j 7_ | S( N( RQ t StructR� R{ Rz R� ( R[ t fmtR RN ( ( s7 /usr/lib/python2.7/site-packages/pymysql/connections.pyt read_struct\ s c C s) | j d d !d k o( t | j � d k S( Ni i s i ( R{ R3 ( R[ ( ( s7 /usr/lib/python2.7/site-packages/pymysql/connections.pyt is_ok_packetb s c C s) | j d d !d k o( t | j � d k S( Ni i s �i ( R{ R3 ( R[ ( ( s7 /usr/lib/python2.7/site-packages/pymysql/connections.pyt is_eof_packetf s c C s | j d d !d k S( Ni i s �( R{ ( R[ ( ( s7 /usr/lib/python2.7/site-packages/pymysql/connections.pyt is_auth_switch_requestl s c C s. t | j d d !� } d | k o+ d k SS( Ni i i� ( R� R{ ( R[ t field_count( ( s7 /usr/lib/python2.7/site-packages/pymysql/connections.pyt is_resultset_packetp s c C s | j d d !d k S( Ni i s �( R{ ( R[ ( ( s7 /usr/lib/python2.7/site-packages/pymysql/connections.pyt is_load_local_packett s c C s | j d d !d k S( Ni i s �( R{ ( R[ ( ( s7 /usr/lib/python2.7/site-packages/pymysql/connections.pyt is_error_packetw s c C s\ | j � rX | j � | j d � | j � } t rE t d | � n t j | j � n d S( Ni s errno =( R� R� R� R� RC R2 R t raise_mysql_exceptionR{ ( R[ t errno( ( s7 /usr/lib/python2.7/site-packages/pymysql/connections.pyt check_errorz s c C s t | j � d S( N( RB R{ ( R[ ( ( s7 /usr/lib/python2.7/site-packages/pymysql/connections.pyR~ � s ( Rz R{ ( R_ R` t __doc__t __slots__R\ R} R� R� R� R� R� R R� R� R� R� R� R� R� R� R� R� R� R� R� R� R� R� R~ ( ( ( s7 /usr/lib/python2.7/site-packages/pymysql/connections.pyRy � s8 t FieldDescriptorPacketc B s; e Z d Z d � Z d � Z d � Z d � Z d � Z RS( s� A MysqlPacket that represents a specific column's metadata in the result. Parsing is automatically done and the results are exported via public attributes on the class such as: db, table_name, name, length, type_code. c C s$ t j | | | � | j | � d S( N( Ry R\ t _parse_field_descriptor( R[ R* R| ( ( s7 /usr/lib/python2.7/site-packages/pymysql/connections.pyR\ � s c C s� | j � | _ | j � | _ | j � j | � | _ | j � j | � | _ | j � j | � | _ | j � j | � | _ | j d � \ | _ | _ | _ | _ | _ d S( s� Parse the 'Field Descriptor' (Metadata) packet. This is compatible with MySQL 4.1+ (not compatible with MySQL 4.0). s <xHIBHBxxN( R� t catalogt dbR t table_namet org_tablet namet org_nameR� t charsetnrRV t type_codet flagst scale( R[ R| ( ( s7 /usr/lib/python2.7/site-packages/pymysql/connections.pyR� � s c C s; | j | j d | j � | j � | j | j d d k f S( sB Provides a 7-item tuple compatible with the Python PEP249 DB Spec.i i N( R� R� R� t get_column_lengthR� R� ( R[ ( ( s7 /usr/lib/python2.7/site-packages/pymysql/connections.pyt description� s c C s9 | j t j k r2 t j | j d � } | j | S| j S( Ni ( R� R t VAR_STRINGR t getR� RV ( R[ t mblen( ( s7 /usr/lib/python2.7/site-packages/pymysql/connections.pyR� � s c C s, d | j | j | j | j | j | j f S( Ns %s %r.%r.%r, type=%s, flags=%x( t __class__R� R� R� R� R� ( R[ ( ( s7 /usr/lib/python2.7/site-packages/pymysql/connections.pyt __str__� s ( R_ R` R� R\ R� R� R� R� ( ( ( s7 /usr/lib/python2.7/site-packages/pymysql/connections.pyR� � s t OKPacketWrapperc B s e Z d Z d � Z d � Z RS( s� OK Packet Wrapper. It uses an existing packet object, and wraps around it, exposing useful variables while still providing access to the original packet objects variables and methods. c C s� | j � s/ t d t | j j � d � � n | | _ | j j d � | j j � | _ | j j � | _ | j d � \ | _ | _ | j j � | _ | j t j @| _ d S( Ns Cannot create s object from invalid packet typei s <HH( R� R: RD R� R_ t packetR� R� t affected_rowst insert_idR� t server_statust warning_countR� RK R t SERVER_MORE_RESULTS_EXISTSt has_next( R[ t from_packet( ( s7 /usr/lib/python2.7/site-packages/pymysql/connections.pyR\ � s c C s t | j | � S( N( t getattrR� ( R[ t key( ( s7 /usr/lib/python2.7/site-packages/pymysql/connections.pyt __getattr__� s ( R_ R` R� R\ R� ( ( ( s7 /usr/lib/python2.7/site-packages/pymysql/connections.pyR� � s t EOFPacketWrapperc B s e Z d Z d � Z d � Z RS( s� EOF Packet Wrapper. It uses an existing packet object, and wraps around it, exposing useful variables while still providing access to the original packet objects variables and methods. c C s~ | j � s' t d j | j � � � n | | _ | j j d � \ | _ | _ t rg t d | j � n | j t j @| _ d S( Ns3 Cannot create '{0}' object from invalid packet types <xhhs server_status=( R� R: R. R� R� R� R� R� RC R2 R R� R� ( R[ R� ( ( s7 /usr/lib/python2.7/site-packages/pymysql/connections.pyR\ � s c C s t | j | � S( N( R� R� ( R[ R� ( ( s7 /usr/lib/python2.7/site-packages/pymysql/connections.pyR� � s ( R_ R` R� R\ R� ( ( ( s7 /usr/lib/python2.7/site-packages/pymysql/connections.pyR� � s t LoadLocalPacketWrapperc B s e Z d Z d � Z d � Z RS( s� Load Local Packet Wrapper. It uses an existing packet object, and wraps around it, exposing useful variables while still providing access to the original packet objects variables and methods. c C sc | j � s' t d j | j � � � n | | _ | j j � d | _ t r_ t d | j � n d S( Ns3 Cannot create '{0}' object from invalid packet typei s filename=( R� R: R. R� R� R} t filenameRC R2 ( R[ R� ( ( s7 /usr/lib/python2.7/site-packages/pymysql/connections.pyR\ � s c C s t | j | � S( N( R� R� ( R[ R� ( ( s7 /usr/lib/python2.7/site-packages/pymysql/connections.pyR� � s ( R_ R` R� R\ R� ( ( ( s7 /usr/lib/python2.7/site-packages/pymysql/connections.pyR� � s t Connectionc B s~ e Z d Z d1 Z d Z e Z d1 d1 d d1 d d1 d d1 d1 d1 d1 d e d1 d d1 d1 d1 d1 d1 e d1 d1 e d3 e i d1 d1 d1 e d � Z d � Z d � Z e d � � Z d � Z e Z d � Z d � Z d � Z d � Z d � Z d � Z d � Z d � Z d � Z d1 d � Z d � Z d � Z d � Z d1 d � Z d � Z d � Z e d � Z e d � Z! d � Z" d � Z# e$ d � Z% d � Z& d1 d! � Z' d" � Z( e) d# � Z* d$ � Z+ d% � Z, e d& � Z- d' � Z. d( � Z/ d) � Z0 d* � Z1 d+ � Z2 d, � Z3 d- � Z4 d. � Z5 d/ � Z6 d0 � Z7 e8 j9 Z9 e8 j: Z: e8 j; Z; e8 j< Z< e8 j= Z= e8 j> Z> e8 j? Z? e8 j@ Z@ e8 jA ZA e8 jB ZB RS(4 s Representation of a socket with a mysql server. The proper way to get an instance of this class is to call connect(). Establish a connection to the MySQL database. Accepts several arguments: :param host: Host where the database server is located :param user: Username to log in as :param password: Password to use. :param database: Database to use, None to not use a particular one. :param port: MySQL port to use, default is usually OK. (default: 3306) :param bind_address: When the client has multiple network interfaces, specify the interface from which to connect to the host. Argument can be a hostname or an IP address. :param unix_socket: Optionally, you can use a unix socket rather than TCP/IP. :param charset: Charset you want to use. :param sql_mode: Default SQL_MODE to use. :param read_default_file: Specifies my.cnf file to read these parameters from under the [client] section. :param conv: Conversion dictionary to use instead of the default one. This is used to provide custom marshalling and unmarshaling of types. See converters. :param use_unicode: Whether or not to default to unicode strings. This option defaults to true for Py3k. :param client_flag: Custom flags to send to MySQL. Find potential values in constants.CLIENT. :param cursorclass: Custom cursor class to use. :param init_command: Initial SQL statement to run when connection is established. :param connect_timeout: Timeout before throwing an exception when connecting. (default: 10, min: 1, max: 31536000) :param ssl: A dict of arguments similar to mysql_ssl_set()'s parameters. For now the capath and cipher arguments are not supported. :param read_default_group: Group to read from in the configuration file. :param compress: Not supported :param named_pipe: Not supported :param autocommit: Autocommit mode. None means use server default. (default: False) :param local_infile: Boolean to enable the use of LOAD DATA LOCAL command. (default: False) :param max_allowed_packet: Max size of packet sent to server in bytes. (default: 16MB) Only used to limit size of "LOAD LOCAL INFILE" data packet smaller than default (16KB). :param defer_connect: Don't explicitly connect on contruction - wait for connect call. (default: False) :param auth_plugin_map: A dict of plugin names to a class that processes that plugin. The class will take the Connection object as the argument to the constructor. The class needs an authenticate method taking an authentication packet as an argument. For the dialog plugin, a prompt(echo, prompt) method can be used (if no authenticate method) for returning a string from the user. (experimental) :param db: Alias for database. (for compatibility to MySQLdb) :param passwd: Alias for password. (for compatibility to MySQLdb) :param binary_prefix: Add _binary prefix on bytes and bytearray. (default: False) R1 i i i i c % s | d k r t j d t � n | d k rG t j d d k rG t } n | d k rh | d k rh | } n | d k r� | r� | } n | s� | r� t d � � n t | � | _ | j r� | t j O} n � r� | r� t j j d � r� d } q� d } n | r2� s d � n t � � � j t j j | � � � � f d � } | d | � } | d | � } | d | � } | d | � } | d | � } t | d | � � } | d | � } | d | � } | s�i } n t | t � r2xO d d d d d g D]5 }! | d |! | j |! � � }" |" r�|" | |! <q�q�Wq2n t | _ | r�t sVt d � � n t | _ | t j O} | j | � | _ n | p�d | _ | p�d | _ | p�t | _ | p�d | _! | | _" | | _# | | _$ d | k o�d k n st% d � � n | p d | _& | d k r9| d k r9t% d � � n | | _' | d k ri| d k rit% d � � n | | _( | r�| | _) t | _* n t+ | _) t | _* | d k r�| | _* n t, | j) � j- | _- | t j. O} | j" r�| t j/ O} n | | _0 | | _1 d | _2 d | _3 d | _4 | | _5 | d k r@t6 j7 } n t g | j8 � D]* \ }# }$ t9 |# � t k rP|# |$ f ^ qP� | _: t g | j8 � D]* \ }# }$ t9 |# � t k r�|# |$ f ^ q�� | _; | | _< | | _= | | _> | | _? | | _@ | r d | _A n | jB � d S(! Ns no_delay option is deprecatedi i s3 compress and named_pipe arguments are not supportedt wins c:\my.inis /etc/my.cnft clientc s7 | r | Sy � j � | � SWn t k r2 | SXd S( N( R� R� ( R� t arg( t cfgt read_default_group( s7 /usr/lib/python2.7/site-packages/pymysql/connections.pyt _configc s t userRJ t hostt databaset sockett ports bind-addresss default-character-sett cat capatht certR� t ciphers ssl-s ssl module not foundt localhosti� R1 i�3�s+ connect_timeout should be >0 and <=31536000s read_timeout should be >= 0s write_timeout should be >= 0s Not connected(C R� t warningst warnt DeprecationWarningR5 t version_infot Truet NotImplementedErrort boolt _local_infileR t LOCAL_FILESt platformt startswithR R� t ost patht expanduserR( R' t dictR� t Falset sslt SSL_ENABLEDt SSLt _create_ssl_ctxt ctxR� R� t DEFAULT_USERR� RJ R� t unix_sockett bind_addressR: t connect_timeoutt _read_timeoutt _write_timeoutt charsett use_unicodet DEFAULT_CHARSETR R| t CAPABILITIESt CONNECT_WITH_DBt client_flagt cursorclasst _resultt _affected_rowst host_infot autocommit_modeR t conversionst itemst typet encoderst decoderst sql_modet init_commandt max_allowed_packett _auth_plugin_mapt _binary_prefixt _sockt connect(% R[ R� R� RJ R� R� R� R� R t read_default_filet convR� R R R R� R� R� t compresst named_pipet no_delayt autocommitR� t passwdt local_infileR t defer_connectt auth_plugin_mapt read_timeoutt write_timeoutR� t binary_prefixR� R� t valuet kt v( ( R� R� s7 /usr/lib/python2.7/site-packages/pymysql/connections.pyR\ 9 s� FF c C s t | t j � r | S| j d � } | j d � } | d k oI | d k } t j d | d | � } | oz | j d t � | _ | r� t j n t j | _ d | k r� | j | d d | j d � �n d | k r� | j | d � n | j t j O_ | j t j O_ | S( NR� R� t cafilet check_hostnameR� t keyfileR� R� ( R' R� t SSLContextR� R� t create_default_contextR� R# t CERT_NONEt CERT_REQUIREDt verify_modet load_cert_chaint set_cipherst optionst OP_NO_SSLv2t OP_NO_SSLv3( R[ t sslpR� R� t hasnocaR� ( ( s7 /usr/lib/python2.7/site-packages/pymysql/connections.pyR� � s # c C s� | j r t j d � � n t | _ | j d k r7 d St j d d t j � } z) y | j | � Wn t k rv n XWd | j � Xd S( s* Send the quit message and close the sockets Already closedNs <iBi ( t _closedR t ErrorR� R R� RQ RS R t COM_QUITt _write_bytesR� t _force_close( R[ t send_data( ( s7 /usr/lib/python2.7/site-packages/pymysql/connections.pyt close� s c C s | j d k S( N( R R� ( R[ ( ( s7 /usr/lib/python2.7/site-packages/pymysql/connections.pyt open� s c C s= | j r' y | j j � Wq' q' Xn d | _ d | _ d S( s% Close connection without QUIT messageN( R R7 R� t _rfile( R[ ( ( s7 /usr/lib/python2.7/site-packages/pymysql/connections.pyR5 � s c C s8 t | � | _ | j � } | | k r4 | j � n d S( N( R� R t get_autocommitt _send_autocommit_mode( R[ R t current( ( s7 /usr/lib/python2.7/site-packages/pymysql/connections.pyR � s c C s t | j t j @� S( N( R� R� R t SERVER_STATUS_AUTOCOMMIT( R[ ( ( s7 /usr/lib/python2.7/site-packages/pymysql/connections.pyR: � s c C sI | j � } | j � s- t j d d � � n t | � } | j | _ | S( Ni� s Command Out of Sync( t _read_packetR� R t OperationalErrorR� R� ( R[ t pktt ok( ( s7 /usr/lib/python2.7/site-packages/pymysql/connections.pyt _read_ok_packet� s c C s1 | j t j d | j | j � � | j � d S( s2 Set whether or not to commit after every execute()s SET AUTOCOMMIT = %sN( t _execute_commandR t COM_QUERYt escapeR RB ( R[ ( ( s7 /usr/lib/python2.7/site-packages/pymysql/connections.pyR; � s c C s! | j t j d � | j � d S( s Begin transaction.t BEGINN( RC R RD RB ( R[ ( ( s7 /usr/lib/python2.7/site-packages/pymysql/connections.pyt begin s c C s! | j t j d � | j � d S( s Commit changes to stable storaget COMMITN( RC R RD RB ( R[ ( ( s7 /usr/lib/python2.7/site-packages/pymysql/connections.pyt commit s c C s! | j t j d � | j � d S( s! Roll back the current transactiont ROLLBACKN( RC R RD RB ( R[ ( ( s7 /usr/lib/python2.7/site-packages/pymysql/connections.pyt rollback s c C s0 | j t j d � t | � } | j � | j S( s SHOW WARNINGS( RC R RD t MySQLResultR� t rows( R[ RN ( ( s7 /usr/lib/python2.7/site-packages/pymysql/connections.pyt show_warnings s c C s! | j t j | � | j � d S( s Set current dbN( RC R t COM_INIT_DBRB ( R[ R� ( ( s7 /usr/lib/python2.7/site-packages/pymysql/connections.pyt select_db s c C s{ t | t � r$ d | j | � d St | t t f � rb | j | � } | j r^ d | } n | St j | | j d | �S( s� Escape whatever value you pass to it. Non-standard, for internal use; do not use this in your applications. t 't _binaryt mapping( R' R t escape_stringt bytest bytearrayt _quote_bytesR R t escape_itemR� ( R[ t objRS t ret( ( s7 /usr/lib/python2.7/site-packages/pymysql/connections.pyRE s c C s | j | | j � S( sr Alias for escape() Non-standard, for internal use; do not use this in your applications. ( RE R ( R[ RY ( ( s7 /usr/lib/python2.7/site-packages/pymysql/connections.pyt literal. s c C s- | j t j @r | j d d � St j | � S( NRQ s ''( R� R t" SERVER_STATUS_NO_BACKSLASH_ESCAPESt replaceR RT ( R[ R ( ( s7 /usr/lib/python2.7/site-packages/pymysql/connections.pyRT 5 s c C s: | j t j @r- d t | j d d � � f St j | � S( Ns '%s'RQ s ''( R� R R\ R R] R t escape_bytes( R[ R ( ( s7 /usr/lib/python2.7/site-packages/pymysql/connections.pyRW ; s c C s | r | | � S| j | � S( s+ Create a new cursor to execute queries with( R ( R[ t cursor( ( s7 /usr/lib/python2.7/site-packages/pymysql/connections.pyR_ A s c C s | j � S( s% Context manager that returns a Cursor( R_ ( R[ ( ( s7 /usr/lib/python2.7/site-packages/pymysql/connections.pyt __enter__G s c C s! | r | j � n | j � d S( s2 On successful exit, commit. On exception, rollbackN( RK RI ( R[ t excR t traceback( ( s7 /usr/lib/python2.7/site-packages/pymysql/connections.pyt __exit__K s c C s~ t | t � rO t p t rO t r7 | j | j � } qO | j | j d � } n | j t j | � | j d | � | _ | j S( NR t unbuffered( R' R R R R t encodeR| RC R RD t _read_query_resultR ( R[ t sqlRd ( ( s7 /usr/lib/python2.7/site-packages/pymysql/connections.pyt queryS s c C s | j d | � | _ | j S( NRd ( Rf R ( R[ Rd ( ( s7 /usr/lib/python2.7/site-packages/pymysql/connections.pyt next_result_ s c C s | j S( N( R ( R[ ( ( s7 /usr/lib/python2.7/site-packages/pymysql/connections.pyR� c s c C s/ t j d | � } | j t j | � | j � S( Ns <I( RQ RS RC R t COM_PROCESS_KILLRB ( R[ t thread_idR� ( ( s7 /usr/lib/python2.7/site-packages/pymysql/connections.pyt killf s c C s� | j d k r: | r( | j � t } q: t j d � � n y! | j t j d � | j � Wn4 t k r� | r� | j � | j t � q� � n Xd S( s Check if the server is alives Already closedR1 N( R R� R R� R R2 RC R t COM_PINGRB R� t ping( R[ t reconnect( ( s7 /usr/lib/python2.7/site-packages/pymysql/connections.pyRn k s c C sO t | � j } | j t j d | j | � � | j � | | _ | | _ d S( Ns SET NAMES %s( R R| RC R RD RE R> R� ( R[ R� R| ( ( s7 /usr/lib/python2.7/site-packages/pymysql/connections.pyt set_charset} s c C s t | _ yU| d k r�| j r� | j d k r� t j t j t j � } | j | j � | j | j � d | _ t rdt d � qdn� i } | j d k r� | j d f | d <n xj t r y) t j | j | j f | j | � } PWq� t t f k r} | j t j k rq� n � q� Xq� Wd | j | j f | _ t rKt d � n | j t j t j d � | j d � | j t j t j d � n | | _ t | d � | _ d | _ | j � | j � | j! d k r�| j" � } | j# d | j! f � n | j$ d k r;| j" � } | j# | j$ � | j% � | j& � n | j' d k r]| j( | j' � n Wn� t) k r} d | _ | d k r�y | j% � Wq�q�Xn t* | t t t j+ f � rt, j- d d | j | f � } | | _. t/ j0 � | _/ t rt | j/ � n | � n � n Xd S( NR� s 127.0.0.1s Localhost via UNIX sockets connected using unix_socketi t source_addresss socket %s:%ds connected using socketi t rbs SET sql_mode=%si� s( Can't connect to MySQL server on %r (%s)( R� s 127.0.0.1(1 R� R1 R� R� R� R� t AF_UNIXt SOCK_STREAMt settimeoutR� R R RC R2 R� R� t create_connectionR� t OSErrort IOErrorR� t EINTRt setsockoptt IPPROTO_TCPt TCP_NODELAYt SOL_SOCKETt SO_KEEPALIVER R# R9 t _next_seq_idt _get_server_informationt _request_authenticationR R_ t executeR R7 RI R R t BaseExceptionR' R� R R? t original_exceptionRb t format_exc( R[ R! t kwargst eRo Ra ( ( s7 /usr/lib/python2.7/site-packages/pymysql/connections.pyR � s| c C s[ t t | � � t | j � | } t r6 t | � n | j | � | j d d | _ d S( sw Writes an entire "mysql packet" in its entirety to the network addings its length and sequence number. i i N( Rw R3 R R RC RB R4 ( R[ t payloadR* ( ( s7 /usr/lib/python2.7/site-packages/pymysql/connections.pyt write_packet� s # c C s) d } x t r| j d � } t j d | � \ } } } | | d >} | | j k r� | j � | d k r� t j t j d � � n t j d | | j f � � n | j d d | _ | j | � } t r� t | � n | | 7} | d k r� q n | t k r Pq q W| | | j � } | j � | S( s� Read an entire "mysql packet" in its entirety from the network and return a MysqlPacket type that represents the results. R1 i s <HBBi i s, Lost connection to MySQL server during querys1 Packet sequence number wrong - got %d expected %di i i��� ( R� t _read_bytesRQ RR R R5 R R? R t CR_SERVER_LOSTt InternalErrorRC RB t MAX_PACKET_LENR| R� ( R[ t packet_typet bufft packet_headert btrlt btrht packet_numbert bytes_to_readt recv_dataR� ( ( s7 /usr/lib/python2.7/site-packages/pymysql/connections.pyR> � s4 c C s� | j j | j � x{ t r� y | j j | � } PWq t t f k r� } | j t j k rc q n | j � t j t j d | f � � q Xq Wt | � | k r� | j � t j t j d � � n | S( Ns1 Lost connection to MySQL server during query (%s)s, Lost connection to MySQL server during query( R Ru R� R� R9 R� Rx Rw R� Ry R5 R R? R R� R3 ( R[ t num_bytesR* R� ( ( s7 /usr/lib/python2.7/site-packages/pymysql/connections.pyR� � s" c C sg | j j | j � y | j j | � Wn9 t k rb } | j � t j t j d | f � � n Xd S( Ns MySQL server has gone away (%r)( R Ru R� t sendallRx R5 R R? R t CR_SERVER_GONE_ERROR( R[ R* R� ( ( s7 /usr/lib/python2.7/site-packages/pymysql/connections.pyR4 s c C s� | rB y t | � } | j � WqX t | _ d | _ � qX Xn t | � } | j � | | _ | j d k r | j | _ n | j S( N( RL t init_unbuffered_queryR� t unbuffered_activeR� t connectionR� R R� R� ( R[ Rd RN ( ( s7 /usr/lib/python2.7/site-packages/pymysql/connections.pyRf s c C s | j r | j j Sd Sd S( Ni ( R R� ( R[ ( ( s7 /usr/lib/python2.7/site-packages/pymysql/connections.pyR� + s c C s | j s t j d � � n | j d k r| | j j rS t j d � | j j � n x | j j ro | j � qV Wd | _ n t | t � r� | j | j � } n t t t | � d � } t j d | | � } | | | d } | j | � t r t | � n d | _ | t k rd S| | d } xQ t rzt t t | � � } | j | | � | | } | r*| t k r*Pq*q*Wd S( Ns (0, '')s. Previous unbuffered result was left incompletei s <iB( R R t InterfaceErrorR R� R� R� R� t _finish_unbuffered_queryR� Ri R' R Re R| R; R� R3 RQ RS R4 RC RB R R� R� ( R[ t commandRg t packet_sizet preludeR� ( ( s7 /usr/lib/python2.7/site-packages/pymysql/connections.pyRC 1 s6 c C s t | j j d d � d � d k r: | j t j O_ n | j d k rX t d � � n t | j � j } t | j t � r� | j j | j � | _ n t j d | j d | d � } | j r| j t j @r| j | � | j j | j d | j �| _ t | j d � | _ n | | j d } d } | j d k r[t | j j d � | j � } n | j t j @r�| t! t" | � � | 7} nA | j t j# @r�| t j d t" | � � | 7} n | | d 7} | j$ r#| j t j% @r#t | j$ t � r| j$ j | j � | _$ n | | j$ d 7} n | j t j& @rn| j } t | t � r]| j d � } n | | d 7} n | j | � | j' � } | j( � r| j) � | j* � } | j t j& @r�| d k r�| j+ | | � } qt, | j j d � | j � d } | j | � | j' � } n d S( NR& i i i s Did not specify a usernames <iIB23sR1 t server_hostnameRr s t mysql_native_passwordR RP R ( R1 R� (- R( t server_versiont splitR R t MULTI_RESULTSR� R� R: R R� t idR' R Re R| RQ RS R� t server_capabilitiesR� R� R� t wrap_socketR R� R# R9 t _auth_plugin_nameRO RJ t saltt PLUGIN_AUTH_LENENC_CLIENT_DATARx R3 t SECURE_CONNECTIONR� R� t PLUGIN_AUTHR> R� R� R� t _process_authRp ( R[ t charset_idt data_initR* t authrespR� t auth_packett plugin_name( ( s7 /usr/lib/python2.7/site-packages/pymysql/connections.pyR� W sP % !! # " c C s� | j j | � } | s6 | j j | j d � � } n | r� y | | � } | j | � SWq� t k r� | d k r� t j d d | | f � � q� q� t k r� t j d d | | f � � q� Xn d } | d k r� t | j j d � | j � � } n�| d k r1t | j j d � | j � � d } n�| d k rV| j j d � d } n}| d k r�| } xNt r�| j � } | d @d k } | d @d k } | j � } | d k r�| j | j j d � d � n� | rmd } y' | j | | � } | j | d � Wq�t k r7t j d d | | f � � q�t k rit j d d | | | | f � � q�Xn t j d d | | f � � | j � } | j � | j � s�| rkPqkqkW| St j d d | � � | j | � | j � } | j � | S( NR t dialogi sG Authentication plugin '%s' not loaded: - %r missing authenticate methodsX Authentication plugin '%s' not loaded: - %r cannot be constructed with connection objectR� R t mysql_old_passwords t mysql_clear_passwordi i i s Password: s3 no response - TypeError within plugin.prompt methodsA Authentication plugin '%s' not loaded: - %r missing prompt methodi sT Authentication plugin '%s' %r didn't respond with string. Returned '%r' to prompt %rs. Authentication plugin '%s' (%r) not configureds) Authentication plugin '%s' not configured( R R� R t authenticatet AttributeErrorR R? t TypeErrorR� RO RJ Re R� Rp R� R� R� t promptR> R� R� ( R[ R� R� t plugin_classt handlerR* R@ t flagt echot lastR� t resp( ( s7 /usr/lib/python2.7/site-packages/pymysql/connections.pyR� � sh $ ( c C s | j d S( Ni ( t server_thread_id( R[ ( ( s7 /usr/lib/python2.7/site-packages/pymysql/connections.pyRk � s c C s | j S( N( R� ( R[ ( ( s7 /usr/lib/python2.7/site-packages/pymysql/connections.pyt character_set_name� s c C s | j S( N( R ( R[ ( ( s7 /usr/lib/python2.7/site-packages/pymysql/connections.pyt get_host_info� s c C s | j S( N( t protocol_version( R[ ( ( s7 /usr/lib/python2.7/site-packages/pymysql/connections.pyt get_proto_info� s c C s� d } | j � } | j � } t | | | d !� | _ | d 7} | j d | � } | | | !j d � | _ | d } t j d | | | d !� | _ | d 7} | | | d !| _ | d 7} t j d | | | d !� d | _ | d 7} t | � | d k r�t j d | | | d !� \ } } } } | d 7} | | _ y t | � j | _ Wn t k rqd | _ n X| | _ t r�t d | � n | j | d >O_ t r�t d | � n t d | d � } n | d 7} t | � | | k r| j | | | | !7_ | | 7} n | d 7} | j t j @r�t | � | k r�| j d | � } | d k r{| | j d � | _ q�| | | !j d � | _ n d S( Ni i s R s <Ii i i s <Hi i s <BHHBs server_status: %xi s salt_len:i i ( R> R} R R� R� R R� RQ RR R� R� R� R3 t server_languageR R� t server_charsett KeyErrorR� R� RC R2 t maxR R� R� ( R[ R> R� R* t server_endt langt statt cap_ht salt_len( ( s7 /usr/lib/python2.7/site-packages/pymysql/connections.pyR� � sN $ ) " c C s | j S( N( R� ( R[ ( ( s7 /usr/lib/python2.7/site-packages/pymysql/connections.pyt get_server_info s Ni @ i (C R_ R` R� R� R R� R� R1 R R\ R� R7 t propertyR8 R5 t __del__R R: RB R; RG RI RK RN RP RE R[ RT RW R_ R` Rc Rh Ri R� Rl R� Rn Rp R R� Ry R> R� R4 Rf R� RC R� R� Rk R� R� R� R� R� R t WarningR2 R� t DatabaseErrort DataErrorR? t IntegrityErrorR� t ProgrammingErrort NotSupportedError( ( ( s7 /usr/lib/python2.7/site-packages/pymysql/connections.pyR� � s� 7 z H $ & = ? ? RL c B s} e Z d � Z d � Z d � Z d � Z d � Z d � Z d � Z d � Z d � Z d � Z d � Z d � Z d � Z RS( c C sg | | _ d | _ d | _ d | _ d | _ d | _ d | _ d | _ d | _ d | _ t | _ d S( s. :type connection: Connection i N( R� R� R� R� R� R� RK R� R� RM R� R� R� ( R[ R� ( ( s7 /usr/lib/python2.7/site-packages/pymysql/connections.pyR\ / s c C s | j r | j � n d S( N( R� R� ( R[ ( ( s7 /usr/lib/python2.7/site-packages/pymysql/connections.pyR� ? s c C si zX | j j � } | j � r. | j | � n) | j � rJ | j | � n | j | � Wd d | _ Xd S( N( R� R> R� RB R� t _read_load_local_packett _read_result_packetR� ( R[ t first_packet( ( s7 /usr/lib/python2.7/site-packages/pymysql/connections.pyR� C s c C s� t | _ | j j � } | j � rF | j | � t | _ d | _ nP | j � rt | j | � t | _ d | _ n" | j � | _ | j � d | _ d S( Nl ���� ( R� R� R� R> R� RB R� R� R� R� R� R� t _get_descriptionsR� ( R[ R� ( ( s7 /usr/lib/python2.7/site-packages/pymysql/connections.pyR� P s c C sX t | � } | j | _ | j | _ | j | _ | j | _ | j | _ | j | _ d S( N( R� R� R� R� R� RK R� ( R[ R� t ok_packet( ( s7 /usr/lib/python2.7/site-packages/pymysql/connections.pyRB e s c C s� | j j s t d � � n t | � } t | j | j � } y | j � Wn | j j � � n X| j j � } | j � s� t j d d � � n | j | � d S( NsF **WARN**: Received LOAD_LOCAL packet but local_infile option is false.i� s Commands Out of Sync( R� R� t RuntimeErrorR� t LoadLocalFileR� R6 R> R� R R? RB ( R[ R� t load_packett senderR� ( ( s7 /usr/lib/python2.7/site-packages/pymysql/connections.pyR� n s c C s8 | j � s t St | � } | j | _ | j | _ t S( N( R� R� R� R� R� R� ( R[ R� t wp( ( s7 /usr/lib/python2.7/site-packages/pymysql/connections.pyt _check_packet_is_eof s c C s' | j � | _ | j � | j � d S( N( R� R� R� t _read_rowdata_packet( R[ R� ( ( s7 /usr/lib/python2.7/site-packages/pymysql/connections.pyR� � s c C sr | j s d S| j j � } | j | � rJ t | _ d | _ d | _ d S| j | � } d | _ | f | _ | S( Ni ( R� R� R> R� R� R� RM t _read_row_from_packetR� ( R[ R� t row( ( s7 /usr/lib/python2.7/site-packages/pymysql/connections.pyt _read_rowdata_packet_unbuffered� s c C sG x@ | j rB | j j � } | j | � r t | _ d | _ q q Wd S( N( R� R� R> R� R� R� ( R[ R� ( ( s7 /usr/lib/python2.7/site-packages/pymysql/connections.pyR� � s c C sv g } xK t rS | j j � } | j | � r: d | _ Pn | j | j | � � q Wt | � | _ t | � | _ d S( s: Read a rowdata packet for each data row in the result set.N( R� R� R> R� R� t appendR� R3 R� t tupleRM ( R[ RM R� ( ( s7 /usr/lib/python2.7/site-packages/pymysql/connections.pyR� � s c C s� g } x� | j D]� \ } } y | j � } Wn t k r@ Pn X| d k r� | d k rk | j | � } n t r� t d | � n | d k r� | | � } q� n | j | � q Wt | � S( Ns DEBUG: DATA = ( R R� t IndexErrorR� R RC R2 R� R� ( R[ R� R� R| t converterR* ( ( s7 /usr/lib/python2.7/site-packages/pymysql/connections.pyR� � s c C sf g | _ g | _ | j j } | j j } g } xt | j � D] } | j j t � } | j j | � | j | j � � | j } | r� | t j k r� | } q� | t k r� | j d k r� d } q� | } q� d } n d } | j j j | � } | t j k r d } n t r*t d j | | � � n | j j | | f � q@ W| j j � } t | � | _ d S( s> Read a column descriptor packet for each column in the result.i? R s DEBUG: field={}, converter={}N( t fieldsR R� R� R| R R� R> R� R� R� R� R t JSONt TEXT_TYPESR� R� R R� t throughRC R2 R. R� ( R[ R� t conn_encodingR� R> t fieldt field_typeR| R� t eof_packet( ( s7 /usr/lib/python2.7/site-packages/pymysql/connections.pyR� � s6 ( R_ R` R\ R� R� R� RB R� R� R� R� R� R� R� R� ( ( ( s7 /usr/lib/python2.7/site-packages/pymysql/connections.pyRL - s R� c B s e Z d � Z d � Z RS( c C s | | _ | | _ d S( N( R� R� ( R[ R� R� ( ( s7 /usr/lib/python2.7/site-packages/pymysql/connections.pyR\ � s c C s� | j j s t j d � � n | j } z� yd t | j d � �L } t | j d � } x0 t r� | j | � } | sv Pn | j | � qW WWd QXWn/ t k r� t j d d j | j � � � n XWd | j d � Xd S( s3 Send data packets from the local file to the servers (0, '')Rr i i Ni� s Can't find file '{0}'R1 i @ ( R� R R R� R8 R� R; R R� R� R� Rx R? R. ( R[ t connt open_fileR� t chunk( ( s7 /usr/lib/python2.7/site-packages/pymysql/connections.pyR6 � s &( R_ R` R\ R6 ( ( ( s7 /usr/lib/python2.7/site-packages/pymysql/connections.pyR� � s (d t __future__R t _compatR R R R R R R� t functoolsR t hashlibR R� R� RQ R5 Rb R� R� R R R t constantsR R R R R R1 R t cursorsR t optionfileR t utilR R R R� R� R� t ImportErrorR� R� t getpasst getuserR� R� RC R� t _py_versionR4 R> R) R R t _socketioR R# t sett BITt BLOBt LONG_BLOBt MEDIUM_BLOBt STRINGt TINY_BLOBR� t VARCHARt GEOMETRYR� t newRE R� R� R� R� R� R� R� RB RH RO RI Rb t objectRW Rp Ra Rw Rx Ry R� R� R� R� R� RL R� ( ( ( s7 /usr/lib/python2.7/site-packages/pymysql/connections.pyt <module> s� . ( A �2� � � 4�