a cfz |jtj|j|`Wntjtfy8Yn0dS)z&Shut down the socket before closing itN)r'shutdownsocket SHUT_RDWRcloser+errorAttributeErrorr,rrrr6s  zBaseMySQLSocket.shutdownc Cs0z|j|`Wntjtfy*Yn0dS)zClose the socketN)r'r9r+r7r:r;r,rrrclose_connections  z BaseMySQLSocket.close_connectioncCs |dSN)r6r,rrr__del__szBaseMySQLSocket.__del__Nc Cs|dur|jn||_t||j}|D]p}z|j|Wq&tyx}z&tjd|t |fdWYd}~q&d}~0t ytjddYq&0q&dS)z Send packets to the MySQL serverNrvaluesr) r0r)r$r'sendallIOErrorr OperationalErrorr5rr;)r-r packet_numbercompressed_packet_numberpacketspacketrrrr send_plains  zBaseMySQLSocket.send_plainc Cs|dur|jn||_|dur&|jn||_|j}t|}g}tj}||krt||}d|} ~t | dd} t dt| ddt d|jd} | | | | dd} t| }|j||kr8t | d|} t dt| ddt d|jd } | | | | |d} t| }|jq| rt | } t dt| ddt d|jt d|dd} | | | ~ nt d|ddt d||} t| }|d krt | } | t dt| ddt d|jt d|dd| nDt d|ddt d|jt dddd} | | | |D]v} z|j| Wn^ty}z&tjd |t|fd WYd}~n(d}~0tytjd dYn0qbdS)z+Send compressed packets to the MySQL serverN@rrrrs@r2r?r@rBrC)r0r)r1r*rr rr$joinzlibcompressrrrr'rDrEr rFr5rr;)r-rrGrHr r"Zzpktsr#r!ZtmpbufZzbufheaderpktZ zip_packetrrrrsend_compresseds               zBaseMySQLSocket.send_compressedc Cs"ztd}d}|dkrH|jd|}|s6tjdd||7}t|}q|d|_td|dddd}|}| t|t |}|dd }|r|j ||}|dkr|dkrtjdd||d }||8}q|WSt y}z&tj d |t|fd WYd }~n d }~00d S) %Receive packets from the MySQL serverrLrrCrrNr?r@) bytearrayr'recvr r rr)runpackextend memoryview recv_intorErFr5r) r-rJZ packet_lenchunk payload_lenrestZ packet_viewreadrrrr recv_plains4       zBaseMySQLSocket.recv_plainc Csztd}d}|dkrH|jd|}|s6tjdd||7}t|}q|d|_td|dddd}|}t d}|dkr|j|}|stjdd||7}|t|}qz||WSt y}z&tj d | t |fd WYd }~n d }~00d S) rUrLrrVrWrCrrrXr?r@N)rYr'rZr r rr)rr[r rErFr5r)r-rRZ header_lenr_r`rapayloadrrrrrecv_py26_plains0      zBaseMySQLSocket.recv_py26_plainr)rfcCsN|rJtd|dddd}|j|d|d||dd}qdS)zSplit compressed payloadrrrrXrVN)rr[r+r)r-Z packet_bunchpayload_lengthrrr_split_zipped_payload5sz%BaseMySQLSocket._split_zipped_payloadc CsHz|j}|d|_|WSty,Yn0td}g}zd|jd}|rpt|dkrp||7}|jd}qJ|rt|dkrtj ddt d|ddd d}|d|_ t d|d dd d}t |}t||kr|j|t|}|s tj dd||}q|dkrD|||j}|d|_|WS|||f|d kr`qt d}|jd}|rpt|dkrp||7}|jd}qtqpWn@ty} z&tjd |t| fd WYd} ~ n d} ~ 00t d} |D]\}} | t| 7} q|| ~ z|j}|d|_|WStyBYn0dS)z0Receive compressed packets from the MySQL serverrrLr rWrCrrrXrVrMr?r@N)r+popleftr) IndexErrorrYr'rZrr r rr[r*r rirrErFr5rrP decompress) r-rSrRrIZabyteZzip_payload_lengthrhZ zip_payloadr_rtmprdrrrrecv_compressed<sv                   zBaseMySQLSocket.recv_compressedcCs||_|jr|j|dS)zSet the connection timeoutN)r(r' settimeout)r-timeoutrrrset_connection_timeoutsz&BaseMySQLSocket.set_connection_timeoutFc Cs|jstjddz|r"tj}n|r.tj}ntj}|dus@|sTt} |sd| _n|j dd|d} t s| dkrt |d kr|d } t | } t | } | dkrd |vr| jtjO_d |vr| jtjO_d |vr| jtjO_d| _|| _| |rXz| |WnDttjfyV} z$|jtd | WYd} ~ n d} ~ 00|rz| ||WnDttjfy} z$|jtd| WYd} ~ n d} ~ 00|r| |t|dr| j|j|jd|_n| |j|_|rd| _|jg} tjdkrL|jdkrLddg} t !|j}| "|dg|d d}g}| D]^}zt#|j$|Wn6tj%y} z|&t'| WYd} ~ nd} ~ 00d}qqX|s|jtdd(|Wnt)yt*dYntjtfy@} z&tjd|+t,| fdWYd} ~ npd} ~ 0tj%yt} ztt'| WYd} ~ nrKsendrTrcresys version_inforZrirorrrrrrrr%Zs>     E!Lr%cs2eZdZdZd fdd ZddZddZZS) MySQLUnixSocketzoMySQL socket class using UNIX sockets Opens a connection through the UNIX socket of the MySQL Server. /tmp/mysql.sockcstt|||_dSr=)superrr. unix_socket)r-r __class__rrr.szMySQLUnixSocket.__init__cCs|jSr=)rr,rrrr5szMySQLUnixSocket.get_addressc Csz2ttjtj|_|j|j|j|jWnntyp}z&t j d| t |fdWYd}~n:d}~0t y}zt t|WYd}~n d}~00dS)Nir@)r7AF_UNIX SOCK_STREAMr'rpr(connectrrEr r r5r Exceptionr)r-rrrrr4szMySQLUnixSocket.open_connection)rrrrrr.r5r4 __classcell__rrrrrsrcs2eZdZdZd fdd ZddZd d ZZS) MySQLTCPSocketzXMySQL socket class using TCP/IP Opens a TCP/IP connection to the MySQL Server. rx Fcs*tt|||_||_||_d|_dS)Nr)rrr.rt server_port force_ipv6_family)r-hostportrrrrr.s zMySQLTCPSocket.__init__cCsd|j|jS)Nz{0}:{1})rrtrr,rrrr5szMySQLTCPSocket.get_addressc Csdgd}zt|j|jdtjtj}|D]8}|jrL|dtjkrL|}qdq*|dtjkr*|}qdq*|jr|ddurt d |j|ddur|d}Wn>t y}z&t j d| t|fdWYd}~nd}~00|\|_}}}}z0t|j|||_|j|j|j|Wntt y`}z(t j d|j|jt|fdWYd}~ns@