o bY@sdZddlZddlZddlZddlmZmZddlmZddl m Z ddl m Z ddl mZdd lmZdd lmZd ZGd d d eZddZd7ddZd7ddZd7ddZd7ddZGdddeZGdddeZGdddeZGdd d eZGd!d"d"eZGd#d$d$eZ Gd%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)8zImplementation of Statements.N)ProgrammingErrorNotSupportedError) ExprParser)LockContention)DbDoc) deprecated)Result) mysqlxpb_enumz&The given index name "{}" is not validc@seZdZdZddZdS)ExprzExpression wrapper.cC ||_dSN)expr)selfrrO/var/www/secure340b-portal/env/lib/python3.10/site-packages/mysqlx/statement.py__init__0s z Expr.__init__N)__name__ __module__ __qualname____doc__rrrrrr .s r cGs*t|dkrt|dttfr|dS|S)zParse flexible parameters.rr)len isinstancelisttuple)valuesrrrflexible_params4srcCsPd|vr|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_moderrris_quoted_identifier;s  r%cCs<t|dkrdSd|vrd|ddSd|ddS) 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``rz"{0}"r!z""z`{0}`r)rformatreplacer"rrrquote_identifierKs 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 gsz.quote_multipart_identifier..)join)Z identifiersr$rr+rquote_multipart_identifier]s r.cCs^d|vrdnd}||vrd|nd}||d}t|dkr!|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!rz.{0}r)rrr )r&splitrstrip)Zdefault_schemaZ table_namer$quote delimitertemprrrparse_table_nameks    r4c@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_basedrrrrs zStatement.__init__cC|jS)z#object: The database object target.)r6rrrrr@zStatement.targetcCs|jjS)z*:class:`mysqlx.Schema`: The Schema object.)r6schemarCrrrrEszStatement.schemacCrB)zXReturns this statement ID. Returns: int: The statement ID. r:rCrrrstmt_idszStatement.stmt_idcCr r rFrvaluerrrrG cCrB)z5int: The number of times this statement was executed.r;rCrrr exec_counterrDzStatement.exec_countercCrB)z+bool: `True` if this statement has changes.r<rCrrrchangedrDzStatement.changedcCr r rMrHrrrrNrJcCrB)z1bool: `True` if this statement has been prepared.r=rCrrrpreparedrDzStatement.preparedcCr r rOrHrrrrPrJcCs |jdkS)zDbool: `True` if this statement was executed more than once. rrKrCrrrrepeateds zStatement.repeatedcCrB)zBbool: `True` to deallocate + prepare + execute statement. r>rCrrrdeallocate_prepare_executesz$Statement.deallocate_prepare_executecCr r rRrHrrrrSrJcCrB)zkCheck if it is document based. Returns: bool: `True` if it is document based. )r7rCrrr is_doc_basedzStatement.is_doc_basedcCs|jd7_dS)z@Increments the number of times this statement has been executed.rNrKrCrrrincrement_exec_countersz Statement.increment_exec_countercCs d|_dS)z              r5cseZdZdZd1fdd 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. TNcstt|j||di|_i|_d|_d|_d|_d|_d|_ d|_ d|_ d|_ d|_ d|_d|_d|_d|_d|_d|_d|_d|_d|_|rO||dSdS)Nr@rArrF)superrar _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@rA condition __class__rrrs4 zFilterableStatement.__init__cCst|tr|t|dSt|tr||dSt|trNzt|}t|ts0tWn ty<t dw| D] }||||qAdSt d)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 bindz%Invalid JSON string or object to bindN) rdictbindrZas_strstrjsonloads ValueErrorrkeys)robjreskeyrrr _bind_single s"       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,) rvr-rrmrr7Zparse_order_specrnr<rZclausesrrr_sort%s zFilterableStatement._sortcCsRd|_||_zt||j }||_Wn tytdw|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 condition) rwrorr7rrprrZplaceholder_name_to_positionrdr<)rrzrrrrrx5s  zFilterableStatement._set_wherecGs:t|}d|_d||_t|j|j |_d|_dS)zJSet group by. Args: *fields: List of fields. TrN) rrsr-rgrr7Zparse_expr_listrhr<rfieldsrrr _set_group_byJs  z!FilterableStatement._set_group_bycCs$d|_t||j |_d|_dS)zOSet having. Args: condition (str): The condition. TN)rtrr7rrfr<rrzrrr _set_havingWs zFilterableStatement._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) rrur-rkrr7Zparse_table_select_projectionrlr<rrrr_set_projectionas  z#FilterableStatement._set_projectioncCrBzlReturns the binding map dictionary. Returns: dict: The binding map dictionary. rdrCrrrget_binding_mapsrUz#FilterableStatement.get_binding_mapcCrBz\Returns the bindings list. Returns: `list`: The bindings list. rerCrrr get_bindings{rUz FilterableStatement.get_bindingscCrB)zrReturns the grouping expression list. Returns: `list`: The grouping expression list. )rhrCrrr get_groupingrUz FilterableStatement.get_groupingcCrB)zdReturns the having expression. Returns: object: The having expression. )rfrCrrr get_havingrUzFilterableStatement.get_havingcCrB)z]Returns the limit row count. Returns: int: The limit row count. )rjrCrrrget_limit_row_countrUz'FilterableStatement.get_limit_row_countcCrB)zWReturns the limit offset. Returns: int: The limit offset. )rirCrrrget_limit_offsetrUz$FilterableStatement.get_limit_offsetcCrB)zbReturns the where expression. Returns: object: The where expression. )rprCrrrget_where_exprrUz"FilterableStatement.get_where_exprcCrB)zlReturns the projection expression. Returns: object: The projection expression. )rlrCrrrget_projection_exprrUz'FilterableStatement.get_projection_exprcCrB)z`Returns the sort expression. Returns: object: The sort expression. )rnrCrrr get_sort_exprrUz!FilterableStatement.get_sort_expr8.0.12cC ||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 rxrrrrwheres zFilterableStatement.wherecG |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 |dkr td|js!t|jdk|_t|jdk |_||_d|_|r5| |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) rintrrrboolr;r<r>rjoffsetwarningswarnDeprecationWarning)r row_countrrrrlimits zFilterableStatement.limitcCs$t|tr |dkr td||_|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)rrrri)rrrrrrszFilterableStatement.offsetcGsNd|_t|}|dkr||d|S|dkr#|d|j|d<|Std)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)rqrrrer)rargscountrrrr~ szFilterableStatement.bindcCrXrYrZrCrrrr\!r]zFilterableStatement.executeTNr )rrrrrrrrxrrrrrrrrrrrrrrrrrr~r\ __classcell__rrr{rras4      racsLeZdZdZfddZeddZddZdd 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. cs<tt|jddd||_||_d|_g|_d|_d|_dSNFrb) rcrrr9_sqlrdrerqrr)r connectionsqlr{rrr1s zSqlStatement.__init__cCrB)zstring: The SQL text statement.)rrCrrrr:rDzSqlStatement.sqlcCrBrrrCrrrr?rUzSqlStatement.get_binding_mapcCrBrrrCrrrrGrUzSqlStatement.get_bindingscGsJt|dkr tdd|_t|}t|ttfr||_|S|j||S)zBinds value(s) to a specific placeholder(s). Args: *args: The value(s) to bind. Returns: mysqlx.SqlStatement: SqlStatement object. rrT) rrrqrrrrreappend)rrZbindingsrrrr~Os  zSqlStatement.bindcC |j|S)zaExecute the statement. Returns: mysqlx.SqlResult: SqlResult object. )r9Zsend_sqlrCrrrr\b zSqlStatement.execute) rrrrrr_rrrr~r\rrrr{rr*s  rc0eZdZdZfddZddZddZZS)WriteStatementz/Provide common write operation attributes. cstt|||g|_dSr )rcrr_valuesr?r{rrrns zWriteStatement.__init__cCrB)z^Returns the list of values. Returns: `list`: The list of values. )rrCrrr get_valuesrrUzWriteStatement.get_valuescCrXrYrZrCrrrr\zr]zWriteStatement.execute)rrrrrrr\rrrr{rrks  rcsBeZdZdZfddZddZd ddZd d Zd d ZZ S) AddStatementzA statement for document addition on a collection. Args: collection (mysqlx.Collection): The Collection object. cs"tt||dd|_g|_dS)NTF)rcrr_upsertids)r collectionr{rrrs zAddStatement.__init__cCrB)zhReturns `True` if it's an upsert. Returns: bool: `True` if it's an upsert. rrCrrr is_upsertrUzAddStatement.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. rrHrrrupsertszAddStatement.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|jdkr tS|j|S)[Execute the statement. Returns: mysqlx.Result: Result object. r)rrr r9 send_insertrCrrrr\s zAddStatement.executer^) rrrrrrrrr\rrrr{rrs   rc@s"eZdZdZdddZddZdS) UpdateSpeczUpdate specification class implementation. Args: update_type (int): The update type. source (str): The source. value (Optional[str]): The value. NcCsl|tdkr|||dS||_||_t|dkr'|ddkr'|dd|_t|jdj|_||_dS)N*Mysqlx.Crud.UpdateOperation.UpdateType.SETr$rF) r _table_set update_typesourcerrZdocument_fieldr#rI)rrrrIrrrrs zUpdateSpec.__init__cCs$td|_t|d|_||_dS)zlTable set. Args: source (str): The source. value (str): The value. rTN)r rrZparse_table_update_fieldrrI)rrrIrrrrs  zUpdateSpec._table_setr )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. cstt|j||di|_dSN)r@rz)rcrr _update_opsrrrzr{rrrs  zModifyStatement.__init__cGr)zSets the sorting criteria. Args: *clauses: The expression strings defining the sort criteria. Returns: mysqlx.ModifyStatement: ModifyStatement object. rrrrrr zModifyStatement.sortcCrBztReturns the list of update operations. Returns: `list`: The list of update operations. rrCrrrget_update_opsrUzModifyStatement.get_update_opscC 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_pathrIrrrsets  zModifyStatement.setrcCr)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_REPLACETrrrrrchanges 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_pathsitemrrrunset&s  zModifyStatement.unsetcCr)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_INSERTTrrfieldrIrrr array_insert6s  zModifyStatement.array_insertcCr)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_appendHs  zModifyStatement.array_appendcCsX|durd}t|ttttfstdttddt|tr!|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_PATCHpatchT) rrr}rrrrr rrr<)rdocrrrr[s  zModifyStatement.patchcC|jstd|j|S)Execute the statement. Returns: mysqlx.Result: Result object. Raises: ProgrammingError: If condition was not set. z!No condition was found for modifyrwrr9Z send_updaterCrrrr\s  zModifyStatement.execute)rrrrrrrrrrrrrrr\rrrr{rrs   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,tt||||d|_d|_tj|_dSNF)rcrr_lock_exclusive _lock_sharedrDEFAULT_lock_contentionryr{rrrs zReadStatement.__init__cCrB)z::class:`mysqlx.LockContention`: The lock contention value.)rrCrrrlock_contentionrDzReadStatement.lock_contentioncCs0zt|}Wn tytdw||_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)rindexrrr)rr_rrr_set_lock_contentions    z"ReadStatement._set_lock_contentioncCrB)zrReturns `True` if is `EXCLUSIVE LOCK`. Returns: bool: `True` if is `EXCLUSIVE LOCK`. )rrCrrris_lock_exclusiverUzReadStatement.is_lock_exclusivecCrB)zlReturns `True` if is `SHARED LOCK`. Returns: bool: `True` if is `SHARED LOCK`. )rrCrrris_lock_sharedrUzReadStatement.is_lock_sharedcCd|_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_shared zReadStatement.lock_sharedcCr)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_exclusiverzReadStatement.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.havingcCrr)r9Z send_findrCrrrr\rzReadStatement.executer)rrrrrr_rrrrrrrrrrr\rrrr{rrs     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. Ncstt||d|dS)NT)rcrrrr{rrrzFindStatement.__init__cGr)zSets a document field filter. Args: *fields: The string expressions identifying the fields to be extracted. Returns: mysqlx.FindStatement: FindStatement object. )rrrrrrs zFindStatement.fieldscGrzSets the sorting criteria. Args: *clauses: The expression strings defining the sort criteria. Returns: mysqlx.FindStatement: FindStatement object. rrrrrr rzFindStatement.sortr )rrrrrrrrrrr{rrs   rc8eZdZdZfddZddZddZdd ZZS) SelectStatementzA statement for record retrieval operations on a Table. Args: table (mysqlx.Table): The Table object. *fields: The fields to be retrieved. cs tt||d|j|dSr)rcrrrrtablerr{rrrzSelectStatement.__init__cCr)zSets the search condition to filter. Args: condition (str): Sets the search condition to filter records. Returns: mysqlx.SelectStatement: SelectStatement object. rrrrrr#rzSelectStatement.wherecGr)zSets the order by criteria. Args: *clauses: The expression strings defining the order by criteria. Returns: mysqlx.SelectStatement: SelectStatement object. rrrrrorder_by.rzSelectStatement.order_byc Cs|jr d|jnd}|jrd|jnd}|jrd|jnd}|jr*d|jnd}|j r7d|j |j nd}dj|j p?d|j j|jj|||||d }|S) zYReturns the generated SQL. Returns: str: The generated SQL. z WHERE {0}rz 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}*)selectrErrrgrouprorder)rwr&rorsrgrtrfrvrmrrrjrirkrEnamer@)rrrrrrstmtrrrget_sql9s.  zSelectStatement.get_sql) rrrrrrrrrrrr{rrs    rcr)InsertStatementzA statement for insert operations on Table. Args: table (mysqlx.Table): The Table object. *fields: The fields to be inserted. cs tt||dt||_dSr)rcrrr_fieldsrr{rrrXrzInsertStatement.__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)rrrrrr\s zInsertStatement.valuescCrr)r9rrCrrrr\hrzInsertStatement.execute)rrrrrrr\rrrr{rrQs   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. cstt|j|ddi|_dSr)rcrrrrrr{rrrzs zUpdateStatement.__init__cCr)zSets the search condition to filter. Args: condition (str): Sets the search condition to filter records. Returns: mysqlx.UpdateStatement: UpdateStatement object. rrrrrr~rzUpdateStatement.wherecGr)zSets the order by criteria. Args: *clauses: The expression strings defining the order by criteria. Returns: mysqlx.UpdateStatement: UpdateStatement object. rrrrrrrzUpdateStatement.order_bycCrBrrrCrrrrrUzUpdateStatement.get_update_opscCr)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.setcCr)zExecute the statement. Returns: mysqlx.Result: Result object Raises: ProgrammingError: If condition was not set. z!No condition was found for updaterrCrrrr\rzUpdateStatement.execute) rrrrrrrrrr\rrrr{rrqs   rcr)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. cstt|j||ddSr)rcrrrr{rrrs  zRemoveStatement.__init__cGrrrrrrrrrzRemoveStatement.sortcCr)rz!No condition was found for removerwrr9Z send_deleterCrrrr\rzRemoveStatement.execute)rrrrrrr\rrrr{rrs   rcr) DeleteStatementzA statement that drops a table. Args: table (mysqlx.Table): The Table object. .. versionchanged:: 8.0.12 The ``condition`` parameter was removed. cstt|j|dddSr)rcrrrr{rrrrzDeleteStatement.__init__cCr)zSets the search condition to filter. Args: condition (str): Sets the search condition to filter records. Returns: mysqlx.DeleteStatement: DeleteStatement object. rrrrrrrzDeleteStatement.wherecGr)zSets the order by criteria. Args: *clauses: The expression strings defining the order by criteria. Returns: mysqlx.DeleteStatement: DeleteStatement object. rrrrrrrzDeleteStatement.order_bycCr)rz!No condition was found for deleterrCrrrr\rzDeleteStatement.execute) rrrrrrrr\rrrr{rrs    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} cs8tt|j|dt||_||_|jdg|_dS)N)r@r) rcrrcopydeepcopy _index_desc _index_namepop _fields_desc)rrZ index_nameZ index_descr{rrr's z'CreateCollectionIndexStatement.__init__c Cs,|jdur tt|jz0t|j}t|tr-|dt dkr,tt|jn|j t dkrsH          iFA:"#r%9 H(0