3 de)W @sJdZddlZddlZddlZddlZddlZddlmZyHddlZej ej ej dZ e edrdejneje d<e edo|ejZWnek rdZYnXdd lmZmZmZmZmZmZd d lmZd d lmZmZmZd d l m!Z!d dl"m#Z#e$e%dddZ&e'e(ee'dddZ)GdddZ*Gddde*Z+Gddde*Z,dS)zGModule implementing low-level socket communication with MySQL servers. N)deque)TLSv1zTLSv1.1zTLSv1.2 PROTOCOL_TLSzTLSv1.3 HAS_TLSv1_3F)AnyDequeListOptionalTupleUnion)MAX_PACKET_LENGTH)InterfaceErrorNotSupportedErrorOperationalError)StrOrBytesPath)init_bytearray)errreturncCs |jst|S|jd|jS)z_Reformat the IOError error message This function reformats the IOError error message.  )errnostrstrerror)rrN/var/www/agendate/envp3/lib/python3.6/site-packages/mysql/connector/network.py _strioerrorEsr)bufpktnrrcCsg}t|}t}xJ||krZ|jdtjd||d|||d}t|}|d}qW|jtjd|ddtjd|||S)z0Prepare a packet for sending to the MySQL serverszy |jjtj|jj|`Wnttfk r8YnXdS)z&Shut down the socket before closing itN)r)shutdownsocket SHUT_RDWRcloser-AttributeErrorOSError)r/rrrr7s  zBaseMySQLSocket.shutdownc Cs0y|jj|`Wnttfk r*YnXdS)zClose the socketN)r)r:r-r;r<)r/rrrclose_connections  z BaseMySQLSocket.close_connectioncCs |jdS)N)r7)r/rrr__del__szBaseMySQLSocket.__del__)r packet_numbercompressed_packet_numberrcCs|}|dkr|jn||_t||j}x|D]~}y|jj|Wq.tk r~}z td|jt|fd|WYdd}~Xq.t k r}ztdd|WYdd}~Xq.Xq.WdS)z Send packets to the MySQL serverNi)rvaluesi)r) r2r+r&r)sendallIOErrorrr6rr;)r/rr?r@_packetspacketrrrr send_plains   zBaseMySQLSocket.send_plaincCs|dkr|jn||_|dkr*|jn||_|j}t|}g}t}||krt||}dj|} ~tj | dd} t j dt| ddt j d|jd} |j | | | dd} t| }|jxt||kr@tj | d|} t j dt| ddt j d|jd } |j | | | |d} t| }|jqW| rtj | } t j dt| ddt j d|jt j d|dd} |j | | ~ nt j d|ddt j d||} t| }|d kr$tj | } |j t j dt| ddt j d|jt j d|dd| nDt j d|ddt j d|jt j dddd} |j | | x|D]} y|j j| Wnltk r}z td |jt|fd |WYdd}~Xn0tk r}ztd d|WYdd}~XnXqnWdS)z+Send compressed packets to the MySQL serverNi@zt||kr|jj|t|}|stdd||}qW|dkrJ|j ||jj}|d|_|S|j||f|d krdPt d}|jjd}x.|rt|dkr||7}|jjd}qzWqxWWn>tk r} z td |jt| fd | WYdd} ~ XnXt d} x |D]\}} | tj| 7} qW|j | ~ y|jj}|d|_|Stk rRYnXdS)z0Receive compressed packets from the MySQL serverrrHr i)rzbytesr rGsendrOrRr[rSr^rerhrboolrrrrrrrr']s4  N"L r'csXeZdZdZdeddfdd Zeddd Zddd d Zeedd d dZ Z S)MySQLUnixSocketzoMySQL socket class using UNIX sockets Opens a connection through the UNIX socket of the MySQL Server. /tmp/mysql.sockN) unix_socketrcstj||_dS)N)superr0r)r/r) __class__rrr0s zMySQLUnixSocket.__init__)rcCs|jS)N)r)r/rrrr6szMySQLUnixSocket.get_addresscCsy2tjtjtj|_|jj|j|jj|jWnjtk rn}z t d|j t |fd|WYdd}~Xn0t k r}zt t ||WYdd}~XnXdS)Ni)rrA)r8AF_UNIX SOCK_STREAMr)rgr*connectrrCrr6r Exceptionr)r/rrrrr5szMySQLUnixSocket.open_connection)argskwargsrcOstjdtdS)zSwitch the socket to use SSL.z2SSL is disabled when using unix socket connectionsN)warningswarnWarning)r/rrrrrrszMySQLUnixSocket.switch_to_ssl)r) rrrrrr0r6r5rr __classcell__rr)rrrs rcsJeZdZdZdeeeddfdd Zed d d Zdd d d Z Z S)MySQLTCPSocketzXMySQL socket class using TCP/IP Opens a TCP/IP connection to the MySQL Server. 127.0.0.1 FN)hostport force_ipv6rcs&tj||_||_||_d|_dS)Nr)rr0r. server_portr_family)r/rrr)rrrr0s  zMySQLTCPSocket.__init__)rcCs|jd|jS)N:)r.r)r/rrrr6(szMySQLTCPSocket.get_addressc Csd}ytj|j|jdtjtj}x:|D]2}|jrD|dtjkrD|}P|dtjkr&|}Pq&W|jr~|ddkr~t d|j|ddkr|d}Wn<t k r}z t d|j t |fd|WYdd}~XnX|\|_ }}}}y0tj|j |||_|jj|j|jj|Wnpt k rR}z"t d|j|jt |fd|WYdd}~Xn2tk r}ztt||WYdd}~XnXdS)z.Open the TCP/IP connection to the MySQL serverNrzNo IPv6 address found for i)rrA)NNNNN)r8 getaddrinfor.rrSOL_TCPrAF_INET6AF_INETrrCr6rrr)rgr*rrrr) r/addrinfoZ addrinfosinforsocktypeprotorDsockaddrrrrr5+sJ     zMySQLTCPSocket.open_connection)rrF) rrrrrrrr0r6r5rrr)rrrs r)-rrr8r!rrK collectionsrrtPROTOCOL_TLSv1PROTOCOL_TLSv1_1PROTOCOL_TLSv1_2r|rrPROTOCOL_SSLv23rr{ ImportErrortypingrrrr r r constantsr errorsrrrtypesrutilsrrCrrrrr&r'rrrrrr s:         %