a cfvy@sdZddlZddlZddlZddlmZmZddlmZddlm Z ddl m Z m Z dd Z d d Zd d ZddZddZddZddZddZddZddZddZGdddeZGd d!d!eZGd"d#d#eZGd$d%d%eZGd&d'd'eZGd(d)d)eZGd*d+d+eZGd,d-d-eZ Gd.d/d/eZ!Gd0d1d1eZ"Gd2d3d3eZ#Gd4d5d5eZ$Gd6d7d7eZ%Gd8d9d9eZ&Gd:d;d;e&Z'Gdd?d?e(Z)Gd@dAdAe)Z*GdBdCdCe(Z+dS)Dz%Implementation of the Result classes.N)datetime timedelta)DbDoc)MYSQL_CHARACTER_SETS)decode_from_bytes deprecatedc Cst|dkrdS|tjkr.t|ddSztj||WSty}z8t j d |t j d | dWYd}~dSd}~00dS)Nr{0}hex)lenget_type ColumnTypeSTRINGrColumnProtoType converter_mapget_proto_typeKeyErrorsysstderrwriteformatencode)columnpayloaderrrJ/home/httpd/docs/test/DocsMgr/lib/python3.9/site-packages/mysqlx/result.py from_protobuf+s rcCs |ddS)Nr rrrrrbytes_from_protobuf<sr cCs t|dksJtd|dS)Nz rU"#cCs*t|D]\}}||kr |Sq dSN)varsitems)clsneedlekeyvaluerrr to_strings zColumnType.to_stringcCst||dSrs)getattrupper)rvrxrrr from_stringszColumnType.from_stringcCs||j|jfvSrs)CHARVARCHARrvcol_typerrris_charszColumnType.is_charcCs||j|jfvSrs)BINARY VARBINARYrrrr is_binaryszColumnType.is_binarycCs||j|j|j|jfvSrs)TEXTTINYTEXT MEDIUMTEXTLONGTEXTrrrris_text#szColumnType.is_textcCs||j|j|j|j|jfvSrs)REALDOUBLEFLOATDECIMALNUMERICrrrr is_decimals(szColumnType.is_decimalscCs ||j|j|j|j|j|jfvSrs)BITTINYINTSMALLINT MEDIUMINTINTBIGINTrrrr is_numeric-szColumnType.is_numericcCs||j|jfvSrs)SETENUMrrrr is_finite_set2szColumnType.is_finite_setN)/rVrWrXrrrrrrrrrrrJSONrBYTESTIMEDATEDATETIME TIMESTAMPrrGEOMETRYXMLZYEARr~rrrZTINYBLOBZBLOBZ MEDIUMBLOBZLONGBLOBrrrr classmethodrzr}rrrrrrrrrrrsf       rc@sheZdZdZdZdZdZdZdZdZ dZ d Z d Z d Z eeeeeee eeeeeeee ee ee ee ei Zd S) rrrYr[r\r*r?r@r>r`rarbN)rVrWrXSINTUINTrrrrrrrrrr:r9r rOrSr%r'r<rGrrrrrr7s.rc@s6eZdZddZddZeddZejddZdS) FlagscCsVi|_i|_|jjD]2\}}|dr,qt|tr||j|<||j|<q||_dS)N__) Z_allowed_flags _flag_names __class____dict__ru startswithr,r-_value)selfryrxvalrrr__init__Ts    zFlags.__init__c Csd}g}|j}tddD]j}|dK}||@}|rz||j|Wqtytjd|jtjd|j j Yq0qd |S)Nrr?r ,) rranger;rrrrrrrrjoin)rmaskZ flag_namesry_flagrrr__str___s z Flags.__str__cCs|jSrsrrrrrryqsz Flags.valuecCs ||_dSrsr)rrrrrryusN)rVrWrXrrpropertyrysetterrrrrrSs   rc@s eZdZdZdZdZdZdZdS) ColumnFlagsr`rp@r(N)rVrWrXZNOT_NULLZ PRIMARY_KEYZ UNIQUE_KEYZ MULTIPLE_KEYZAUTO_INCREMENTrrrrrzs rc@seZdZdZdS)DatetimeColumnFlagsrN)rVrWrXrrrrrrsrc@seZdZdZdS)UIntColumnFlagsrN)rVrWrXZZEROFILLrrrrrsrc@seZdZdZdS)DoubleColumnFlagsrNrVrWrXUNSIGNEDrrrrrsrc@seZdZdZdS)FloatColumnFlagsrNrrrrrrsrc@seZdZdZdS)BytesColumnFlagsrN)rVrWrXZ RIGHT_PADrrrrrsrc@seZdZdZdZdZdS)BytesContentTyperrYrZN)rVrWrXrrrrrrrrsrc @s2eZdZdZdAddZddZddZd 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 dkr|j ttkrtd|j t|j } | d|_| d|_d|jvpd|jv|_||jtjtjtjtjtjfv|_dS)NFrz"No mapping found for collation {0}rbinaryZ_bin) r_schema_name_original_name_table_original_table _proto_type _col_type_catalog_lengthZ _collation_fractional_digits_flags _content_type_number_signed _is_padded _is_binary _is_bytes_collation_name_character_set_name _zero_fillr rr+r _map_typerrrrrr)rrcatalogschematableZoriginal_tablename original_namelengthZ collationfractional_digitsflags content_typeinforrrrsH           zColumn.__init__cCst|j|j|jt|jdS)N)rrrr)strrrrrrrrrrs zColumn.__str__cCsj|jtjkrtj|_nD|jtjkr,tj|_n.|jtjkrBtj|_n|jrRtj|_ntj |_|j d@|_ dS)z Map bytes.rN) rrrrrrrrrrrrrrrr _map_bytess       zColumn._map_bytescCsN|jdkrtj|_n6|jtj@dkr.tj|_n|jdkrBtj|_ntddS)z Map datetime.r?rrcz#Datetime mapping scenario unhandledN) rrrrrrrrr+rrrr _map_datetimes     zColumn._map_datetimecCsb|jdkrtj|_nD|jdkr(tj|_n0|jdkrszBaseResult.get_warningscCs t|jS)zcReturns the number of warnings. Returns: int: The number of warnings. )r r!rrrrget_warnings_countFszBaseResult.get_warnings_countcCs ||_dS)z)Sets if resultset fetch is done. N)rrrrrr set_closedNszBaseResult.set_closedcCs|j|||ddS)zAppend a warning. Args: level (int): The warning level. code (int): The warning code. msg (str): The warning message. )levelcodemsgN)r!r;)rr,r-r.rrrappend_warningSszBaseResult.append_warningcCs ||_dS)z Sets the generated ids. Nr )rZ generated_idsrrrset_generated_ids]szBaseResult.set_generated_idscCs ||_dS)z&Sets the generated insert id. Nr)rZ generated_idrrrset_generated_insert_idbsz"BaseResult.set_generated_insert_idcCs ||_dS)z*Sets the number of rows affected. Nr&)rtotalrrrset_rows_affectedgszBaseResult.set_rows_affectedN) rVrWrXr rr'r(r)r+r/r1r3r5rrrrr"s rcsReZdZdZdfdd 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. Ncs.tt||||_|dur*|j|dSrs)superr6r_idsrZ close_result)rr%idsrrrruszResult.__init__cCs|jS)zjReturns the last insert id auto generated. Returns: int: The last insert id. r2rrrrget_autoincrement_value|szResult.get_autoincrement_valuercCs&|jdust|jdkrdS|jdS)zdReturns ID of the last document inserted into a collection. .. deprecated:: 8.0.12 Nr)r8r rrrrget_document_idszResult.get_document_idcCs|jS)zIReturns the generated insert id. .. deprecated:: 8.0.12 r2rrrrget_generated_insert_idszResult.get_generated_insert_idcCs|jS)z#Returns the generated ids. r0rrrrget_generated_idsszResult.get_generated_ids)NN) rVrWrXr rr;rr<r=r> __classcell__rrr:rr6ms  r6csteZdZdZfddZddZeddZdd 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) r7r@r_columns _has_data_has_more_results_items _page_size _position _init_resultr$r:rrrszBufferingResult.__init__cCs |j|Srs)rD)rrrrrrszBufferingResult.__getitem__cCs t|jS)zint: The total of items.)r rDrrrrcountszBufferingResult.countcCsR|j||_t|jdkr dnd|_g|_d|_d|_|j|jrH|nddS)zInitialize the result.rTFrdr N) rZget_column_metadatarAr Z_has_more_datarDrErFZset_active_resultrrrrrGszBufferingResult._init_resultcCsn|j|}|durdSdgt|d}|sdtt|dD]$}|j|}t||d|||<q>t||S)zRead item. Args: dumping (bool): `True` for dumping. Returns: :class:`mysqlx.Row`: A `Row` object. Nfield)rZread_rowr rrArr )rdumpingrowr3rxrrrr _read_items  zBufferingResult._read_itemcCsL|jr dSd}t|jD].}|d}|dur2qH|j||d7}q|S)zSReads the page items. Returns: int: Total items read. FrNr)rrrErLrDr;)rrHrr3rrr_page_in_itemss   zBufferingResult._page_in_itemscCs0d}|jD] }||kr"|S|d7}q dS)zeReturns the index of the column. Returns: int: The index of the column. rrr )rAr)rZcol_namercolrrrrs    zBufferingResult.index_ofcCs|jr dS|dS)zuFetch one item. Returns: :class:`mysqlx.Row` or :class:`mysqlx.DbDoc`: one result item. NF)rrLrrrr fetch_oneszBufferingResult.fetch_onecCs|sq q|jS)zFetch all items. Returns: `list`: The list of items of :class:`mysqlx.DbDoc` or :class:`mysqlx.Row`. )rMrDrrrr fetch_allszBufferingResult.fetch_allcCs ||_dS)zdSets if result has data. Args: flag (bool): `True` if result has data. NrBr*rrr set_has_dataszBufferingResult.set_has_datacCs ||_dS)zfSets if has more results. Args: flag (bool): `True` if has more results. N)rCr*rrrset_has_more_resultssz$BufferingResult.set_has_more_results)rVrWrXr rrrrHrGrLrMrrOrPrRrSr?rrr:rr@s      r@cs4eZdZdZfddZeddZddZZS) RowResultzAllows traversing the Row objects returned by a Table.select operation. Args: connection (mysqlx.connection.Connection): The Connection object. cstt||dSrs)r7rTrr$r:rrrszRowResult.__init__cCs|jS)z`list`: The list of columns.rArrrrcolumns"szRowResult.columnscCs|jS)zReturns the list of columns. Returns: `list`: The list of columns. .. versionadded:: 8.0.12 rUrrrr get_columns'szRowResult.get_columns) rVrWrXr rrrVrWr?rrr:rrTs   rTcs8eZdZdZfddZddZddZdd ZZS) SqlResultzRepresents a result from a SQL statement. Args: connection (mysqlx.connection.Connection): The Connection object. cstt||dSrs)r7rXrr$r:rrr8szSqlResult.__init__cCs|jS)zReturns the identifier for the last record inserted. Returns: str: The identifier of the last record inserted. r2rrrrr;;sz!SqlResult.get_autoincrement_valuecCs|jr dSd|_|dS)zjProcess the next result. Returns: bool: Returns `True` if the fetch is done. FT)rrCrGrrrr next_resultCs zSqlResult.next_resultcCs|jS)zReturns True if result has data. Returns: bool: Returns `True` if result has data. .. versionadded:: 8.0.12 rQrrrrhas_dataOszSqlResult.has_data) rVrWrXr rr;rYrZr?rrr:rrX2s   rXcs,eZdZdZfddZfddZZS) DocResultzAllows traversing the DbDoc objects returned by a Collection.find operation. Args: connection (mysqlx.connection.Connection): The Connection object. cstt||dSrs)r7r[rr$r:rrr`szDocResult.__init__cs,tt||}|durdStt|dS)zRead item. Args: dumping (bool): `True` for dumping. Returns: :class:`mysqlx.DbDoc`: A `DbDoc` object. Nr)r7r[rLrr)rrJrKr:rrrLcs zDocResult._read_item)rVrWrXr rrLr?rrr:rr[Ys r[),r rBr#rrrZdbdocrZcharsetsrhelpersrrrr r%r'r5r9r:r<rGrOrSobjectrTrrrrrrrrrrrr rr6r@rTrXr[rrrrsN  $ L'[,K/}'