:?hSrSSKJr SSKrSSKrSSKrSSKJrJr SSKJ r J r J r J r J r JrJrJr SSKJr SSKJr SS KJrJr SS KJrJr SSjrS>SjrS?SjrS@Sjr S@Sjr!SASjr"SBSjr#SCSjr$SDSjr%"SS5r&"SS5r'"SS5r("SS5r)"SS \)5r*"S!S"\*5r+"S#S$\*5r,"S%S&\*5r-"S'S(\*5r."S)S*\*5r/"S+S,\*5r0"S-S 5r1"S.S/5r2"S0S15r3"S2S3\35r4"S4S5\35r5"S6S7\55r6"S8S9\65r7"S:S;\55r8g)Ez%Implementation of the Result classes.) annotationsN)datetime timedelta)AnyCallableDictListOptionalSequenceTupleUnion)MYSQL_CHARACTER_SETS)DbDoc)decode_from_bytes deprecated)ConnectionType FieldTypesColumnc[U5S:XagUR5[R:Xa[ USS5$[ R UR5"U5$![aYn[RRU5 [RRURS55 SnAgSnAff=f)Nrhex) lenget_type ColumnTypeSTRINGrColumnProtoType converter_mapget_proto_typeKeyErrorsysstderrwriteencode)columnpayloaderrs U/var/www/ev-aguas/ev-aguas-proceso/venv/lib/python3.13/site-packages/mysqlx/result.py from_protobufr)/s 7|q J--- "..,,V-B-B-DEgNN  C5" GNN5124s&A)) C 3ACC c USS$)Nrr&s r(bytes_from_protobufr->s 3B<cX[U5S:Xde[R"SU5S$)Nzr?r@rRr=decimalDecimal)r&digitssignscalerErFhigh_bcdlow_bcds r(decimal_from_protobufrcs# F D$WQZ55GAJ3wqz?EabkG!$,,t#d)4KA%+ d? MM( #~ g&DD //  Dd? "?   Dd? "? }XJ78 836 ??D5&1 22r.c SnSnSnSn[U5upP[U5up`[U5upp[U5up[U5up [U5up0[U5up@[XVXqX#U5$![a Nf=f)Nr)rIr=r)r&hourminutessecondsusecondsyearmonthdays r(datetime_from_protobufrls DGGH/8MD09NE.w7LC 3G< 6w?6w?7@ DGh GG    s4A33 B?Bc>SnSnSnSnUSS:HnUSSn[U5up[U5up [U5up0[U5up@U(a3U(aUS-nO&U(aUS-nOU(aUS-nO U(aUS-n[XX4S9$![a NPf=f)Nrrr)hoursrfrg microseconds)rIr=r)r&rerfrgrhnegates r(time_from_protobufrqs DGGH QZ1_FabkG 3G< 6w?6w?7@  BJD  rMG  rMG  NH W     s4B BBc\rSrSrSrSrg) Collations!r+N)__name__ __module__ __qualname____firstlineno__UTF8_GENERAL_CI__static_attributes__r+r.r(rsrssOr.rsc@\rSrSrSrSrSrSrSrSr Sr S r S r S r S rS rSrSrSrSrSrSrSrSrSrSrSrSrSrSrSrSrSr Sr!S r"S!r#S"r$S#r%S$r&\'S/S%j5r(\'S0S&j5r)\'S1S'j5r*\'S1S(j5r+\'S1S)j5r,\'S1S*j5r-\'S1S+j5r.\'S1S,j5r/S-r0g.)2rrr0r<r7 rY rZr[rX ru"#cZ[U5R5Hup#X1:XdM Us $ gN)varsitems)clsneedlekeyvalues r( to_stringColumnType.to_strings(s)//+JC ,r.c6[XR5S5$r)getattrupper)rrs r( from_stringColumnType.from_stringssIIK..r.c8UURUR4;$r)CHARVARCHARrcol_types r(is_charColumnType.is_chars" HH KK   r.c8UURUR4;$r)BINARY VARBINARYrs r( is_binaryColumnType.is_binary%s" JJ MM   r.cdUURURURUR4;$r)TEXTTINYTEXT MEDIUMTEXTLONGTEXTrs r(is_textColumnType.is_text,s0 HH LL NN LL    r.czUURURURURUR4;$r)REALDOUBLEFLOATDECIMALNUMERICrs r( is_decimalsColumnType.is_decimals5s7 HH JJ II KK KK    r.cUURURURURURUR 4;$r)BITTINYINTSMALLINT MEDIUMINTINTBIGINTrs r( is_numericColumnType.is_numeric?s> GG KK LL MM GG JJ    r.c8UURUR4;$r)SETENUMrs r( is_finite_setColumnType.is_finite_setJs" GG HH   r.r+N)rrreturn Optional[str])rstrrr)rr?rbool)1rvrwrxryrrrrrrrrrrrJSONrBYTESTIMEDATEDATETIME TIMESTAMPrrGEOMETRYXMLYEARrrrrTINYBLOBBLOB MEDIUMBLOBLONGBLOBrrrr classmethodrrrrrrrrr{r+r.r(rrsO CGHI C F D EGG F D F E D DHI C DH C D DG FIH DJHH DJH //            r.rc|\rSrSr%SrSrSrSrSrSr Sr S r S r S r S r\\\\\\\ \\ \\\\\\ \\ \\ \\\0 rS \S'Srg)riRrr~rrr<rYrZrXrrrz!Dict[int, Callable[[bytes], Any]]rr+N)rvrwrxrySINTUINTrrrrrrrrrrPrNr-rlrqr4r8rUrcr__annotations__r{r+r.r(rrRs D D F E E DH C D CG # " "(   "$ !  !& 8M4 r.rcd\rSrSrSSjrS Sjr\S Sj5r\RS Sj5rSr g) Flagsinc0Ul0UlURRR 5HPup#UR S5(aM[ U[5(dM4X0RU'X RU'MR Xlg)N__) _allowed_flags _flag_names __class____dict__r startswithr>r?_value)selfrrvals r(__init__Flags.__init__oss.0+-//557HC~~d###s##+.##C((+  % 8 ! r.cSn/nURn[SS5H4nUS-nX1-nU(dMURURU5 M6 SRU5$![ab [ R RUR5 [ R RURR5 Mf=f)Nrr?,) rrangerRrr r!r"r#rrjoin)rmask flag_namesr_flags r(__str__ Flags.__str__zs  q"A QJDR>R4R O     OO NN       ,  r.c[URURUR[UR5S.5$)N)rr>r?rF)rr.r(r+r3rs r(rColumn.__str__s5 NN,,T[[)    r.cUR[R:Xa[RUlOUR[R :Xa[R UlOpUR[R :Xa[R UlOrr?rr@rrArrBrrC Optional[int]rDrrErrFrrGrrrrrrrrrrzUnion[bool, int])&rvrwrxry__doc__rrrMrPrSrVr<rr]rbrgrlrqrvrCrErrrrrrrrrrrrrrrrr{r+r.r(rrs,"& $#(,"'+ $#'+/#&*4 4 4  4  4 & 4 4 %4 4 !4 )4 4 $4  4 l  * D # *H<33331111''$$((3311 '$(#r.cb\rSrSrSrS SjrS SjrS Sjr\"S5S Sj5r Sr g )Rowi"zRepresents a row element returned from a SELECT query. Args: resultset (mysqlx.SqlResult or mysqlx.RowResult): The result set. fields (`list`): The list of fields. cX lXlgr_fields _resultset)r resultsetfieldss r(r Row.__init__*s.4 =Fr.c,[UR5$r)reprrrs r(__repr__ Row.__repr__0sDLL!!r.c,[U[5(aURRU5OUnUS:Xa$[U[5(a[ SUS35eU[ UR 5:dUS:a [S5eUR U$)zLReturns the value of a column by name or index. .. versionchanged:: 8.0.12 r Column name ' ' not foundrzIndex out of range)r>rrindex_ofr=rr IndexError)rindex int_indexs r( __getitem__Row.__getitem__3s 8B%7M7MDOO,,U3SX ?z%55}UG;?@ @ DLL) )Y]12 2||I&&r.8.0.12cURRU5nU[UR5:a [ S5eUS:Xa[ SUS35e[ URU5$)znReturns the value using the column name. Args: str_index (str): The column name. .. deprecated:: 8.0.12 zArgument out of rangerrr)rrrrrr=r)r str_indexrs r( get_stringRow.get_string?sdOO,,Y7 DLL) )45 5 ?}YK{CD D4<< *++r.rN)rz!Union[BufferingResult, RowResult]rzSequence[FieldTypes]rrr)rzUnion[int, str]rr)rrrr) rvrwrxryrrrrrrr{r+r.r(rr"sKG:GDXG G " ' , ,r.rcr\rSrSrSrSSjrSSjrSSjrSSjrSSjr SSjr SS jr SS jr SS jr S rg ) BaseResultiPz}Provides base functionality for result objects. Args: connection (mysqlx.connection.Connection): The Connection object. cXlSUlSUlSUl/Ul/UlUcSUlgURUlUR5 gNFrr) _connection_closed_rows_affected _generated_id_generated_ids _warnings _protocolprotocolfetch_active_result)r connections r(rBaseResult.__init__WsT+5" #$"$)+;=  !DN'00DN  * * ,r.cUR$)znReturns the number of affected items for the last operation. Returns: int: The number of affected items. rrs r(get_affected_items_count#BaseResult.get_affected_items_counterr.cUR$)zBReturns the warnings. Returns: `list`: The list of warnings. )rrs r( get_warningsBaseResult.get_warningsmrxr.c,[UR5$)zKReturns the number of warnings. Returns: int: The number of warnings. )rrrs r(get_warnings_countBaseResult.get_warnings_countus 4>>""r.cXlg)z Sets if resultset fetch is done.N)rrrs r( set_closedBaseResult.set_closed}s r.c@URRXUS.5 g)zAppend a warning. Args: level (int): The warning level. code (int): The warning code. msg (str): The warning message. )levelcodemsgN)rrR)rrrrs r(append_warningBaseResult.append_warnings CHIr.cXlg)zSets the generated ids.Nr)r generated_idss r(set_generated_idsBaseResult.set_generated_idss+r.cXlg)zSets the generated insert id.Nr)r generated_ids r(set_generated_insert_id"BaseResult.set_generated_insert_ids)r.cXlg)z!Sets the number of rows affected.Nr)rtotals r(set_rows_affectedBaseResult.set_rows_affecteds#r.)rrrrrrrNrrrrr)rz List[Dict[str, Union[int, str]]]rrrr)rr?rr?rrrr)r List[int]rr)rr?rr)rr?rr)rvrwrxryrrrrrrrrrrr{r+r.r(rrPs5 -##J,*$r.rc^\rSrSrSrS S U4SjjjrS Sjr\"S5S Sj5r\"S5S Sj5r SSjr S r U=r $)ResultizAllows retrieving information about non query operations performed on the database. Args: connection (mysqlx.connection.Connection): The Connection object. ids (`list`): A list of IDs. cn>[TU]U5 X lUbURR U5 ggr)superr_idsr close_result)rridsrs r(rResult.__init__s6 $),  !    ) )$ / "r.cUR$)zRReturns the last insert id auto generated. Returns: int: The last insert id. rrs r(get_autoincrement_valueResult.get_autoincrement_value !!!r.rcnURb[UR5S:XagURS$)zTReturns ID of the last document inserted into a collection. .. deprecated:: 8.0.12 Nr)r rrs r(get_document_idResult.get_document_ids. 99 DII! 3yy|r.cUR$)z9Returns the generated insert id. .. deprecated:: 8.0.12 rrs r(get_generated_insert_idResult.get_generated_insert_idrr.cUR$)zReturns the generated ids.rrs r(get_generated_idsResult.get_generated_idss"""r.)r )NN)rzOptional[ConnectionType]r zOptional[List[int]]rrr)rr)rr) rvrwrxryrrrrrrrr{ __classcell__rs@r(rrsw04#' 0, 0! 0  0 0"""##r.rc^\rSrSrSrSU4SjjrSSjr\SSj5rSSjr SSjr SSjr SS jr SS jr SS jrSS jrSS jrSrU=r$)BufferingResultizProvides base functionality for buffering result objects. Args: connection (mysqlx.connection.Connection): The Connection object. ids (`list`): A list of IDs. c>[TU]U5 /UlSUlSUl/UlSUlSUlUR5 gr) r r_columns _has_data_has_more_results_items _page_size _position _init_result)rrrs r(rBufferingResult.__init__sG $&( $',/1    r.c URU$r)r$)rrs r(rBufferingResult.__getitem__s{{5!!r.c,[UR5$)zint: The total of items.)rr$rs r(countBufferingResult.counts4;;r.cURRU5Ul[UR5S:Ul/UlSUlSUlURRUR(aU5 gS5 g)zInitialize the result.rrrN) rget_column_metadatar!r_has_more_datar$r%r&set_active_resultrs r(r'BufferingResult._init_resultsf((<rrr?)rrO)rzList[Union[Row, DbDoc]]r)rvrwrxryrrrrr,r'r8r;rrBrErIrMr{rrs@r(rrsT"  R&$  & &&r.rc6\rSrSrSr\SSj5rSSjrSrg) RowResultiHzAllows traversing the Row objects returned by a Table.select operation. Args: connection (mysqlx.connection.Connection): The Connection object. cUR$)z`list`: The list of columns.r!rs r(columnsRowResult.columnsOs}}r.cUR$)zbReturns the list of columns. Returns: `list`: The list of columns. .. versionadded:: 8.0.12 rSrs r( get_columnsRowResult.get_columnsTs}}r.r+N)rz List[Column]) rvrwrxryrrrTrWr{r+r.r(rQrQHs  r.rQc6\rSrSrSrSSjrS SjrS SjrSrg) SqlResulti_zwRepresents a result from a SQL statement. Args: connection (mysqlx.connection.Connection): The Connection object. cUR$)ztReturns the identifier for the last record inserted. Returns: str: The identifier of the last record inserted. rrs r(r!SqlResult.get_autoincrement_valuefrr.cVUR(agSUlUR5 g)zRProcess the next result. Returns: bool: Returns `True` if the fetch is done. FT)rr#r'rs r( next_resultSqlResult.next_resultns% <<!& r.cUR$)zrReturns True if result has data. Returns: bool: Returns `True` if result has data. .. versionadded:: 8.0.12 rHrs r(has_dataSqlResult.has_datazs~~r.rLNrr) rvrwrxryrrr^rar{r+r.r(rZrZ_s " r.rZc0^\rSrSrSrSU4SjjrSrU=r$) DocResultizAllows traversing the DbDoc objects returned by a Collection.find operation. Args: connection (mysqlx.connection.Connection): The Connection object. cX>[TU]U5nUcg[[US55$)zqRead item. Args: dumping (bool): `True` for dumping. Returns: :class:`mysqlx.DbDoc`: A `DbDoc` object. Nr)r r8rr)rr6r7rs r(r8DocResult._read_items1g ) ;&s1v.//r.r+)r6rrr)rvrwrxryrr8r{rrs@r(rdrds 0 0r.rd)r%rr&bytesrr)r&rgrrg)r&rgrfloat)r&rgrzTuple[int, bytes])r&rgrr?)r&rgrz List[bytes])r&rgrzdecimal.Decimal)r&rgrr)r&rgrr)9r __future__rr\r2r!rrtypingrrrr r r r r charsetsrdbdocrhelpersrrtypesrrr)r-r4r8rIrNrPrUrcrlrqrsrrrr rrrrr r#rrrrrrQrZrdr+r.r(rosN:," (NNN*2-  + + (,   *!3HH*Ba a H8$$N%+k {{{eeP +,+,\E$E$P0#Z0#fz&jz&z.# #L00r.