U ec@sdZddlZddlZddlZddlmZddlmZddlm Z m Z ddl m Z ddl mZdd lmZdd lmZd ZGd d d ZddZd7ddZd8ddZd9ddZd:ddZGdddZGdddeZGdddeZGdd d eZGd!d"d"eZGd#d$d$ZGd%d&d&eZ Gd'd(d(eZ!Gd)d*d*e!Z"Gd+d,d,e!Z#Gd-d.d.eZ$Gd/d0d0eZ%Gd1d2d2eZ&Gd3d4d4eZ'Gd5d6d6eZ(dS);zImplementation of Statements.N)LockContention)DbDoc)NotSupportedErrorProgrammingError) ExprParser) deprecated) mysqlxpb_enum)Resultz&The given index name "{}" is not validc@seZdZdZddZdS)ExprzExpression wrapper.cCs ||_dSN)expr)selfr r4/tmp/pip-unpacked-wheel-ix8dg7li/mysqlx/statement.py__init__1sz Expr.__init__N)__name__ __module__ __qualname____doc__rrrrrr .sr cGs*t|dkr&t|dttfr&|dS|S)zParse flexible parameters.rr)len isinstancelisttuple)valuesrrrflexible_params5srcCsPd|kr8|ddkr |ddkp6|ddko6|ddkS|ddkoN|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_moderrris_quoted_identifier<s r#cCsHt|dkrdSd|kr0|dd}d|dS|dd}d|dS)a@Quote the given identifier with backticks, converting backticks (`) in the identifier name with the correct escape sequence (``). Args: identifier (string): Identifier to quote. sql_mode (Optional[string]): SQL mode. Returns: A string with the identifier quoted with backticks. rz``rr z""r)rreplace)r!r"quotedrrrquote_identifierMs    r&csdfdd|DS)aQuote the given multi-part identifier with backticks. Args: identifiers (iterable): List of identifiers to quote. sql_mode (Optional[string]): SQL mode. Returns: A string with the multi-part identifier quoted with backticks. .csg|]}t|qSr)r&).0r!r"rr lsz.quote_multipart_identifier..)join)Z identifiersr"rr)rquote_multipart_identifieras r,cCs^d|kr dnd}||kr"d|nd}||d}t|dkrB|n |d||d|fS)zParse table name. Args: default_schema (str): The default schema. table_name (str): The table name. sql_mode(Optional[str]): The SQL mode. Returns: str: The parsed table name. rr rr'rrr)splitrstrip)Zdefault_schemaZ table_namer"quote delimitertemprrrparse_table_nameps   r2c@seZdZdZd"ddZeddZeddZed d Zej d d Zed d Z eddZ e j ddZ eddZ e j ddZ eddZ eddZej ddZddZddZddZdd Zd!S)# 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. TcCs@||_||_|r|nd|_d|_d|_d|_d|_d|_dS)NrTF) _target _doc_basedget_connection _connection_stmt_id _exec_counter_changed _prepared_deallocate_prepare_executertarget doc_basedrrrrszStatement.__init__cCs|jS)z#object: The database object target.)r4rrrrr>szStatement.targetcCs|jjS)z*:class:`mysqlx.Schema`: The Schema object.)r4schemar@rrrrAszStatement.schemacCs|jS)zXReturns this statement ID. Returns: int: The statement ID. r8r@rrrstmt_idszStatement.stmt_idcCs ||_dSr rBrvaluerrrrCscCs|jS)z5int: The number of times this statement was executed.r9r@rrr exec_counterszStatement.exec_countercCs|jS)z+bool: `True` if this statement has changes.r:r@rrrchangedszStatement.changedcCs ||_dSr rHrDrrrrIscCs|jS)z1bool: `True` if this statement has been prepared.r;r@rrrpreparedszStatement.preparedcCs ||_dSr rJrDrrrrKscCs |jdkS)z;bool: `True` if this statement was executed more than once.rrFr@rrrrepeatedszStatement.repeatedcCs|jS)z9bool: `True` to deallocate + prepare + execute statement.r<r@rrrdeallocate_prepare_executesz$Statement.deallocate_prepare_executecCs ||_dSr rMrDrrrrNscCs|jS)zkCheck if it is document based. Returns: bool: `True` if it is document based. )r5r@rrr is_doc_basedszStatement.is_doc_basedcCs|jd7_dS)z@Increments the number of times this statement has been executed.rNrFr@rrrincrement_exec_countersz Statement.increment_exec_countercCs d|_dS)zrArCsetterrGrIrKrLrNrOrPrQrUrrrrr3s<             r3cseZdZdZd1fdd ZddZdd Zd d Zd d ZddZ ddZ ddZ ddZ ddZ ddZddZddZddZd d!Zd"d#Zed$d%d&Zed$d'd(Zd2d)d*Zd+d,Zd-d.Zd/d0ZZS)3FilterableStatementaA 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. TNcstj||di|_i|_d|_d|_d|_d|_d|_d|_ d|_ d|_ d|_ d|_ d|_d|_d|_d|_d|_d|_d|_d|_|r||dS)Nr>r?rrF)superr _binding_map _bindings_having _grouping_str _grouping _limit_offset_limit_row_count_projection_str_projection_expr _sort_str _sort_expr _where_str _where_expr has_bindings has_limit has_group_by has_havinghas_projectionhas_sort has_where _set_whererr>r? condition __class__rrrs.zFilterableStatement.__init__c Cst|tr|t|nt|tr8||n|t|trzt|}t|ts\tWn,tk r}zt d|W5d}~XYnX| D]}||||qnt ddS)aBind single object. Args: obj (:class:`mysqlx.DbDoc` or str): DbDoc or JSON string object. Raises: :class:`mysqlx.ProgrammingError`: If invalid JSON string to bind. ValueError: If JSON loaded is not a dictionary. zInvalid JSON string to bindNz%Invalid JSON string or object to bind) rdictbindrZas_strstrjsonloads ValueErrorrkeys)robjreserrkeyrrr _bind_singles      z FilterableStatement._bind_singlecGs6d|_dt||_t|j|j |_d|_|S)zSets the sorting criteria. Args: *clauses: The expression strings defining the sort criteria. Returns: mysqlx.FilterableStatement: FilterableStatement object. T,) rmr+rrdrr5Zparse_order_specrer:rZclausesrrr_sort+s  zFilterableStatement._sortc Cshd|_||_zt||j }||_Wn,tk rT}ztd|W5d}~XYnX|j|_ d|_ |S)aSets the search condition to filter. Args: condition (str): Sets the search condition to filter documents or records. Returns: mysqlx.FilterableStatement: FilterableStatement object. TzInvalid conditionN) rnrfrr5r rgryrZplaceholder_name_to_positionr[r:)rrqr r}rrrro<s zFilterableStatement._set_wherecGs:t|}d|_d||_t|j|j |_d|_dS)zJSet group by. Args: *fields: List of fields. TrN) rrjr+r^rr5Zparse_expr_listr_r:rfieldsrrr _set_group_byQs  z!FilterableStatement._set_group_bycCs$d|_t||j |_d|_dS)zOSet having. Args: condition (str): The condition. TN)rkrr5r r]r:rrqrrr _set_having_szFilterableStatement._set_havingcGs:t|}d|_d||_t|j|j |_d|_|S)zSet the projection. Args: *fields: List of fields. Returns: :class:`mysqlx.FilterableStatement`: Returns self. Tr) rrlr+rbrr5Zparse_table_select_projectionrcr:rrrr_set_projectionis   z#FilterableStatement._set_projectioncCs|jSzlReturns the binding map dictionary. Returns: dict: The binding map dictionary. r[r@rrrget_binding_map{sz#FilterableStatement.get_binding_mapcCs|jSz\Returns the bindings list. Returns: `list`: The bindings list. r\r@rrr get_bindingssz FilterableStatement.get_bindingscCs|jS)zrReturns the grouping expression list. Returns: `list`: The grouping expression list. )r_r@rrr get_groupingsz FilterableStatement.get_groupingcCs|jS)zdReturns the having expression. Returns: object: The having expression. )r]r@rrr get_havingszFilterableStatement.get_havingcCs|jS)z]Returns the limit row count. Returns: int: The limit row count. )rar@rrrget_limit_row_countsz'FilterableStatement.get_limit_row_countcCs|jS)zWReturns the limit offset. Returns: int: The limit offset. )r`r@rrrget_limit_offsetsz$FilterableStatement.get_limit_offsetcCs|jS)zbReturns the where expression. Returns: object: The where expression. )rgr@rrrget_where_exprsz"FilterableStatement.get_where_exprcCs|jS)zlReturns the projection expression. Returns: object: The projection expression. )rcr@rrrget_projection_exprsz'FilterableStatement.get_projection_exprcCs|jS)z`Returns the sort expression. Returns: object: The sort expression. )rer@rrr get_sort_exprsz!FilterableStatement.get_sort_expr8.0.12cCs ||S)a&Sets the search condition to filter. Args: condition (str): Sets the search condition to filter documents or records. Returns: mysqlx.FilterableStatement: FilterableStatement object. .. deprecated:: 8.0.12 rorrrrwheres zFilterableStatement.wherecGs |j|S)zSets the sorting criteria. Args: *clauses: The expression strings defining the sort criteria. Returns: mysqlx.FilterableStatement: FilterableStatement object. .. deprecated:: 8.0.12 rrrrrsorts zFilterableStatement.sortcCsnt|tr|dkrtd|jsBt|jdk|_t|jdk |_||_d|_|rj| |t j dt d|S)aSets the maximum number of items to be returned. Args: row_count (int): The maximum number of items. Returns: mysqlx.FilterableStatement: FilterableStatement object. Raises: ValueError: If ``row_count`` is not a positive integer. .. versionchanged:: 8.0.12 The usage of ``offset`` was deprecated. rz0The 'row_count' value must be a positive integerTzh'limit(row_count, offset)' is deprecated, please use 'offset(offset)' to set the number of items to skip)category) rintryriboolr9r:r<raoffsetwarningswarnDeprecationWarning)rZ row_countrrrrlimits zFilterableStatement.limitcCs$t|tr|dkrtd||_|S)a:Sets the number of items to skip. Args: offset (int): The number of items to skip. Returns: mysqlx.FilterableStatement: FilterableStatement object. Raises: ValueError: If ``offset`` is not a positive integer. .. versionadded:: 8.0.12 rz-The 'offset' value must be a positive integer)rrryr`)rrrrrrszFilterableStatement.offsetcGsNd|_t|}|dkr&||dn$|dkrB|d|j|d<ntd|S)aBinds value(s) to a specific placeholder(s). 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. Trr#Invalid number of arguments to bind)rhrrr\r)rargscountrrrruszFilterableStatement.bindcCstdSrRrSr@rrrrU,szFilterableStatement.execute)TN)N)rrrrrrrrorrrrrrrrrrrrrrrrrrurU __classcell__rrrrrrXs2    !rXcsLeZdZdZfddZeddZddZdd Zd d Z d d Z Z S) SqlStatementzA statement for SQL execution. Args: connection (mysqlx.connection.Connection): Connection object. sql (string): The sql statement to be executed. cs8tjddd||_||_d|_g|_d|_d|_dSNFrY)rZrr7_sqlr[r\rhri)r connectionsqlrrrrr=szSqlStatement.__init__cCs|jS)zstring: The SQL text statement.)rr@rrrrFszSqlStatement.sqlcCs|jSrrr@rrrrKszSqlStatement.get_binding_mapcCs|jSrrr@rrrrSszSqlStatement.get_bindingscGsHt|dkrtdd|_t|}t|ttfr8||_n |j||S)zBinds value(s) to a specific placeholder(s). Args: *args: The value(s) to bind. Returns: mysqlx.SqlStatement: SqlStatement object. rrT) rrrhrrrrr\append)rrbindingsrrrru[s  zSqlStatement.bindcCs |j|S)zaExecute the statement. Returns: mysqlx.SqlResult: SqlResult object. )r7Zsend_sqlr@rrrrUnszSqlStatement.execute) rrrrrrVrrrrurUrrrrrrr5s  rcs0eZdZdZfddZddZddZZS)WriteStatementz*Provide common write operation attributes.cst||g|_dSr )rZr_valuesr=rrrrrzszWriteStatement.__init__cCs|jS)z^Returns the list of values. Returns: `list`: The list of values. )rr@rrr get_values~szWriteStatement.get_valuescCstdSrRrSr@rrrrUszWriteStatement.execute)rrrrrrrUrrrrrrrws rcsBeZdZdZfddZddZd ddZd d Zd d ZZ S) AddStatementzA statement for document addition on a collection. Args: collection (mysqlx.Collection): The Collection object. cst|dd|_g|_dS)NTF)rZr_upsertids)r collectionrrrrrszAddStatement.__init__cCs|jS)zhReturns `True` if it's an upsert. Returns: bool: `True` if it's an upsert. rr@rrr is_upsertszAddStatement.is_upsertTcCs ||_|S)zSets the upset flag to the boolean of the value provided. Setting of this flag allows updating of the matched rows/documents with the provided value. Args: value (optional[bool]): Set or unset the upsert flag. rrDrrrupsertszAddStatement.upsertcGs:t|D],}t|tr$|j|q|jt|q|S)zAdds a list of documents into a collection. Args: *values: The documents to be added into the collection. Returns: mysqlx.AddStatement: AddStatement object. )rrrrr)rrvalrrradds  zAddStatement.addcCs t|jdkrtS|j|S)[Execute the statement. Returns: mysqlx.Result: Result object. r)rrr r7 send_insertr@rrrrUszAddStatement.execute)T) rrrrrrrrrUrrrrrrrs   rc@s"eZdZdZdddZddZdS) UpdateSpeczUpdate specification class implementation. Args: update_type (int): The update type. source (str): The source. value (Optional[str]): The value. Raises: ProgrammingError: If `source` is invalid. Nc Csp|tdkr|||nR||_zt|dj|_Wn.tk rd}zt||W5d}~XYnX||_ dS)N*Mysqlx.Crud.UpdateOperation.UpdateType.SETF) r _table_set update_typerZdocument_fieldr!sourceryrrE)rrrrEr}rrrrs zUpdateSpec.__init__cCs$td|_t|d|_||_dS)zlTable set. Args: source (str): The source. value (str): The value. rTN)r rrZparse_table_update_fieldrrE)rrrErrrrs zUpdateSpec._table_set)N)rrrrrrrrrrrs rcspeZdZdZfddZddZddZdd Zed d d Z d dZ ddZ ddZ ddZ ddZZS)ModifyStatementaUA statement for document update operations on a Collection. Args: collection (mysqlx.Collection): The Collection object. condition (str): Sets the search condition to identify the documents to be modified. .. versionchanged:: 8.0.12 The ``condition`` parameter is now mandatory. cstj||di|_dSN)r>rqrZr _update_opsrrrqrrrrrszModifyStatement.__init__cGs |j|S)zSets the sorting criteria. Args: *clauses: The expression strings defining the sort criteria. Returns: mysqlx.ModifyStatement: ModifyStatement object. rrrrrrs zModifyStatement.sortcCs|jSztReturns the list of update operations. Returns: `list`: The list of update operations. rr@rrrget_update_opsszModifyStatement.get_update_opscCs ttd|||j|<d|_|S)a2Sets or updates attributes on documents in a collection. Args: doc_path (string): The document path of the item to be set. value (string): The value to be set on the specified attribute. Returns: mysqlx.ModifyStatement: ModifyStatement object. z/Mysqlx.Crud.UpdateOperation.UpdateType.ITEM_SETTrr rr:rZdoc_pathrErrrsets  zModifyStatement.setrcCs ttd|||j|<d|_|S)aAdd an update to the statement setting the field, if it exists at the document path, to the given value. Args: doc_path (string): The document path of the item to be set. value (object): The value to be set on the specified attribute. Returns: mysqlx.ModifyStatement: ModifyStatement object. .. deprecated:: 8.0.12 z3Mysqlx.Crud.UpdateOperation.UpdateType.ITEM_REPLACETrrrrrchange"s zModifyStatement.changecGs,t|D]}ttd||j|<qd|_|S)aRemoves attributes from documents in a collection. Args: doc_paths (list): The list of document paths of the attributes to be removed. Returns: mysqlx.ModifyStatement: ModifyStatement object. z2Mysqlx.Crud.UpdateOperation.UpdateType.ITEM_REMOVET)rrr rr:)rZ doc_pathsitemrrrunset8s  zModifyStatement.unsetcCs ttd|||j|<d|_|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. z3Mysqlx.Crud.UpdateOperation.UpdateType.ARRAY_INSERTTrrfieldrErrr array_insertJs  zModifyStatement.array_insertcCs ttd|||j|<d|_|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. z3Mysqlx.Crud.UpdateOperation.UpdateType.ARRAY_APPENDTrrrrr array_append^s  zModifyStatement.array_appendcCsX|dkr d}t|ttttfs&tdttddt|trB|n||j d<d|_ |S)aTakes a :class:`mysqlx.DbDoc`, string JSON format or a dict with the changes and applies it on all matching documents. Args: doc (object): A generic document (DbDoc), string in JSON format or dict, with the changes to apply to the matching documents. Returns: mysqlx.ModifyStatement: ModifyStatement object. Nrz>Invalid data for update operation on document collection tablez2Mysqlx.Crud.UpdateOperation.UpdateType.MERGE_PATCH$patchT) rrrtrrvrrr r rr:)rdocrrrrss  zModifyStatement.patchcCs|jstd|j|S)Execute the statement. Returns: mysqlx.Result: Result object. Raises: ProgrammingError: If condition was not set. z!No condition was found for modifyrnrr7Z send_updater@rrrrUs zModifyStatement.execute)rrrrrrrrrrrrrrrUrrrrrrrs   rcszeZdZdZdfdd ZeddZdd Zd d Zd d Z e j fddZ e j fddZ ddZddZddZZS) ReadStatementaProvide base functionality for Read operations 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. TNcs(t|||d|_d|_tj|_dSNF)rZr_lock_exclusive _lock_sharedrDEFAULT_lock_contentionrprrrrrszReadStatement.__init__cCs|jS)z::class:`mysqlx.LockContention`: The lock contention value.)rr@rrrlock_contentionszReadStatement.lock_contentionc CsFzt|j}Wn,tk r:}ztd|W5d}~XYnX||_dS)zSet the lock contention. Args: lock_contention (:class:`mysqlx.LockContention`): Lock contention. Raises: ProgrammingError: If is an invalid lock contention value. z;Invalid lock contention mode. Use 'NOWAIT' or 'SKIP_LOCKED'N)rrEryrr)rr_r}rrr_set_lock_contentions z"ReadStatement._set_lock_contentioncCs|jS)zrReturns `True` if is `EXCLUSIVE LOCK`. Returns: bool: `True` if is `EXCLUSIVE LOCK`. )rr@rrris_lock_exclusiveszReadStatement.is_lock_exclusivecCs|jS)zlReturns `True` if is `SHARED LOCK`. Returns: bool: `True` if is `SHARED LOCK`. )rr@rrris_lock_sharedszReadStatement.is_lock_sharedcCsd|_d|_|||S)zExecute a read operation with `SHARED LOCK`. Only one lock can be active at a time. Args: lock_contention (:class:`mysqlx.LockContention`): Lock contention. FTrrrrrrrr lock_shareds zReadStatement.lock_sharedcCsd|_d|_|||S)zExecute a read operation with `EXCLUSIVE LOCK`. Only one lock can be active at a time. Args: lock_contention (:class:`mysqlx.LockContention`): Lock contention. TFrrrrrlock_exclusives zReadStatement.lock_exclusivecGs|j||S)zSets a grouping criteria for the resultset. Args: *fields: The string expressions identifying the grouping criteria. Returns: mysqlx.ReadStatement: ReadStatement object. )rrrrrgroup_bys zReadStatement.group_bycCs|||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.ReadStatement: ReadStatement object. )rrrrrhavings zReadStatement.havingcCs |j|Sr)r7Z send_findr@rrrrUszReadStatement.execute)TN)rrrrrrVrrrrrrrrrrrUrrrrrrrs     rcs2eZdZdZd fdd ZddZddZZS) 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. Ncst|d|dS)NTrZrrrrrrrszFindStatement.__init__cGs |j|S)zSets a document field filter. Args: *fields: The string expressions identifying the fields to be extracted. Returns: mysqlx.FindStatement: FindStatement object. )rrrrrrs zFindStatement.fieldscGs |j|SzSets the sorting criteria. Args: *clauses: The expression strings defining the sort criteria. Returns: mysqlx.FindStatement: FindStatement object. rrrrrr)s zFindStatement.sort)N)rrrrrrrrrrrrrrs  rcs8eZdZdZfddZddZddZdd ZZS) SelectStatementzA statement for record retrieval operations on a Table. Args: table (mysqlx.Table): The Table object. *fields: The fields to be retrieved. cst|d|j|dSr)rZrrrtablerrrrrr=szSelectStatement.__init__cCs ||S)zSets the search condition to filter. Args: condition (str): Sets the search condition to filter records. Returns: mysqlx.SelectStatement: SelectStatement object. rrrrrrAs zSelectStatement.wherecGs |j|S)zSets the order by criteria. Args: *clauses: The expression strings defining the order by criteria. Returns: mysqlx.SelectStatement: SelectStatement object. rrrrrorder_byLs zSelectStatement.order_byc Cs|jrd|jnd}|jr(d|jnd}|jr>d|jnd}|jrTd|jnd}|jrrd|j d|j nd}d|j pd d |j j d |jj ||||| }|S) zYReturns the generated SQL. Returns: str: The generated SQL. z WHERE rz GROUP BY z HAVING z ORDER BY z LIMIT z OFFSET zSELECT *z FROM r')rnrfrjr^rkr]rmrdrirar`rbrAnamer>)rrrrrrZstmtrrrget_sqlWs6zSelectStatement.get_sql) rrrrrrrrrrrrrrr5s    rcs0eZdZdZfddZddZddZZS)InsertStatementzA statement for insert operations on Table. Args: table (mysqlx.Table): The Table object. *fields: The fields to be inserted. cst|dt||_dSr)rZrr_fieldsrrrrrrvszInsertStatement.__init__cGs|jtt||S)zSet the values to be inserted. Args: *values: The values of the columns to be inserted. Returns: mysqlx.InsertStatement: InsertStatement object. )rrrr)rrrrrrzs zInsertStatement.valuescCs |j|Sr)r7rr@rrrrUszInsertStatement.execute)rrrrrrrUrrrrrrrns  rcsHeZdZdZfddZddZddZdd Zd d Zd d Z Z S)UpdateStatementzA statement for record update operations on a Table. Args: table (mysqlx.Table): The Table object. .. versionchanged:: 8.0.12 The ``fields`` parameters were removed. cstj|ddi|_dSrrrrrrrrrszUpdateStatement.__init__cCs ||S)zSets the search condition to filter. Args: condition (str): Sets the search condition to filter records. Returns: mysqlx.UpdateStatement: UpdateStatement object. rrrrrrs zUpdateStatement.wherecGs |j|S)zSets the order by criteria. Args: *clauses: The expression strings defining the order by criteria. Returns: mysqlx.UpdateStatement: UpdateStatement object. rrrrrrs zUpdateStatement.order_bycCs|jSrrr@rrrrszUpdateStatement.get_update_opscCs ttd|||j|<d|_|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. rTrrrrrrs  zUpdateStatement.setcCs|jstd|j|S)zExecute the statement. Returns: mysqlx.Result: Result object Raises: ProgrammingError: If condition was not set. z!No condition was found for updaterr@rrrrUs zUpdateStatement.execute) rrrrrrrrrrUrrrrrrrs   rcs0eZdZdZfddZddZddZZS)RemoveStatementaEA statement for document removal from a collection. Args: collection (mysqlx.Collection): The Collection object. condition (str): Sets the search condition to identify the documents to be removed. .. versionchanged:: 8.0.12 The ``condition`` parameter was added. cstj||ddSrrrrrrrrszRemoveStatement.__init__cGs |j|Srrrrrrrs zRemoveStatement.sortcCs|jstd|j|S)rz!No condition was found for removernrr7Z send_deleter@rrrrUs zRemoveStatement.execute)rrrrrrrUrrrrrrrs  rcs8eZdZdZfddZddZddZdd ZZS) DeleteStatementzA statement that drops a table. Args: table (mysqlx.Table): The Table object. .. versionchanged:: 8.0.12 The ``condition`` parameter was removed. cstj|dddSrrrrrrrr szDeleteStatement.__init__cCs ||S)zSets the search condition to filter. Args: condition (str): Sets the search condition to filter records. Returns: mysqlx.DeleteStatement: DeleteStatement object. rrrrrrs zDeleteStatement.wherecGs |j|S)zSets the order by criteria. Args: *clauses: The expression strings defining the order by criteria. Returns: mysqlx.DeleteStatement: DeleteStatement object. rrrrrrs zDeleteStatement.order_bycCs|jstd|j|S)rz!No condition was found for deleterr@rrrrU&s zDeleteStatement.execute) rrrrrrrrUrrrrrrrs    rcs(eZdZdZfddZddZZS)CreateCollectionIndexStatementa)A statement that creates an index on a collection. Args: collection (mysqlx.Collection): Collection. index_name (string): Index name. index_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, "collation": collation, "options": options, "srid": srid}, # {... more members, # repeated as many times # as needed} ], "type": type} cs4tj|dt||_||_|jdg|_dS)N)r>r)rZrcopydeepcopy _index_desc _index_namepop _fields_desc)rrZ index_nameZ index_descrrrrrKs z'CreateCollectionIndexStatement.__init__c Csh|jdkrtt|jz`t|j}t|trZ|dt dkrxtt|jn|j t dkrxtt|jWn8t t fk r}ztt|j|W5d}~XYnX|j std|jt|j tstdi}|j|d<|jj|d<|jjj|d<d|jkr$|jd|d<nd |d<|jd d |d <|d rPtd g|d <|jrptd|jz|j D]x}i}|d|d<|d|d<|dd |d<|dd |d<t|dtstdt|dtstd|ddkr|dstd|dd kr<|ddkrsF          hKB;#/t&9!L(1