:?hgnSrSSKJr SSKrSSKrSSKJrJrJrJ r J r J r SSK J r SSKJrJrJrJr SSKJrJrJr SS KJrJrJr SS KJrJrJrJrJ r J!r!J"r"J#r#J$r$ SS K%J&r&J'r'J(r(J)r) \(aSS K*J+r+ S r,Sr-Sr.Sr/Sr0"SS5r1"SS\15r2"SS\15r3"SS\15r4"SS\45r5g)z,Implementation of the CRUD database objects.) annotationsN) TYPE_CHECKINGAnyDictListOptionalUnion)DbDoc)ER_NO_SUCH_TABLEER_TABLE_EXISTS_ERRORER_X_CMD_NUM_ARGUMENTSER_X_INVALID_ADMIN_COMMAND)NotSupportedErrorOperationalErrorProgrammingError) deprecatedescapequote_identifier) AddStatementCreateCollectionIndexStatementDeleteStatement FindStatementInsertStatementModifyStatementRemoveStatementSelectStatementUpdateStatement)ConnectionType SchemaType SessionType StrOrBytes)Resultz_SELECT COUNT(*) FROM information_schema.views WHERE table_schema = '{0}' AND table_name = '{1}'z`SELECT COUNT(*) FROM information_schema.tables WHERE table_schema = '{0}' AND table_name = '{1}'zJSELECT COUNT(*) FROM information_schema.schemata WHERE schema_name = '{0}'zSELECT COUNT(*) FROM {0}.{1}zDROP TABLE IF EXISTS {0}.{1}c\rSrSrSrSSjr\SSj5r\SSj5r\SSj5r SSjr SSjr SS jr SS jr SS jr\"S S 5SSj5r\"S S5SSj5rSrg)DatabaseObjectNzProvides base functionality for database objects. Args: schema (mysqlx.Schema): The Schema object. name (str): The database object name. cXl[U[5(aUR5OUUlURR 5UlUR R5UlgN) _schema isinstancebytesdecode_name get_session_sessionget_connection _connection)selfschemanames S/var/www/ev-aguas/ev-aguas-proceso/venv/lib/python3.13/site-packages/mysqlx/crud.py__init__DatabaseObject.__init__VsK#) +5dE+B+B$++- %)\\%=%=%? +/==+G+G+IcUR$)z,:class:`mysqlx.Session`: The Session object.r/r2s r5sessionDatabaseObject.session\s}}r8cUR$)z*:class:`mysqlx.Schema`: The Schema object.r)r;s r5r3DatabaseObject.schemaas||r8cUR$)z&str: The name of this database object.r-r;s r5r4DatabaseObject.namefszzr8cUR$)zfReturns the underlying connection. Returns: mysqlx.connection.Connection: The connection object. )r1r;s r5r0DatabaseObject.get_connectionks r8cUR$)z_Returns the session of this database object. Returns: mysqlx.Session: The Session object. r:r;s r5r.DatabaseObject.get_sessionss }}r8cUR$)zcReturns the Schema object of this database object. Returns: mysqlx.Schema: The Schema object. r?r;s r5 get_schemaDatabaseObject.get_schema{s ||r8cUR$)z_Returns the name of this database object. Returns: str: The name of this database object. rBr;s r5get_nameDatabaseObject.get_names zzr8c[e)zVerifies if this object exists in the database. Returns: bool: `True` if object exists in database. Raises: NotImplementedError: This method must be implemented. )NotImplementedErrorr;s r5exists_in_database!DatabaseObject.exists_in_databases "!r8z8.0.12z)Use 'exists_in_database()' method insteadc"UR5$)zVerifies if this object exists in the database. Returns: bool: `True` if object exists in database. Raises: NotImplementedError: This method must be implemented. .. deprecated:: 8.0.12 Use ``exists_in_database()`` method instead. )rPr;s r5 am_i_realDatabaseObject.am_i_reals&&((r8zUse 'get_name()' method insteadc"UR5$)zReturns the name of this database object. Returns: str: The name of this database object. .. deprecated:: 8.0.12 Use ``get_name()`` method instead. )rLr;s r5who_am_iDatabaseObject.who_am_is}}r8)r1r-r)r/N)r3r r4r"returnNone)rXr!)rXr )rXstr)rXr)rXr)__name__ __module__ __qualname____firstlineno____doc__r6propertyr<r3r4r0r.rIrLrPrrSrV__static_attributes__r8r5r%r%NsJ   "EF )G );< = r8r%c^\rSrSrSrSU4SjjrSSjrSSjrSSSjjrSSjr SSSjjr SSS jjr SSS jjr SS jr SSS jjrSSS jjrSrU=r$)SchemazA client-side representation of a database schema. Provides access to the schema contents. Args: session (mysqlx.XSession): Session object. name (str): The Schema name. c0>Xl[TU] X5 gr()r/superr6)r2r<r4 __class__s r5r6Schema.__init__s%,  $r8c[R[UR55nURR U5S:H$ziVerifies if this object exists in the database. Returns: bool: `True` if object exists in database. r )_COUNT_SCHEMAS_QUERYformatrr-r1execute_sql_scalarr2sqls r5rPSchema.exists_in_databases9 #))&*<=22371<> r8cj[X5nU(a UR5(d [S5eU$)z\Returns the view of the given name for this schema. Returns: mysqlx.View: View object. zView does not exist)ViewrPr)r2r4rviews r5get_viewSchema.get_views1 D **,,&'<== r8cj[X5nU(a UR5(d [S5eU$)znReturns the collection of the given name for this schema. Returns: mysqlx.Collection: Collection object. zCollection does not exist)ryrPr)r2r4rrs r5get_collectionSchema.get_collections2  + 0022&'BCCr8c URRS[R[ UR 5[ U55S5 g)zUDrops a collection. Args: name (str): The name of the collection to be dropped. rpFN)r1execute_nonquery_DROP_TABLE_QUERYrmrr-)r2r4s r5drop_collectionSchema.drop_collection sB ))   $ $ ,.>t.D    r8c U(d [S5eSU;a [R"S[5 USn[ X5nUR US.nUb[ U[5(aU(d [S5eSnUHnX;dM [SU35e /n S U;a8US n [ U [5(d [S 5eU RS U 45 S U;aiUS n [ U [[45(d [S 5eU RS [ U [5(a[R"U 5OU 45 S U 4US'URRSSSU5 U$![awn U R[ :Xa [#S5U eU R[$:XaU(d[SUS35U eSn A U$[U R&U R5U eSn A ff=f)aCreates in the current schema a new collection with the specified name and retrieves an object representing the new collection created. Args: name (str): The name of the collection. reuse_existing (bool): `True` to reuse an existing collection. validation (Optional[dict]): A dict, containing the keys `level` with the validation level and `schema` with a dict or a string representation of a JSON schema specification. Returns: mysqlx.Collection: Collection object. Raises: :class:`mysqlx.ProgrammingError`: If ``reuse_existing`` is False and collection exists or the collection name is invalid. :class:`mysqlx.NotSupportedError`: If schema validation is not supported by the server. .. versionchanged:: 8.0.21 Collection name is invalidreusezG'reuse' is deprecated since 8.0.21. Please use 'reuse_existing' instead)r3r4NInvalid value for 'validation'levelr3 Invalid option in 'validation': rInvalid value for 'level'r3Invalid value for 'schema' validationoptionsmysqlxcreate_collectionTlYour MySQL server does not support the requested operation. Please update to MySQL 8.0.19 or a later version Collection 'z' already exists)rwarningswarnDeprecationWarningryr-r*dictrZr{jsondumpsr1rrerrnorrr msg) r2r4reuse_existingrkwargsrfields valid_optionsoptionrrr3errs r5rSchema.create_collection.s<"#?@ @ f  MM6"  $G_N+ ,0JJ!E  !j$//z&'GHH/M$.*-MfX+VWW%G*$"7+!%--*+FGG/0:%#H-!&3+66*+GHH .8.F.F 6*F".w 7F9  D    - --tV $ Dyy22'  yy11%*&tf,<=&'sww :C DsE22 G3>@@r8cURS5RSU5R5nUR5nURR 5 U$)zReturns a Document matching the Document ID. Args: doc_id (str): Document ID Returns: mysqlx.DbDoc: The Document matching the Document ID. rr)rrr fetch_oner1fetch_active_result)r2rresultrs r5get_oneCollection.get_onezsM;',,T6:BBD  ,,. r8c`URS5RSU5R5$)z~Removes a Document matching the Document ID. Args: doc_id (str): Document ID Returns: mysqlx.Result: Result object. rr)rrr)r2rs r5 remove_oneCollection.remove_ones){{;',,T6:BBDDr8rbrr()rz Optional[str]rXr)rr rXr)rrZrXr)rrZrXrrXint)rrZrzDict[str, Any]rXr)rrZrXrY)rrZrzUnion[Dict, DbDoc]rX'Result')rrZrXr )rrZrXr)r[r\r]r^r_rPrrrrrrrrrrr rarbr8r5ryrysb=  /""(MM,:M 'M4 " SA"  Er8ryc^\rSrSrSrS SjrS SjrSSjrSSjrSSjr SSjr S S jr S r g )rizRepresents a database table on a schema. Provides access to the table through standard INSERT/SELECT/UPDATE/DELETE statements. Args: schema (mysqlx.Schema): The Schema object. name (str): The table name. c[R[URR5[UR 55nUR RU5S:H$rkrros r5rPTable.exists_in_databaserr8c\[U/UQ76nURR5UlU$)zCreates a new :class:`mysqlx.SelectStatement` object. Args: *fields: The fields to be retrieved. Returns: mysqlx.SelectStatement: SelectStatement object )rr1rrr2rrs r5select Table.select.t-f-''==?  r8c\[U/UQ76nURR5UlU$)zCreates a new :class:`mysqlx.InsertStatement` object. Args: *fields: The fields to be inserted. Returns: mysqlx.InsertStatement: InsertStatement object )rr1rrrs r5insert Table.insertrr8cZ[U5nURR5UlU$)zsCreates a new :class:`mysqlx.UpdateStatement` object. Returns: mysqlx.UpdateStatement: UpdateStatement object )rr1rrr2rs r5update Table.updates) t$''==?  r8cZ[U5nURR5UlU$)zCreates a new :class:`mysqlx.DeleteStatement` object. Returns: mysqlx.DeleteStatement: DeleteStatement object .. versionchanged:: 8.0.12 The ``condition`` parameter was removed. )rr1rrrs r5delete Table.deletes)t$''==?  r8cz[R[URR5[UR 55nUR RU5nU$![aKnUR[:Xa1[SUR SURRS35UeeSnAff=f)zQCounts the rows in the table. Returns: int: The total of rows in the table. zTable 'rrNrrs r5r Table.counts !! T\\.. /1A$**1M  ""55c:C   yy,,&djj\* ))*!-   rc[R[URR5[UR 55nUR RU5S:H$)ztDetermine if the underlying object is a view or not. Returns: bool: `True` if the underlying object is a view. r _COUNT_VIEWS_QUERYrmrr)r4r-r1rnros r5is_view Table.is_viewJ !''t||/@/@(A6$**CUV22371<r5s:3" BB JI99   GF8 8 Q. 2aaH]@^]@@ EED`=N`=F=5=r8