vdBdZddlmZddlmZmZmZmZmZm Z m Z m Z m Z m Z mZmZmZdZdZdZdZdZd ZGd d eZGd d eZGddeZGddeZGddeZdS)z,Implementation of the CRUD database objects.)ProgrammingError) FindStatement AddStatementRemoveStatementModifyStatementSelectStatementInsertStatementDeleteStatementUpdateStatementCreateCollectionIndexStatementDropCollectionIndexStatementCreateViewStatementAlterViewStatementCreateTableStatementz_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}'zMSELECT COUNT(*) FROM information_schema.schemata WHERE schema_name like '{0}'z SELECT COUNT(*) FROM `{0}`.`{1}`z DROP TABLE IF EXISTS `{0}`.`{1}`zDROP VIEW IF EXISTS `{0}`.`{1}`cbeZdZdZdZedZedZdZdZ dZ dZ d Z d S) DatabaseObjectzProvides base functionality for database objects. Args: schema (mysqlx.Schema): The Schema object. name (str): The database object name. ch||_||_|jj|_dSN)_schema_name get_session _connection)selfschemanames G/var/www/html/t/fyr/venv311/lib/python3.11/site-packages/mysqlx/crud.py__init__zDatabaseObject.__init__5s/  <3355Ac|jS)z3:class:`mysqlx.Schema`: The Schema object. rrs rrzDatabaseObject.schema:s |rc|jS)z/str: The name of this database object. rr!s rrzDatabaseObject.name@s zrc|jS)z{Returns the Schema object of this database object. Returns: mysqlx.Schema: The Schema object. r r!s r get_schemazDatabaseObject.get_schemaFs |rc|jS)zwReturns the name of this database object. Returns: str: The name of this database object. r#r!s rget_namezDatabaseObject.get_nameNs zrct)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 rexists_in_databasez!DatabaseObject.exists_in_databaseVs "!rc*|Sr)r*r!s r am_i_realzDatabaseObject.am_i_realas&&(((rc*|Sr)r'r!s rwho_am_izDatabaseObject.who_am_ids}}rN) __name__ __module__ __qualname____doc__rpropertyrrr%r'r*r,r.rrrr.s BBB X X  " " ")))rrceZdZdZfdZdZdZdZddZdZ dd Z dd Z dd Z d Z d ZdZddZddZdZddZxZS)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)_sessionsuperr6r)rsessionr __class__s rrzSchema.__init__ps0  fd$$T400000rc|t|j}|j|dkSzVerifies if this object exists in the database. Returns: bool: `True` if object exists in database. r)_COUNT_SCHEMAS_QUERYformatrrexecute_sql_scalarrsqls rr*zSchema.exists_in_databasets5 #))$*55223771<(>??EEE@ e$$$ s#A99-B)(B)cpt||}|r#|std|S)zwReturns the table of the given name for this schema. Returns: mysqlx.Table: Table object. zTable does not exist)r[r*r)rrrVr^s rrUzSchema.get_tablesC dD!!  ?++-- ?&'=>>> rcpt||}|r#|std|S)ztReturns the view of the given name for this schema. Returns: mysqlx.View: View object. zView does not exist)Viewr*r)rrrVviews rget_viewzSchema.get_viewsC D$  >**,, >&'<=== rcpt||}|r#|std|S)zReturns the collection of the given name for this schema. Returns: mysqlx.Collection: Collection object. zCollection does not exist)rLr*r)rrrVrRs rget_collectionzSchema.get_collectionsF  d++  D0022 D&'BCCCrcz|jdt|j|ddS)zmDrops a collection. Args: name (str): The name of the collection to be dropped. rBFN)rexecute_nonquery_DROP_TABLE_QUERYr?rrrs rdrop_collectionzSchema.drop_collectionsH )) $++DJ==u F F F F Frct||}|r||dS|jdt |j|ddS)zcDrops a table. Args: name (str): The name of the table to be dropped. rBFN)r[is_view drop_viewrrhrir?r)rrr^s r drop_tablezSchema.drop_tables dD!! ==?? J NN4   - -(// DAA5 J J J J Jrcz|jdt|j|ddS)zaDrops a view. Args: name (str): The name of the view to be dropped. rBFN)rrh_DROP_VIEW_QUERYr?rrjs rrnzSchema.drop_viewsH )) #**4:t<?? ?rcLt||}||S)aACreates in the current schema a new view with the specified name and retrieves an object representing the new view created. Args: name (string): The name of the view. replace (Optional[bool]): `True` to add replace. Returns: mysqlx.View: View object. )rbget_create_statement)rrreplacercs r create_viewzSchema.create_views'D$((111rcJt||}|S)zAlters a view in the current schema with the specified name and retrieves an object representing the view. Args: name (string): The name of the view. Returns: mysqlx.View: View object. )rbget_alter_statement)rrrcs r alter_viewzSchema.alter_views%D$'')))rc|stdt||}|st||S|std|S)NzTable name is invalidzTable already exists)rr[r*r)rrrur^s r create_tablezSchema.create_table*sh <"#:;; ;dD!!'')) ;'d33 3 ;"#9:: : rF)r/r0r1r2rr*rrSrWr_rUrdrfrkrornrtryr|r~ __classcell__r;s@rr6r6hsO11111===&5555&            FFF J J JEEE0 2 2 2 2 * * *rr6c^eZdZdZfdZdZd dZdZdZd dZ d d Z d Z d Z d Z xZS)rLzRepresents a collection of documents on a schema. Args: schema (mysqlx.Schema): The Schema object. name (str): The collection name. cZtt|||dSr)r9rLrrrrr;s rrzCollection.__init__<s) j$((66666rct|j|j}|j|dkSr=)_COUNT_TABLES_QUERYr?rr'rrr@rAs rr*zCollection.exists_in_database?sE "(()>)>)@)@$*MM223771<>>>>>>rrLcNeZdZdZfdZdZdZdZdZd dZ d Z d Z xZ S) r[zRepresents 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. cZtt|||dSr)r9r[rrs rrzTable.__init__s) eT##FD11111rct|jj|j}|j|dkSr=)rr?rrrrr@rAs rr*zTable.exists_in_databases< "(():DJGG223771<rrirqobjectrr6rLr[rbr4rrrs032$$$$$$BBBBBBBBBBBBBBBBBBBBBBBBBBBBBBJK71 6477777V777tJJJJJ^JJJZe>e>e>e>e>e>e>e>PS=S=S=S=S=NS=S=S=l'('('('('(5'('('('('(r