U e:W@sJdZddlZddlZddlZddlZddlZddlmZzHddlZej 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)TLSv1TLSv1.1TLSv1.2 PROTOCOL_TLSTLSv1.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)rrX/var/www/html/assets/scripts/venv/lib/python3.8/site-packages/mysql/connector/network.py _strioerrorEsr)bufpktnrrcCsg}t|}t}||krX|dtd||d|||d}t|}|d}q|td|ddtd|||S)z0Prepare a packet for sending to the MySQL serverz |jtj|j|`Wnttfk r8YnXdS)z&Shut down the socket before closing itN)r0shutdownsocket SHUT_RDWRcloser4AttributeErrorOSErrorr6rrrr@s  zBaseMySQLSocket.shutdownc Cs0z|j|`Wnttfk r*YnXdS)zClose the socketN)r0rCr4rDrEr6rrrclose_connections  z BaseMySQLSocket.close_connectioncCs |dSN)r@r6rrr__del__szBaseMySQLSocket.__del__)r packet_numbercompressed_packet_numberrc Cs|}|dkr|n||_t||j}|D]~}z|j|Wq,tk r|}ztd|t|fd|W5d}~XYq,t k r}ztdd|W5d}~XYq,Xq,dS)z Send packets to the MySQL serverNrvaluesr) r:r2r,r0sendallIOErrorrr?rrD)r7rrIrJ_packetspacketrrrr send_plains"  zBaseMySQLSocket.send_plainc Cs|dkr|n||_|dkr*|n||_|j}t|}g}t}||krt||}d|} ~t | dd} t dt| ddt d|jd} | | | | dd} t| }|||kr>t | d|} t dt| ddt d|jd } | | | | |d} t| }|q| rt | } t dt| ddt d|jt d|dd} | | | ~ nt d|ddt d||} t| }|d kr t | } | t dt| ddt d|jt d|dd| nDt d|ddt d|jt dddd} | | | |D]} z|j | Wnltk r}ztd |t|fd |W5d}~XYn0tk r}ztd d|W5d}~XYnXqhdS)z+Send compressed packets to the MySQL serverN@r#rr$r"s@r!2rKrLrNrO)r:r2r;r3r%rr,joinzlibcompressr'r(r&r0rPrQrr?rrD)r7rrIrJr r*Zzpktsr+r)ZtmpbufZzbufheaderpktZ zip_packetrrrrsend_compresseds             $    zBaseMySQLSocket.send_compressedc Csztd}d}|dkrF|jd|}|s4tdd||7}t|}q|d|_td|dddd}|}|t|t |}|dd }|r|j ||}|dkr|dkrtdd||d }||8}q|WSt k r}zt d | t|fd |W5d }~XYnXd S) z%Receive packets from the MySQL serverrVrrOr$r#NrKrL) bytearrayr0recvrr%r2r'unpackextend memoryview recv_intorQrr?r) r7rTZ packet_lenchunkZ payload_lenrestZ packet_viewreadrrrr recv_plains:       zBaseMySQLSocket.recv_plain) packet_bunchrcCsN|rJtd|dddd}|j|d|d||dd}qdS)zSplit compressed payloadr#rr$rar_N)r'rdr4r&)r7rlpayload_lengthrrr_split_zipped_payload+sz%BaseMySQLSocket._split_zipped_payloadc CsFz|j}|d|_|WStk r.YnXtd}g}z`|jd}|rrt|dkrr||7}|jd}qL|rt|dkrtddt d|ddd d}|d|_ t d|d dd d}t |}t||kr|j|t|}|s tdd||}q|dkrB| ||j}|d|_|WS|||f|d kr^qt d}|jd}|rrt|dkrr||7}|jd}qrqrWn>tk r} ztd |t| fd | W5d} ~ XYnXt d} |D]\}} | t| 7} q| | ~ z|j}|d|_|WStk r@YnXdS)z0Receive compressed packets from the MySQL serverr$rVrr`rOr#rrar_rWrKrLN)r4popleftr2 IndexErrorrbr0rcr%rr'rdr3rrnr&rQrr?rrZ decompress) r7r]r\rSZabyteZzip_payload_lengthrmZ zip_payloadrhrtmppayloadrrrrecv_compressed2sr                  zBaseMySQLSocket.recv_compressed)timeoutrcCs||_|jr|j|dS)zSet the connection timeoutN)r1r0 settimeout)r7rvrrrset_connection_timeout~sz&BaseMySQLSocket.set_connection_timeoutF)cacertkey verify_certverify_identity cipher_suites tls_versionsrc Cs|jstddz|r tj}n|r,tj}ntj}|dks>|sRt} |sd| _n|jdd|d} t s| dkrt |d kr|d } t | } t | } | dkrd |kr| j tjO_ d |kr| j tjO_ d |kr| j tjO_ d| _|| _| |rVz| |WnDttjfk rT} z|jtd | | W5d} ~ XYnX|rz| ||WnDttjfk r} z|jtd| | W5d} ~ XYnX|r| |t|dr| j|j|jd|_n| |j|_|rd| _|jr|jgng} tjdkrV|jdkrVddg} t|j}| |dg|d d}g}| D]\}zt!|j"|Wn4tj#k r} z|$t%| W5d} ~ XYn Xd}qqb|s|jtdd&|Wnt'k r} zt(d| W5d} ~ XYntjtfk rV} ztd|)t*| fd| W5d} ~ XYndtj#k r} ztt%| | W5d} ~ XYn2t+k r} ztt%| | W5d} ~ XYnXdS)zSwitch the socket to use SSLirONFT)reverserrrrrrzInvalid CA Certificate: zInvalid Certificate/Key: r5)server_hostnament localhost 127.0.0.1z"Unable to verify server identity: z, z&Python installation has no SSL supportrKrL),r0rssl CERT_REQUIRED CERT_OPTIONAL CERT_NONEcreate_default_contextcheck_hostnamesortTLS_V1_3_SUPPORTEDr% TLS_VERSIONS SSLContextoptions OP_NO_TLSv1_2 OP_NO_TLSv1_1 OP_NO_TLSv1 verify_modeload_default_certsload_verify_locationsrQSSLErrorrCload_cert_chain set_ciphershasattr wrap_socketr5osnamerA gethostbyaddrrematch_hostname getpeercertCertificateErrorr&rrY NameErrorrr?rr=)r7ryrzr{r|r}r~r cert_reqscontextZ tls_version ssl_protocolrZ hostnamesaliasesZ match_foundZerrshostnamerrr switch_to_ssls       " "       zBaseMySQLSocket.switch_to_ssl)NN)NN)FFNN)__name__ __module__ __qualname____doc__r8intr:r;r r>r?r@rFrHbytesr rUsendr^rbrkrcrnrurxrboolrr rrrrrr-]sZ    S"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_socketrcst||_dSrG)superr8r)r7r __class__rrr8s zMySQLUnixSocket.__init__r.cCs|jSrG)rr6rrrr?szMySQLUnixSocket.get_addressc Csz2ttjtj|_|j|j|j|jWnjtk rn}zt d| t |fd|W5d}~XYn0t k r}zt t ||W5d}~XYnXdS)NirL)rAAF_UNIX SOCK_STREAMr0rwr1connectrrQrr?r Exceptionr)r7rrrrr>s zMySQLUnixSocket.open_connection)argskwargsrcOstdtdS)zSwitch the socket to use SSL.z2SSL is disabled when using unix socket connectionsN)warningswarnWarning)r7rrrrrrszMySQLUnixSocket.switch_to_ssl)r) rrrrrr8r?r>r r __classcell__rrrrrsrcsJeZdZdZdeeeddfdd Zed d d Zdd d d Z Z S)MySQLTCPSocketzXMySQL socket class using TCP/IP Opens a TCP/IP connection to the MySQL Server. r FN)hostport force_ipv6rcs&t||_||_||_d|_dS)Nr)rr8r5 server_portr_family)r7rrrrrrr8s  zMySQLTCPSocket.__init__r.cCs|jd|jS)N:)r5rr6rrrr?(szMySQLTCPSocket.get_addressc Csd}zt|j|jdtjtj}|D]6}|jrD|dtjkrD|}q\|dtjkr$|}q\q$|jr~|ddkr~t d|j|ddkr|d}Wn<t k r}zt d| t |fd|W5d}~XYnX|\|_ }}}}z0t|j |||_|j|j|j|Wnpt k rR}z t d|j|jt |fd|W5d}~XYn2tk r}ztt||W5d}~XYnXdS)z.Open the TCP/IP connection to the MySQL server)NNNNNrNzNo IPv6 address found for irL)rA getaddrinfor5rrSOL_TCPrAF_INET6AF_INETrrQr?rrr0rwr1rrrr) r7addrinfo addrinfosinforsocktypeprotorRsockaddrrrrr>+sZ    zMySQLTCPSocket.open_connection)rrF) rrrrrrrr8r?r>rrrrrrs r)-rrrAr'rrZ collectionsrrPROTOCOL_TLSv1PROTOCOL_TLSv1_1PROTOCOL_TLSv1_2rrrPROTOCOL_SSLv23rr ImportErrortypingr r r r r r constantsrerrorsrrrtypesrutilsrrQrrrrr,r-rrrrrrs@       %