o hy@sdZddlZddlZddlZddlmZmZddlmZddlm Z ddl m Z ddl m Z mZd d Zd d Zd dZddZddZddZddZddZddZddZddZGdd d eZGd!d"d"eZGd#d$d$eZGd%d&d&eZGd'd(d(eZGd)d*d*eZ Gd+d,d,eZ!Gd-d.d.eZ"Gd/d0d0eZ#Gd1d2d2eZ$Gd3d4d4eZ%Gd5d6d6eZ&Gd7d8d8eZ'Gd9d:d:eZ(Gd;d<dd>e(Z*Gd?d@d@e*Z+GdAdBdBe+Z,GdCdDdDe*Z-dS)Ez%Implementation of the Result classes.N)datetime timedelta)DbDoc)MYSQL_CHARACTER_SETS) STRING_TYPES)decode_from_bytes deprecatedcCst|dkrdSz(tjttjttjttjt tj t tj t tjttjttjttjttjti ||WStyX}ztjd|tjd|dWYd}~dSd}~ww)Nr{0}hex)lenColumnProtoTypeSINTvarsint_from_protobufUINTvarint_from_protobufBYTESbytes_from_protobufDATETIMEdatetime_from_protobufTIMEtime_from_protobufFLOATfloat_from_protobufDOUBLEdouble_from_protobufBITSETset_from_protobufENUMDECIMALdecimal_from_protobufKeyErrorsysstderrwriteformatencode)col_typepayloaderrr+?/var/www/html/env/lib/python3.10/site-packages/mysqlx/result.py from_protobuf,s2    r-cCst|ddS)N)rr)r+r+r,rDrcCt|dksJtd|S)NzrKr;r&decimalDecimal)r)digitssignscalerCrDhigh_bcdlow_bcdr+r+r,r!s:"      r!cCsd}d}d}d}t|\}}t|\}}t|\}}zt|\}}t|\}}t|\}}t|\}}Wn ty=Ynwt|||||||S)Nr)rGr;r)r)hourminutessecondsusecondsyearmonthdayr+r+r,rs        rcCsd}d}d}d}|ddk}|dd}zt|\}}t|\}}t|\}}t|\}}Wn ty7Ynw|rU|rA|d9}n|rH|d9}n |rO|d9}n|rU|d9}t||||dS)Nrrr.)hoursr[r\ microseconds)rGr;r)r)rZr[r\r]negater+r+r,rs4         rc@eZdZdZdS) Collations!N)__name__ __module__ __qualname__UTF8_GENERAL_CIr+r+r+r,rerec@seZdZdZdZdZdZdZdZdZ dZ d Z d Z d Z d Zd ZdZdZdZdZdZdZdZdZdZdZdZdZdZdZdZdZdZ dZ!d Z"d!Z#d"Z$d#Z%e&d$d%Z'e&d&d'Z(e&d(d)Z)e&d*d+Z*e&d,d-Z+e&d.d/Z,e&d0d1Z-e&d2d3Z.d4S)5 ColumnTyperr2r:r7 rP rQrRrO rf"#cCs*t|D] \}}||kr|SqdSN)varsitems)clsneedlekeyvaluer+r+r, to_strings zColumnType.to_stringcCst||dSr)getattrupper)rrr+r+r, from_stringr0zColumnType.from_stringcC||j|jfvSr)CHARVARCHARrr(r+r+r,is_char#r0zColumnType.is_charcCrr)BINARY VARBINARYrr+r+r, is_binary'r0zColumnType.is_binarycCs||j|j|j|jfvSr)TEXTTINYTEXT MEDIUMTEXTLONGTEXTrr+r+r,is_text+szColumnType.is_textcCs||j|j|j|j|jfvSr)REALrrr NUMERICrr+r+r, is_decimals0szColumnType.is_decimalscCs ||j|j|j|j|j|jfvSr)rTINYINTSMALLINT MEDIUMINTINTBIGINTrr+r+r, is_numeric5szColumnType.is_numericcCrr)rrrr+r+r, is_finite_set:r0zColumnType.is_finite_setN)/rgrhrirrrrrrrrr rrJSONSTRINGrrDATEr TIMESTAMPrrGEOMETRYXMLYEARrrrrTINYBLOBBLOB MEDIUMBLOBLONGBLOBrrrr classmethodrrrrrrrrr+r+r+r,rlsh       rlc@s8eZdZdZdZdZdZdZdZdZ dZ d Z d Z d Z d S) r rrmrorpr:rPrQrOrtrurvN)rgrhrirrrrrrrrrrr r+r+r+r,r ?sr c@s6eZdZddZddZeddZejddZdS) FlagscCsVi|_i|_|jjD]\}}|drq t|tr%||j|<||j|<q ||_dS)N__) _allowed_flags _flag_names __class____dict__r startswithr<r=_value)selfrrvalr+r+r,__init__Ns     zFlags.__init__c Csd}g}|j}tddD]5}|dK}||@}|rAz ||j|Wq ty@tjd|jtjd|j j Yq wq d |S)Nrr?r ,) rrangerKrr"r#r$r%r&rrjoin)rmask flag_namesr_flagr+r+r,__str__Ys  z Flags.__str__cC|jSrrrr+r+r,rksz Flags.valuecCs ||_dSrr)rrr+r+r,ros N)rgrhrirrpropertyrsetterr+r+r+r,rMs  rc@s eZdZdZdZdZdZdZdS) ColumnFlagsrtr@r8N)rgrhriNOT_NULL PRIMARY_KEY UNIQUE_KEY MULTIPLE_KEYAUTO_INCREMENTr+r+r+r,rts rc@rd)DatetimeColumnFlagsrN)rgrhrirr+r+r+r,r|rkrc@rd)UIntColumnFlagsrN)rgrhriZEROFILLr+r+r+r,rrkrc@rd)DoubleColumnFlagsrNrgrhriUNSIGNEDr+r+r+r,rrkrc@rd)FloatColumnFlagsrNrr+r+r+r,rrkrc@rd)BytesColumnFlagsrN)rgrhri RIGHT_PADr+r+r+r,rrkrc@seZdZdZdZdZdS)BytesContentTyperrmrnN)rgrhrirrrr+r+r+r,rsrc@s:eZdZdZ    dAddZddZddZd d Zd d Zd dZ ddZ e ddZ e ddZ e ddZe ddZe ddZe ddZe ddZe dd Ze d!d"Ze d#d$Zd%d&Zd'd(Zd)d*Zd+d,Zd-d.Zd/d0Zd1d2Zd3d4Zd5d6Zd7d8Zd9d:Z d;d<Z!d=d>Z"d?d@Z#dS)BColumna_Represents meta data for a table column. Args: col_type (int): The column type. catalog (str): The catalog. schema (str): The schema name. table (str): The table name. original_table (str): The original table name. name (str): The column name. original_name (str): The original table name. length (int): The column length, collation (str): The collation name. fractional_digits (int): The fractional digits. flags (int): The flags. content_type (int): The content type. .. versionchanged:: 8.0.12 Nc Cst||_t||_t||_t||_t||_||_d|_||_||_ | |_ | |_ | |_ | |_ d|_d|_d|_d|_d|_d|_d|_|j dkrt|j ttkrZtd|j t|j } | d|_| d|_d|jvprd|jv|_||jtjtjtjtjtjfv|_dS)NFrz"No mapping found for collation {0}rbinary_bin) r_schema_name_original_name_table_original_table _proto_type _col_type_catalog_length _collation_fractional_digits_flags _content_type_number_signed _is_padded _is_binary _is_bytes_collation_name_character_set_name _zero_fillr rr;r& _map_typerlrrrrr)rr(catalogschematableoriginal_tablename original_namelength collationfractional_digitsflags content_typeinfor+r+r,rsH            zColumn.__init__cCst|j|j|jt|jdS)N)r(rrr)strrrrrrr+r+r,rs zColumn.__str__cCsj|jtjkr tj|_n"|jtjkrtj|_n|jtjkr!tj|_n |jr)tj|_ntj |_|j d@|_ dS)z Map bytes.rN) rrrrlrrrrrrrrrr+r+r, _map_bytess       zColumn._map_bytescCsP|jdkr tj|_dS|jdkrtj|_dS|jtj@dkr$tj|_dStd)z Map datetime.rPrwrz#Datetime mapping scenario unhandledN) rrlrrrrrrr;rr+r+r, _map_datetimes     zColumn._map_datetimecCsb|jdkr tj|_n"|jdkrtj|_n|jdkrtj|_n|jdkr(tj|_ntj|_d|_dS)z Map int type.r2rprqrrTN) rrlrrrrrrrrr+r+r, _map_int_types         zColumn._map_int_typecCsh|jdkr tj|_n"|jdkrtj|_n|jdkrtj|_n|jdkr(tj|_ntj|_|jd@|_ dS)zMap uint type.rnror7rPrN) rrlrrrrrrrrrr+r+r,_map_uint_types        zColumn._map_uint_typecCsN|jtjkr |dS|jtjkr|dS|jtjkr-tj|_|j t j @dk|_ dS|jtj krBtj |_|j t j @dk|_ dS|jtjkrWtj|_|j t j @dk|_ dS|jtjkrc|dS|jtjkrotj|_dS|jtjkr{|dS|jtjkrtj|_dS|jtjkrtj|_dS|jtjkrtj|_dStd|j)z Map type.rzUnknown column type {0}N)rr rrrrrrlrrrr_is_number_signedr rrrrrrrrrr;r&rr+r+r,rs:                   zColumn._map_typecCr)z@str: The schema name. .. versionadded:: 8.0.12 rrr+r+r, schema_name/zColumn.schema_namecC |jp|jS)z?str: The table name. .. versionadded:: 8.0.12 rrrr+r+r, table_name7 zColumn.table_namecCr )z@str: The table label. .. versionadded:: 8.0.12 rrrr+r+r, table_label?rzColumn.table_labelcCr )z@str: The column name. .. versionadded:: 8.0.12 rrrr+r+r, column_nameGrzColumn.column_namecCr )zAstr: The column label. .. versionadded:: 8.0.12 rrrr+r+r, column_labelOrzColumn.column_labelcCr)z@int: The column type. .. versionadded:: 8.0.12 rrr+r+r,typeWr z Column.typecCr)zBint. The column length. .. versionadded:: 8.0.12 rrr+r+r,r_r z Column.lengthcCr)zMint: The column fractional digits. .. versionadded:: 8.0.12 rrr+r+r,rgr zColumn.fractional_digitscCr)zCstr: The collation name. .. versionadded:: 8.0.12 rrr+r+r,collation_nameor zColumn.collation_namecCr)zGstr: The character set name. .. versionadded:: 8.0.12 rrr+r+r,character_set_namewr zColumn.character_set_namecCr)zUReturns the schema name. Returns: str: The schema name. r rr+r+r,get_schema_namer zColumn.get_schema_namecCr )zSReturns the table name. Returns: str: The table name. rrr+r+r,get_table_namerzColumn.get_table_namecCr )zUReturns the table label. Returns: str: The table label. rrr+r+r,get_table_labelrzColumn.get_table_labelcCr )zUReturns the column name. Returns: str: The column name. rrr+r+r,get_column_namerzColumn.get_column_namecCr )zWReturns the column label. Returns: str: The column label. rrr+r+r,get_column_labelrzColumn.get_column_labelcCr)zaReturns the column proto type. Returns: int: The column proto type. )rrr+r+r,get_proto_typer zColumn.get_proto_typecCr)zUReturns the column type. Returns: int: The column type. rrr+r+r,get_typer zColumn.get_typecCr)zYReturns the column length. Returns: int: The column length. rrr+r+r, get_lengthr zColumn.get_lengthcCr)zoReturns the column fractional digits. Returns: int: The column fractional digits. rrr+r+r,get_fractional_digitsr zColumn.get_fractional_digitscCr)z[Returns the collation name. Returns: str: The collation name. rrr+r+r,get_collation_namer zColumn.get_collation_namecCr)zcReturns the character set name. Returns: str: The character set name. rrr+r+r,get_character_set_namer zColumn.get_character_set_namecCr)zxReturns `True` if is a number signed. Returns: bool: Returns `True` if is a number signed. )rrr+r+r,is_number_signedr zColumn.is_number_signedcCr)zfReturns `True` if is padded. Returns: bool: Returns `True` if is padded. )rrr+r+r, is_paddedr zColumn.is_paddedcCr)zdReturns `True` if is bytes. Returns: bool: Returns `True` if is bytes. )rrr+r+r,is_bytesr zColumn.is_bytes) NNNNNNNNNNN)$rgrhri__doc__rrrrrrrrr rrrrrrrrrrr r!r"r#r$r%r&r'r(r)r*r+r,r+r+r+r,rs^ ' !           rc@s0eZdZdZddZddZedddZd S) RowzRepresents a row element returned from a SELECT query. Args: rs (mysqlx.SqlResult or mysqlx.RowResult): The result set. fields (`list`): The list of fields. cCs||_||_dSr)_fields _resultset)rrsfieldsr+r+r,rs z Row.__init__cCsbt|tr |j|n|}|dkrt|trtd||t|jks(|dkr,td|j|S)z\Returns the value of a column by name or index. .. versionchanged:: 8.0.12 r.Column name '{0}' not foundrzIndex out of range) r<rr0index_ofr;r&r r/ IndexError)rindex int_indexr+r+r, __getitem__s zRow.__getitem__8.0.12cCsF|j|}|t|jkrtd|dkrtd|t|j|S)zReturns the value using the column name. Args: str_index (str): The column name. .. deprecated:: 8.0.12 zArgument out of ranger.r3)r0r4r r/r5r;r&r)r str_indexr7r+r+r, get_strings zRow.get_stringN)rgrhrir-rr8r r;r+r+r+r,r.s  r.c@sXeZdZdZddZddZddZdd Zd d Zd d Z ddZ ddZ ddZ dS) BaseResultzProvides base functionality for result objects. Args: connection (mysqlx.connection.Connection): The Connection object. cCsJ||_d|_d|_d|_g|_g|_|durd|_dS|j|_|dSNFrr.) _connection_closed_rows_affected _generated_id_generated_ids _warnings _protocolprotocolfetch_active_resultr connectionr+r+r,rs  zBaseResult.__init__cCr)zReturns the number of affected items for the last operation. Returns: int: The number of affected items. r@rr+r+r,get_affected_items_count-r z#BaseResult.get_affected_items_countcCr)zZReturns the warnings. Returns: `list`: The list of warnings. )rCrr+r+r, get_warnings5r zBaseResult.get_warningscC t|jS)zcReturns the number of warnings. Returns: int: The number of warnings. )r rCrr+r+r,get_warnings_count= zBaseResult.get_warnings_countcC ||_dS)z)Sets if resultset fetch is done. N)r?rrr+r+r, set_closedE zBaseResult.set_closedcCs|j|||ddS)zAppend a warning. Args: level (int): The warning level. code (int): The warning code. msg (str): The warning message. )levelcodemsgN)rCrK)rrSrTrUr+r+r,append_warningJszBaseResult.append_warningcCrO)z Sets the generated ids. NrB)r generated_idsr+r+r,set_generated_idsTrRzBaseResult.set_generated_idscCrO)z&Sets the generated insert id. NrA)r generated_idr+r+r,set_generated_insert_idYrRz"BaseResult.set_generated_insert_idcCrO)z*Sets the number of rows affected. NrI)rtotalr+r+r,set_rows_affected^rRzBaseResult.set_rows_affectedN) rgrhrir-rrJrKrMrQrVrYr\r^r+r+r+r,r<s  r<csReZdZdZdfdd ZddZeddd Zedd d Zd d Z Z S)ResultaAllows retrieving information about non query operations performed on the database. Args: connection (mysqlx.connection.Connection): The Connection object. ids (`list`): A list of IDs. Ncs2tt||||_|dur|j|dSdSr)superr_r_idsr> close_result)rrHidsrr+r,rls zResult.__init__cCr)zjReturns the last insert id auto generated. Returns: int: The last insert id. rZrr+r+r,get_autoincrement_valuesr zResult.get_autoincrement_valuer9cCs&|jdus t|jdkrdS|jdS)zdReturns ID of the last document inserted into a collection. .. deprecated:: 8.0.12 Nr)rar rr+r+r,get_document_id{s zResult.get_document_idcCr)zIReturns the generated insert id. .. deprecated:: 8.0.12 rZrr+r+r,get_generated_insert_idr zResult.get_generated_insert_idcCr)z#Returns the generated ids. rWrr+r+r,get_generated_idszResult.get_generated_ids)NN) rgrhrir-rrer rfrgrh __classcell__r+r+rdr,r_ds  r_csteZdZdZfddZddZeddZdd Zd d Z d d Z ddZ ddZ ddZ ddZddZZS)BufferingResultzProvides base functionality for buffering result objects. Args: connection (mysqlx.connection.Connection): The Connection object. ids (`list`): A list of IDs. cs@tt||g|_d|_d|_g|_d|_d|_| dSr=) r`rkr_columns _has_data_has_more_results_items _page_size _position _init_resultrGrdr+r,rs zBufferingResult.__init__cCs |j|Sr)ro)rr6r+r+r,r8s zBufferingResult.__getitem__cCrL)zint: The total of items.)r rorr+r+r,countrRzBufferingResult.countcCsX|j||_t|jdkrdnd|_g|_d|_d|_|j|jr'|dSddS)zInitialize the result.rTFrxr.N) r>get_column_metadatarlr _has_more_datarorprqset_active_resultrr+r+r,rrszBufferingResult._init_resultcCsr|j|}|dur dSdgt|d}|s4tt|dD]}|j|}t||d|||<qt||S)zRead item. Args: dumping (bool): `True` for dumping. Returns: :class:`mysqlx.Row`: A `Row` object. Nfield)r>read_rowr rrlr-r$r.)rdumpingrowrCrcolr+r+r, _read_items    zBufferingResult._read_itemcCsN|jrdSd}t|jD]}|d}|dur|S|j||d7}q |S)zSReads the page items. Returns: int: Total items read. FrNr)r?rrpr|rorK)rrsrrCr+r+r,_page_in_itemss  zBufferingResult._page_in_itemscCs0d}|jD]}||kr|S|d7}qdS)zeReturns the index of the column. Returns: int: The index of the column. rrr.)rlr")rcol_namer6r{r+r+r,r4s    zBufferingResult.index_ofcCs|jrdS|dS)zuFetch one item. Returns: :class:`mysqlx.Row` or :class:`mysqlx.DbDoc`: one result item. NF)r?r|rr+r+r, fetch_ones zBufferingResult.fetch_onecCs |s |jSq)zFetch all items. Returns: `list`: The list of items of :class:`mysqlx.DbDoc` or :class:`mysqlx.Row`. )r}rorr+r+r, fetch_alls zBufferingResult.fetch_allcCrO)zdSets if result has data. Args: flag (bool): `True` if result has data. NrmrPr+r+r, set_has_datarNzBufferingResult.set_has_datacCrO)zfSets if has more results. Args: flag (bool): `True` if has more results. N)rnrPr+r+r,set_has_more_resultsrNz$BufferingResult.set_has_more_results)rgrhrir-rr8rrsrrr|r}r4rrrrrjr+r+rdr,rks       rkcs4eZdZdZfddZeddZddZZS) RowResultzAllows traversing the Row objects returned by a Table.select operation. Args: connection (mysqlx.connection.Connection): The Connection object. ctt||dSr)r`rrrGrdr+r,rzRowResult.__init__cCr)z`list`: The list of columns.rlrr+r+r,columnsrizRowResult.columnscCr)zReturns the list of columns. Returns: `list`: The list of columns. .. versionadded:: 8.0.12 rrr+r+r, get_columnszRowResult.get_columns) rgrhrir-rrrrrjr+r+rdr,rs   rcs8eZdZdZfddZddZddZdd ZZS) SqlResultzRepresents a result from a SQL statement. Args: connection (mysqlx.connection.Connection): The Connection object. crr)r`rrrGrdr+r,r0rzSqlResult.__init__cCr)zReturns the identifier for the last record inserted. Returns: str: The identifier of the last record inserted. rZrr+r+r,re3r z!SqlResult.get_autoincrement_valuecCs|jrdSd|_|dS)zjProcess the next result. Returns: bool: Returns `True` if the fetch is done. FT)r?rnrrrr+r+r, next_result;s zSqlResult.next_resultcCr)zReturns True if result has data. Returns: bool: Returns `True` if result has data. .. versionadded:: 8.0.12 rrr+r+r,has_dataGrzSqlResult.has_data) rgrhrir-rrerrrjr+r+rdr,r*s   rcs,eZdZdZfddZfddZZS) DocResultzAllows traversing the DbDoc objects returned by a Collection.find operation. Args: connection (mysqlx.connection.Connection): The Connection object. crr)r`rrrGrdr+r,rXrzDocResult.__init__cs,tt||}|durdStt|dS)zRead item. Args: dumping (bool): `True` for dumping. Returns: :class:`mysqlx.DbDoc`: A `DbDoc` object. Nr)r`rr|rr)rryrzrdr+r,r|[s zDocResult._read_item)rgrhrir-rr|rjr+r+rdr,rQs r).r-rSr4r#rrdbdocrcharsetsrcompatrhelpersrr r-rrrrGrrrr!rrobjectrerlr rrrrrrrrrr.r<r_rkrrrr+r+r+r,sR   $ L'[)K/~'