B Ñš[(mã@sˆdZddlZddlZddlmZddlmZmZmZm Z m Z ddl m Z m Z ddlmZddlmZmZdd l mZGd d „d eƒZdS) z,Implements the MySQL Client/Server protocol éN)ÚDecimalé)Ú FieldFlagÚ ServerCmdÚ FieldTypeÚ ClientFlagÚMAX_MYSQL_TABLE_COLUMNS)ÚerrorsÚutils)Úget_auth_plugin)ÚPY2Ú struct_unpack)Ú get_exceptionc@súeZdZdZdd„Zdd„ZdBd d „ZdCd d„ZdDdd„ZdEdd„Z dd„Z dd„Z dd„Z dFdd„Z dd„ZdGdd „ZdHd"d#„Zd$d%„Zd&d'„Zd(d)„Zd*d+„Zd,d-„ZdId.d/„Zd0d1„Zd2d3„Zd4d5„Zd6d7„Zd8d9„ZdJdd?„Zd@dA„ZdS)KÚ MySQLProtocolzRImplements MySQL client/server protocol Create and parses MySQL packets. cCs |tj@r|r| d¡dSdS)z.Prepare database string for handshake responseÚutf8ó)rZCONNECT_WITH_DBÚencode)ÚselfÚ client_flagsÚdatabase©rúœC:\Users\HIRONO~1\AppData\Local\Temp\pip-install-ioykiiwb\mysql-connector-python-rf\mysql_connector_python_rf-2.2.2.data\purelib\mysql\connector\protocol.pyÚ_connect_with_db-szMySQLProtocol._connect_with_dbc Cs˜|sdSy"t|ƒ|||||d}| ¡} Wn<ttjfk rf} zt d t| ƒ¡¡‚Wdd} ~ XYnX|tj @rŒt | ƒ} t   d| ¡| } n| d} | S)z#Prepare the authentication responser)ÚusernameÚpasswordrÚ ssl_enabledzFailed authentication: {0}Nz%sz2MySQLProtocol.parse_statistics..ó:r`zutf-8z{0} ({1}:{2}).)Úsplitr rrHÚintrr ) rr6Z with_headerÚerrmsgrKÚpairsÚpairZlblÚvalrrrÚparse_statisticss(    zMySQLProtocol.parse_statisticsrc Cs^g}d}d}d}|dk}x:|s(||kr*P| ¡} |  d¡r¤| dd…g} | ¡} x(|  d¡rz|  | dd…¡| ¡} qTW|  | dd…¡t tdƒ | ¡¡}nj| ddkrÌ| ddkrÌ| | ¡}d}nB|rø| ddkrø| dd krø| | ¡}d}nd}t | dd…¡}|dkr.|dk r.| |¡n|dkrJ|dkrJt | ƒ‚|d 7}qW||fS) z¶Read MySQL text result Reads all or given number of rows from the socket. Returns a tuple with 2 elements: a list with all rows and the EOF packet. Nr)r?ér?sÿÿÿrNr-r^rpr_r) ÚrecvrJÚappendr Zread_lc_string_listÚ bytearrayÚjoinrcrTr) rÚsockÚversionrVÚrowsÚeofZrowdataÚiZeof57r6ZdatasrrrÚread_text_result5s>        zMySQLProtocol.read_text_resultcCsœ|dtjkrd}d}nL|dtjkr0d}d}n4|dtjtjfkrNd}d}n|dtjkrdd}d}|d tj@rz| ¡}||d …t ||d |…ƒd fS) z%Parse an integer from a binary packetrÚbÚhr`ryrNÚqrDrpNr) rÚTINYÚSHORTÚINT24ÚLONGÚLONGLONGrZUNSIGNEDÚupperr )rr6ÚfieldÚformat_ÚlengthrrrÚ_parse_binary_integer_sz#MySQLProtocol._parse_binary_integercCsB|dtjkrd}d}nd}d}||d…t||d|…ƒdfS)z)Parse a float/double from a binary packetrrDÚdrNÚfNr)rÚDOUBLEr )rr6r„r†r…rrrÚ_parse_binary_floatss z!MySQLProtocol._parse_binary_floatc CsÀ|d}d}|dkr@tjtd|dd…ƒd|d|dd}nl|dkr¬d}|d krntd |d |d…ƒd}tjtd|dd…ƒd|d|d|d |d |d|d}||dd…|fS)z&Parse a timestamp from a binary packetrNrNÚHrra)ÚyearÚmonthÚdayrpé ÚIrDr?é)rrŽrÚhourÚminuteÚsecondÚ microsecond)ÚdatetimeÚdater )rr6r„r†ÚvalueÚmcsrrrÚ_parse_binary_timestamp~s(z%MySQLProtocol._parse_binary_timestampcCs˜|d}|d|d…}d}|dkr:td|dd…ƒd}td|dd…ƒd}|ddkrd|d9}tj||d||d |dd }||dd…|fS) z'Parse a time value from a binary packetrrrDr‘Nr?rErpr’)ÚdaysÚsecondsÚ microsecondsÚminutesÚhours)r r—Ú timedelta)rr6r„r†r<ršrœÚtmprrrÚ_parse_binary_time–s  z MySQLProtocol._parse_binary_timec Cstt|ƒddd}dd„|d|…Dƒ}||d…}g}x.t|ƒD] \}}|t|ddƒd|dd>@r‚| d¡qFqF|dtjtjtjtjtj fkr¾|  ||¡\}}| |¡qF|dtj tj fkrî|  ||¡\}}| |¡qF|dtjtjtjfkr$| ||¡\}}| |¡qF|dtjkrP| ||¡\}}| |¡qFt |¡\}}| |¡qFWt|ƒS) z(Parse values from a binary result packetrpr`rDcSsg|] }t|ƒ‘qSr)rj)reryrrrrg«sz6MySQLProtocol._parse_binary_values..rNr)r#Ú enumeraterjrrrr~rr€rr‚r‡rŠÚFLOATr‹ÚDATETIMEÚDATEÚ TIMESTAMPr›ÚTIMEr£r rRÚtuple) rÚfieldsr6Znull_bitmap_lengthÚ null_bitmapÚvaluesÚposr„r™rrrÚ_parse_binary_values¨s4 $      z"MySQLProtocol._parse_binary_valuesc Cs¶g}d}d}d}xœ|dk rP||kr&P| ¡}|ddkrJ| |¡}d}n$|ddkrnd}| ||dd…¡}|dkrŠ|dk rŠ| |¡n|dkr¢|dkr¢t|ƒ‚|d7}qW||fS)zwRead MySQL binary protocol result Reads all or given number of binary resultset rows from the socket. NrrNr^r?r)rqrcr¯rrr) rruÚcolumnsrVrwrxr­ryr6rrrÚread_binary_resultÈs,     z MySQLProtocol.read_binary_resultcCs¦|ddkst d¡‚i}yht |dd…d¡\}|d<t |d¡\}|d<t |d¡\}|d <|d d…}t |d¡\}|d <Wntk r t d¡‚YnX|S) z'Parse a MySQL Binary Protocol OK packetrNrzFailed parsing Binary OK packetr?NÚ statement_idr`Z num_columnsZ num_paramsrrP)r rr Zread_intrS)rr6Zok_pktrrrÚparse_binary_prepare_okäs   z%MySQLProtocol.parse_binary_prepare_okcCs´d}d}|dkrX|dkr$d}tj}q¢|dkr8d}tj}q¢|dkrLd}tj}q¢d }tj}nJd }|d krpd }tj}n2|d kr„d}tj}n|dkr˜d}tj}n tj}d}t ||¡||fS)z0Prepare an integer for the MySQL binary protocolNri€ÿÿÿr{i€ÿÿr|i€ryr}é€éÿÚBiÿÿrŒlÿÿr‘ÚQ)rr~rrr‚r$r%)rr™r[r\r…rrrÚ_prepare_binary_integerõs6z%MySQLProtocol._prepare_binary_integercCs¼t|tjƒrtj}nt|tjƒr(tj}ntdƒ‚t |j ¡t  |j ¡t  |j ¡}t|tjƒr¢|t  |j ¡t  |j¡t  |j¡}|jdkr¢|t |j¡7}t  t|ƒ¡|}||fS)aƒPrepare a timestamp object for the MySQL binary protocol This method prepares a timestamp of type datetime.datetime or datetime.date for sending over the MySQL binary protocol. A tuple is returned with the prepared value and field type as elements. Raises ValueError when the argument value is of invalid type. Returns a tuple. z2Argument must a datetime.datetime or datetime.dater)Ú isinstancer—rr¦r˜r§rSr Ú int2storerr9rŽrr“r”r•r–r8r#)rr™r[ÚpackedrrrÚ_prepare_binary_timestamps    z'MySQLProtocol._prepare_binary_timestampc Cst|tjtjfƒstdƒ‚tj}d}d}d}t|tjƒrž|jdkrFd}t|j dƒ\}}t|dƒ\}} |t   t |jƒ¡t   |¡t   |¡t   | ¡7}|j}n8|t   d¡t   |j¡t   |j¡t   |j¡7}|j}|rè|t   |¡7}t   |¡|}t   t|ƒ¡|}||fS)aPrepare a time object for the MySQL binary protocol This method prepares a time object of type datetime.timedelta or datetime.time for sending over the MySQL binary protocol. A tuple is returned with the prepared value and field type as elements. Raises ValueError when the argument value is of invalid type. Returns a tuple. z3Argument must a datetime.timedelta or datetime.timerNr-rié<)r¹r—r¡ÚtimerSrr©rœÚdivmodrr r8Úabsr9ržr“r”r•r–r#) rr™r[Únegativeršr»r Ú remainderZminsÚsecsrrrÚ_prepare_binary_time8s2   " z"MySQLProtocol._prepare_binary_timecCst |¡t |¡|}|S)zMPrepare long data for prepared statements Returns a string. )r r8rº)rZ statementÚparamr<r6rrrÚ_prepare_stmt_send_long_dataesz*MySQLProtocol._prepare_stmt_send_long_datarrc Cs8d}dgt|ƒdd}g} g} d} |dkr2i}|rÈ|rÈt|ƒt|ƒkrXt d¡‚xlt|ƒD]^\} } || }d}|dkrÀ|| dd| d>O<|  t tj¡t |¡¡qdnê| |kræ|| drÜtj }ntj }nÄt |t ƒr|  |¡\} }}|  | ¡nšt |tƒrhtr<|  t t|ƒ¡|¡n"| |¡}|  t t|ƒ¡|¡tj}nBt |tƒr–|  t t|ƒ¡|¡tj }ntrÒt |tƒrÒ| |¡}|  t t|ƒ¡|¡tj}nØt |tƒr|  t tt|ƒ |¡ƒ¡t|ƒ |¡¡tj}n˜t |tƒr8|  t d|¡¡tj}nrt |tjtjfƒrf| |¡\} }|  | ¡nDt |tjtjfƒr”|  |¡\} }|  | ¡nt !d j"|j#j$d ¡‚|  t |¡t |¡¡qdWt %|¡t |¡t %|¡d &d d „|Dƒ¡t d¡}x| D]}||7}q Wx| D]}||7}q"W|S) z6Make a MySQL packet with the Statement Execute commandrrrprDr-NzTFailed executing prepared statement: data values does not match number of parametersrˆz:MySQL binary protocol can not handle '{classname}' objects)Ú classnamecSsg|]}t d|¡‘qS)r¶)r$r%)reÚbitrrrrg¾sz3MySQLProtocol.make_stmt_execute..)'r#r rr¤rrr r9rÚNULLZBLOBÚSTRINGr¹rjr¸r!r Zlc_intrZVARCHARÚbytesÚunicoderZDECIMALÚfloatr$r%rŠr—r˜r¼r¡r¾rÄrr Ú __class__Ú__name__r8rt)rr²r<Ú parametersr\Zlong_data_usedr3Ziteration_countr¬r­Útypesr»r®rYr™r[r6Za_typeZa_valuerrrÚmake_stmt_executepsŠ                  0   zMySQLProtocol.make_stmt_executecCsZ|ddkst d¡‚tj|dd…dd\}}|rL|dd krL|dd…}| d ¡|fS) z&Parse a MySQL AuthSwitchRequest-packetrNr^z'Failed parsing AuthSwitchRequest packetr?Nr)rArErr)r rr rGrH)rr6Z plugin_namerrrÚparse_auth_switch_requestÊs  z'MySQLProtocol.parse_auth_switch_requestcCs"|ddkst d¡‚|dd…S)z!Parse a MySQL AuthMoreData-packetrNrz"Failed parsing AuthMoreData packetr?N)r r)rr6rrrÚparse_auth_more_dataÖs z"MySQLProtocol.parse_auth_more_data)NNNr+rr,FN)r+rr,)N)NNNr+rFN)rX)T)r)r)rrrNr)rÏÚ __module__Ú __qualname__Ú__doc__rr*r7r:r=r>rMrTrWr]rcrorzr‡r‹r›r£r¯r±r³r¸r¼rÄrÆrÒrÓrÔrrrrr'sF "   ",   *  !"-  Y r)r×r$r—ÚdecimalrÚ constantsrrrrrÚr r Zauthenticationr Zcatch23r r rÚobjectrrrrrÚs