"ic2dZddlZddlZddlmZddlmZmZmZm Z ddl m Z m Z m Z ddlmZmZmZddlmZmZmZmZmZmZmZmZmZd Zd Zd Zd Zd Z Gdde!Z"Gdde"Z#Gdde"Z$Gdde"Z%Gdde%Z&dS)z,Implementation of the CRUD database objects.N)DbDoc)ER_NO_SUCH_TABLEER_TABLE_EXISTS_ERRORER_X_CMD_NUM_ARGUMENTSER_X_INVALID_ADMIN_COMMAND)NotSupportedErrorOperationalErrorProgrammingError) deprecatedescapequote_identifier) FindStatement AddStatementRemoveStatementModifyStatementSelectStatementInsertStatementDeleteStatementUpdateStatementCreateCollectionIndexStatementz_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}ceZdZdZdZedZedZedZdZ dZ dZ d Z d Z ed d d Zed ddZdS)DatabaseObjectzProvides base functionality for database objects. Args: schema (mysqlx.Schema): The Schema object. name (str): The database object name. c||_t|tr|n||_|j|_|j|_dSN) _schema isinstancebytesdecode_name get_session_sessionget_connection _connection)selfschemanames C/srv/django_bis/venv311/lib/python3.11/site-packages/mysqlx/crud.py__init__zDatabaseObject.__init__>s\ &0u&=&=GT[[]]]4  0022 =7799c|jS)z5:class:`mysqlx.Session`: The Session object. r"r%s r(sessionzDatabaseObject.sessionDs }r*c|jS)z3:class:`mysqlx.Schema`: The Schema object. rr-s r(r&zDatabaseObject.schemaJs |r*c|jS)z/str: The name of this database object. r r-s r(r'zDatabaseObject.namePs zr*c|jS)z~Returns the underlying connection. Returns: mysqlx.connection.Connection: The connection object. )r$r-s r(r#zDatabaseObject.get_connectionVs r*c|jS)zwReturns the session of this database object. Returns: mysqlx.Session: The Session object. r,r-s r(r!zDatabaseObject.get_session^s }r*c|jS)z{Returns the Schema object of this database object. Returns: mysqlx.Schema: The Schema object. r0r-s r( get_schemazDatabaseObject.get_schemafs |r*c|jS)zwReturns the name of this database object. Returns: str: The name of this database object. r2r-s r(get_namezDatabaseObject.get_namens zr*ct)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 r(exists_in_databasez!DatabaseObject.exists_in_databasevs "!r*z8.0.12z)Use 'exists_in_database()' method insteadc*|S)a+Verifies 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. )r;r-s r( am_i_realzDatabaseObject.am_i_reals&&(((r*zUse 'get_name()' method insteadc*|S)zReturns the name of this database object. Returns: str: The name of this database object. .. deprecated:: 8.0.12 Use ``get_name()`` method instead. )r8r-s r(who_am_izDatabaseObject.who_am_is}}r*N)__name__ __module__ __qualname____doc__r)propertyr.r&r'r#r!r6r8r;r r=r?r*r(rr7s ::: X X X     " " "ZEFF ) )GF )Z;<<  =<   r*rcjeZdZdZfdZdZdZddZdZddZ dd Z dd Z d Z dd Z ddZxZS)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. ch||_tt|||dSr)r"superrGr))r%r.r' __class__s r(r)zSchema.__init__s0  fd$$T400000r*ctt|j}|j|dkSzVerifies if this object exists in the database. Returns: bool: `True` if object exists in database. r)_COUNT_SCHEMAS_QUERYformatr r r$execute_sql_scalarr%sqls r(r;zSchema.exists_in_databases= #))&*<*<==223771<|jdd|ji}|g}d}|D]_}|d|vrS t ||d}n&#t $rt ||d}YnwxYw||`|S)zoReturns a list of tables for this schema. Returns: `list`: List of Table objects. rSr&)TABLEVIEWrTrVr')r$rWr rXTablerZr[)r%r\tables object_typesr^tables r( get_tableszSchema.get_tabless ..~08$*/EGG )  % %C6{l**5!$L(9::EE!555!$F 44EEE5 e$$$ s A!! BBcpt||}|r#|std|S)zwReturns the table of the given name for this schema. Returns: mysqlx.Table: Table object. zTable does not exist)rhr;r )r%r'rcrks r(rbzSchema.get_tablesC dD!!  ?++-- ?&'=>>> r*cpt||}|r#|std|S)ztReturns the view of the given name for this schema. Returns: mysqlx.View: View object. zView does not exist)Viewr;r )r%r'rcviews r(get_viewzSchema.get_viewsC D$  >**,, >&'<=== r*cpt||}|r#|std|S)zReturns the collection of the given name for this schema. Returns: mysqlx.Collection: Collection object. zCollection does not exist)rYr;r )r%r'rcr_s r(get_collectionzSchema.get_collectionsF  d++  D0022 D&'BCCCr*c |jdtt |jt |ddS)zmDrops a collection. Args: name (str): The name of the collection to be dropped. rQFN)r$execute_nonquery_DROP_TABLE_QUERYrNrr )r%r's r(drop_collectionzSchema.drop_collectionsa )) $++, >..*,..4fVnn>>>/G*$$"7+!%--H*+FGGG/000:%%#H-!&3+66I*+GHHH",VT":": Gtz&111@FHIII".w 7F9  ;   - --tV = = = = ; ; ;y222'y111%G*8??EEGGGG'sw ::: GGGGG ;s0F HA.H  Hc:|stdt|tr|stdd}|D](}||vr"td|)g}d|vrC|d}t|tstd|d|fd|vrs|d}t|ttfstd|dt|trt j|n|f|j|d |fd } |j d d d |dS#t$r>} | j tkrtdt| j| j d} ~ wwxYw)a Modifies a collection using a JSON schema validation. Args: name (str): The name of the 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. Raises: :class:`mysqlx.ProgrammingError`: If the collection name or validation is invalid. :class:`mysqlx.NotSupportedError`: If schema validation is not supported by the server. .. versionadded:: 8.0.21 ryr{r|r~r}rr&rr)r&r'rrmodify_collection_optionsTrN)r rrrNrr[rrr r$rur rrr r) r%r'rrrrr}r&rrs r(modify_collectionzSchema.modify_collectionds$ A"#?@@ @*d++ E: E"#CDD D+   : :F]**&(**0&..:::+ j w'EeS)) D&'BCCC NNGU+ , , , z ! !)FfsDk22 E&'CDDD NN(66C4:f---">@@ "55c::CC   y,,,&vdj$,*;<<>>>     A!! B3+AB..B3c$t|||S)abCreates a collection index. Args: index_name (str): Index name. fields_desc (dict): A dictionary containing the fields members that constraints the index to be created. It must have the form as shown in the following:: {"fields": [{"field": member_path, "type": member_type, "required": member_required, "array": array, "collation": collation, "options": options, "srid": srid}, # {... more members, # repeated as many times # as needed} ], "type": type} )r)r% index_name fields_descs r( create_indexzCollection.create_indexs,.dJ LLLr*c f|jddd|jj|j|ddS)z[Drops a collection index. Args: index_name (str): Index name. rdrop_collection_indexF)r&r_r'N)r$rurr'r )r%rs r( drop_indexzCollection.drop_indexsQ ))(4K*/DL>@@@r*c|dd|}|}|j|S)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_oner$fetch_active_result)r%rresultrs r(get_onezCollection.get_oneCs\;'',,T6::BBDD   ,,... r*cx|dd|S)zRemoves a Document matching the Document ID. Args: doc_id (str): Document ID Returns: mysqlx.Result: Result object. rr)rrr)r%rs r( remove_onezCollection.remove_oneQs2{{;'',,T6::BBDDDr*r)r@rArBrCr;rrrrrrrrrrrrEr*r(rYrYs===     / / /""$MMM0 G G G111 AAA"    E E E E Er*rYc<eZdZdZdZdZdZdZdZdZ dZ d S) rhzRepresents 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. ctt|jjt|j}|j|dkSrLrrPs r(r;zTable.exists_in_databasehrr*c\t|g|R}|j|_|S)zCreates a new :class:`mysqlx.SelectStatement` object. Args: *fields: The fields to be retrieved. Returns: mysqlx.SelectStatement: SelectStatement object )rr$rrr%rrs r(selectz Table.selectr4t-f---'==??  r*c\t|g|R}|j|_|S)zCreates a new :class:`mysqlx.InsertStatement` object. Args: *fields: The fields to be inserted. Returns: mysqlx.InsertStatement: InsertStatement object )rr$rrrs r(insertz Table.insertrr*c`t|}|j|_|S)zCreates a new :class:`mysqlx.UpdateStatement` object. Returns: mysqlx.UpdateStatement: UpdateStatement object )rr$rrr%rs r(updatez Table.updates, t$$'==??  r*c`t|}|j|_|S)zCreates a new :class:`mysqlx.DeleteStatement` object. Returns: mysqlx.DeleteStatement: DeleteStatement object .. versionchanged:: 8.0.12 The ``condition`` parameter was removed. )rr$rrrs r(deletez Table.deletes,t$$'==??  r*cptt|jjt|j} |j|}nU#t$rH}|j tkr2td|j|jjd}~wwxYw|S)ziCounts the rows in the table. Returns: int: The total of rows in the table. z(Table '{}' does not exist in schema '{}'Nrrs r(rz Table.countrrctt|jjt|j}|j|dkS)zDetermine if the underlying object is a view or not. Returns: bool: `True` if the underlying object is a view. r_COUNT_VIEWS_QUERYrNr rr'r r$rOrPs r(is_viewz Table.is_viewQ !''t|/@(A(A(.tz(:(:<<223771<rsP:32 LLLLLLLLLLLLIIIIIIIIII99999999998888888888888888888888 JK4- 2cccccVcccLC7C7C7C7C7^C7C7C7LwEwEwEwEwEwEwEwEt`=`=`=`=`=N`=`=`=F=====5=====r*