:?hcSrSSKJr SSKrSSKrSSKrSSKJrJrJ r J r J r J r J r SSKJr SSKJr SSKJrJr SS KJr SS KJr SS KJr SS KJrJrJrJr SS K J!r!J"r"J#r#J$r$J%r%J&r& Sr'"SS5r(S4Sjr)S5S6Sjjr*S5S7Sjjr+S5S8Sjjr,S5S9Sjjr-"SS5r."SS\.5r/"SS\.5r0"SS\.5r1"SS\15r2"S S!5r3"S"S#\/5r4"S$S%\/5r5"S&S'\55r6"S(S)\55r7"S*S+\15r8"S,S-\/5r9"S.S/\/5r:"S0S1\/5r;"S2S3\.5rB3)> qMS :Z^s%:  a=C  9JrNc$99r(c[U5S:XagSU;aURSS5nSUS3$URSS5nSUS3$)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;)r3replace)r>r?quoteds r%quote_identifierrD[s[ :! ##C.6(!}   T *F vha=r(c `SRUVs/sHn[X!5PM sn5$s snf)zQuote 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. .)joinrD) identifiersr?r>s r%quote_multipart_identifierrIos0 88BMN+J * /+N Ns+cSU;aSOSnX1;aSU3OSnURUS5n[U5S:XaUOUSRU5USRU54$)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;rFr rr<)splitr3strip)default_schema table_namer?quote delimitertemps r%parse_table_namerR~sl!H,C#E$2!E7 I   Iq )Dd)q.d1gmmE.B Ru r(c\rSrSrSrSSSjjr\SSj5r\SSj5r\SSj5r \ RSSj5r \SSj5r \SS j5r \ RSS j5r \SS j5r \ RSS j5r \SS j5r\SSj5r\RSSj5rSSjrSSjrSSjrSSjrSrg) StatementzProvides 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. cXlX lU(aUR5OSUlSUlSUlSUlSUlSUlg)NrTF) _target _doc_basedget_connection _connection_stmt_id _exec_counter_changed _prepared_deallocate_prepare_execute)r$target doc_baseds r%r&Statement.__init__sK+1 )'-F ! ! #4 (, "#" $16(r(cUR$)z#object: The database object target.)rWr$s r%r`Statement.targets||r(c.URR$)z*:class:`mysqlx.Schema`: The Schema object.)rWschemards r%rgStatement.schemas||"""r(cUR$)z@Returns this statement ID. Returns: int: The statement ID. r[rds r%stmt_idStatement.stmt_ids}}r(cXlgr!rjr$values r%rkrl r(cUR$)z5int: The number of times this statement was executed.r\rds r% exec_counterStatement.exec_counters!!!r(cUR$)z+bool: `True` if this statement has changes.r]rds r%changedStatement.changeds}}r(cXlgr!rvrns r%rwrxrpr(cUR$)z1bool: `True` if this statement has been prepared.r^rds r%preparedStatement.prepareds~~r(cXlgr!r{rns r%r|r}sr(c URS:$)z;bool: `True` if this statement was executed more than once.r rrrds r%repeatedStatement.repeateds!!A%%r(cUR$)z9bool: `True` to deallocate + prepare + execute statement.r_rds r%deallocate_prepare_execute$Statement.deallocate_prepare_executes///r(cXlgr!rrns r%rrs+0(r(cUR$)zSCheck if it is document based. Returns: bool: `True` if it is document based. )rXrds r% is_doc_basedStatement.is_doc_baseds r(c.U=RS- slg)z@Increments the number of times this statement has been executed.r Nrrrds r%increment_exec_counter Statement.increment_exec_counters ar(cSUlg)z[TU]XS9 0Ul0UlSUlSUlSUlSUlSUlSUl SUl SUl SUl SUl SUlSUlSUlSUlSUlSUlSUlSUlU(aUR-U5 gg)Nr`rarF)superr& _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_wherer$r`ra condition __class__s r%r&FilterableStatement.__init__ s <,.68.2 "$  #$%)$&  !   "(,"'$"' %$)# $  OOI & r(c"[U[5(a)UR[U5R 55 g[U[5(a URUR 55 g[U[ 5(a_[ R"U5n[U[5(d[eUR5HnURXBU5 M g[S5e![an[S5UeSnAff=f)zBind 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 bindNz%Invalid JSON string or object to bind) r4dictbindr as_strstrjsonloads ValueErrorrkeys)r$objreserrkeys r% _bind_single FilterableStatement._bind_single.s c4 IIeCj'') * U # # IIcjjl # S ! ! Ojjo!#t,,$$-xxz #3x("##JK K  O&'DE3N Os 1C33 D= D  DcSUlSR[U65Ul[ URUR (+5R 5UlSUlU$)zSets the sorting criteria. Args: *clauses: The expression strings defining the sort criteria. Returns: mysqlx.FilterableStatement: FilterableStatement object. T,) rrGr8rrrXparse_order_specrr]r$clausess r%_sortFilterableStatement._sortHsV /7";<$ NN/      r(cSUlXl[XR(+5nUR 5UlURUl SUl U$![ an[S5UeSnAff=f)zSets the search condition to filter. Args: condition (str): Sets the search condition to filter documents or records. Returns: mysqlx.FilterableStatement: FilterableStatement object. TzInvalid conditionN) rrrrXr#rrrplaceholder_name_to_positionrr])r$rr#rs r%rFilterableStatement._set_whereYss# Ai__)<=D#yy{D !==   A"#67S @ As/A A3" A..A3c[U6nSUlSRU5Ul[ URUR (+5R 5UlSUlg)z2Set group by. Args: *fields: List of fields. TrN) r8rrGrrrXparse_expr_listrr]r$fieldss r% _set_group_by!FilterableStatement._set_group_bynsY !&)  XXf-#   DOO 3 /   r(czSUl[XR(+5R5UlSUlg)z7Set having. Args: condition (str): The condition. TN)rrrXr#rr]r$rs r% _set_havingFilterableStatement._set_having|s. !)-@AFFH  r(c[U6nSUlSRU5Ul[ URUR (+5R 5UlSUlU$)zySet the projection. Args: *fields: List of fields. Returns: :class:`mysqlx.FilterableStatement`: Returns self. Tr) r8rrGrrrXparse_table_select_projectionrr]rs r%_set_projection#FilterableStatement._set_projections`!&)""xx/ *  doo"5! ' ' )   r(cUR$zTReturns the binding map dictionary. Returns: dict: The binding map dictionary. rrds r%get_binding_map#FilterableStatement.get_binding_map    r(cUR$zDReturns the bindings list. Returns: `list`: The bindings list. rrds r% get_bindings FilterableStatement.get_bindings ~~r(cUR$)zZReturns the grouping expression list. Returns: `list`: The grouping expression list. )rrds r% get_grouping FilterableStatement.get_groupingrr(cUR$)zLReturns the having expression. Returns: object: The having expression. )rrds r% get_havingFilterableStatement.get_having ||r(cUR$)zEReturns the limit row count. Returns: int: The limit row count. )rrds r%get_limit_row_count'FilterableStatement.get_limit_row_counts $$$r(cUR$)z?Returns the limit offset. Returns: int: The limit offset. )rrds r%get_limit_offset$FilterableStatement.get_limit_offsets !!!r(cUR$)zJReturns the where expression. Returns: object: The where expression. )rrds r%get_where_expr"FilterableStatement.get_where_expr r(cUR$)zTReturns the projection expression. Returns: object: The projection expression. )rrds r%get_projection_expr'FilterableStatement.get_projection_exprs$$$r(cUR$)zHReturns the sort expression. Returns: object: The sort expression. )rrds r% get_sort_expr!FilterableStatement.get_sort_exprsr(8.0.12c$URU5$)zSets 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 r%whereFilterableStatement.wheresy))r(c UR"U6$)zSets the sorting criteria. Args: *clauses: The expression strings defining the sort criteria. Returns: mysqlx.FilterableStatement: FilterableStatement object. .. deprecated:: 8.0.12 rrs r%sortFilterableStatement.sortszz7##r(cf[U[5(aUS:a [S5eUR(d;[ UR S:H5Ul[ UR S:X+5UlXlSUlU(a*URU5 [R"S[S9 U$)a<Sets 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) r4rrrrr\r]r_roffsetwarningswarnDeprecationWarning)r$ row_countrs r%limitFilterableStatement.limits")S))Y]OP P~~ !3!3q!89DM/38J8Ja4O/PD , )  KK  MM,    r(c^[U[5(aUS:a [S5eXlU$)zSets 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)r4rrr)r$rs r%rFilterableStatement.offset$s.&#&&&1*LM M# r(cSUl[U5nUS:XaURUS5 U$US:XaUSURUS'U$[ S5e)a`Binds 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. Tr r#Invalid number of arguments to bind)rr3rrr)r$argscounts r%rFilterableStatement.bind7si!D  A:   d1g &  aZ&*1gDNN47 # ##HI Ir(c[errrds r%rFilterableStatement.executeOrr()rrr]r_rrrrrrrrrrrrrrrrrrTNr`rrarr Optional[str]r)r*)rz!Union[DbDoc, Dict[str, Any], str]r)r*)rrr)r)rrr)r)rrr)r*)rrr)r*)rrr)rr)Dict[str, Any])r)zUnion[Dict[str, Any], List])r)z9List[Union[ProtobufMessageType, ProtobufMessageCextType]])r)rrr!)rrrz Optional[int]r)r)rrr)r)r!rr)rr)r+r,r-r.r/r&rrrrrrrrrrrrrrrrr rrrrrr0 __classcell__rs@r%rrs #' "'""'"'! "'  "'"'HL4"* $!%" % B% B * * $ $7;!!&3! !F&0""r(rcl^\rSrSrSrS U4Sjjr\S Sj5rS SjrS Sjr SSjr SSjr S r U=r $) SqlStatementiXzA statement for SQL execution. Args: connection (mysqlx.connection.Connection): Connection object. sql (string): The sql statement to be executed. cr>[TU]SSS9 XlX lSUl/UlSUlSUlgNFr)rr&rZ_sqlrrrr)r$ connectionsqlrs r%r&SqlStatement.__init__`s> 6+5 6:-/"'$r(cUR$)zstring: The SQL text statement.)r1rds r%r3SqlStatement.sqlisyyr(cUR$rrrds r%rSqlStatement.get_binding_mapnrr(cUR$rrrds r%rSqlStatement.get_bindingsvrr(c[U5S:Xa [S5eSUl[U6n[ U[ [ 45(aX lU$URRU5 U$)zBinds value(s) to a specific placeholder(s). Args: *args: The value(s) to bind. Returns: mysqlx.SqlStatement: SqlStatement object. rr T) r3rrr8r4r5r6rappend)r$r!bindingss r%rSqlStatement.bind~sc t9>"#HI I "D) hu . .%N  NN ! !( + r(c8URRU5$)zIExecute the statement. Returns: mysqlx.SqlResult: SqlResult object. )rZsend_sqlrds r%rSqlStatement.executes ((..r()rrrZr1rr)r2rr3rr)r*r)rr))r)zUnion[Tuple, List])r!rr)r.)r)r)r+r,r-r.r/r&rr3rrrrr0r+r,s@r%r.r.Xs:%!&//r(r.cH^\rSrSrSrSU4SjjrSSjrS SjrSrU=r $) WriteStatementiz*Provide common write operation attributes.c2>[TU]X5 /Ulgr!)rr&_values)r$r`rars r%r&WriteStatement.__init__s +  r(cUR$)zFReturns the list of values. Returns: `list`: The list of values. rFrds r% get_valuesWriteStatement.get_valuess ||r(c[errrds r%rWriteStatement.executerr(rIr)r)zpList[Union[int, str, DbDoc, Dict[str, Any], List[Optional[Union[str, int, float, ExprParser, Dict[str, Any]]]]]]r) r+r,r-r.r/r&rJrr0r+r,s@r%rDrDs$4  $""r(rDc\^\rSrSrSrS U4SjjrS SjrS S SjjrS SjrSSjr Sr U=r $) AddStatementizuA statement for document addition on a collection. Args: collection (mysqlx.Collection): The Collection object. cB>[TU]US5 SUl/Ulg)NTF)rr&_upsertids)r$ collectionrs r%r&AddStatement.__init__s  T*" r(cUR$)zPReturns `True` if it's an upsert. Returns: bool: `True` if it's an upsert. rQrds r% is_upsertAddStatement.is_upsertrr(cXlU$)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. rVrns r%upsertAddStatement.upserts  r(c[U6HYn[U[5(aURR U5 M5URR [U55 M[ U$)zAdds a list of documents into a collection. Args: *values: The documents to be added into the collection. Returns: mysqlx.AddStatement: AddStatement object. )r8r4r rFr<)r$r7vals r%addAddStatement.addsO#F+C#u%% ##C( ##E#J/ ,  r(c~[UR5S:Xa [5$URR U5$)CExecute the statement. Returns: mysqlx.Result: Result object. r)r3rFrrZ send_insertrds r%rAddStatement.executes3 t||  !8O++D11r()rQrR)rSrr)r*rr)rorr)rO)r7r r)rOr)r) r+r,r-r.r/r&rWrZr^rr0r+r,s@r%rOrOs&    2 2r(rOc0\rSrSrSrSSSjjrS SjrSrg) UpdateSpecizUpdate 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. NcU[S5:XaURX#5 gXl[US5R 5R UlX0l g![an[U5UeSnAff=f)N*Mysqlx.Crud.UpdateOperation.UpdateType.SETF) r _table_set update_typerdocument_fieldr>sourcerrro)r$rjrlrors r%r&UpdateSpec.__init__ sl -(TU U OOF *$/  :#-fe#<#K#K#M#X#X $J :&#0c9 :s)A A5# A00A5cn[S5Ul[US5R5UlX lg)zLTable set. Args: source (str): The source. value (str): The value. rhTN)rrjrparse_table_update_fieldrlro)r$rlros r%riUpdateSpec._table_sets.))UV .GGI  r()rlrjror!)rjrrlrrorr)r*)rlrrorr)r*)r+r,r-r.r/r&rir0r1r(r%rfrfs  $ r(rfc^\rSrSrSrSU4SjjrSSjrSSjrSSjr\ "S5SSj5r SS jr SS jr SS jr SS jrSS jrSrU=r$)ModifyStatementi"a9A 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. c.>[TU]XS9 0UlgN)r`rrr& _update_opsr$rSrrs r%r&ModifyStatement.__init__.s  @+-r(c UR"U6$)zSets the sorting criteria. Args: *clauses: The expression strings defining the sort criteria. Returns: mysqlx.ModifyStatement: ModifyStatement object. rrs r%rModifyStatement.sort2zz7##r(cUR$z\Returns the list of update operations. Returns: `list`: The list of update operations. rvrds r%get_update_opsModifyStatement.get_update_ops=rr(cZ[[S5UU5URU'SUlU$)aSets 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_SETTrfrrvr]r$doc_pathros r%setModifyStatement.setEs6&0 K L  & "   r(r cZ[[S5UU5URU'SUlU$)aJAdd 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_REPLACETrrs r%changeModifyStatement.changeWs6&0 O P  & "   r(cv[U6H%n[[S5U5URU'M' SUlU$)zRemoves 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)r8rfrrvr])r$ doc_pathsitems r%unsetModifyStatement.unsetmsB$Y/D%/RS&D  T "0   r(cZ[[S5UU5URU'SUlU$)aDInsert 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_INSERTTrr$fieldros r% array_insertModifyStatement.array_inserts6#- O P  #    r(cZ[[S5UU5URU'SUlU$)axInserts 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_APPENDTrrs r% array_appendModifyStatement.array_appends6&0 O P  & "   r(cUcSn[U[[[[45(d [ S5e[ [S5S[U[5(aUR5OU5URS'SUl U$)abTakes 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. rz>Invalid data for update operation on document collection tablez2Mysqlx.Crud.UpdateOperation.UpdateType.MERGE_PATCH$patchT) r4rrr rrrfrr#rvr])r$docs r%rModifyStatement.patchs| ;C# D%=>>"P %/ N O $S*55CHHJ3% !   r(cpUR(d [S5eURRU5$)|Execute the statement. Returns: mysqlx.Result: Result object. Raises: ProgrammingError: If condition was not set. z!No condition was found for modifyrrrZ send_updaterds r%rModifyStatement.execute.~~"#FG G++D11r(r]rvrSrrrr)r*)rrr)rrr))rrrorr)rr)rrr)rr)rrrorr)rr)rz#Union[Dict, DbDoc, ExprParser, str]r)rrrd)r+r,r-r.r/r&rrrrrrrrrrr0r+r,s@r%rrrr"sS . $ $*$(*4 2 2r(rrc^\rSrSrSrSSU4Sjjjr\SSj5rSSjrSSjr SSjr \ R4SSjjr \ R4SS jjrSS jrSS jrSS jrS rU=r$) ReadStatementiaProvide 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. cl>[TU]XU5 SUlSUl[R UlgNF)rr&_lock_exclusive _lock_sharedr DEFAULT_lock_contentionrs r%r&ReadStatement.__init__s2 I6%*"'0>0F0Fr(cUR$)z::class:`mysqlx.LockContention`: The lock contention value.)rrds r%lock_contentionReadStatement.lock_contentions$$$r(cx[UR5nXlg![an[S5UeSnAff=f)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 rorrr)r$r_rs r%_set_lock_contention"ReadStatement._set_lock_contentionsD 445A !0  "M  s 9 49cUR$)zZReturns `True` if is `EXCLUSIVE LOCK`. Returns: bool: `True` if is `EXCLUSIVE LOCK`. )rrds r%is_lock_exclusiveReadStatement.is_lock_exclusives ###r(cUR$)zTReturns `True` if is `SHARED LOCK`. Returns: bool: `True` if is `SHARED LOCK`. )rrds r%is_lock_sharedReadStatement.is_lock_sharedrr(cDSUlSUlURU5 U$)zExecute a read operation with `SHARED LOCK`. Only one lock can be active at a time. Args: lock_contention (:class:`mysqlx.LockContention`): Lock contention. FTrrrr$rs r% lock_sharedReadStatement.lock_shareds' %  !!/2 r(cDSUlSUlURU5 U$)zExecute a read operation with `EXCLUSIVE LOCK`. Only one lock can be active at a time. Args: lock_contention (:class:`mysqlx.LockContention`): Lock contention. TFrrs r%lock_exclusiveReadStatement.lock_exclusives' $! !!/2 r(c$UR"U6 U$)zSets a grouping criteria for the resultset. Args: *fields: The string expressions identifying the grouping criteria. Returns: mysqlx.ReadStatement: ReadStatement object. )rrs r%group_byReadStatement.group_by*s F# r(c(URU5 U$)aSets 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%havingReadStatement.having6s # r(c8URRU5$ra)rZ send_findrds r%rReadStatement.executeDs ))$//r()rrrr&r')r)r )rr r)r*r)rr r)r)rrr)r)rrr)r)r)zUnion[DocResult, RowResult])r+r,r-r.r/r&rrrrrr rrrrrrr0r+r,s@r%rrs #' G" G G! G  G G%%0$$!1?0F0F -   1?0F0F -     00r(rcT^\rSrSrSrSSU4SjjjrS SjrS SjrSrU=r $) FindStatementiMaA 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. c(>[TU]USU5 g)NTrr&rws r%r&FindStatement.__init__Xs T95r(c UR"U6$)zSets a document field filter. Args: *fields: The string expressions identifying the fields to be extracted. Returns: mysqlx.FindStatement: FindStatement object. )rrs r%rFindStatement.fields]s##V,,r(c UR"U6$zSets the sorting criteria. Args: *clauses: The expression strings defining the sort criteria. Returns: mysqlx.FindStatement: FindStatement object. rrs r%rFindStatement.sortir{r(r1r!)rSrrr(r)r*)rrr)r)rrr)r) r+r,r-r.r/r&rrr0r+r,s@r%rrMs@JN6,69F6 66 - $ $r(rcN^\rSrSrSrSU4SjjrS SjrS SjrS SjrSr U=r $) SelectStatementiuzA statement for record retrieval operations on a Table. Args: table (mysqlx.Table): The Table object. *fields: The fields to be retrieved. cD>[TU]US5 UR"U6 gr)rr&rr$tablerrs r%r&SelectStatement.__init__}s  & f%r(c$URU5$)zSets the search condition to filter. Args: condition (str): Sets the search condition to filter records. Returns: mysqlx.SelectStatement: SelectStatement object. r rs r%r SelectStatement.wherey))r(c UR"U6$)zSets the order by criteria. Args: *clauses: The expression strings defining the order by criteria. Returns: mysqlx.SelectStatement: SelectStatement object. rrs r%order_bySelectStatement.order_byr{r(c UR(aSUR3OSnUR(aSUR3OSnUR(aSUR 3OSnUR (aSUR3OSnUR(aSURSUR3OSnSUR=(d S S URRS URRUUUUU3 nU$) zAReturns the generated SQL. Returns: str: The generated SQL. z WHERE rz GROUP BY z HAVING z ORDER BY z LIMIT z OFFSET zSELECT *z FROM rF)rrrrrrrrrrrrrgnamer`)r$r rrrrstmts r%get_sqlSelectStatement.get_sqls 04~~'$//*+28<8I8IZ 2 234r.2oo8DLL>*248MMZ/0r~~d++,HT5G5G4H I  d**1c23KK$$%Qt{{'7'7&8ghZxz% :  r(r1)rrrrr)r*)rrr)r)rrr)rrB) r+r,r-r.r/r&r rrr0r+r,s@r%rrus!& * $r(rcD^\rSrSrSrSU4SjjrSSjrS SjrSrU=r $) InsertStatementizA statement for insert operations on Table. Args: table (mysqlx.Table): The Table object. *fields: The fields to be inserted. c@>[TU]US5 [U6Ulgr)rr&r8_fieldsrs r%r&InsertStatement.__init__s &+:F+C r(cZURR[[U655 U$)zSet the values to be inserted. Args: *values: The values of the columns to be inserted. Returns: mysqlx.InsertStatement: InsertStatement object. )rFr<r5r8)r$r7s r%r7InsertStatement.valuess% D&!9:; r(c8URRU5$r)rZrbrds r%rInsertStatement.executes ++D11r()r)rrrrr)r*)r7rr)rrd) r+r,r-r.r/r&r7rr0r+r,s@r%rrsD 22r(rcb^\rSrSrSrS U4SjjrS SjrS SjrS SjrSSjr SSjr S r U=r $)UpdateStatementizA statement for record update operations on a Table. Args: table (mysqlx.Table): The Table object. .. versionchanged:: 8.0.12 The ``fields`` parameters were removed. c0>[TU]USS9 0Ulgr0rur$rrs r%r&UpdateStatement.__init__s 7+-r(c$URU5$)zSets the search condition to filter. Args: condition (str): Sets the search condition to filter records. Returns: mysqlx.UpdateStatement: UpdateStatement object. r rs r%r UpdateStatement.whererr(c UR"U6$)zSets the order by criteria. Args: *clauses: The expression strings defining the order by criteria. Returns: mysqlx.UpdateStatement: UpdateStatement object. rrs r%rUpdateStatement.order_byr{r(cUR$r}r~rds r%rUpdateStatement.get_update_opsrr(cZ[[S5UU5URU'SUlU$)zUpdates 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. rhTrrs r%rUpdateStatement.sets6#- F G  #    r(cpUR(d [S5eURRU5$)z{Execute the statement. Returns: mysqlx.Result: Result object Raises: ProgrammingError: If condition was not set. z!No condition was found for updaterrds r%rUpdateStatement.execute rr(rrrr)r*)rrr)r)rrr)rr))rrrorr)rrd) r+r,r-r.r/r&r rrrrr0r+r,s@r%rrs+. * $ $ 2 2r(rcD^\rSrSrSrSU4SjjrSSjrS SjrSrU=r $) RemoveStatementia)A 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 >[TU]XS9 grtrrws r%r&RemoveStatement.__init__'s  @r(c UR"U6$rrrs r%rRemoveStatement.sort*r{r(cpUR(d [S5eURRU5$)rz!No condition was found for removerrrZ send_deleterds r%rRemoveStatement.execute5rr(r1r)rrr)rrd) r+r,r-r.r/r&rrr0r+r,s@r%rrs A $ 2 2r(rcN^\rSrSrSrSU4SjjrS SjrS SjrS SjrSr U=r $) DeleteStatementiCzA statement that drops a table. Args: table (mysqlx.Table): The Table object. .. versionchanged:: 8.0.12 The ``condition`` parameter was removed. c">[TU]USS9 gr0rrs r%r&DeleteStatement.__init__Ms 7r(c$URU5$)zSets the search condition to filter. Args: condition (str): Sets the search condition to filter records. Returns: mysqlx.DeleteStatement: DeleteStatement object. r rs r%r DeleteStatement.wherePrr(c UR"U6$)zSets the order by criteria. Args: *clauses: The expression strings defining the order by criteria. Returns: mysqlx.DeleteStatement: DeleteStatement object. rrs r%rDeleteStatement.order_by[r{r(cpUR(d [S5eURRU5$)rz!No condition was found for deleterrds r%rDeleteStatement.executefrr(r1r)rrr)r )rrr)r rd) r+r,r-r.r/r&r rrr0r+r,s@r%r r Cs!8 * $ 2 2r(r cJ^\rSrSrSrSU4SjjrSSjrSrU=r$)CreateCollectionIndexStatementitaA 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} c>[TU]US9 [R"U5UlX lURR S/5Ulg)N)r`r)rr&copydeepcopy _index_desc _index_namepop _fields_desc)r$rS index_name index_descrs r%r&'CreateCollectionIndexStatement.__init__sH  ++/==+D *262B2B2F2FxQS2Tr(c URc([[RUR55e[ UR5R 5R 5n[U[5(a;US[S5:wa([[RUR55eOBUR[S5:wa([[RUR55eUR(d[SUR35e[UR[5(d [S5e0nURUS'UR R"US'UR R$R"US'SUR;aURR'S5US'OS US'URR'S S 5US 'US (a [)S 5e/US 'UR(a[SUR35eURGHn0nUR'S5US'UR'S5US'UR'SS 5US'UR'SS 5US'[US[*5(d [-S5e[US[*5(d [-S5eUSR/5S:XaUS(d [S5eUSR/5S :XaUSS:Xa [S5eSU;a[USR/5R1S5(d [SUSR/5S35eUR'S5US'SU;a6USR/5S:wa [S5eUR'S5US'SU;a6USR/5S:wa [S 5eUR'S5US'US R3U5 GM URHnU(dM [S#U35e UR6R9S$S%S&U5$![[4a.n[[RUR55UeSnAff=f![4an[S!US"W35UeSnAff=f)'raNtypezMysqlx.Expr.Expr.Type.IDENTzCRequired member 'fields' not found in the given index description: z,Required member 'fields' must contain a listrrSrgINDEXuniqueFz!Unique indexes are not supported. constraintzUnidentified fields: rmemberrequiredarrayz'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_messager4rrr"rAttributeErrorrrr5rWrrgrrr TypeErrorupper startswithr<KeyErrorrZexecute_nonquery)r$ parsed_identrr! field_descr%s r%r&CreateCollectionIndexStatement.executes    #"#9#@#@AQAQ#RS S %d&6&67<<>JJLL,--'=9V+WW*.55d6F6FGX  $$ 6S(TT*.55d6F6FGU  " $ 0 013  $++T22"#QR R!''V !\\..\,,11X T%% %++//7DL"DL))--h>X >#$GH H\   "%:4;K;K:L#MN N1 "//  '1~~g'> 8$%/^^F%; 6")3 E)J :&&0nnWe&D 7#!*Z"8$??#$MNN!*W"5t<<#$JKK<%%'94Z =S*9<%%'72z&7IY7V*3*,%f-335@@HH. *6 2 8 8 :;1> /9nn[.IJ{+ *!&)//1Y>.=-7NN9,EJy)Z'!&)//1Y>.7*4)?Jv&\"))*5Y0d++Jz&)DZL'QRR,00 /t  mN+ "&--d.>.>?  Z "(-G |T  s8BQ*8AQ*1G3R+*R(:)R##R(+ S 5SS )rrr)rSrrrrr*r)r*rd) r+r,r-r.r/r&rr0r+r,s@r%rrtsD, U& U U# U  Up p r(r)r7rr)zUnion[List, Tuple])r)r>rr?rr)r)r>rr?rr)r)rHz Iterable[str]r?rr)r)rMrrNrr?rr)zTuple[str, str])=r/ __future__rrrrtypingrrrrrr r constantsr dbdocr errorsrrr#rhelpersrprotobufrresultrrrrtypesrrrrrrr2rr8r@rDrIrRrTrr.rDrOrfrrrrrrrrr rr1r(r%rGsa>$" DDD%7#;;B:"(  ;=%(47,g"g"TW")W"t ?/9?/D'"Y'"T82>82v  Fk2)k2\z0'z0z%$M%$P6m6r2n2BI2)I2X%2)%2P.2).2bR YR r(