3 S^Ͷ@sdZddlZddlZddlZddlmZmZddlmZddl m Z m Z ddl m Z ddlmZdd lmZdd lmZdd lmZd ZGd ddeZddZd8ddZd9ddZd:ddZd;ddZGdddeZGdddeZGdddeZ Gd d!d!eZ!Gd"d#d#e!Z"Gd$d%d%eZ#Gd&d'd'eZ$Gd(d)d)eZ%Gd*d+d+e%Z&Gd,d-d-e%Z'Gd.d/d/e!Z(Gd0d1d1eZ)Gd2d3d3eZ*Gd4d5d5eZ+Gd6d7d7eZ,dS)hsz.quote_multipart_identifier..)join)Z identifiersr#r)r#rquote_multipart_identifier^s r,cCs^d|kr dnd}||kr"dj|nd}|j|d}t|dkrB|n |dj||dj|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_namels  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|jnd|_d|_d|_d|_d|_d|_dS)NrTF) _target _doc_basedget_connection _connection_stmt_id _exec_counter_changed _prepared_deallocate_prepare_execute)rtarget doc_basedrrrrszStatement.__init__cCs|jS)z#object: The database object target.)r4)rrrrr=szStatement.targetcCs|jjS)z*:class:`mysqlx.Schema`: The Schema object.)r4schema)rrrrr?szStatement.schemacCs|jS)zXReturns this statement ID. Returns: int: The statement ID. )r8)rrrrstmt_idszStatement.stmt_idcCs ||_dS)N)r8)rvaluerrrr@scCs|jS)z5int: The number of times this statement was executed.)r9)rrrr exec_counterszStatement.exec_countercCs|jS)z+bool: `True` if this statement has changes.)r:)rrrrchangedszStatement.changedcCs ||_dS)N)r:)rrArrrrCscCs|jS)z1bool: `True` if this statement has been prepared.)r;)rrrrpreparedszStatement.preparedcCs ||_dS)N)r;)rrArrrrDscCs |jdkS)zDbool: `True` if this statement was executed more than once. r)r9)rrrrrepeatedszStatement.repeatedcCs|jS)zBbool: `True` to deallocate + prepare + execute statement. )r<)rrrrdeallocate_prepare_executesz$Statement.deallocate_prepare_executecCs ||_dS)N)r<)rrArrrrFscCs|jS)zkCheck if it is document based. Returns: bool: `True` if it is document based. )r5)rrrr is_doc_basedszStatement.is_doc_basedcCs|jd7_dS)z@Increments the number of times this statement has been executed.rN)r9)rrrrincrement_exec_countersz Statement.increment_exec_countercCs d|_dS)zrrF)superrNr _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_where)rr=r> condition) __class__rrrs0 zFilterableStatement.__init__c Cst|tr|jt|jnt|tr8|j|jnpt|trytj|}t|ts\tWntk rzt dYnXx*|j D]}|j|||qWnt 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 bindz%Invalid JSON string or object to bindN) rdictbindr Zas_strrjsonloads ValueErrorrkeys)robjreskeyrrr _bind_single s     z FilterableStatement._bind_singlecGs6d|_djt||_t|j|j j|_d|_|S)zSets the sorting criteria. Args: *clauses: The expression strings defining the sort criteria. Returns: mysqlx.FilterableStatement: FilterableStatement object. T,) rbr+rrYrr5Zparse_order_specrZr:)rclausesrrr_sort&s zFilterableStatement._sortc CsXd|_||_yt||j }|j|_Wntk rDtdYnX|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) rcr[rr5rr\rkrZplaceholder_name_to_positionrPr:)rrerrrrrd6s zFilterableStatement._set_wherecGs:t|}d|_dj||_t|j|j j|_d|_dS)zJSet group by. Args: *fields: List of fields. TrqN) rr_r+rSrr5Zparse_expr_listrTr:)rfieldsrrr _set_group_byKs  z!FilterableStatement._set_group_bycCs$d|_t||j j|_d|_dS)zOSet having. Args: condition (str): The condition. TN)r`rr5rrRr:)rrerrr _set_havingXszFilterableStatement._set_havingcGs:t|}d|_dj||_t|j|j j|_d|_|S)zSet the projection. Args: *fields: List of fields. Returns: :class:`mysqlx.FilterableStatement`: Returns self. Trq) rrar+rWrr5Zparse_table_select_projectionrXr:)rrtrrr_set_projectionbs  z#FilterableStatement._set_projectioncCs|jS)zlReturns the binding map dictionary. Returns: dict: The binding map dictionary. )rP)rrrrget_binding_maptsz#FilterableStatement.get_binding_mapcCs|jS)z\Returns the bindings list. Returns: `list`: The bindings list. )rQ)rrrr get_bindings|sz FilterableStatement.get_bindingscCs|jS)zrReturns the grouping expression list. Returns: `list`: The grouping expression list. )rT)rrrr get_groupingsz FilterableStatement.get_groupingcCs|jS)zdReturns the having expression. Returns: object: The having expression. )rR)rrrr get_havingszFilterableStatement.get_havingcCs|jS)z]Returns the limit row count. Returns: int: The limit row count. )rV)rrrrget_limit_row_countsz'FilterableStatement.get_limit_row_countcCs|jS)zWReturns the limit offset. Returns: int: The limit offset. )rU)rrrrget_limit_offsetsz$FilterableStatement.get_limit_offsetcCs|jS)zbReturns the where expression. Returns: object: The where expression. )r\)rrrrget_where_exprsz"FilterableStatement.get_where_exprcCs|jS)zlReturns the projection expression. Returns: object: The projection expression. )rX)rrrrget_projection_exprsz'FilterableStatement.get_projection_exprcCs|jS)z`Returns the sort expression. Returns: object: The sort expression. )rZ)rrrr get_sort_exprsz!FilterableStatement.get_sort_exprz8.0.12cCs |j|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 )rd)rrerrrwheres 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 )rs)rrrrrrsorts zFilterableStatement.sortcCspt|t s|dkrtd|jsDt|jdk|_t|jdk |_||_d|_|rl|j |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) rrrkr^boolr9r:r<rVoffsetwarningswarnDeprecationWarning)rZ row_countrrrrlimits zFilterableStatement.limitcCs&t|t s|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)rrrkrU)rrrrrrszFilterableStatement.offsetcGsNd|_t|}|dkr&|j|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. Trrz#Invalid number of arguments to bind)r]rrprQr)rargscountrrrrh szFilterableStatement.bindcCstdS)zqExecute the statement. Raises: NotImplementedError: This method must be implemented. N)rJ)rrrrrK"szFilterableStatement.execute)TN)N)rrrrrrprsrdrurvrwrxryrzr{r|r}r~rrr rrrrrhrK __classcell__rr)rfrrNs.    rNcsLeZdZdZfddZeddZddZdd 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|_dS)NF)r=r>) rOrrr7_sqlrPrQr]r^)r connectionsql)rfrrr2szSqlStatement.__init__cCs|jS)zstring: The SQL text statement.)r)rrrrr;szSqlStatement.sqlcCs|jS)zlReturns the binding map dictionary. Returns: dict: The binding map dictionary. )rP)rrrrrx@szSqlStatement.get_binding_mapcCs|jS)z\Returns the bindings list. Returns: `list`: The bindings list. )rQ)rrrrryHszSqlStatement.get_bindingscGsHt|dkrtdd|_t|}t|ttfr8||_n |jj||S)zBinds value(s) to a specific placeholder(s). Args: *args: The value(s) to bind. Returns: mysqlx.SqlStatement: SqlStatement object. rz#Invalid number of arguments to bindT) rrr]rrrrrQappend)rrZbindingsrrrrhPs  zSqlStatement.bindcCs |jj|S)zaExecute the statement. Returns: mysqlx.SqlResult: SqlResult object. )r7Zsend_sql)rrrrrKcszSqlStatement.execute) rrrrrrLrrxryrhrKrrr)rfrr+s rcs0eZdZdZfddZddZddZZS)WriteStatementz/Provide common write operation attributes. cstt|j||g|_dS)N)rOrr_values)rr=r>)rfrrroszWriteStatement.__init__cCs|jS)z^Returns the list of values. Returns: `list`: The list of values. )r)rrrr get_valuessszWriteStatement.get_valuescCstdS)zqExecute the statement. Raises: NotImplementedError: This method must be implemented. N)rJ)rrrrrK{szWriteStatement.execute)rrrrrrrKrrr)rfrrls rcsBeZdZdZfddZddZd ddZd d Zd d ZZ S) AddStatementzA statement for document addition on a collection. Args: collection (mysqlx.Collection): The Collection object. cs"tt|j|dd|_g|_dS)NTF)rOrr_upsertids)r collection)rfrrrszAddStatement.__init__cCs|jS)zhReturns `True` if it's an upsert. Returns: bool: `True` if it's an upsert. )r)rrrr 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. )r)rrArrrupsertszAddStatement.upsertcGs>x8t|D],}t|tr&|jj|q |jjt|q W|S)zAdds a list of documents into a collection. Args: *values: The documents to be added into the collection. Returns: mysqlx.AddStatement: AddStatement object. )rrr rr)rrvalrrradds  zAddStatement.addcCs t|jdkrtS|jj|S)z[Execute the statement. Returns: mysqlx.Result: Result object. r)rrr r7 send_insert)rrrrrKszAddStatement.execute)T) rrrrrrrrrKrrr)rfrrs   rc@s"eZdZdZdddZddZdS) UpdateSpeczUpdate specification class implementation. Args: update_type (int): The update type. source (str): The source. value (Optional[str]): The value. NcCsj|tdkr|j||nL||_||_t|dkrL|ddkrL|dd|_t|jdjj|_||_dS)Nz*Mysqlx.Crud.UpdateOperation.UpdateType.SETr$rF) r _table_set update_typesourcerrZdocument_fieldr"rA)rrrrArrrrszUpdateSpec.__init__cCs$td|_t|dj|_||_dS)zlTable set. Args: source (str): The source. value (str): The value. z*Mysqlx.Crud.UpdateOperation.UpdateType.SETTN)r rrZparse_table_update_fieldrrA)rrrArrrrszUpdateSpec._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. cstt|j||di|_dS)N)r=re)rOrr _update_ops)rrre)rfrrrs zModifyStatement.__init__cGs |j|S)zSets the sorting criteria. Args: *clauses: The expression strings defining the sort criteria. Returns: mysqlx.ModifyStatement: ModifyStatement object. )rs)rrrrrrrs zModifyStatement.sortcCs|jS)ztReturns the list of update operations. Returns: `list`: The list of update operations. )r)rrrrget_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_SETT)rr rr:)rdoc_pathrArrrsets zModifyStatement.setz8.0.12cCs 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_REPLACET)rr rr:)rrrArrrchanges zModifyStatement.changecGs0x$t|D]}ttd||j|<q Wd|_|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.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_INSERTT)rr rr:)rfieldrArrr array_insert7s 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_APPENDT)rr rr:)rrrArrr array_appendIs zModifyStatement.array_appendcCsX|dkr d}t|ttttfs&tdttddt|trB|jn||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) rrrgr strrrr rrr:)rdocrrrr\s  zModifyStatement.patchcCs|jstd|jj|S)zExecute the statement. Returns: mysqlx.Result: Result object. Raises: ProgrammingError: If condition was not set. z!No condition was found for modify)rcrr7 send_update)rrrrrKts zModifyStatement.execute)rrrrrrrrr rrrrrrKrrr)rfrrs   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|j|||d|_d|_tj|_dS)NF)rOrr_lock_exclusive _lock_sharedrDEFAULT_lock_contention)rr=r>re)rfrrrszReadStatement.__init__cCs|jS)z::class:`mysqlx.LockContention`: The lock contention value.)r)rrrrlock_contentionszReadStatement.lock_contentionc Cs6ytj|}Wntk r*tdYnX||_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)rindexrkrr)rr_rrr_set_lock_contentions z"ReadStatement._set_lock_contentioncCs|jS)zrReturns `True` if is `EXCLUSIVE LOCK`. Returns: bool: `True` if is `EXCLUSIVE LOCK`. )r)rrrris_lock_exclusiveszReadStatement.is_lock_exclusivecCs|jS)zlReturns `True` if is `SHARED LOCK`. Returns: bool: `True` if is `SHARED LOCK`. )r)rrrris_lock_sharedszReadStatement.is_lock_sharedcCsd|_d|_|j||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. FT)rrr)rrrrr lock_shareds zReadStatement.lock_sharedcCsd|_d|_|j||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. TF)rrr)rrrrrlock_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. )ru)rrtrrrgroup_bys zReadStatement.group_bycCs|j||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. )rv)rrerrrhavings zReadStatement.havingcCs |jj|S)z[Execute the statement. Returns: mysqlx.Result: Result object. )r7Z send_find)rrrrrKszReadStatement.execute)TN)rrrrrrLrrrrrrrrrrrKrrr)rfrrs     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|j|d|dS)NT)rOrr)rrre)rfrrrszFindStatement.__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. )rw)rrtrrrrts zFindStatement.fieldscGs |j|S)zSets the sorting criteria. Args: *clauses: The expression strings defining the sort criteria. Returns: mysqlx.FindStatement: FindStatement object. )rs)rrrrrrr s zFindStatement.sort)N)rrrrrrtrrrr)rfrrs  rcs8eZdZdZfddZddZddZdd 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|j|d|j|dS)NF)rOrrrw)rtablert)rfrrr szSelectStatement.__init__cCs |j|S)zSets the search condition to filter. Args: condition (str): Sets the search condition to filter records. Returns: mysqlx.SelectStatement: SelectStatement object. )rd)rrerrrr$s zSelectStatement.wherecGs |j|S)zSets the order by criteria. Args: *clauses: The expression strings defining the order by criteria. Returns: mysqlx.SelectStatement: SelectStatement object. )rs)rrrrrrorder_by/s zSelectStatement.order_byc Cs|jrdj|jnd}|jr(dj|jnd}|jr>dj|jnd}|jrTdj|jnd}|j rndj|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}*)selectr?rrrgrouprorder)rcr%r[r_rSr`rRrbrYr^rVrUrWr?namer=)rrrrrrstmtrrrget_sql:s zSelectStatement.get_sql) rrrrrrrrrrr)rfrrs    rcs0eZdZdZfddZddZddZZS)InsertStatementzA statement for insert operations on Table. Args: table (mysqlx.Table): The Table object. *fields: The fields to be inserted. cs tt|j|dt||_dS)NF)rOrrr_fields)rrrt)rfrrrYszInsertStatement.__init__cGs|jjtt||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.valuescCs |jj|S)z[Execute the statement. Returns: mysqlx.Result: Result object. )r7r)rrrrrKiszInsertStatement.execute)rrrrrrrKrrr)rfrrRs  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|_dS)NF)r=r>)rOrrr)rr)rfrrr{szUpdateStatement.__init__cCs |j|S)zSets the search condition to filter. Args: condition (str): Sets the search condition to filter records. Returns: mysqlx.UpdateStatement: UpdateStatement object. )rd)rrerrrrs zUpdateStatement.wherecGs |j|S)zSets the order by criteria. Args: *clauses: The expression strings defining the order by criteria. Returns: mysqlx.UpdateStatement: UpdateStatement object. )rs)rrrrrrrs zUpdateStatement.order_bycCs|jS)ztReturns the list of update operations. Returns: `list`: The list of update operations. )r)rrrrrszUpdateStatement.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. z*Mysqlx.Crud.UpdateOperation.UpdateType.SETT)rr rr:)rrrArrrrs zUpdateStatement.setcCs|jstd|jj|S)zExecute the statement. Returns: mysqlx.Result: Result object Raises: ProgrammingError: If condition was not set. z!No condition was found for update)rcrr7r)rrrrrKs zUpdateStatement.execute) rrrrrrrrrrKrrr)rfrrrs   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. cstt|j||ddS)N)r=re)rOrr)rrre)rfrrrs zRemoveStatement.__init__cGs |j|S)zSets the sorting criteria. Args: *clauses: The expression strings defining the sort criteria. Returns: mysqlx.FindStatement: FindStatement object. )rs)rrrrrrrs zRemoveStatement.sortcCs|jstd|jj|S)zExecute the statement. Returns: mysqlx.Result: Result object. Raises: ProgrammingError: If condition was not set. z!No condition was found for remove)rcrr7 send_delete)rrrrrKs zRemoveStatement.execute)rrrrrrrKrrr)rfrrs   rcs8eZdZdZfddZddZddZdd ZZS) DeleteStatementzA statement that drops a table. Args: table (mysqlx.Table): The Table object. .. versionchanged:: 8.0.12 The ``condition`` parameter was removed. cstt|j|dddS)NF)r=r>)rOrr)rr)rfrrrszDeleteStatement.__init__cCs |j|S)zSets the search condition to filter. Args: condition (str): Sets the search condition to filter records. Returns: mysqlx.DeleteStatement: DeleteStatement object. )rd)rrerrrrs zDeleteStatement.wherecGs |j|S)zSets the order by criteria. Args: *clauses: The expression strings defining the order by criteria. Returns: mysqlx.DeleteStatement: DeleteStatement object. )rs)rrrrrrrs zDeleteStatement.order_bycCs|jstd|jj|S)zExecute the statement. Returns: mysqlx.Result: Result object. Raises: ProgrammingError: If condition was not set. z!No condition was found for delete)rcrr7r)rrrrrKs zDeleteStatement.execute) rrrrrrrrKrrr)rfrrs    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|dtj||_||_|jjdg|_dS)N)r=rt) rOrrcopydeepcopy _index_desc _index_namepop _fields_desc)rrZ index_nameZ index_desc)rfrrr(s z'CreateCollectionIndexStatement.__init__cCsT|jdkrttj|jy`t|jjj}t|trZ|dt dkrxttj|jn|j t dkrxttj|jWn(t t fk rttj|jYnX|j stdj|jt|j tstdi}|j|d<|jj|d<|jjj|d<d|jkr|jjd|d<nd |d<|jjd d |d <|d r@td g|d <|jr`tdj|jyx||j D]p}i}|jd|d<|jd|d<|jdd |d<|jdd |d<t|dtstdt|dtstd|djdkr |d r td|djd kr2|ddkr2tdd|krh|djjdsZtdn|jd|d<d|kr|djdkrtdn|jd|d<d|kr|djdkrtdn|jd|d<|d j|qnWWn4tk r}ztd j||WYdd}~XnXx$|j D]}|r$td!j|q$W|jjd"d#d$|S)%z[Execute the statement. Returns: mysqlx.Result: Result object. NtypezMysqlx.Expr.Expr.Type.IDENTzERequired member 'fields' not found in the given index description: {}z-Required member 'fields' must contain a list.rrr?ZINDEXuniqueFz!Unique indexes are not supported. constraintzUnidentified fields: {}rmemberrequiredarrayz'Field member 'required' must be Booleanz$Field member 'array' must be BooleanZSPATIALzQField member 'required' must be set to 'True' when index type is set to 'SPATIAL'ZGEOJSONzIIndex 'type' must be set to 'SPATIAL' when field type is set to 'GEOJSON'Z collationZTEXTzLThe 'collation' member can only be used when field type is set to 'GEOJSON'optionszIThe 'options' member can only be used when index type is set to 'GEOJSON'ZsridzFThe 'srid' member can only be used when index type is set to 'GEOJSON'z4Required inner member {} not found in constraint: {}zUnidentified inner fields:{}ZmysqlxZcreate_collection_indexT)rrERR_INVALID_INDEX_NAMEr%rrZ get_messagerrgr rrkAttributeErrorrrrr4rr?rrr TypeErrorupper startswithrKeyErrorr7Zexecute_nonquery)rZ parsed_identrZ field_descrerrrrrrK.s              z&CreateCollectionIndexStatement.execute)rrrrrrKrrr)rfrrs r)r)r)r)r)-rrrirerrorsrrrrcompatrr constantsrZdbdocr helpersr resultr Zprotobufr robjectr rr$r'r,r2r3rNrrrrrrrrrrrrrrrrrsH          iFA:"#r%9 H(0