o c_S.@sddlmZddlmZmZddlmZddlZddlZdZ dZ dZ dZ d Z d Zd d ZGd ddZGdddeZGdddZGdddZGdddZdS))MBLENGTH) FIELD_TYPE SERVER_STATUS)errNFcsddz&tdttddD]}t|}td||jj|jfqtdWn ty3Ynwfdd td t td d D}|D]$}td dd|Ddd t|dd fdd|DqHtdtdS)NcSs$d|kr dkrt|SdSdS)N .)chrdatar2/usr/lib/python3/dist-packages/pymysql/protocol.py printableszdump_packet..printablezpacket length:rzcall[%d]: %s (line %d)zB------------------------------------------------------------------csg|] }||dqS)r).0irrr #szdump_packet..rr css|]}d|VqdS)z{:02X}N)formatrxrrr &szdump_packet..z z c3s|]}|VqdSNrr)rrrr)s) printlenrangesys _getframef_codeco_namef_lineno ValueErrorminjoin)rrf dump_datadr)rrr dump_packets.   $ r/c@seZdZdZdZddZddZddZd d Zd d Z d:ddZ d;ddZ ddZ ddZ ddZddZddZddZdd Zd!d"Zd#d$Zd%d&Zd'd(Zd)d*Zd+d,Zd-d.Zd/d0Zd1d2Zd3d4Zd5d6Zd7d8Zd9S)< MysqlPacketzrRepresentation of a MySQL response packet. Provides an interface for reading/parsing the packet results.  _position_datacCsd|_||_dS)Nrr1selfrencodingrrr__init__7s zMysqlPacket.__init__cCs|jSr r3r5rrr get_all_data;szMysqlPacket.get_all_datacCsl|j|j|j|}t||kr-d|t||jt|jf}tr)t||t||j|7_|S)zCRead the first 'size' bytes in packet and advance cursor past them.z\Result length not requested length: Expected=%s. Actual=%s. Position: %s. Data Length: %s)r3r2r"DEBUGr!dumpAssertionError)r5sizeresulterrorrrrread>s zMysqlPacket.readcCs|j|jd}d|_|S)z`Read all remaining data in the packet. (Subsequent read() will return errors.) Nr3r2r5r?rrrread_allNszMysqlPacket.read_allcCs:|j|}|dks|t|jkrtd||f||_dS)z1Advance the cursor in data buffer 'length' bytes.rz4Invalid advance amount (%s) for cursor. Position=%sN)r2r"r3 Exception)r5length new_positionrrradvanceWs  zMysqlPacket.advancercCs,|dks |t|jkrtd|||_dS)z9Set the position of the data buffer cursor to 'position'.rz)Invalid position to rewind cursor to: %s.N)r"r3rEr2)r5positionrrrrewindas  zMysqlPacket.rewindrcCs|j|||S)a>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! r8)r5rIrFrrr get_bytesgs zMysqlPacket.get_bytescCs|j|j}|jd7_|SNrrBrCrrr read_uint8rs zMysqlPacket.read_uint8cC(td|j|jd}|jd7_|S)NzS)Nz)r5fmtsr?rrr read_structs zMysqlPacket.read_structcCs|jddko t|jdkS)Nrrr3r"r9rrr is_ok_packetszMysqlPacket.is_ok_packetcCs|jddko t|jdkS)Nrr rmr9rrr is_eof_packetszMysqlPacket.is_eof_packetcC|jddkS)Nrr r8r9rrris_auth_switch_requestz"MysqlPacket.is_auth_switch_requestcCrq)Nrrr8r9rrris_extra_auth_datarszMysqlPacket.is_extra_auth_datacCs"|jd}d|kodkSS)Nrrr8)r5 field_countrrris_resultset_packets zMysqlPacket.is_resultset_packetcCrq)Nrrr8r9rrris_load_local_packetz MysqlPacket.is_load_local_packetcCrq)Nrr8r9rrris_error_packetryzMysqlPacket.is_error_packetcCs|r |dSdSr )r{raise_for_errorr9rrr check_errors zMysqlPacket.check_errorcCs8||d|}trtd|t|jdS)Nrzerrno =)rJrHrSr;r!rraise_mysql_exceptionr3)r5errnorrrr|s   zMysqlPacket.raise_for_errorcCst|jdSr )r/r3r9rrrr<ryzMysqlPacket.dumpN)r)r)__name__ __module__ __qualname____doc__ __slots__r7r:rArDrHrJrKrMrSrXrZr\r`rgrhrlrnrprrrtrwrxr{r}r|r<rrrrr0/s:    r0c@s8eZdZdZddZddZddZdd Zd d Zd S) FieldDescriptorPacketzA 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. cCst|||||dSr )r0r7_parse_field_descriptorr4rrrr7szFieldDescriptorPacket.__init__cCsv||_||_|||_|||_|||_|||_|d\|_ |_ |_ |_ |_ dS)zParse the 'Field Descriptor' (Metadata) packet. This is compatible with MySQL 4.1+ (not compatible with MySQL 4.0). z s$  5=