o hK@sdZddlZddlZddlZddlmZmZddlmZddl m Z m Z ddl m Z ddlmZdd lmZdd lmZmZdd lmZd ZGd ddeZddZd8ddZd8ddZd8ddZd8ddZGdddeZGdddeZ GdddeZ!Gd d!d!eZ"Gd"d#d#e"Z#Gd$d%d%eZ$Gd&d'd'e Z%Gd(d)d)e Z&Gd*d+d+e&Z'Gd,d-d-e&Z(Gd.d/d/e"Z)Gd0d1d1e Z*Gd2d3d3e Z+Gd4d5d5e Z,Gd6d7d7eZ-dS)9zImplementation of Statements.N)ProgrammingErrorNotSupportedError) ExprParser) INT_TYPES STRING_TYPES)LockContention)DbDoc) deprecated) SqlResultResult) mysqlxpb_enumz&The given index name "{}" is not validc@seZdZdZddZdS)ExprzExpression wrapper.cCs ||_dSN)expr)selfrrB/var/www/html/env/lib/python3.10/site-packages/mysqlx/statement.py__init__1s z Expr.__init__N)__name__ __module__ __qualname____doc__rrrrrr/s rcGs*t|dkrt|dttfr|dS|S)zParse flexible parameters.rr)len isinstancelisttuple)valuesrrrflexible_params5srcCsPd|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``r z"{0}"r#z""z`{0}`r!)rformatreplacer$rrrquote_identifierLs 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 hsz.quote_multipart_identifier..)join) identifiersr&rr-rquote_multipart_identifier^s r1cCs^d|vrdnd}||vrd|nd}||d}t|dur!|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. r r#r!z.{0}r+rrr")r(splitrstrip)default_schema table_namer&quote delimitertemprrrparse_table_namels    r9c@sBeZdZdZdddZeddZeddZd d Zd d Z d 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||_dSd|_dSr)_target _doc_basedget_connection _connectionrtarget doc_basedrrrrszStatement.__init__cC|jS)z#object: The database object target.)r;rrrrr@zStatement.targetcCs|jjS)z*:class:`mysqlx.Schema`: The Schema object.)r;schemarCrrrrEszStatement.schemacCrB)zkCheck if it is document based. Returns: bool: `True` if it is document based. )r<rCrrr is_doc_basedzStatement.is_doc_basedcCtzqExecute the statement. Raises: NotImplementedError: This method must be implemented. NotImplementedErrorrCrrrexecutezStatement.executeNT) rrrrrpropertyr@rErFrLrrrrr:~s    r:cseZdZdZd1fdd 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|_g|_d|_d|_d|_d|_d|_ d|_ d|_ d|_ d|_ d|_d|_d|_d|_d|_d|_d|_d|_d|_|rO||dSdS)Nr@rArrF)superrPr _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>zt|}t|ts tWn ty,t dw| D] }||||q1dSt 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) rr bindstrrjsonloadsdict ValueErrorrkeys)robjreskeyrrr _bind_singles      z FilterableStatement._bind_singlecGs0d|_dt||_t|j|j |_|S)zSets the sorting criteria. Args: *clauses: The expression strings defining the sort criteria. Returns: mysqlx.FilterableStatement: FilterableStatement object. T,)rer/rr\rr<parse_order_specr]rclausesrrr_sorts zFilterableStatement._sortcCsLd|_||_zt||j }||_Wn tytdw|j|_ |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) rfr^rr<rr_rqrplaceholder_name_to_positionrS)rrirrrrrgs  zFilterableStatement._set_wherecGs4t|}d|_d||_t|j|j |_dS)zJSet group by. Args: *fields: List of fields. TrwN)rrbr/rVrr<parse_expr_listrWrfieldsrrr _set_group_bys z!FilterableStatement._set_group_bycCsd|_t||j |_dS)zOSet having. Args: condition (str): The condition. TN)rcrr<rrUrrirrr _set_havingszFilterableStatement._set_havingcGs4t|}d|_d||_t|j|j |_|S)zSet the projection. Args: *fields: List of fields. Returns: :class:`mysqlx.FilterableStatement`: Returns self. Trw)rrdr/rZrr<parse_table_select_projectionr[r~rrr_set_projections  z#FilterableStatement._set_projectioncCrB)zlReturns the binding map dictionary. Returns: dict: The binding map dictionary. )rSrCrrrget_binding_map,rGz#FilterableStatement.get_binding_mapcCrB)z\Returns the bindings list. Returns: `list`: The bindings list. )rTrCrrr get_bindings4rGz FilterableStatement.get_bindingscCrB)zrReturns the grouping expression list. Returns: `list`: The grouping expression list. )rWrCrrr get_grouping<rGz FilterableStatement.get_groupingcCrB)zdReturns the having expression. Returns: object: The having expression. )rUrCrrr get_havingDrGzFilterableStatement.get_havingcCrB)z]Returns the limit row count. Returns: int: The limit row count. )rYrCrrrget_limit_row_countLrGz'FilterableStatement.get_limit_row_countcCrB)zWReturns the limit offset. Returns: int: The limit offset. )rXrCrrrget_limit_offsetTrGz$FilterableStatement.get_limit_offsetcCrB)zbReturns the where expression. Returns: object: The where expression. )r_rCrrrget_where_expr\rGz"FilterableStatement.get_where_exprcCrB)zlReturns the projection expression. Returns: object: The projection expression. )r[rCrrrget_projection_exprdrGz'FilterableStatement.get_projection_exprcCrB)z`Returns the sort expression. Returns: object: The sort expression. )r]rCrrr get_sort_exprlrGz!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 rgrrrrwherets 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 r{ryrrrsorts zFilterableStatement.sortcCsFt|tr |dkr tdd|_||_|r!||tjdtd|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) rrrqrarYoffsetwarningswarnDeprecationWarning)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)rrrqrX)rrrrrrszFilterableStatement.offsetcGsVd|_t|}|dkr||d|S|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)r`rrvrrTappend)rargscountrrrrlszFilterableStatement.bindcCrHrIrJrCrrrrLrMzFilterableStatement.executeTNr)rrrrrrvr{rgrrrrrrrrrrrrr rrrrrlrL __classcell__rrrjrrPs4      rPc(eZdZdZfddZddZZS) SqlStatementzA statement for SQL execution. Args: connection (mysqlx.connection.Connection): Connection object. sql (string): The sql statement to be executed. cs$tt|jddd||_||_dSNFrQ)rRrrr>_sql)r connectionsqlrjrrrs zSqlStatement.__init__cCs|j|jt|jS)zaExecute the statement. Returns: mysqlx.SqlResult: SqlResult object. )r>send_sqlrr rCrrrrLs zSqlStatement.executerrrrrrLrrrrjrrs rc0eZdZdZfddZddZddZZS)WriteStatementz/Provide common write operation attributes. cstt|||g|_dSr)rRrr_valuesr?rjrrrs zWriteStatement.__init__cCrB)z^Returns the list of values. Returns: `list`: The list of values. )rrCrrr get_valuesrGzWriteStatement.get_valuescCrHrIrJrCrrrrLrMzWriteStatement.execute)rrrrrrrLrrrrjrrs  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)rRrr_upsertids)r collectionrjrrrs zAddStatement.__init__cCrB)zhReturns `True` if it's an upsert. Returns: bool: `True` if it's an upsert. rrCrrr is_upsertrGzAddStatement.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)rrrrrupsert szAddStatement.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. )rrr rr)rrvalrrradd+s zAddStatement.addcCs t|jdkr tS|j|S)[Execute the statement. Returns: mysqlx.Result: Result object. r)rrr r> send_insertrCrrrrL;s zAddStatement.executerN) rrrrrrrrrLrrrrjrr s   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_typesourcerrdocument_fieldr%r)rrrrrrrrOs zUpdateSpec.__init__cCs$td|_t|d|_||_dS)zlTable set. Args: source (str): The source. value (str): The value. rTN)r rrparse_table_update_fieldrr)rrrrrrr\s  zUpdateSpec._table_setr)rrrrrrrrrrrGs  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||dg|_dSN)r@ri)rRrr _update_opsrrrirjrrrts  zModifyStatement.__init__cGr)zSets the sorting criteria. Args: *clauses: The expression strings defining the sort criteria. Returns: mysqlx.ModifyStatement: ModifyStatement object. rryrrrry zModifyStatement.sortcCrBztReturns the list of update operations. Returns: `list`: The list of update operations. rrCrrrget_update_opsrGzModifyStatement.get_update_opscC|jttd|||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_SETrrrr rdoc_pathrrrrsets 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_REPLACErrrrrchanges zModifyStatement.changecGs|jddt|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. cSsg|] }ttd|qS)z2Mysqlx.Crud.UpdateOperation.UpdateType.ITEM_REMOVE)rr )r,itemrrrr.sz)ModifyStatement.unset..)rextendr)r doc_pathsrrrunsets 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_INSERTrrfieldrrrr array_inserts 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_APPENDrrrrr array_appends zModifyStatement.array_appendcCsT|durd}t|ttttfstd|jtt ddt|tr$| n||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) rrrpr rmrrrrr r)rdocrrrpatchs 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 modifyrfrr>updaterCrrrrL  zModifyStatement.execute)rrrrrrrrr rrrrrrLrrrrjrris   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)rRrr_lock_exclusive _lock_sharedrDEFAULT_lock_contentionrhrjrrrs 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)rindexrqrr)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_exclusive0rGzReadStatement.is_lock_exclusivecCrB)zlReturns `True` if is `SHARED LOCK`. Returns: bool: `True` if is `SHARED LOCK`. )rrCrrris_lock_shared8rGzReadStatement.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_exclusiveLrzReadStatement.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. )rr~rrrgroup_byXs 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. )rrrrrhavingds zReadStatement.havingcC |j|Sr)r>findrCrrrrLr zReadStatement.executer)rrrrrrOrrrrrrrrrrrLrrrrjrr s     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)rRrrrrjrrrzFindStatement.__init__cGr)zSets a document field filter. Args: *fields: The string expressions identifying the fields to be extracted. Returns: mysqlx.FindStatement: FindStatement object. )rr~rrrrs zFindStatement.fieldscGrzSets the sorting criteria. Args: *clauses: The expression strings defining the sort criteria. Returns: mysqlx.FindStatement: FindStatement object. rryrrrrrzFindStatement.sortr)rrrrrrrrrrrjrr{s   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)rRrrrrtablerrjrrrzSelectStatement.__init__cCr)zSets the search condition to filter. Args: condition (str): Sets the search condition to filter records. Returns: mysqlx.SelectStatement: SelectStatement object. rrrrrrrzSelectStatement.wherecGr)zSets the order by criteria. Args: *clauses: The expression strings defining the order by criteria. Returns: mysqlx.SelectStatement: SelectStatement object. rryrrrorder_byrzSelectStatement.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)rfr(r^rbrVrcrUrer\rarYrXrZrErr@)rrrrrrstmtrrrget_sqls.  zSelectStatement.get_sql) rrrrrrrrrrrrjrrs    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)rRrrr_fieldsrrjrrrrzInsertStatement.__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)rrrrrrs zInsertStatement.valuescCrr)r>rrCrrrrLrzInsertStatement.execute)rrrrrrrLrrrrjrrs   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|ddg|_dSr)rRr rrrrrjrrrs zUpdateStatement.__init__cCr)zSets the search condition to filter. Args: condition (str): Sets the search condition to filter records. Returns: mysqlx.UpdateStatement: UpdateStatement object. rrrrrrrzUpdateStatement.wherecGr)zSets the order by criteria. Args: *clauses: The expression strings defining the order by criteria. Returns: mysqlx.UpdateStatement: UpdateStatement object. rryrrrrrzUpdateStatement.order_bycCrBrrrCrrrrrGzUpdateStatement.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. rrrrrrr%s zUpdateStatement.setcCr)zExecute the statement. Returns: mysqlx.Result: Result object Raises: ProgrammingError: If condition was not set. z!No condition was found for updaterrCrrrrL4rzUpdateStatement.execute) rrrrrrrrrrLrrrrjrr s   r cr)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)rRr rrrjrrrMs  zRemoveStatement.__init__cGrrrryrrrrQrzRemoveStatement.sortcCr)rz!No condition was found for removerfrr>deleterCrrrrL\rzRemoveStatement.execute)rrrrrrrLrrrrjrr Bs   r cr) 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)rRrrr rjrrrsrzDeleteStatement.__init__cCr)zSets the search condition to filter. Args: condition (str): Sets the search condition to filter records. Returns: mysqlx.DeleteStatement: DeleteStatement object. rrrrrrvrzDeleteStatement.wherecGr)zSets the order by criteria. Args: *clauses: The expression strings defining the order by criteria. Returns: mysqlx.DeleteStatement: DeleteStatement object. rryrrrrrzDeleteStatement.order_bycCr)rz!No condition was found for deleter rCrrrrLrzDeleteStatement.execute) rrrrrrrrLrrrrjrrjs    rcr)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) rRrrcopydeepcopy _index_desc _index_namepop _fields_desc)rr index_name index_descrjrrrs z'CreateCollectionIndexStatement.__init__c Cs|jdur tt|jz0t|j}t|tr-|dt dkr,tt|jn|j t dkrexecute_nonquery)r parsed_identr field_descrerrrrrrLs               ' z&CreateCollectionIndexStatement.executerrrrjrrs r)r).rrrnrerrorsrrrrcompatrr constantsrdbdocr helpersr resultr r protobufr r&objectrrr'r*r1r9r:rPrrrrrrrrrr r rrrrrrsJ         (;:"!r%: H(0