hcdZddlmZddlZddlZddlZddlmZmZm Z m Z m Z m Z m Z ddlmZddlmZddlmZmZdd lmZdd lmZdd lmZdd lmZmZmZmZdd l m!Z!m"Z"m#Z#m$Z$m%Z%m&Z&dZ'GddZ(dBdZ)dCdDdZ*dCdEdZ+dCdFdZ, dCdGd#Z-Gd$d%Z.Gd&d'e.Z/Gd(d)e.Z0Gd*d+e.Z1Gd,d-e1Z2Gd.d/Z3Gd0d1e/Z4Gd2d3e/Z5Gd4d5e5Z6Gd6d7e5Z7Gd8d9e1Z8Gd:d;e/Z9Gd<d=e/Z:Gd>d?e/Z;Gd@dAe.ZB3)> qMS :Z^s%:  a=C  9JrNc$99r'ct|dkrdSd|vr|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``r;r>z""r<)r0replace)r6r8quoteds r%quote_identifierrC[sk :!t  ##C..6}}}   T * *F v===r' identifiers Iterable[str]cFdfd|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. .c0g|]}t|Sr,)rC).0r6r8s r% z.quote_multipart_identifier..zs$NNNJ *h / /NNNr')join)rDr8s `r%quote_multipart_identifierrLos2 88NNNN+NNN  r'default_schema table_nameTuple[str, str]cd|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. r;r>r<rGr rr=)splitr0strip)rMrNr8quote delimitertemps r%parse_table_namerV~s!H,,CC#E$ 22 E I   Iq ) )Dd))q..d1gmmE.B.B Ru r'ceZdZdZdd d Zed!d Zed"d Zed#dZej d$dZed#dZ ed%dZ e j d&dZ ed%dZ e j d&dZ ed%dZ ed%dZej d&dZd%dZd'dZd'dZd(dZdS)) 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. Ttargetr doc_basedr9r r!c||_||_|r|nd|_d|_d|_d|_d|_d|_dS)NrTF) _target _doc_basedget_connection _connection_stmt_id _exec_counter_changed _prepared_deallocate_prepare_execute)r$rYrZs r%r&zStatement.__init__s^+1 )'- 7F ! ! # # #4 (, "#" $16(((r'c|jS)z#object: The database object target.)r\r$s r%rYzStatement.targets |r'rc|jjS)z*:class:`mysqlx.Schema`: The Schema object.)r\schemarfs r%rhzStatement.schemas|""r'intc|jS)zXReturns this statement ID. Returns: int: The statement ID. r`rfs r%stmt_idzStatement.stmt_ids }r'valuec||_dSr#rkr$rms r%rlzStatement.stmt_id  r'c|jS)z5int: The number of times this statement was executed.rarfs r% exec_counterzStatement.exec_counters !!r'c|jS)z+bool: `True` if this statement has changes.rbrfs r%changedzStatement.changeds }r'c||_dSr#ruros r%rvzStatement.changedrpr'c|jS)z1bool: `True` if this statement has been prepared.rcrfs r%preparedzStatement.prepareds ~r'c||_dSr#ryros r%rzzStatement.prepareds r'c|jdkS)z;bool: `True` if this statement was executed more than once.r rrrfs r%repeatedzStatement.repeateds!A%%r'c|jS)z9bool: `True` to deallocate + prepare + execute statement.rdrfs r%deallocate_prepare_executez$Statement.deallocate_prepare_executes //r'c||_dSr#rros r%rz$Statement.deallocate_prepare_executes+0(((r'c|jS)zkCheck if it is document based. Returns: bool: `True` if it is document based. )r]rfs r% is_doc_basedzStatement.is_doc_baseds r'c&|xjdz c_dS)z@Increments the number of times this statement has been executed.r Nrrrfs r%increment_exec_counterz Statement.increment_exec_counters ar'cd|_dS)zd!Zd>d"Zd=d#Zd>"#HII I "D) hu . . ,%DNN N ! !( + + + r'rc6|j|S)zaExecute the statement. Returns: mysqlx.SqlResult: SqlResult object. )r_send_sqlrfs r%rzSqlStatement.executes ((...r')rrrr7r r!r r7r )r r)rrr r)r r) r(r)r*r+r&rrrrrrr r s@r%rrXs%%%%%%X!!!!&////////r'rc4eZdZdZd fd Zdd Zdd ZxZS)WriteStatementz*Provide common write operation attributes.rYrrZr9r r!cZt||g|_dSr#)rr&_values)r$rYrZrs r%r&zWriteStatement.__init__s- +++  r'pList[Union[int, str, DbDoc, Dict[str, Any], List[Optional[Union[str, int, float, ExprParser, Dict[str, Any]]]]]]c|jS)z^Returns the list of values. Returns: `list`: The list of values. )r!rfs r% get_valueszWriteStatement.get_valuess |r'rctrrrfs r%rzWriteStatement.executerr'r)r r"r)r(r)r*r+r&r$rr r s@r%rrsk44      $""""""""r'rcFeZdZdZdfd ZddZddd ZddZddZxZ S) AddStatementzA statement for document addition on a collection. Args: collection (mysqlx.Collection): The Collection object. collectionrr r!cht|dd|_g|_dS)NTF)rr&_upsertids)r$r(rs r%r&zAddStatement.__init__s/ T***" r'r9c|jS)zhReturns `True` if it's an upsert. Returns: bool: `True` if it's an upsert. r*rfs r% is_upsertzAddStatement.is_upsertrr'Trmc||_|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-ros r%upsertzAddStatement.upserts  r'r-r ct|D]Y}t|tr|j|2|jt|Z|S)zAdds a list of documents into a collection. Args: *values: The documents to be added into the collection. Returns: mysqlx.AddStatement: AddStatement object. )r4r1r r!r)r$r-vals r%addzAddStatement.addsg#F+ 0 0C#u%% 0 ##C(((( ##E#JJ//// r'rct|jdkrtS|j|S)[Execute the statement. Returns: mysqlx.Result: Result object. r)r0r!rr_ send_insertrfs r%rzAddStatement.executes9 t|   ! !88O++D111r')r(rr r!rr)rmr9r r')r-r r r'r r) r(r)r*r+r&r.r0r3rr r s@r%r'r's        2 2 2 2 2 2 2 2r'r'c$eZdZdZd dd Zdd ZdS) 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. N update_typerisourcer7rmrr r!c|tdkr|||dS||_ t|dj|_n##t$r}t||d}~wwxYw||_ dS)N*Mysqlx.Crud.UpdateOperation.UpdateType.SETF) r _table_setr:rdocument_fieldr6r;rrrm)r$r:r;rmrs r%r&zUpdateSpec.__init__ s -(TUU U U OOFE * * * * *$/D  :#-fe#<#<#K#K#M#M#X  : : :&#x00c9 :#DJJJs,A!! B+A<<Bctd|_t|d|_||_dS)zlTable set. Args: source (str): The source. value (str): The value. r=TN)rr:rparse_table_update_fieldr;rm)r$r;rms r%r>zUpdateSpec._table_sets=))UVV ..GGII  r'r#)r:rir;r7rmrr r!)r;r7rmrr r!)r(r)r*r+r&r>r,r'r%r9r9sK   $ $ $ $ $      r'r9ceZdZdZdfd Zdd Zdd Zd dZedd dZ d!dZ d"dZ d dZ d#dZ d$dZxZS)%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. r(rrr7r r!c\t||i|_dSN)rYrrr& _update_opsr$r(rrs r%r&zModifyStatement.__init__.s.  i@@@+-r'rc|j|S)zSets the sorting criteria. Args: *clauses: The expression strings defining the sort criteria. Returns: mysqlx.ModifyStatement: ModifyStatement object. rrs r%rzModifyStatement.sort2tz7##r'rc|jSztReturns the list of update operations. Returns: `list`: The list of update operations. rGrfs r%get_update_opszModifyStatement.get_update_ops=rr'doc_pathrmrc`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_SETTr9rrGrbr$rOrms r%setzModifyStatement.setEs;&0 K L L  & & "   r'rc`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_REPLACETrQrRs r%changezModifyStatement.changeWs;&0 O P P  & & "   r' doc_pathscvt|D]'}ttd||j|<(d|_|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)r4r9rrGrb)r$rVitems r%unsetzModifyStatement.unsetmsO$Y/  D%/RSS&&D T " "  r'fieldc`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_INSERTTrQr$rZrms r% array_insertzModifyStatement.array_inserts;#- O P P  # #    r'c`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_APPENDTrQrRs r% array_appendzModifyStatement.array_appends;&0 O P P  & & "   r'doc#Union[Dict, DbDoc, ExprParser, str]c(|d}t|ttttfst dt tddt|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. Nr5z>Invalid data for update operation on document collection tablez2Mysqlx.Crud.UpdateOperation.UpdateType.MERGE_PATCH$patchT) r1rrr r7rr9rrrGrb)r$r`s r%rdzModifyStatement.patchs ;C# D%=>> "P %/ N O O $S*55 >CHHJJJ3% % !   r'rcb|jstd|j|S)Execute the statement. Returns: mysqlx.Result: Result object. Raises: ProgrammingError: If condition was not set. z!No condition was found for modifyrrr_ send_updaterfs r%rzModifyStatement.execute5~ H"#FGG G++D111r'r(rrr7r r!)rr7r rCr )rOr7rmrr rC)rVr7r rC)rZr7rmrr rC)r`rar rCr7)r(r)r*r+r&rrNrSrrUrYr]r_rdrr r s@r%rCrC"s  ...... $ $ $ $    $Z*$(*4 2 2 2 2 2 2 2 2r'rCceZdZdZ ddfd ZeddZddZddZddZ e j fd dZ e j fd dZ d!dZd"dZd#dZxZS)$ 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. TNrYrrZr9rrr r!ct|||d|_d|_tj|_dSNF)rr&_lock_exclusive _lock_sharedr DEFAULT_lock_contentionrs r%r&zReadStatement.__init__sB I666%*"'0>0Fr'r c|jS)z::class:`mysqlx.LockContention`: The lock contention value.)rrrfs r%lock_contentionzReadStatement.lock_contentions $$r'rtc t|j}n"#t$r}td|d}~wwxYw||_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)r rmrrrr)r$rt_rs r%_set_lock_contentionz"ReadStatement._set_lock_contentions` 455AA   "M  !0s 616c|jS)zrReturns `True` if is `EXCLUSIVE LOCK`. Returns: bool: `True` if is `EXCLUSIVE LOCK`. )rorfs r%is_lock_exclusivezReadStatement.is_lock_exclusives ##r'c|jS)zlReturns `True` if is `SHARED LOCK`. Returns: bool: `True` if is `SHARED LOCK`. )rprfs r%is_lock_sharedzReadStatement.is_lock_sharedrr'cLd|_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. FTrorprwr$rts r% lock_sharedzReadStatement.lock_shareds- %  !!/222 r'cLd|_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. TFr}r~s r%lock_exclusivezReadStatement.lock_exclusives- $! !!/222 r'rr7c|j||S)zSets a grouping criteria for the resultset. Args: *fields: The string expressions identifying the grouping criteria. Returns: mysqlx.ReadStatement: ReadStatement object. )rrs r%group_byzReadStatement.group_by*s F## r'c0|||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. )rrs r%havingzReadStatement.having6s ### r'Union[DocResult, RowResult]c6|j|Sr5)r_ send_findrfs r%rzReadStatement.executeDs ))$///r'rr )r r )rtr r r!r)rtr r rl)rr7r rl)rr7r rl)r r)r(r)r*r+r&rrtrwryr{r rqrrrrrr r s@r%rlrls5  #' G G G G G G G%%%X%0000$$$$$!!!!1?0F     1?0F             00000000r'rlc8eZdZdZ ddfd Zdd ZddZxZS) 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. Nr(rrrr r!cNt|d|dS)NTrr&rHs r%r&zFindStatement.__init__Xs' T955555r'rr7c|j|S)zSets a document field filter. Args: *fields: The string expressions identifying the fields to be extracted. Returns: mysqlx.FindStatement: FindStatement object. )rrs r%rzFindStatement.fields]s$t#V,,r'rc|j|SzSets the sorting criteria. Args: *clauses: The expression strings defining the sort criteria. Returns: mysqlx.FindStatement: FindStatement object. rrs r%rzFindStatement.sortirJr'r#)r(rrrr r!)rr7r r)rr7r r)r(r)r*r+r&rrr r s@r%rrMs{JN6666666 - - - - $ $ $ $ $ $ $ $r'rc<eZdZdZdfd Zdd Zdd Zdd ZxZS)SelectStatementzA statement for record retrieval operations on a Table. Args: table (mysqlx.Table): The Table object. *fields: The fields to be retrieved. tablerrr7r r!c`t|d|j|dSrn)rr&rr$rrrs r%r&zSelectStatement.__init__}s3 &&&f%%%%r'rc,||S)zSets the search condition to filter. Args: condition (str): Sets the search condition to filter records. Returns: mysqlx.SelectStatement: SelectStatement object. rrs r%rzSelectStatement.wherey)))r'rc|j|S)zSets the order by criteria. Args: *clauses: The expression strings defining the order by criteria. Returns: mysqlx.SelectStatement: SelectStatement object. rrs r%order_byzSelectStatement.order_byrJr'c 4|jr d|jnd}|jr d|jnd}|jr d|jnd}|jr d|jnd}|jrd|j d|j nd}d|j pd d |j j d |jj ||||| }|S) zYReturns the generated SQL. Returns: str: The generated SQL. z WHERE r5z GROUP BY z HAVING z ORDER BY z LIMIT z OFFSET zSELECT *z FROM rG)rrrrrrrrrrrrrhnamerY)r$rrrrrstmts r%get_sqlzSelectStatement.get_sqls 04~E+$/+++28<8IQ4 2444r.2oE*DL***248MI0000r~  Id+ I IT5G I I I   :d*1c : :K$ : :'+{'7 : : : & :(0 :27 : :  r')rrrr7r r!)rr7r r)rr7r rr) r(r)r*r+r&rrrr r s@r%rrus&&&&&& * * * * $ $ $ $r'rc4eZdZdZd fd Zdd Zdd ZxZS)InsertStatementzA statement for insert operations on Table. Args: table (mysqlx.Table): The Table object. *fields: The fields to be inserted. rrrrr r!cht|dt||_dSrn)rr&r4_fieldsrs r%r&zInsertStatement.__init__s- &&&+:F+C r'r-cb|jtt||S)zSet the values to be inserted. Args: *values: The values of the columns to be inserted. Returns: mysqlx.InsertStatement: InsertStatement object. )r!rr2r4)r$r-s r%r-zInsertStatement.valuess, D&!9::;;; r'rc6|j|Sr)r_r6rfs r%rzInsertStatement.executes ++D111r')rrrrr r!)r-rr rr7)r(r)r*r+r&r-rr r s@r%rrsuDDDDDD    22222222r'rcLeZdZdZdfd Zdd Zdd Zdd ZddZddZ xZ 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. rrr r!c\t|di|_dSrrFr$rrs r%r&zUpdateStatement.__init__s. 777+-r'rr7c,||S)zSets the search condition to filter. Args: condition (str): Sets the search condition to filter records. Returns: mysqlx.UpdateStatement: UpdateStatement object. rrs r%rzUpdateStatement.whererr'rc|j|S)zSets the order by criteria. Args: *clauses: The expression strings defining the order by criteria. Returns: mysqlx.UpdateStatement: UpdateStatement object. rrs r%rzUpdateStatement.order_byrJr'rc|jSrLrMrfs r%rNzUpdateStatement.get_update_opsrr'rZrmrc`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. r=TrQr\s r%rSzUpdateStatement.sets;#- F G G  # #    r'rcb|jstd|j|S)zExecute the statement. Returns: mysqlx.Result: Result object Raises: ProgrammingError: If condition was not set. z!No condition was found for updatergrfs r%rzUpdateStatement.execute rir'rrr r!)rr7r r)rr7r rr )rZr7rmrr rr7) r(r)r*r+r&rrrNrSrr r s@r%rrs...... * * * * $ $ $ $    $ 2 2 2 2 2 2 2 2r'rc4eZdZdZd fd Zdd Zdd ZxZS)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. r(rrr7r r!cNt||dSrErrHs r%r&zRemoveStatement.__init__'s&  i@@@@@r'rc|j|Srrrs r%rzRemoveStatement.sort*rJr'rcb|jstd|j|S)rfz!No condition was found for removerrr_ send_deleterfs r%rzRemoveStatement.execute5rir'rj)rr7r rr7)r(r)r*r+r&rrr r s@r%rrsu  AAAAAA $ $ $ $ 2 2 2 2 2 2 2 2r'rc<eZdZdZdfd Zdd Zdd Zdd ZxZS)DeleteStatementzA statement that drops a table. Args: table (mysqlx.Table): The Table object. .. versionchanged:: 8.0.12 The ``condition`` parameter was removed. rrr r!cNt|ddSrrrs r%r&zDeleteStatement.__init__Ms& 77777r'rr7c,||S)zSets the search condition to filter. Args: condition (str): Sets the search condition to filter records. Returns: mysqlx.DeleteStatement: DeleteStatement object. rrs r%rzDeleteStatement.wherePrr'rc|j|S)zSets the order by criteria. Args: *clauses: The expression strings defining the order by criteria. Returns: mysqlx.DeleteStatement: DeleteStatement object. rrs r%rzDeleteStatement.order_by[rJr'rcb|jstd|j|S)rfz!No condition was found for deleterrfs r%rzDeleteStatement.executefrir'r)rr7r r)rr7r rr7) r(r)r*r+r&rrrr r s@r%rrCs888888 * * * * $ $ $ $ 2 2 2 2 2 2 2 2r'rc,eZdZdZd fd Zdd ZxZS)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} r(r index_namer7 index_descrr r!ct|tj||_||_|jdg|_dS)N)rYr)rr&copydeepcopy _index_desc _index_namepop _fields_desc)r$r(rrrs r%r&z'CreateCollectionIndexStatement.__init__s\  ++++/=+D+D *262B2F2FxQS2T2Tr'rc |j,tt|j t |j}t|trF|dtdkr,tt|jnD|j tdkr,tt|jnF#ttf$r2}tt|j|d}~wwxYw|j std|jt|j tstdi}|j|d<|jj|d<|jjj|d<d|jvr|jd|d<nd |d<|jd d |d <|d rt)d g|d <|jrtd|j |j D]J}i}|d|d<|d|d<|dd |d<|dd |d<t|dt*st-dt|dt*st-d|ddkr|dstd|dd kr|ddkrtdd|vrp|dds+td|dd|d|d<d|vrE|ddkrtd|d|d<d|vrE|ddkrtd |d|d<|d |Ln(#t4$r}td!|d"||d}~wwxYw|j D]}|rtd#||jd$d%d&|S)'r5NtypezMysqlx.Expr.Expr.Type.IDENTzCRequired member 'fields' not found in the given index description: z,Required member 'fields' must contain a listrr(rhINDEXuniqueFz!Unique indexes are not supported. constraintzUnidentified fields: rZmemberrequiredarrayz'Field member 'required' must be Booleanz$Field member 'array' must be BooleanSPATIALzQField member 'required' must be set to 'True' when index type is set to 'SPATIAL'GEOJSONzIIndex 'type' must be set to 'SPATIAL' when field type is set to 'GEOJSON' collationTEXTzCThe 'collation' member can only be used when field type is set to ''optionszIThe 'options' member can only be used when index type is set to 'GEOJSON'sridzFThe 'srid' member can only be used when index type is set to 'GEOJSON'zRequired inner member z not found in constraint: zUnidentified inner fields: mysqlxcreate_collection_indexT)rrERR_INVALID_INDEX_NAMEformatrr get_messager1rrrrAttributeErrorrrr2r\rrhrrr9 TypeErrorupper startswithrKeyErrorr_execute_nonquery)r$ parsed_identrr field_descrs r%rz&CreateCollectionIndexStatement.executes   #"#9#@#@AQ#R#RSS S %d&677<<>>JJLLL,-- '=9V+W+WWW*.55d6FGGX  $ 6S(T(TTT*.55d6FGGN+   "&--d.>??     "3 $ 033  $+T22 S"#QRR R!'V !\.\,1X T% % %+//77DLL"DL)--h>>X > I#$GHH H\   O"#M4;K#M#MNN N1 "/, 6, 6  '1~~g'>'> 8$%/^^F%;%; 6")3 E)J)J :&&0nnWe&D&D 7#!*Z"8$??O#$MNNN!*W"5t<<L#$JKKK<%%''944Z =S4*9<%%''722z&7IY7V7V*3*,,%f-3355@@HH.> *6 2 8 8 : :>>> /9nn[.I.IJ{+ **!&)//11Y>>.=-7NN9,E,EJy)Z''!&)//11Y>>.7*4)?)?Jv&\"))*5555Y, 6Z   "TTT TT   + S SJ S&'QZ'Q'QRRR S00 /t   s1CD E-E  EIR"" S,SS)r(rrr7rrr r!r7)r(r)r*r+r&rr r s@r%rrtsi, U U U U U Up p p p p p p p r'r)r-rr r.)r5)r6r7r8r7r r9)r6r7r8r7r r7)rDrEr8r7r r7)rMr7rNr7r8r7r rO)=r+ __future__rrrrtypingrrrrrr r constantsr dbdocr errorsrrrrhelpersrprotobufrresultrrrrtypesrrrrrrrrr4r?rCrLrVrXrrrr'r9rCrlrrrrrrrr,r'r%rs>$#"""""" DDDDDDDDDDDDDDDDDD%%%%%%77777777######;;;;;;;;;;;;B:::::"(      ;=,g"g"g"g"g"g"g"g"TW"W"W"W"W")W"W"W"t ?/?/?/?/?/9?/?/?/D'"'"'"'"'"Y'"'"'"T8282828282>828282v        Fk2k2k2k2k2)k2k2k2\z0z0z0z0z0'z0z0z0z%$%$%$%$%$M%$%$%$P66666m666r22222n222BI2I2I2I2I2)I2I2I2X%2%2%2%2%2)%2%2%2P.2.2.2.2.2).2.2.2bR R R R R YR R R R R r'