vdO$dZddlZddlZddlmZddlmZddlmZddl m Z m Z ddl m Z dd lmZdd lmZmZmZGd d eZd Zd?dZd?dZd?dZd?dZGddeZGddeZGddeZGddeZGddeZ GddeZ!Gdd eZ"Gd!d"eZ#Gd#d$eZ$Gd%d&eZ%Gd'd(eZ&Gd)d*eZ'Gd+d,eZ(Gd-d.eZ)Gd/d0eZ*Gd1d2eZ+Gd3d4e+Z,Gd5d6eZ-Gd7d8eZ.Gd9d:e.Z/Gd;deZ1dS)@zImplementation of Statements.N)ProgrammingError) ExprParser) STRING_TYPES) Algorithms Securities)DbDoc)mysqlx_crud_pb2) SqlResultResult ColumnTypeceZdZdZdS)Exprc||_dSN)expr)selfrs L/var/www/html/t/fyr/venv311/lib/python3.11/site-packages/mysqlx/statement.py__init__z Expr.__init__&s  N)__name__ __module__ __qualname__rrrrr%s#rrct|dkr*t|dttfr|dS|S)Nrr)len isinstancelisttuple)valuess rflexible_paramsr!*s9 6{{aJvay4.AAay Mrcd|vr0|ddkr |ddkp|ddko |ddkS|ddko |ddkS)zCheck if the given identifier is quoted. Args: identifier (string): Identifier to check. sql_mode (Optional[string]): SQL mode. Returns: `True` if the identifier has backtick quotes, and False otherwise. ANSI_QUOTESr`"r identifiersql_modes ris_quoted_identifierr+0sn  A#%?*R.C*?AA#%?*R.C*? B!}#= 2#(==rct||r|Sd|vr)d|ddSd|ddS)aQuote the given identifier with backticks, converting backticks (`) in the identifier name with the correct escape sequence (``) unless the identifier is quoted (") as in sql_mode set to ANSI_QUOTES. Args: identifier (string): Identifier to quote. sql_mode (Optional[string]): SQL mode. Returns: A string with the identifier quoted with backticks. r$z"{0}"r'z""z`{0}`r%z``)r+formatreplacer(s rquote_identifierr/AskJ11  ~~j00d;;<<<~~j00d;;<<z.quote_multipart_identifier.._s3444#&j(;;444r)join) identifiersr*s `rquote_multipart_identifierr8UsA 884444'2444 5 55rcd|vrdnd}||vrd|nd}||d}t|dur|n|d||d|fS) Nr$r'r%z.{0}r1rrr&)r-splitrstrip)default_schema table_namer*quote delimitertemps rparse_table_namerAcs H,,CC#E(-(;(; e$$$I   Iq ) )D!$ii1nnNN$q'--2F2F HNN5 ! ! $$rcLeZdZdZddZedZedZdZdS) Statementa Provides base functionality for statement objects. Args: target (object): The target database object, it can be :class:`mysqlx.Collection` or :class:`mysqlx.Table`. doc_based (bool): `True` if it is document based. TcB||_||_|r|jnd|_dSr)_target _doc_based _connection)rtarget doc_baseds rrzStatement.__init__ss+ #17A6--Trc|jS)z,object: The database object target. )rErs rrHzStatement.targetxs |rc|jjS)z3:class:`mysqlx.Schema`: The Schema object. )rEschemarKs rrMzStatement.schema~s|""rctzqExecute the statement. Raises: NotImplementedError: This method must be implemented. NotImplementedErrorrKs rexecutezStatement.execute "!rN)T) rrr__doc__rpropertyrHrMrRrrrrCrCks{BBBB X ##X# """""rrCc\eZdZdZdfd ZdZdZddZd Zd Z d Z d Z d Z dZ xZS)FilterableStatementaA statement to be used with filterable statements. Args: target (object): The target database object, it can be :class:`mysqlx.Collection` or :class:`mysqlx.Table`. doc_based (Optional[bool]): `True` if it is document based (default: `True`). condition (Optional[str]): Sets the search condition to filter documents or records. TNc tt|||d|_d|_d|_d|_d|_d|_d|_ i|_ g|_ || |dSdS)NrHrIF) superrWr_has_projection _has_where _has_limit _has_sort _has_group_by _has_having _has_bindings _binding_map _bindingswhere)rrHrI condition __class__s rrzFilterableStatement.__init__s !4((11!>!@!@  rrc0d|_||_||_|S)aESets the maximum number of records or documents to be returned. Args: row_count (int): The maximum number of records or documents. offset (Optional[int]) The number of records or documents to skip. Returns: mysqlx.FilterableStatement: FilterableStatement object. T)r] _limit_offset_limit_row_count)r row_countoffsets rlimitzFilterableStatement.limits # ) rct|}d|_d||_t |j|j |_|S)zSets the sorting criteria. Args: *sort_clauses: The expression strings defining the sort criteria. Returns: mysqlx.FilterableStatement: FilterableStatement object. Trm)r!r^r6 _sort_strrrFparse_order_spec _sort_expr)r sort_clausess rsortzFilterableStatement.sortsY' 5 ,//$T^)-%8:::J:J:L:L  rct|}d|_d||_t |j|j |_dSrl)r!r_r6 _grouping_strrrFparse_expr_list _groupingrqs r _group_byzFilterableStatement._group_bysX &)! XXf--#D$6(,$7999H9J9J rcnd|_t||j |_dSNT)r`rrFr_havingrres rrzFilterableStatement._havings0!)-@AAFFHH rcd|_t|}|dkr||dn>|dkrtd|j|d|dd|S)aBinds a value to a specific placeholder. Args: *args: The name of the placeholder and the value to bind. A :class:`mysqlx.DbDoc` object or a JSON string representation can be used. Returns: mysqlx.FilterableStatement: FilterableStatement object. Raises: ProgrammingError: If the number of arguments is invalid. Trrz#Invalid number of arguments to bind)namevalue)rar _bind_singlerrcappend)rargscounts rbindzFilterableStatement.binds~"D  A::   d1g & & & & QYY"#HII I N ! !47T!W"E"E F F F rc4t|tr$|t|dSt|trGt j|}|D] }||||dSdSr)rr rstrrjsonloadskeys)robjectdictkeys rrz FilterableStatement._bind_singles fe $ $ * IIc&kk " " " " "  - - *:f%%Dyy{{ * * #tCy)))) * * * *rctrOrPrKs rrRzFilterableStatement.execute rSr)TN)r)rrrrTrrdrsryrrrrrrR __classcell__rfs@rrWrWs   " " " " " ""     KKKIII0***"""""""rrWc(eZdZdZfdZdZxZS) SqlStatementzA statement for SQL execution. Args: connection (mysqlx.connection.Connection): Connection object. sql (string): The sql statement to be executed. cxtt|dd||_||_dSNFrY)rZrrrG_sql)r connectionsqlrfs rrzSqlStatement.__init__s9 lD!!**$%*HHH% rch|j|jt|jS)zaExecute the statement. Returns: mysqlx.SqlResult: SqlResult object. )rGsend_sqlrr rKs rrRzSqlStatement.executes. !!$),,,)***rrrrrTrrRrrs@rrrsQ  +++++++rrc.eZdZdZfdZdZdZxZS) AddStatementzA statement for document addition on a collection. Args: collection (mysqlx.Collection): The Collection object. cvtt||g|_g|_dSN)rH)rZrr_values_idsr collectionrfs rrzAddStatement.__init__/s6 lD!!****===  rct|D]Y}t|tr|j|2|jt|Z|S)zAdds a list of documents into a collection. Args: *values: The documents to be added into the collection. Returns: mysqlx.AddStatement: AddStatement object. )r!rr rr)rr vals raddzAddStatement.add4sg#F+ 0 0C#u%% 0 ##C(((( ##E#JJ//// rct|jdkrtS|jD].}|j|/|j|S)[Execute the statement. Returns: mysqlx.Result: Result object. r)rrr rr ensure_idrG send_insert)rdocs rrRzAddStatement.executeDsk t|   ! !88O< . .C I  S]]__ - - - -++D111r)rrrrTrrrRrrs@rrr)s`   2 2 2 2 2 2 2rrceZdZddZdZdS) UpdateSpecNcH|tjjkr|||dS||_||_t |dkr|ddkr|dd|_t|jdj |_||_ dS)Nr$rF) MySQLxCrudUpdateOperationSET _table_set update_typesourcerrdocument_fieldr)r)rrrrs rrzUpdateSpec.__init__Ts *48 8 8 OOFE * * * * **D  DK6{{Q6!9#3#3$QRRj $T[%*,,,:N,<,      rc\|jdt|D|S)aRemoves attributes from documents in a collection. Args: doc_path (string): The document path of the attribute to be removed. Returns: mysqlx.ModifyStatement: ModifyStatement object. cLg|]!}ttjj|"Sr)rrr ITEM_REMOVE)r4xs rr5z)ModifyStatement.unset..s8!2!2!2 z1=q A A!2!2!2r)rextendr!)r doc_pathss runsetzModifyStatement.unsetsG !2!2$i0!2!2!2 3 3 3 rcv|jttjj|||S)aInsert a value into the specified array in documents of a collection. Args: field (string): A document path that identifies the array attribute and position where the value will be inserted. value (object): The value to be inserted. Returns: mysqlx.ModifyStatement: ModifyStatement object. )rrrrr ARRAY_INSERTrfieldrs r array_insertzModifyStatement.array_inserts<  z1>u M M O O O rcv|jttjj|||S)aInserts a value into a specific position in an array attribute in documents of a collection. Args: doc_path (string): A document path that identifies the array attribute and position where the value will be inserted. value (object): The value to be inserted. Returns: mysqlx.ModifyStatement: ModifyStatement object. )rrrrr ARRAY_APPENDrs r array_appendzModifyStatement.array_appends@  z1>      rc6|j|SrrGupdaterKs rrRzModifyStatement.execute &&t,,,rr) rrrrTrrrrrrrRrrs@rrrfs       $-------rrc<eZdZdZdfd ZdZdZdZdZxZ S) FindStatementaA statement document selection on a Collection. Args: collection (mysqlx.Collection): The Collection object. condition (Optional[str]): An optional expression to identify the documents to be retrieved. If not specified all the documents will be included on the result unless a limit is set. Nc\tt||d|dSr)rZrrrs rrzFindStatement.__init__s+ mT""++JiHHHHHrc|j|S)zSets a document field filter. Args: *fields: The string expressions identifying the fields to be extracted. Returns: mysqlx.FindStatement: FindStatement object. )rsrqs rrrzFindStatement.fieldss t((rc|j||S)zSets a grouping criteria for the resultset. Args: *fields: The string expressions identifying the grouping criteria. Returns: mysqlx.FindStatement: FindStatement object. rrqs rgroup_byzFindStatement.group_by  rc0|||S)a=Sets a condition for records to be considered in agregate function operations. Args: condition (string): A condition on the agregate functions used on the grouping criteria. Returns: mysqlx.FindStatement: FindStatement object. rrs rhavingzFindStatement.having Y rc6|j|S)zaExecute the statement. Returns: mysqlx.DocResult: DocResult object. rGfindrKs rrRzFindStatement.execute $$T***rr) rrrrTrrrrrrRrrs@rrrsIIIIII ) ) )      +++++++rrc:eZdZdZfdZdZdZdZdZxZ S)SelectStatementzA statement for record retrieval operations on a Table. Args: table (mysqlx.Table): The Table object. *fields: The fields to be retrieved. cntt||d|j|dSNF)rZrrrsrtablerrrfs rrzSelectStatement.__init__s9 ot$$--eU;;;&!!!!rc|j||S)zSets a grouping criteria for the resultset. Args: *fields: The fields identifying the grouping criteria. Returns: mysqlx.SelectStatement: SelectStatement object. rrqs rrzSelectStatement.group_byrrc0|||S)a;Sets a condition for records to be considered in agregate function operations. Args: condition (str): A condition on the agregate functions used on the grouping criteria. Returns: mysqlx.SelectStatement: SelectStatement object. rrs rrzSelectStatement.havingrrc6|j|S)zaExecute the statement. Returns: mysqlx.RowResult: RowResult object. rrKs rrRzSelectStatement.execute,rrc |jrd|jnd}|jrd|jnd}|jrd|jnd}|jrd|jnd}|j r d|j |j nd}dt|dd |j j|jj||||| }|S) Nz WHERE {0}r"z GROUP BY {0}z HAVING {0}z ORDER BY {0}z LIMIT {0} OFFSET {1}zISELECT {select} FROM {schema}.{table}{where}{group}{having}{order}{limit}rn*)selectrMrryrdgrouprorder)r\r-rhr_rr`rr^r{r]rvrugetattrrMrrH)rrdrrorder_byrystmts rget_sqlzSelectStatement.get_sql4s48OK ##DK000  '?))$*<===$& 7;7GO%%dl333R=A^?))$.999 $(?;'..t/D     8: !!'t%6<<{'t{/?u8F("("L"L  r) rrrrTrrrrRrrrs@rrrs~ """""      +++rrc.eZdZdZfdZdZdZxZS)InsertStatementzA statement for insert operations on Table. Args: table (mysqlx.Table): The Table object. *fields: The fields to be inserted. ctt||dt||_g|_dSr)rZrrr!_fieldsrrs rrzInsertStatement.__init__Ms= ot$$--Ue-LLL&/  rcb|jtt||S)zSet the values to be inserted. Args: *values: The values of the columns to be inserted. Returns: mysqlx.InsertStatement: InsertStatement object. )rrrr!rr s rr zInsertStatement.valuesRs, D&!9::;;; rc6|j|Sr)rGrrKs rrRzInsertStatement.execute^s ++D111r)rrrrTrr rRrrs@rrrFs`    2222222rrc.eZdZdZfdZdZdZxZS)UpdateStatementzA statement for record update operations on a Table. Args: table (mysqlx.Table): The Table object. *fields: The fields to be updated. cjtt||dg|_dSr)rZrrrrs rrzUpdateStatement.__init__ns4 ot$$--Ue-LLLrcv|jttjj|||S)aUpdates the column value on records in a table. Args: field (string): The column name to be updated. value (object): The value to be set on the specified column. Returns: mysqlx.UpdateStatement: UpdateStatement object. )rrrrrrrs rrzUpdateStatement.setrs<  z15ue D D F F F rc6|j|S)zZExecute the statement. Returns: mysqlx.Result: Result object rrKs rrRzUpdateStatement.executerr)rrrrTrrrRrrs@rrrgs`    -------rrc(eZdZdZfdZdZxZS)RemoveStatementzA statement for document removal from a collection. Args: collection (mysqlx.Collection): The Collection object. cZtt||dSr)rZrrrs rrzRemoveStatement.__init__s* ot$$--Z-@@@@@rc6|j|SrrGdeleterKs rrRzRemoveStatement.executerrrrs@rrrsV AAAAA-------rrc*eZdZdZdfd ZdZxZS)DeleteStatementzA statement that drops a table. Args: table (mysqlx.Table): The Table object. condition (Optional[str]): The string with the filter expression of the rows to be deleted. Nc^tt|||ddS)NF)rHrerI)rZrr)rrrerfs rrzDeleteStatement.__init__s< ot$$--U8A8= . ? ? ? ? ?rc6|j|SrrrKs rrRzDeleteStatement.executerrrrrs@rrrsV?????? -------rrc.eZdZdZfdZdZdZxZS)CreateCollectionIndexStatementzA statement that creates an index on a collection. Args: collection (mysqlx.Collection): Collection. index_name (string): Index name. is_unique (bool): `True` if the index is unique. ctt||||_||_g|_dSr)rZrr _index_name _is_uniquer )rr index_name is_uniquerfs rrz'CreateCollectionIndexStatement.__init__s? ,d33<.s%GGG7wGGt$GGGGrxplugincreate_collection_indexT)r rGexecute_nonqueryrErMrr r!rqs rrRz&CreateCollectionIndexStatement.executesg HGdlGGG0t0 0$ L  $dl&79I O&%&&& &r)rrrrTrrrRrrs@rrrs`    & & & & & & &rrc(eZdZdZfdZdZxZS)DropCollectionIndexStatementzA statement that drops an index on a collection. Args: collection (mysqlx.Collection): The Collection object. index_name (string): The index name. chtt||||_dSr)rZr0rr )rrr"rfs rrz%DropCollectionIndexStatement.__init__s3 *D11::*:MMM%rc||jddd|jjj|jj|jS)rr,drop_collection_indexT)rGr.rErMrr rKs rrRz$DropCollectionIndexStatement.executesA 00 . L  $dl&79IKK Krrrs@rr0r0sX &&&&&KKKKKKKrr0c"eZdZdZdZdZdZdS) TableIndexrrc0||_||_||_dSr)_name _index_type_columns)rr index_typecolumnss rrzTableIndex.__init__s % rcd}|jtjur|dz }|dz }||jd|jS)Nr"zUNIQUE zINDEX {0} ({1})rm)r8r5 UNIQUE_INDEXr-r7r6r9)rrs rrzTableIndex.get_sqlsQ  z6 6 6 I D !!{{4:sxx '>'>???rN)rrrr=INDEXrrrrrr5r5sAL E   @@@@@rr5cNeZdZdZd fd ZdZdZdZdZdZ d Z d Z xZ S) CreateViewStatementzA statement for creating views. Args: view (mysqlx.View): The View object. replace (Optional[bool]): `True` to add replace. Fc$tt||d||_|j|_|j|_||_g|_ tj |_ tj|_d|_d|_d|_dSr)rZr@r_viewrM_schemarr7_replacer9r UNDEFINED _algorithmrDEFINER _security_definer _defined_as _check_option)rviewr.rfs rrzCreateViewStatement.__init__s !4((111OOO { Y   $.#+ !rc(d|D|_|S)zSets the column names. Args: columns (list): The list of column names. Returns: mysqlx.CreateViewStatement: CreateViewStatement object. c,g|]}t|Srr3)r4cols rr5z/CreateViewStatement.columns..s!BBB3)#..BBBr)r9)rr;s rr;zCreateViewStatement.columnssCB'BBB  rc||_|S)zSets the algorithm. Args: mysqlx.constants.ALGORITHMS: The algorithm. Returns: mysqlx.CreateViewStatement: CreateViewStatement object. )rF)r algorithms rrQzCreateViewStatement.algorithm!$ rc||_|S)zSets the SQL security mode. Args: mysqlx.constants.SECURITIES: The SQL security mode. Returns: mysqlx.CreateViewStatement: CreateViewStatement object. )rH)rsecuritys rrTzCreateViewStatement.security-s" rc||_|S)zSets the definer. Args: definer (string): The definer. Returns: mysqlx.CreateViewStatement: CreateViewStatement object. )rI)rdefiners rrVzCreateViewStatement.definer9   rc||_|S)zSets the SelectStatement statement for describing the view. Args: mysqlx.SelectStatement: SelectStatement object. Returns: mysqlx.CreateViewStatement: CreateViewStatement object. )rJ)r statements r defined_aszCreateViewStatement.defined_asEs% rc||_|S)zSets the check option. Args: mysqlx.constants.CHECK_OPTIONS: The check option. Returns: mysqlx.CreateViewStatement: CreateViewStatement object. )rK)r check_options rwith_check_optionz%CreateViewStatement.with_check_optionQs* rc |jrdnd}|jrd|jnd}|jr-dd|jnd}t |jj|jf}|j rd|j nd}d||j ||j |||j |}|j d ||jS) zhExecute the statement to create a view. Returns: mysqlx.View: View object. z OR REPLACEr" DEFINER = {0} ({0}),  WITH {0} CHECK OPTIONzCREATE{replace} ALGORITHM = {algorithm}{definer} SQL SECURITY {security} VIEW {view_name}{columns} AS {defined_as}{check_option})r.rQrVrT view_namer;rZr\r)rDrIr-r9r6r8rCrr7rKrFrHrJrGr.rB)rr.rVr;rcr\rs rrRzCreateViewStatement.execute]s $(=8--b]+"))$-888(* ]+(//$))DM":":;;;(* . 0A4:/NOO ,5/66t7IJJJ24 &DO!(4>#,g$($4&2 44  ))%555zr)F) rrrrTrr;rQrTrVrZr]rRrrs@rr@r@s " " " " " "                  rr@c(eZdZdZfdZdZxZS)AlterViewStatementzYA statement for alter views. Args: view (mysqlx.View): The View object. cXtt||dSr)rZrer)rrLrfs rrzAlterViewStatement.__init__~s(  $''0066666rc |jrd|jnd}|jr-dd|jnd}t |jj|jf}|jrd|jnd}d|j ||j |||j |}|j d||jS) zgExecute the statement to alter a view. Returns: mysqlx.View: View object. r_r"r`rarbzvALTER ALGORITHM = {algorithm}{definer} SQL SECURITY {security} VIEW {view_name}{columns} AS {defined_as}{check_option})rQrVrTrcr;rZr\r)rIr-r9r6r8rCrr7rKrFrHrJrGr.rB)rrVr;rcr\rs rrRzAlterViewStatement.executes]+"))$-888(* ]+(//$))DM":":;;;(* . 0A4:/NOO ,5/66t7IJJJ24 &4?G"&.I!(T5E&244  ))%555zrrrs@rrerexsQ 77777rreceZdZdZejdejZfdZe dZ dZ dZ dZ dZd Zd Zd Zd Zd ZdZdZdZdZdZdZxZS)CreateTableStatementzA statement that creates a new table if it doesn't exist already. Args: collection (mysqlx.Schema): The Schema object. table_name (string): The name for the new table. z$(from\s+)([`\"].+[`\"]|[^\.]+)(\s|$)cptt||d|_d|_d|_d|_d|_d|_g|_ g|_ g|_ g|_ g|_ d|_||_d|j|_dS)NFrz \1{0}.\2\3)rZrir_charset _collation_comment_as_like_tempr9_f_keys_indices_p_keys _u_indices _auto_incr7r-rMget_name _tbl_repl)rrMr=rfs rrzCreateTableStatement.__init__s "D))226:::         &--dk.B.B.D.DEErcZtt|jj|jS)z7string: The fully qualified name of the Table. )r8rArMrr7rKs rr=zCreateTableStatement.table_names/**: K dj+*+*++ +rc\g}|d|jr|d|jr|d|jr|dd|}||j|j|j|jS)NzAUTO_INCREMENT = {inc}z!DEFAULT CHARACTER SET = {charset}zDEFAULT COLLATE = {collation}zCOMMENT = '{comment}'rm)inccharset collationcomment)rrkrlrmr6r-ru)roptions table_optss r_get_table_optsz$CreateTableStatement._get_table_optss/000 = @ NN> ? ? ? ? < NN: ; ; ; = 4 NN2 3 3 3XXg&&   T^T]ot}!>> >rcFg}|jr@|dd|j|jD])}||*|jD])}||*|jD])}||*|jD])}||*d|S)NzPRIMARY KEY ({0})rm) rsrr-r6r9rrqrrrt)rdefsrOrindexs r_get_create_defz$CreateTableStatement._get_create_defs  < L KK+22388DL3I3IJJ K K K= ' 'C KK & & & &< ' 'C KK & & & &] ) )E KK  ( ( ( (_ ) )E KK  ( ( ( (xx~~rc^tt|jj||_|S)zCreate table with the definition of another existing Table. Args: table_name (string): Name of the source table. Returns: mysqlx.CreateTableStatement: CreateTableStatement object. )r8rArMrro)rr=s rlikezCreateTableStatement.likes,0 T[-z : :<<  rct|tr+tj|j||_n.t|tr||_|S)a.Create the Table and fill it with values from a Select Statement. Args: select (object): Select Statement. Can be a string or an instance of :class`mysqlx.SelectStatement`. Returns: mysqlx.CreateTableStatement: CreateTableStatement object. ) rrritbl_frmtsubrwrnrr)rrs r as_selectzCreateTableStatement.as_selects\ fl + + (+488PPDHH  0 0 (~~''DH rc||j|j||S)zAdd a Column to the Table. Args: column_def (MySQLx.ColumnDef): Column Definition object. Returns: mysqlx.CreateTableStatement: CreateTableStatement object. ) set_schemarMrvr9r)r column_defs r add_columnzCreateTableStatement.add_columnsA dk2244555 Z((( rcLt|}|j||S)zAdd multiple Primary Keys to the Table. Args: *keys: Fields to be used as Primary Keys. Returns: mysqlx.CreateTableStatement: CreateTableStatement object. )r!rsr)rrs radd_primary_keyz$CreateTableStatement.add_primary_keys)% D!!! rc z|jt|tjt ||S)zAdds an Index to the Table. Args: index_name (string): Name of the Index. *cols: Fields to be used as an Index. Returns: mysqlx.CreateTableStatement: CreateTableStatement object. )rrrr5r>r!rr"colss r add_indexzCreateTableStatement.add_indexs> Z J4D T "$$ % % % rc z|jt|tjt ||S)aAdds a Unique Index to the Table. Args: index_name (string): Name of the Unique Index. *cols: Fields to be used as a Unique Index. Returns: mysqlx.CreateTableStatement: CreateTableStatement object. )rtrr5r=r!rs radd_unique_indexz%CreateTableStatement.add_unique_indexs> z*j6M T " $ $ % % % rc||j|||j||S)zAdds a Foreign Key to the Table. Args: key (MySQLx.ForeignKeyDef): The Foreign Key Definition object. Returns: mysqlx.CreateTableStatement: CreateTableStatement object. )rrMrvset_namerqr)rrrs radd_foreign_keyz$CreateTableStatement.add_foreign_key*sQ t{++--... T C    rc||_|S)zSet the initial Auto Increment value for the table. Args: inc (int): The initial AUTO_INCREMENT value for the table. Returns: mysqlx.CreateTableStatement: CreateTableStatement object. ru)rrzs rset_initial_auto_incrementz/CreateTableStatement.set_initial_auto_increment8s rc||_|S)zSets the default Charset type for the Table. Args: charset (string): Charset type. Returns: mysqlx.CreateTableStatement: CreateTableStatement object. rkrr{s rset_default_charsetz(CreateTableStatement.set_default_charsetDrWrc||_|S)zSets the default Collation type for the Table. Args: collation (string): Collation type. Returns: mysqlx.CreateTableStatement: CreateTableStatement object. rlrr|s rset_default_collationz*CreateTableStatement.set_default_collationPrRrc||_|S)zAdd a comment to the Table. Args: comment (string): Comment to be added to the Table. Returns: mysqlx.CreateTableStatement: CreateTableStatement object. rmrr}s r set_commentz CreateTableStatement.set_comment\rWrcd|_|S)zSet the Table to be Temporary. Returns: mysqlx.CreateTableStatement: CreateTableStatement object. T)rprKs r temporaryzCreateTableStatement.temporaryhs   rcpd|j|jrdnd}|jrd}nd}|||jp|jpd||}|jd |d |j |j S) zYExecute the statement. Returns: mysqlx.Table: Table object. zCREATE {table_type} {name}zTEMPORARY TABLETABLE)r table_typez{create} LIKE {query}z,{create} ({create_def}) {table_opts} {query}r")createquery create_defrrF) r-r=rprornrrrGr.rM get_tabler7)rrrs rrRzCreateTableStatement.executeqs .44$/,0JC((G5EE : B*DDAD{{*..B++--++-- // ))%u==={$$TZ000r)rrrrTrecompile IGNORECASErrrUr=rrrrrrrrrrrrrrrRrrs@rriris[ rzA2=QQHFFFFF$++X+ > > >                                 1111111rric6eZdZdZdZdZdZdZdZdZ dS) ColumnDefBasezA Base class defining the basic parameters required to define a column. Args: name (string): Name of the column. type (MySQLx.ColumnType): Type of the column. size (int): Size of the column. cvd|_d|_d|_d|_||_||_d|_||_dS)NFr")_default_schema _not_null_p_key_u_indexr7_sizerm_type)rrtypesizes rrzColumnDefBase.__init__s?#      rcd|_|S)zwDisable NULL values for this column. Returns: mysqlx.ColumnDefBase: ColumnDefBase object. T)rrKs rnot_nullzColumnDefBase.not_null  rcd|_|S)zwSet current column as a Unique Index. Returns: mysqlx.ColumnDefBase: ColumnDefBase object. T)rrKs r unique_indexzColumnDefBase.unique_indexs   rc||_|S)zAdd a comment to the column. Args: comment (string): Comment to be added to the column. Returns: mysqlx.ColumnDefBase: ColumnDefBase object. rrs rr}zColumnDefBase.commentrWrcd|_|S)ztSets the Column as a Primary Key. Returns: mysqlx.ColumnDefBase: ColumnDefBase object. T)rrKs rprimaryzColumnDefBase.primarys   rc||_dSrrrrMs rrzColumnDefBase.set_schema%rN) rrrrTrrrr}rrrrrrrsx   &&&&&rrcleZdZdZdfd ZdZdZdZdZdZ d Z d Z d Z d Z d ZdZdZxZS) ColumnDefzClass containing the complete definition of the Column. Args: name (string): Name of the column. type (MySQL.ColumnType): Type of the column. size (int): Size of the column. Nctt||||d|_d|_d|_d|_d|_d|_d|_ g|_ g|_ d|_ d|_ dSr)rZrr_ref_default _decimals _ref_table_binaryru _unsignedr _ref_fieldsrkrl)rrrrrfs rrzColumnDef.__init__sw i''dD999     rcDd}|jrftj|js2tj|jstj|jrd|j}ntj|jr*|jr#d|j|jpd}nFtj |jr-dd |j }|j rd|}|j rd|}|jrd||j}|jrd ||j}d tj|j|S) Nr"z({0})z ({0}, {1})rrmz {0} UNSIGNEDz {0} BINARYz{0} CHARACTER SET {1}z{0} COLLATE {1}{0} {1})rr is_numericris_char is_binaryr- is_decimalsr is_finite_setr6rrrrkrl to_string)rtype_defs r _data_typezColumnDef._data_typesw : >:0<< >  tz * * >.8.B4:.N.N >~~dj11HH  #DJ / / >DJ >#**4:t~7JKKHH  %dj 1 1 >~~chht|&<&<==H > 7%,,X66H < 5#**844H = O.55h NNH ? K(//$/JJH 4TZ @ @(KKKrc,|jrdnd}|jrdnd}|jrdnd}|jrdnd}d|||||}|jrd|}n|jrd |}|jr]|j rVtt|j |j}d ||d |j }||j|j S) Nz NOT NULLz NULLz AUTO_INCREMENTr"z DEFAULT {default}z COMMENT '{comment}'z{0}{1}{2}{3}{4}z{0} PRIMARY KEYz{0} UNIQUE KEYz{0} REFERENCES {1} ({2})rm)defaultr})rrurrmr-rrrrrr8rArr6)rnullauto_incrr}defn ref_tables r_col_definitionzColumnDef._col_definitions1"n9{{'(,>$$B*.-?&&R,0MA((r ''(9(94 g ; 1$++D11DD ] 1#**400D ? ,t/ ,23C$do474788I-44T9)**,,D{{4=$-{HHHrct|tr |j|_n|d|_nt ||_|S)zSets the default value of this Column. Args: default_val (object): The default value of the Column. Can be a string, number or :class`MySQLx.Expr`. Returns: mysqlx.ColumnDef: ColumnDef object. NNULL)rrrrrepr)r default_vals r set_defaultzColumnDef.set_defaultsE k4 ( ( .',DMM  "DMM --DM rcd|_|S)zlSet the Column to Auto Increment. Returns: mysqlx.ColumnDef: ColumnDef object. TrrKs rauto_incrementzColumnDef.auto_incrementrrc0t||_||_|S)zSets the Column as a Foreign Key. Args: name (string): Name of the referenced Table. *refs: Fields this Column references. Returns: mysqlx.ColumnDef: ColumnDef object. )r!rrrrrefss r foreign_keyzColumnDef.foreign_key$s+D1 rcd|_|S)zfSet the Column as unsigned. Returns: mysqlx.ColumnDef: ColumnDef object. T)rrKs runsignedzColumnDef.unsigned2rrc||_|S)zSet the size of the decimal Column. Args: size (int): Size of the decimal. Returns: mysqlx.ColumnDef: ColumnDef object. )r)rrs rdecimalszColumnDef.decimals;s rc||_|S)zSet the Charset type of the Column. Args: charset (string): Charset type. Returns: mysqlx.ColumnDef: ColumnDef object. rrs rr{zColumnDef.charsetGrWrc||_|S)zSet the Collation type of the Column. Args: collation (string): Collation type. Returns: mysqlx.ColumnDef: ColumnDef object. rrs rr|zColumnDef.collationSrRrcd|_|S)zqSet the current column to binary type. Returns: mysqlx.ColumnDef: ColumnDef object. T)rrKs rbinaryzColumnDef.binary_   rcHttt||_|S)zSet the Enum/Set values. Args: *values: Values for Enum/Set type Column. Returns: mysqlx.ColumnDef: ColumnDef object. )maprr!rr s rr zColumnDef.valueshs4&!9::  rc\d|j|S)Nr)r-r7rrKs rrzColumnDef.get_sqlts& D,@,@,B,BCCCrr)rrrrTrrrrrrrrr{r|rr rrrs@rrrs"LLL*III*&               DDDDDDDrrc2eZdZdZfdZdZfdZxZS)GeneratedColumnDefzClass used to describe a Generated Column. Args: name: Name of the column. col_type: Type of the column. expr: The Expression used to generate the value of this column. ctt|||t|tsJd|_|j|_dSr)rZrrrr_storedr_expr)rrcol_typerrfs rrzGeneratedColumnDef.__init__sN  $''00x@@@$%%%%% Y rcd|_|S)zSet the Generated Column to be stored. Returns: mysqlx.GeneratedColumnDef: GeneratedColumnDef object. T)rrKs rstoredzGeneratedColumnDef.storedrrcdtt||j|jrdndS)Nz {0} GENERATED ALWAYS AS ({1}){2}z STOREDr")r-rZrrrr)rrfs rrzGeneratedColumnDef.get_sqlsG188 $d + + 3 3 5 5 JT\9 r;; ;r)rrrrTrrrrrs@rrrxsj ;;;;;;;;;rrcXeZdZdZdZdZdZdZdZdZ dZ d Z d Z d Z d Zd ZdZdS) ForeignKeyDefzClass describing a Foreign Key.rrcg|_g|_d|_d|_d|_|t j|_|t j|_ dSr) r  _f_fieldsr7_f_tabler_actionr NO_ACTION_update_action_delete_actionrKs rrzForeignKeyDef.__init__sZ   #"ll=+BCC"ll=+BCCrcf|tjurdS|tjurdS|tjurdSdS)NRESTRICTCASCADEzSET NULLz NO ACTION)rrrSET_NULLractions rrzForeignKeyDef._actions@ ]+ + +: }, , ,9 }- - -:{rc||_dSr)r7)rrs rrzForeignKeyDef.set_names  rc||_dSrrrs rrzForeignKeyDef.set_schemarrc"t||_|S)zAdd a list of fields in the parent table. Args: *fields: Fields in the given table which constitute the Foreign Key. Returns: mysqlx.ForeignKeyDef: ForeignKeyDef object. )r!r rqs rrrzForeignKeyDef.fieldss'/  rc0t||_||_|S)zAdd the child table name and the fields. Args: name (string): Name of the referenced table. *refs: A list fields in the referenced table. Returns: mysqlx.ForeignKeyDef: ForeignKeyDef object. )r!r r rs r refers_tozForeignKeyDef.refers_tos)$/  rc:|||_|S)aDefine the action on updating a Foreign Key. Args: action (int): Action to be performed on updating the reference. Can be any of the following values: 1. ForeignKeyDef.NO_ACTION 2. ForeignKeyDef.RESTRICT 3. ForeignKeyDef.CASCADE 4. ForeignKeyDef.SET_NULL Returns: mysqlx.ForeignKeyDef: ForeignKeyDef object. )rrrs r on_updatezForeignKeyDef.on_updates#ll622 rc:|||_|S)aDefine the action on deleting a Foreign Key. Args: action (int): Action to be performed on updating the reference. Can be any of the following values: 1. ForeignKeyDef.NO_ACTION 2. ForeignKeyDef.RESTRICT 3. ForeignKeyDef.CASCADE 4. ForeignKeyDef.SET_NULL Returns: mysqlx.ForeignKeyDef: ForeignKeyDef object. )rrrs r on_deletezForeignKeyDef.on_deletes#ll622 rc |d|j}d|j}d|jd|jt t|j|j d|j }d|||S)Nz ON UPDATE {0}z ON DELETE {0}z)FOREIGN KEY {0}({1}) REFERENCES {2} ({3})rmz {0} {1} {2}) r-rrr7r6r r8rArr r )rrrrs rrzForeignKeyDef.get_sqls ''(;<< ''(;<<9@@ J..0J T14= A A1C1C HHT^ $ $&&##C888rN)rrrrTrrrrrrrrrrrrr rrrrrrs))IHGHDDD&&&      $"99999rr)r")2rTrrerrorsrrrcompatr constantsrrdbdocr protobufr rresultr r r rrr!r+r/r8rArCrWrrrrrrrrrrrr0r5r@rerirrrrrrrr(s=0$# $$$$$$ --------33333311111111116  >>>>"====( 5 5 5 5$$$$""""""""DC"C"C"C"C")C"C"C"L+++++9+++,'2'2'2'2'29'2'2'2T&b-b-b-b-b-)b-b-b-J9+9+9+9+9+'9+9+9+x=====)===~22222i222B-----)---D-----)---$-----)---,'&'&'&'&'&Y'&'&'&TKKKKK9KKK, @ @ @ @ @ @ @ @ ttttt)tttn,Bl1l1l1l1l19l1l1l1^:&:&:&:&:&F:&:&:&zpDpDpDpDpD pDpDpDf;;;;;;;;:c9c9c9c9c9Fc9c9c9c9c9r