"ivydZddlZddlZddlZddlmZmZddlmZddlm Z ddl m Z m Z dZ d Zd Zd Zd Zd ZdZdZdZdZdZGddeZGddeZGddeZGddeZGddeZGddeZGdd eZGd!d"eZ Gd#d$eZ!Gd%d&eZ"Gd'd(eZ#Gd)d*eZ$Gd+d,eZ%Gd-d.eZ&Gd/d0e&Z'Gd1d2e&Z(Gd3d4e(Z)Gd5d6e)Z*Gd7d8e(Z+dS)9z%Implementation of the Result classes.N)datetime timedelta)DbDoc)MYSQL_CHARACTER_SETS)decode_from_bytes deprecatedct|dkrdS|tjkrt |ddS t j||S#t$r}tj d |tj d | dYd}~dSd}~wwxYw)Nr{0}hex)lenget_type ColumnTypeSTRINGrColumnProtoType converter_mapget_proto_typeKeyErrorsysstderrwriteformatencode)columnpayloaderrs E/srv/django_bis/venv311/lib/python3.11/site-packages/mysqlx/result.py from_protobufr+s 7||qt J--- "...,  ! ! # #    c**+++ gnnU&;&;<<===ttttts+A<< DA7DDc|ddS)Nr rs rbytes_from_protobufr#<s 3B3<cbt|dksJtjd|dS)Nz>'.. 0@@#  #"3 )###'  ?Q  #&:";";;; "$$*F4?$;$;==='8D'+AwD $#'7D '4+?? >%)== O   *.  j/,11r$clt|j|j|jt|jdS)N)rrrr&)strrrr rrs rrzColumn.__str__s:l[%%      r$cb|jtjkrtj|_nx|jtjkrtj|_nQ|jtjkrtj|_n*|jrtj|_ntj |_|j dz|_ dS)z Map bytes.rN) rrrrrrrrrrrrrs r _map_byteszColumn._map_bytess  !1!: : :'0DNN  #3#8 8 8'_DNN  #3#7 7 7'^DNN _ /'-DNN'.DN+/r$c|jdkrtj|_dS|jt jzdkrtj|_dS|jdkrtj|_dStd)z Map datetime.rOrrzz#Datetime mapping scenario unhandledN) rrrrrrrrr3rs r _map_datetimezColumn._map_datetimesj <2  '_DNNN [.8 81 < <'1DNNN \R  '0DNNNBCC Cr$c|jdkrtj|_nh|jdkrtj|_nK|jdkrtj|_n.|jdkrtj|_ntj|_d|_dS)z Map int type.r&rsrtruTN) rrrrrrrrrrs r _map_int_typezColumn._map_int_types} <1  '/DNN \Q  '0DNN \Q  '1DNN \R  '^DNN'.DN"r$c.|jdkrtj|_nh|jdkrtj|_nK|jdkrtj|_n.|jdkrtj|_ntj|_|jdz|_ dS)zMap uint type.rqrrr-rOrN) rrrrrrrrrrrs r_map_uint_typezColumn._map_uint_types <1  '/DNN \Q  '0DNN \Q  '1DNN \R  '^DNN'.DN+/r$c|jtjkr|dS|jtjkr|dS|jtjkr0tj|_|j tj zdk|_ dS|jtj kr0tj |_|j tj zdk|_ dS|jtjkr0tj|_|j tj zdk|_ dS|jtjkr|dS|jtjkrtj|_dS|jtjkr|dS|jtjkrtj|_dS|jtjkrtj|_dS|jtjkrtj|_dSt/d|j)z Map type.rzUnknown column type {0}N)r rrr0rr2rrrrrr_is_number_signedrrrr,rrr.rrrr3rrs rrzColumn._map_types  3 3 3     !5 5 5    ! ! ! ! !  !6 6 6'-DN/88Q>  " " "  !8 8 8'/DN/88Q>  " " "  !7 7 7'.DN/88Q>  " " "  !6 6 6 OO       !5 5 5'_DNNN  !9 9 9     !4 4 4'^DNNN  !5 5 5'_DNNN  !4 4 4'^DNNN6==d>NOOPP Pr$c|jS)z@str: The schema name. .. versionadded:: 8.0.12 rrs r schema_namezColumn.schema_name5 |r$c|jp|jS)z?str: The table name. .. versionadded:: 8.0.12 r r rs r table_namezColumn.table_name= #2t{2r$c|jp|jS)z@str: The table label. .. versionadded:: 8.0.12 r r rs r table_labelzColumn.table_labelE {2d22r$c|jp|jS)z@str: The column name. .. versionadded:: 8.0.12 r r rs r column_namezColumn.column_nameM "0dj0r$c|jp|jS)zAstr: The column label. .. versionadded:: 8.0.12 r r rs r column_labelzColumn.column_labelU z0T00r$c|jS)z@int: The column type. .. versionadded:: 8.0.12 rrs rtypez Column.type] ~r$c|jS)zBint. The column length. .. versionadded:: 8.0.12 rrs rr#z Column.lengther8r$c|jS)zMint: The column fractional digits. .. versionadded:: 8.0.12 rrs rr%zColumn.fractional_digitsm &&r$c|jS)zCstr: The collation name. .. versionadded:: 8.0.12 rrs rcollation_namezColumn.collation_nameu ##r$c|jS)zGstr: The character set name. .. versionadded:: 8.0.12 rrs rcharacter_set_namezColumn.character_set_name} ''r$c|jS)zUReturns the schema name. Returns: str: The schema name. r6rs rget_schema_namezColumn.get_schema_namer8r$c|jp|jS)zSReturns the table name. Returns: str: The table name. r:rs rget_table_namezColumn.get_table_namer<r$c|jp|jS)zUReturns the table label. Returns: str: The table label. r>rs rget_table_labelzColumn.get_table_labelr@r$c|jp|jS)zUReturns the column name. Returns: str: The column name. rBrs rget_column_namezColumn.get_column_namerDr$c|jp|jS)zWReturns the column label. Returns: str: The column label. rFrs rget_column_labelzColumn.get_column_labelrHr$c|jS)zaReturns the column proto type. Returns: int: The column proto type. )r rs rrzColumn.get_proto_types r$c|jS)zUReturns the column type. Returns: int: The column type. rJrs rrzColumn.get_typerLr$c|jS)zYReturns the column length. Returns: int: The column length. rNrs r get_lengthzColumn.get_lengthr8r$c|jS)zoReturns the column fractional digits. Returns: int: The column fractional digits. rPrs rget_fractional_digitszColumn.get_fractional_digitsrQr$c|jS)z[Returns the collation name. Returns: str: The collation name. rSrs rget_collation_namezColumn.get_collation_namerUr$c|jS)zcReturns the character set name. Returns: str: The character set name. rWrs rget_character_set_namezColumn.get_character_set_namerYr$c|jS)zxReturns `True` if is a number signed. Returns: bool: Returns `True` if is a number signed. )rrs ris_number_signedzColumn.is_number_signed ""r$c|jS)zfReturns `True` if is padded. Returns: bool: Returns `True` if is padded. )rrs r is_paddedzColumn.is_paddeds r$c|jS)zdReturns `True` if is bytes. Returns: bool: Returns `True` if is bytes. )rrs ris_byteszColumn.is_bytesrLr$) NNNNNNNNNNN)$rkrlrm__doc__rrr,r.r0r2rrr7r;r?rCrGrKr#r%rTrXr[r]r_rarcrrrgrirkrmrorrrtr!r$rrrs$CG?C@D*.%1%1%1%1N    * * * D D D # # # * * *QQQBX33X333X311X111X1XX''X'$$X$((X(333333111111   '''$$$(((###r$rcLeZdZdZdZdZdZeddZdS)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. c"||_||_dSr)_fields _resultset)rrsfieldss rrz Row.__init__s r$c*t|jSr)reprryrs r__repr__z Row.__repr__sDL!!!r$cRt|tr|j|n|}|dkr7t|tr"t d||t |jks|dkrtd|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) r4r*rzindex_ofr3rrry IndexError)rindex int_indexs r __getitem__zRow.__getitem__s %%%1DO,,U333+0  ??z%55?:AA%HHII I DL)) ) )Y]]122 2|I&&r$8.0.12c|j|}|t|jkrt d|dkr"t d|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 r)rzrrryrr3rr*)r str_indexrs r get_stringzRow.get_stringsxO,,Y77 DL)) ) )455 5 ??:AA)LLMM M4< *+++r$N) rkrlrmrurrrr rr!r$rrwrwsq """ ' ' 'Z , , , , ,r$rwcHeZdZdZdZdZdZdZdZdZ dZ d Z d Z d S) BaseResultzProvides base functionality for result objects. Args: connection (mysqlx.connection.Connection): The Connection object. c||_d|_d|_d|_g|_g|_| d|_dS|j|_|dSNFrr ) _connection_closed_rows_affected _generated_id_generated_ids _warnings _protocolprotocolfetch_active_result)r connections rrzBaseResult.__init__(sc%    !DNNN'0DN  * * , , , , ,r$c|jS)zReturns the number of affected items for the last operation. Returns: int: The number of affected items. rrs rget_affected_items_countz#BaseResult.get_affected_items_count6rpr$c|jS)zZReturns the warnings. Returns: `list`: The list of warnings. )rrs r get_warningszBaseResult.get_warnings>rLr$c*t|jS)zcReturns the number of warnings. Returns: int: The number of warnings. )rrrs rget_warnings_countzBaseResult.get_warnings_countFs 4>"""r$c||_dS)z)Sets if resultset fetch is done. N)rrrs r set_closedzBaseResult.set_closedNs r$cB|j|||ddS)zAppend a warning. Args: level (int): The warning level. code (int): The warning code. msg (str): The warning message. )levelcodemsgN)rrH)rrrrs rappend_warningzBaseResult.append_warningSs* tCHHIIIIIr$c||_dS)z Sets the generated ids. Nr)r generated_idss rset_generated_idszBaseResult.set_generated_ids]s,r$c||_dS)z&Sets the generated insert id. Nr)r generated_ids rset_generated_insert_idz"BaseResult.set_generated_insert_idbs*r$c||_dS)z*Sets the number of rows affected. Nr)rtotals rset_rows_affectedzBaseResult.set_rows_affectedgs$r$N) rkrlrmrurrrrrrrrrr!r$rrr"s - - -###### JJJ,,, *** $$$$$r$rceZdZdZd fd ZdZeddZeddZdZ xZ 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. Nctt||||_||j|dSdSr)superrr_idsr close_result)rridsrs rrzResult.__init__usS fd$$Z000  !   ) )$ / / / / / " !r$c|jS)zjReturns the last insert id auto generated. Returns: int: The last insert id. rrs rget_autoincrement_valuezResult.get_autoincrement_value| !!r$rc^|jt|jdkrdS|jdS)zdReturns ID of the last document inserted into a collection. .. deprecated:: 8.0.12 Nr)rrrs rget_document_idzResult.get_document_ids/ 9 DI! 3 34y|r$c|jS)zIReturns the generated insert id. .. deprecated:: 8.0.12 rrs rget_generated_insert_idzResult.get_generated_insert_idrr$c|jS)z#Returns the generated ids. rrs rget_generated_idszResult.get_generated_idss ""r$)NN) rkrlrmrurrr rrr __classcell__rs@rrrms000000"""ZZ"""#######r$rcneZdZdZfdZdZedZdZdZ dZ dZ d Z d Z d Zd ZxZS) BufferingResultzProvides base functionality for buffering result objects. Args: connection (mysqlx.connection.Connection): The Connection object. ids (`list`): A list of IDs. ctt||g|_d|_d|_g|_d|_d|_| dSr) rrr_columns _has_data_has_more_results_items _page_size _position _init_resultrrrs rrzBufferingResult.__init__sd ot$$--j999 !&  r$c|j|Sr)r)rrs rrzBufferingResult.__getitem__s{5!!r$c*t|jS)zint: The total of items.)rrrs rcountzBufferingResult.counts4;r$c|j||_t|jdkrdnd|_g|_d|_d|_|j|jr|nddS)zInitialize the result.rTFr{r N) rget_column_metadatarr_has_more_datarrrset_active_resultrs rrzBufferingResult._init_results(<|jrdS|dS)zuFetch one item. Returns: :class:`mysqlx.Row` or :class:`mysqlx.DbDoc`: one result item. NF)rrrs r fetch_onezBufferingResult.fetch_ones% < 4u%%%r$c> |sn|jS)zFetch all items. Returns: `list`: The list of items of :class:`mysqlx.DbDoc` or :class:`mysqlx.Row`. )rrrs r fetch_allzBufferingResult.fetch_alls- &&((  {r$c||_dS)zdSets if result has data. Args: flag (bool): `True` if result has data. Nrrs r set_has_datazBufferingResult.set_has_datas r$c||_dS)zfSets if has more results. Args: flag (bool): `True` if has more results. N)rrs rset_has_more_resultsz$BufferingResult.set_has_more_resultss "&r$)rkrlrmrurrrrrrrrrrrrrrs@rrrs """  X 666&$    & & &   &&&&&&&r$rc>eZdZdZfdZedZdZxZS) RowResultzAllows traversing the Row objects returned by a Table.select operation. Args: connection (mysqlx.connection.Connection): The Connection object. cXtt||dSr)rrrrs rrzRowResult.__init__' i'' 33333r$c|jS)z`list`: The list of columns.rrs rcolumnszRowResult.columns"s }r$c|jS)zReturns the list of columns. Returns: `list`: The list of columns. .. versionadded:: 8.0.12 rrs r get_columnszRowResult.get_columns's }r$) rkrlrmrurrrrrrs@rrrsl 44444Xr$rc4eZdZdZfdZdZdZdZxZS) SqlResultzRepresents a result from a SQL statement. Args: connection (mysqlx.connection.Connection): The Connection object. cXtt||dSr)rrrrs rrzSqlResult.__init__8rr$c|jS)zReturns the identifier for the last record inserted. Returns: str: The identifier of the last record inserted. rrs rrz!SqlResult.get_autoincrement_value;rr$cN|jrdSd|_|dS)zjProcess the next result. Returns: bool: Returns `True` if the fetch is done. FT)rrrrs r next_resultzSqlResult.next_resultCs2 < 5!& tr$c|jS)zReturns True if result has data. Returns: bool: Returns `True` if result has data. .. versionadded:: 8.0.12 rrs rhas_datazSqlResult.has_dataOs ~r$) rkrlrmrurrrrrrs@rrr2so 44444"""   r$rc,eZdZdZfdZfdZxZS) DocResultzAllows traversing the DbDoc objects returned by a Collection.find operation. Args: connection (mysqlx.connection.Connection): The Connection object. cXtt||dSr)rrrrs rrzDocResult.__init__`rr$ctt||}|dStt |dS)zRead item. Args: dumping (bool): `True` for dumping. Returns: :class:`mysqlx.DbDoc`: A `DbDoc` object. Nr)rrrrr)rrrrs rrzDocResult._read_itemcsGIt$$//88 ;4&s1v..///r$)rkrlrmrurrrrs@rrrYs[ 44444 0 0 0 0 0 0 0 0 0r$r),rurRr(rrrdbdocrcharsetsrhelpersrr rr#r*r.r?rDrFrKrYrbrgobjectrirrrrrrrrrrrrwrrrrrrr!r$rrsv:,+ ((((((((******22222222" +++ +++ (((,       *!3!3!3HHHH*,,,@I0I0I0I0I0I0I0I0Xf8$$$$$F$$$N%+k {{{VVVVVVVVVr ),),),),),&),),),XH$H$H$H$H$H$H$H$V,#,#,#,#,#Z,#,#,#^z&z&z&z&z&jz&z&z&z2%%%%% %%%N0000000000r$