"iYddZddlZddlZddlZddlmZmZddlmZddl m Z ddl m Z ddl mZdd lmZdd lmZd ZGd d eZdZd2dZd2dZd2dZd2dZGddeZGddeZGddeZGddeZGddeZGddeZ Gd d!eZ!Gd"d#eZ"Gd$d%e"Z#Gd&d'e"Z$Gd(d)eZ%Gd*d+eZ&Gd,d-eZ'Gd.d/eZ(Gd0d1eZ)dS)3zImplementation of Statements.N)ProgrammingErrorNotSupportedError) ExprParser)LockContention)DbDoc) deprecated)Result) mysqlxpb_enumz&The given index name "{}" is not validceZdZdZdZdS)ExprzExpression wrapper.c||_dSN)expr)selfrs H/srv/django_bis/venv311/lib/python3.11/site-packages/mysqlx/statement.py__init__z Expr.__init__0s  N)__name__ __module__ __qualname____doc__rrrr r .s)rr ct|dkr*t|dttfr|dS|S)zParse flexible parameters.rr)len isinstancelisttuple)valuess rflexible_paramsr 4s9 6{{aJvay4.AAay Mrcd|vr0|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_modes ris_quoted_identifierr*;sl  A#%?*R.C*?AA#%?*R.C*? B a=C  9JrNc$99rct|dkrdSd|vr)d|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's rquote_identifierr.Ksi :!t  ~~j00d;;<<< >>*,,S$77 8 88rcFdfd|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)r.).0r(r)s r z.quote_multipart_identifier..gs3444#&j(;;444r)join) identifiersr)s `rquote_multipart_identifierr6]sA 884444'2444 5 55rc 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. r#r&r$z.{0}r0rrr%)r,splitrstrip)default_schema table_namer)quote delimitertemps rparse_table_namer?ks!H,,CC#E(-(;(; e$$$I   Iq ) )D!$ii1nnNN$q'--2F2F HNN5 ! ! $$rcbeZdZdZddZedZedZedZej dZedZ ed Z e j d Z ed Z e j d Z ed Z edZej dZdZdZdZdZdS) 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. Tc||_||_|r|nd|_d|_d|_d|_d|_d|_dS)NrTF) _target _doc_basedget_connection _connection_stmt_id _exec_counter_changed _prepared_deallocate_prepare_execute)rtarget doc_baseds rrzStatement.__init__sY #6<F600222$  +0(((rc|jS)z#object: The database object target.)rCrs rrLzStatement.targets |rc|jjS)z*:class:`mysqlx.Schema`: The Schema object.)rCschemarOs rrQzStatement.schemas|""rc|jS)zXReturns this statement ID. Returns: int: The statement ID. rGrOs rstmt_idzStatement.stmt_ids }rc||_dSrrSrvalues rrTzStatement.stmt_id  rc|jS)z5int: The number of times this statement was executed.rHrOs r exec_counterzStatement.exec_counters !!rc|jS)z+bool: `True` if this statement has changes.rIrOs rchangedzStatement.changeds }rc||_dSrr]rVs rr^zStatement.changedrXrc|jS)z1bool: `True` if this statement has been prepared.rJrOs rpreparedzStatement.prepareds ~rc||_dSrrarVs rrbzStatement.prepareds rc|jdkS)zDbool: `True` if this statement was executed more than once. rrZrOs rrepeatedzStatement.repeateds!A%%rc|jS)zBbool: `True` to deallocate + prepare + execute statement. rKrOs rdeallocate_prepare_executez$Statement.deallocate_prepare_executes //rc||_dSrrgrVs rrhz$Statement.deallocate_prepare_executes+0(((rc|jS)zkCheck if it is document based. Returns: bool: `True` if it is document based. )rDrOs r is_doc_basedzStatement.is_doc_based rc&|xjdz c_dS)z@Increments the number of times this statement has been executed.rNrZrOs rincrement_exec_counterz Statement.increment_exec_counters arcd|_dS)z!>!@!@   rc|jSzlReturns the binding map dictionary. Returns: dict: The binding map dictionary. rrOs rget_binding_mapz#FilterableStatement.get_binding_maps   rc|jSz\Returns the bindings list. Returns: `list`: The bindings list. rrOs r get_bindingsz FilterableStatement.get_bindings{ ~rc|jS)zrReturns the grouping expression list. Returns: `list`: The grouping expression list. )rrOs r get_groupingz FilterableStatement.get_groupingrrc|jS)zdReturns the having expression. Returns: object: The having expression. )rrOs r get_havingzFilterableStatement.get_having |rc|jS)z]Returns the limit row count. Returns: int: The limit row count. )rrOs rget_limit_row_countz'FilterableStatement.get_limit_row_count $$rc|jS)zWReturns the limit offset. Returns: int: The limit offset. )rrOs rget_limit_offsetz$FilterableStatement.get_limit_offsets !!rc|jS)zbReturns the where expression. Returns: object: The where expression. )rrOs rget_where_exprz"FilterableStatement.get_where_expr rc|jS)zlReturns the projection expression. Returns: object: The projection expression. )rrOs rget_projection_exprz'FilterableStatement.get_projection_exprrrc|jS)z`Returns the sort expression. Returns: object: The sort expression. )rrOs r get_sort_exprz!FilterableStatement.get_sort_exprrlr8.0.12c,||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 rrs rwherezFilterableStatement.wheresy)))rc|j|S)zSets the sorting criteria. Args: *clauses: The expression strings defining the sort criteria. Returns: mysqlx.FilterableStatement: FilterableStatement object. .. deprecated:: 8.0.12 rrs rsortzFilterableStatement.sortstz7##rc^t|tr|dkrtd|js;t |jdk|_t |jdk |_||_d|_|r0| |tj dt|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) rintrrboolrHrIrKroffsetwarningswarnDeprecationWarning)r row_countrs rlimitzFilterableStatement.limits)S)) QY]]OPP P~ Q !3q!899DM/38Ja8O4O/P/PD , )  ? KK    M!+= ? ? ? ? rcht|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)rrrr)rrs rrzFilterableStatement.offsets;&#&& N&1**LMM M# rcd|_t|}|dkr||dn,|dkr|d|j|d<nt d|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)rrrrr)rargscounts rrzFilterableStatement.bind so!D  A::   d1g & & & & aZZ&*1gDN47 # #"#HII I rctrrrsrOs rruzFilterableStatement.execute!rvrTNr)rrrrrrrrrrrrrrrrrrrrr rrrrrru __classcell__rs@rr{r{s  ''''''4LLL4 *   $!!!%%%"""   %%%Z * * *Z $ $ $<&0"""""""rr{cPeZdZdZfdZedZdZdZdZ dZ xZ S) SqlStatementzA statement for SQL execution. Args: connection (mysqlx.connection.Connection): Connection object. sql (string): The sql statement to be executed. ctt|dd||_||_d|_g|_d|_d|_dSNFr}) r~rrrF_sqlrrrr)r connectionsqlrs rrzSqlStatement.__init__1sW lD!!**$%*HHH%  !rc|jS)zstring: The SQL text statement.)rrOs rrzSqlStatement.sql:s yrc|jSrrrOs rrzSqlStatement.get_binding_map?rrc|jSrrrOs rrzSqlStatement.get_bindingsGrrct|dkrtdd|_t|}t |t t fr||_n|j||S)zBinds value(s) to a specific placeholder(s). Args: *args: The value(s) to bind. Returns: mysqlx.SqlStatement: SqlStatement object. rrT) rrrr rrrrappend)rrbindingss rrzSqlStatement.bindOsn t99>>"#HII I "D) hu . . ,%DNN N ! !( + + + rc6|j|S)zaExecute the statement. Returns: mysqlx.SqlResult: SqlResult object. )rFsend_sqlrOs rruzSqlStatement.executebs ((...r) rrrrrrxrrrrrurrs@rrr*s X!!!&///////rrc.eZdZdZfdZdZdZxZS)WriteStatementz/Provide common write operation attributes. chtt|||g|_dSr)r~rr_values)rrLrMrs rrzWriteStatement.__init__ns. nd##,,VY??? rc|jS)z^Returns the list of values. Returns: `list`: The list of values. )rrOs r get_valueszWriteStatement.get_valuesrrrctrrrsrOs rruzWriteStatement.executezrvr)rrrrrrrurrs@rrrks`"""""""rrc<eZdZdZfdZdZddZdZdZxZ S) AddStatementzA statement for document addition on a collection. Args: collection (mysqlx.Collection): The Collection object. cvtt||dd|_g|_dS)NTF)r~rr_upsertids)r collectionrs rrzAddStatement.__init__s5 lD!!**:t<<< rc|jS)zhReturns `True` if it's an upsert. Returns: bool: `True` if it's an upsert. rrOs r is_upsertzAddStatement.is_upsertrrTc||_|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 rVs rupsertzAddStatement.upserts  rct|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. )r rrrr)rrvals raddzAddStatement.addsg#F+ 0 0C#u%% 0 ##C(((( ##E#JJ//// rct|jdkrtS|j|S)[Execute the statement. Returns: mysqlx.Result: Result object. r)rrr rF send_insertrOs rruzAddStatement.executes9 t|   ! !88O++D111rrw) rrrrrr r rrurrs@rrrs       2 2 2 2 2 2 2rrc eZdZdZddZdZdS) UpdateSpeczUpdate specification class implementation. Args: update_type (int): The update type. source (str): The source. value (Optional[str]): The value. NcD|tdkr|||dS||_||_t |dkr|ddkr|dd|_t |jdj|_||_dS)N*Mysqlx.Crud.UpdateOperation.UpdateType.SETr$rF) r _table_set update_typesourcerrdocument_fieldr(rW)rrrrWs rrzUpdateSpec.__init__s -<>> > > OOFE * * * * **D  DK6{{Q6!9#3#3$QRRj $T[%*,,,:N,<,Invalid data for update operation on document collection tablez2Mysqlx.Crud.UpdateOperation.UpdateType.MERGE_PATCHpatchT) rrrrrrrr rr#rI)rdocs rr=zModifyStatement.patch[s ;C# D%=>> " %/ N O O jj99B s%D%D!  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 modifyrrrF send_updaterOs rruzModifyStatement.executes5~ H"#FGG G++D111r)rrrrrrr*r/r r1r5r9r;r=rurrs@rr r s   $ $ $    Z& $&0 2 2 2 2 2 2 2rr ceZdZdZdfd ZedZdZdZdZ e j fd Z e j fd Z d Zd Zd ZxZS) 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. TNctt||||d|_d|_t j|_dSNF)r~rEr_lock_exclusive _lock_sharedrDEFAULT_lock_contentionrs rrzReadStatement.__init__sF mT""++FIyIII$! . 6rc|jS)z::class:`mysqlx.LockContention`: The lock contention value.)rKrOs rlock_contentionzReadStatement.lock_contentions $$rcz tj|}n#t$rtdwxYw||_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)rindexrrrK)rrM_s r_set_lock_contentionz"ReadStatement._set_lock_contentions[ 7$_55AA 7 7 7"$677 7 7!0s1c|jS)zrReturns `True` if is `EXCLUSIVE LOCK`. Returns: bool: `True` if is `EXCLUSIVE LOCK`. )rHrOs ris_lock_exclusivezReadStatement.is_lock_exclusives ##rc|jS)zlReturns `True` if is `SHARED LOCK`. Returns: bool: `True` if is `SHARED LOCK`. )rIrOs ris_lock_sharedzReadStatement.is_lock_sharedrrcLd|_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. FTrHrIrQrrMs r lock_sharedzReadStatement.lock_shareds- %  !!/222 rcLd|_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. TFrWrXs rlock_exclusivezReadStatement.lock_exclusives- $! !!/222 rc|j||S)zSets a grouping criteria for the resultset. Args: *fields: The string expressions identifying the grouping criteria. Returns: mysqlx.ReadStatement: ReadStatement object. )rrs rgroup_byzReadStatement.group_bys F## rc0|||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 rhavingzReadStatement.havings ### rc6|j|Sr)rF send_findrOs rruzReadStatement.executes ))$///rr)rrrrrrxrMrQrSrUrrJrYr[r]r_rurrs@rrErEs  777777 %%X%000"$$$!!!+9*@    .<-C          0000000rrEc0eZdZdZdfd ZdZdZxZS) 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. Nc\tt||d|dS)NT)r~rdrr$s rrzFindStatement.__init__s+ mT""++JiHHHHHrc|j|S)zSets a document field filter. Args: *fields: The string expressions identifying the fields to be extracted. Returns: mysqlx.FindStatement: FindStatement object. )rrs rrzFindStatement.fieldss$t#V,,rc|j|SzSets the sorting criteria. Args: *clauses: The expression strings defining the sort criteria. Returns: mysqlx.FindStatement: FindStatement object. rrs rrzFindStatement.sort r&rr)rrrrrrrrrs@rrdrdskIIIIII - - - $ $ $ $ $ $ $rrdc4eZdZdZfdZdZdZdZxZS)SelectStatementzA statement for record retrieval operations on a Table. Args: table (mysqlx.Table): The Table object. *fields: The fields to be retrieved. cntt||d|j|dSrG)r~rjrrrtablerrs rrzSelectStatement.__init__s9 ot$$--eU;;;f%%%%rc,||S)zSets the search condition to filter. Args: condition (str): Sets the search condition to filter records. Returns: mysqlx.SelectStatement: SelectStatement object. rrs rrzSelectStatement.where#y)))rc|j|S)zSets the order by criteria. Args: *clauses: The expression strings defining the order by criteria. Returns: mysqlx.SelectStatement: SelectStatement object. rrs rorder_byzSelectStatement.order_by.r&rc |jrd|jnd}|jrd|jnd}|jrd|jnd}|jrd|jnd}|j r d|j |j nd}d|j pd|j j|jj||||| }|S) zYReturns the generated SQL. Returns: str: The generated SQL. z WHERE {0}r!z 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}*)selectrQrmrrgroupr_order)rr,rrrrrrrrrrrrQnamerL)rrr]r_rqrstmts rget_sqlzSelectStatement.get_sql9s 9=N ##DO444B  &?))$*<===#% 7;N%%dl333B=A]?))$.999 37.I'..t/D/3/ACCCFH !!'t/C/Js/3{/?.2k.>e.38/5X "("G"G  r) rrrrrrrqryrrs@rrjrjso &&&&& * * * $ $ $rrjc.eZdZdZfdZdZdZxZS)InsertStatementzA statement for insert operations on Table. Args: table (mysqlx.Table): The Table object. *fields: The fields to be inserted. cvtt||dt||_dSrG)r~r{rr _fieldsrls rrzInsertStatement.__init__Xs3 ot$$--eU;;;&/ rcb|jtt||S)zSet the values to be inserted. Args: *values: The values of the columns to be inserted. Returns: mysqlx.InsertStatement: InsertStatement object. )rrrr )rrs rrzInsertStatement.values\s, D&!9::;;; rc6|j|Sra)rFrrOs rruzInsertStatement.executehs ++D111r)rrrrrrrurrs@rr{r{Qs` 00000   2222222rr{c@eZdZdZfdZdZdZdZdZdZ 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. cjtt||di|_dSr)r~rrr#rrmrs rrzUpdateStatement.__init__zs4 ot$$--Ue-LLLrc,||S)zSets the search condition to filter. Args: condition (str): Sets the search condition to filter records. Returns: mysqlx.UpdateStatement: UpdateStatement object. rrs rrzUpdateStatement.where~rorc|j|S)zSets the order by criteria. Args: *clauses: The expression strings defining the order by criteria. Returns: mysqlx.UpdateStatement: UpdateStatement object. rrs rrqzUpdateStatement.order_byr&rc|jSr(r)rOs rr*zUpdateStatement.get_update_opsrrc`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. rTr,r7s rr/zUpdateStatement.sets=#-] 8.:.:;@%#I#I  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 updaterArOs rruzUpdateStatement.executerCr) rrrrrrrqr*r/rurrs@rrrqs * * * $ $ $       2 2 2 2 2 2 2rrc.eZdZdZfdZdZdZxZS)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. c\tt|||dSr")r~rrr$s rrzRemoveStatement.__init__s> ot$$--Z8A . C C C C Crc|j|Srhrrs rrzRemoveStatement.sortr&rcb|jstd|j|S)r@z!No condition was found for removerrrF send_deleterOs rruzRemoveStatement.executerCr)rrrrrrrurrs@rrrse  CCCCC $ $ $ 2 2 2 2 2 2 2rrc4eZdZdZfdZdZdZdZxZS)DeleteStatementzA statement that drops a table. Args: table (mysqlx.Table): The Table object. .. versionchanged:: 8.0.12 The ``condition`` parameter was removed. c\tt||ddSr)r~rrrs rrzDeleteStatement.__init__s, ot$$--Ue-LLLLLrc,||S)zSets the search condition to filter. Args: condition (str): Sets the search condition to filter records. Returns: mysqlx.DeleteStatement: DeleteStatement object. rrs rrzDeleteStatement.whererorc|j|S)zSets the order by criteria. Args: *clauses: The expression strings defining the order by criteria. Returns: mysqlx.DeleteStatement: DeleteStatement object. rrs rrqzDeleteStatement.order_byr&rcb|jstd|j|S)r@z!No condition was found for deleterrOs rruzDeleteStatement.executerCr) rrrrrrrqrurrs@rrrstMMMMM * * * $ $ $ 2 2 2 2 2 2 2rrc(eZdZdZfdZdZxZS)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} ctt||tj||_||_|jdg|_dS)N)rLr) r~rrcopydeepcopy _index_desc _index_namepop _fields_desc)rr index_name index_descrs rrz'CreateCollectionIndexStatement.__init__'s` ,d33<>rc |j,tt|j t |j}t|trF|dtdkr,tt|jnD|j tdkr,tt|jnA#ttf$r-tt|jwxYw|j s'td|jt|j tstdi}|j|d<|jj|d<|jjj|d<d|jvr|jd|d<nd |d<|jd d |d <|d rt)d g|d <|jr'td|j |j D]Y}i}|d|d<|d|d<|dd |d<|dd |d<t|dt*st-dt|dt*st-d|ddkr|dstd|dd kr|ddkrtdd|vr|dds:td|d|d|d<d|vrE|ddkrtd|d|d<d|vrE|ddkrtd|d|d<|d |[n5#t4$r(}td ||d}~wwxYw|j D]&}|r"td!|'|jd"d#d$|S)%rNtypezMysqlx.Expr.Expr.Type.IDENTzERequired member 'fields' not found in the given index description: {}z-Required member 'fields' must contain a list.rwrrQINDEXuniqueFz!Unique indexes are not supported. constraintzUnidentified fields: {}r8memberrequiredarrayz'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' collationTEXTzFThe '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'z4Required inner member {} not found in constraint: {}zUnidentified inner fields:{}mysqlxcreate_collection_indexT)rrERR_INVALID_INDEX_NAMEr,rr get_messagerrr rrAttributeErrorrrrrCrwrQrrr TypeErrorupper startswithrKeyErrorrFexecute_nonquery)r parsed_identr field_descrerrs rruz&CreateCollectionIndexStatement.execute-s   #"&--d.>??AA A A%d&677<<>>JJLLL,-- I'=5,7,777*.55d6FGGIII7  $ 5)7)777*.55d6FGGIIIN+ A A A"&--d.>??AA A A   @"$&&,fT-=&>&>@@ @$+T22 ,"$+,, ,'V !\.\,1X T% % %+//77DLL"DL)--h>>X > I#$GHH H\   @"$&&,fT-=&>&>@@ @- M"/) 6) 6  '1~~g'>'> 8$%/^^F%;%; 6")3 E)J)J :&&0nnWe&D&D 7#!*Z"8$??O#$MNNN!*W"5t<<L#$JKKK<%%''944!*-5*9:::<%%''722f%22*3444*,,%f-3355@@HHC.%vj&8&>&>&@&@AACCC/9nn[.I.IJ{+ **!&)//11Y>>.=>>>-7NN9,E,EJy)Z''!&)//11Y>>.7888*4)?)?Jv&\"))*5555S) 6T M M M"$44:F3 4K4KMM M M+ > >J >&(**0&*<*<>>> >00 /t== =s%CD >E )I"S S>#S99S>)rrrrrrurrs@rrrsX*????? n=n=n=n=n=n=n=rr)r!)*rrrrerrorsrrrr constantsrdbdocrhelpersr resultr protobufr robjectr r r*r.r6r?rAr{rrrrr rErdrjr{rrrrrrrrs:$# 77777777%%%%%%######A6  : : : : 9999$ 5 5 5 5$$$$$f"f"f"f"f"f"f"f"RA"A"A"A"A")A"A"A"H >/>/>/>/>/9>/>/>/B"""""Y"""07272727272>727272tD_2_2_2_2_2)_2_2_2Do0o0o0o0o0'o0o0o0d"$"$"$"$"$M"$"$"$J66666m666r22222n222@E2E2E2E2E2)E2E2E2P%2%2%2%2%2)%2%2%2P-2-2-2-2-2)-2-2-2`J=J=J=J=J=YJ=J=J=J=J=r