@icrdZddlmZddlZddlZddlZddlmZmZm 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(d4dZ)d5d6dZ*d5d7dZ+d5d8dZ, d5 d9dZ-GddZ.Gdde.Z/Gdde.Z0Gdde.Z1Gdde1Z2Gd d!Z3Gd"d#e/Z4Gd$d%e/Z5Gd&d'e5Z6Gd(d)e5Z7Gd*d+e1Z8Gd,d-e/Z9Gd.d/e/Z:Gd0d1e/Z;Gd2d3e.ZB3)> qMS :Z^s%:  a=C  9JrNc$99r%ct|dk(ryd|vr|jdd}d|dS|jdd}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``r5r8z""r6)r.replace)r9r:quoteds r#quote_identifierr?[s[ :! ##C.6(!}   T *F vha=r%c ^dj|Dcgc]}t||c}Scc}w)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. .)joinr?) identifiersr:r9s r#quote_multipart_identifierrDos. 88BMNJ *h /N Ns*cd|vrdnd}||vrd|nd}|j|d}t|dk(r|n|dj||dj|fS)zParse table name. Args: default_schema (str): The default schema. table_name (str): The table name. sql_mode(Optional[str]): The SQL mode. Returns: str: The parsed table name. r5r8r6rAr rr7)splitr.strip)default_schema table_namer:quote delimitertemps r#parse_table_namerM~sn!H,C#E$ 2!E7 I   Iq )Dd)q.d1gmmE.B Ru r%cbeZdZdZdddZeddZeddZeddZejddZeddZ eddZ e jdd Z edd Z e jdd Z edd Z edd ZejddZddZddZddZddZy) 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. c||_||_|r|jnd|_d|_d|_d|_d|_d|_y)NrTF) _target _doc_basedget_connection _connection_stmt_id _exec_counter_changed _prepared_deallocate_prepare_execute)r"target doc_baseds r#r$zStatement.__init__sO+1 )'-F ! ! #4 (, "#" $16(r%c|jS)z#object: The database object target.)rQr"s r#rZzStatement.targets||r%c.|jjS)z*:class:`mysqlx.Schema`: The Schema object.)rQschemar]s r#r_zStatement.schemas||"""r%c|jS)zXReturns this statement ID. Returns: int: The statement ID. rUr]s r#stmt_idzStatement.stmt_ids}}r%c||_yr rar"values r#rbzStatement.stmt_id  r%c|jS)z5int: The number of times this statement was executed.rVr]s r# exec_counterzStatement.exec_counters!!!r%c|jS)z+bool: `True` if this statement has changes.rWr]s r#changedzStatement.changeds}}r%c||_yr rkrds r#rlzStatement.changedrfr%c|jS)z1bool: `True` if this statement has been prepared.rXr]s r#preparedzStatement.prepareds~~r%c||_yr rords r#rpzStatement.prepareds r%c |jdkDS)z;bool: `True` if this statement was executed more than once.r rhr]s r#repeatedzStatement.repeateds!!A%%r%c|jS)z9bool: `True` to deallocate + prepare + execute statement.rYr]s r#deallocate_prepare_executez$Statement.deallocate_prepare_executes///r%c||_yr rurds r#rvz$Statement.deallocate_prepare_executes +0(r%c|jS)zkCheck if it is document based. Returns: bool: `True` if it is document based. )rRr]s r# is_doc_basedzStatement.is_doc_baseds r%c.|xjdz c_y)z@Increments the number of times this statement has been executed.r Nrhr]s r#increment_exec_counterz Statement.increment_exec_counters ar%cd|_y)z"#HI I "D) hu .%DN  NN ! !( + r%c8|jj|S)zaExecute the statement. Returns: mysqlx.SqlResult: SqlResult object. )rTsend_sqlr]s r#rzSqlStatement.executes ((..r%)rrr rr&r'r&rr)r&zUnion[Tuple, List])rrr&r)r&r) r(r)r*r+r$rr rrrrrrs@r#rrXs5%!&/r%rc8eZdZdZdfd Z ddZddZxZS)WriteStatementz*Provide common write operation attributes.c4t|||g|_yr )rr$_values)r"rZr[rs r#r$zWriteStatement.__init__s +  r%c|jS)z^Returns the list of values. Returns: `list`: The list of values. )rr]s r# get_valueszWriteStatement.get_valuess ||r%ctrrr]s r#rzWriteStatement.executerr%r)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$rrrrs@r#rrs4  $"r%rcFeZdZdZdfd ZddZd d dZd dZd dZxZ S) AddStatementzA statement for document addition on a collection. Args: collection (mysqlx.Collection): The Collection object. cBt||dd|_g|_y)NTF)rr$_upsertids)r" collectionrs r#r$zAddStatement.__init__s  T*" r%c|jS)zhReturns `True` if it's an upsert. Returns: bool: `True` if it's an upsert. rr]s r# is_upsertzAddStatement.is_upsertrr%c||_|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!rds r#upsertzAddStatement.upserts  r%ct|D]R}t|tr|jj |/|jj t|T|S)zAdds a list of documents into a collection. Args: *values: The documents to be added into the collection. Returns: mysqlx.AddStatement: AddStatement object. )r3r/r rr)r"r2vals r#addzAddStatement.addsQ#F+ 0C#u% ##C( ##E#J/  0  r%c|t|jdk(r tS|jj |S)[Execute the statement. Returns: mysqlx.Result: Result object. r)r.rrrT send_insertr]s r#rzAddStatement.executes3 t||  !8O++D11r%)rrr&r'rr)rerr&r)r2r r&rr&r) r(r)r*r+r$r"r$r'rrrs@r#rrs!    2r%rc"eZdZdZdddZddZy) 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. Nc|tdk(r|j||y||_ t|dj j |_||_ y#t$r}t||d}~wwxYw)N*Mysqlx.Crud.UpdateOperation.UpdateType.SETF) r _table_set update_typerdocument_fieldr9sourcerrre)r"r1r3rers r#r$zUpdateSpec.__init__ sr -(TU U OOFE *$/D  :#-fe#<#K#K#M#X#X $DJ :&#0c9 :s)A A6$ A11A6cptd|_t|dj|_||_y)zlTable set. Args: source (str): The source. value (str): The value. r/TN)rr1rparse_table_update_fieldr3re)r"r3res r#r0zUpdateSpec._table_sets0))UV .GGI  r%r )r1rr3rrerr&r')r3rrerr&r')r(r)r*r+r$r0r,r%r#r-r-s  $ r%r-ceZdZdZd fd ZddZddZddZedddZ ddZ dd Z dd Z dd Z dd ZxZS)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. c6t|||i|_yN)rZrrr$ _update_opsr"rrrs r#r$zModifyStatement.__init__.s  i@+-r%c |j|S)zSets the sorting criteria. Args: *clauses: The expression strings defining the sort criteria. Returns: mysqlx.ModifyStatement: ModifyStatement object. rrs r#rzModifyStatement.sort2tzz7##r%c|jSztReturns the list of update operations. Returns: `list`: The list of update operations. r;r]s r#get_update_opszModifyStatement.get_update_ops=rr%cZttd|||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_SETTr-rr;rWr"doc_pathres r#setzModifyStatement.setEs6&0 K L  & "   r%rcZttd|||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_REPLACETrDrEs r#changezModifyStatement.changeWs6&0 O P  & "   r%crt|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)r3r-rr;rW)r" doc_pathsitems r#unsetzModifyStatement.unsetmsG$Y/ D%/RS&D  T "    r%cZttd|||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_INSERTTrDr"fieldres r# array_insertzModifyStatement.array_inserts6#- O P  #    r%cZttd|||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_APPENDTrDrEs r# array_appendzModifyStatement.array_appends6&0 O P  & "   r%c|d}t|ttttfs t dt tddt|tr|jn||jd<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. rz>Invalid data for update operation on document collection tablez2Mysqlx.Crud.UpdateOperation.UpdateType.MERGE_PATCH$patchT) r/rrr rrr-rr!r;rW)r"docs r#rVzModifyStatement.patchsv ;C# D%=>"P %/ N O $S*5CHHJ3% !   r%cf|js td|jj|S)Execute the statement. Returns: mysqlx.Result: Result object. Raises: ProgrammingError: If condition was not set. z!No condition was found for modifyrrrT send_updater]s r#rzModifyStatement.execute.~~"#FG G++D11r%rrrrr&r')rrr&r7r)rFrrerr&r7)rKrr&r7)rPrrerr&r7)rWz#Union[Dict, DbDoc, ExprParser, str]r&r7r+)r(r)r*r+r$rrBrGrrIrMrQrSrVrrrs@r#r7r7"sN . $ $*$(*4 2r%r7ceZdZdZ d d fd ZeddZddZddZddZ e jf ddZ e jf ddZ dd Zdd Zdd 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. cnt||||d|_d|_tj |_yNF)rr$_lock_exclusive _lock_sharedr DEFAULT_lock_contentionrs r#r$zReadStatement.__init__s4 I6%*"'0>0F0Fr%c|jS)z::class:`mysqlx.LockContention`: The lock contention value.)rer]s r#lock_contentionzReadStatement.lock_contentions$$$r%cx t|j}||_y#t$r}td|d}~wwxYw)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 rerrre)r"rg_rs r#_set_lock_contentionz"ReadStatement._set_lock_contentionsF 445A !0  "M  s 9 49c|jS)zrReturns `True` if is `EXCLUSIVE LOCK`. Returns: bool: `True` if is `EXCLUSIVE LOCK`. )rbr]s r#is_lock_exclusivezReadStatement.is_lock_exclusives ###r%c|jS)zlReturns `True` if is `SHARED LOCK`. Returns: bool: `True` if is `SHARED LOCK`. )rcr]s r#is_lock_sharedzReadStatement.is_lock_sharedrr%cDd|_d|_|j||S)zExecute a read operation with `SHARED LOCK`. Only one lock can be active at a time. Args: lock_contention (:class:`mysqlx.LockContention`): Lock contention. FTrbrcrjr"rgs r# lock_sharedzReadStatement.lock_shareds' %  !!/2 r%cDd|_d|_|j||S)zExecute a read operation with `EXCLUSIVE LOCK`. Only one lock can be active at a time. Args: lock_contention (:class:`mysqlx.LockContention`): Lock contention. TFrprqs r#lock_exclusivezReadStatement.lock_exclusives' $! !!/2 r%c$|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%c(|j||S)a=Sets a condition for records to be considered in agregate function operations. Args: condition (string): A condition on the agregate functions used on the grouping criteria. Returns: mysqlx.ReadStatement: ReadStatement object. )rrs r#havingzReadStatement.having6s # r%c8|jj|Sr))rT send_findr]s r#rzReadStatement.executeDs ))$//r%rr)r&r )rgr r&r'r)rgr r&r_)rrr&r_)rrr&r_)r&zUnion[DocResult, RowResult])r(r)r*r+r$rrgrjrlrnr rdrrrtrvrxrrrs@r#r_r_s #' G" G G! G  G%%0$$!1?0F0F -   1?0F0F -     0r%r_cBeZdZdZ d dfd ZddZddZxZS) 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. c(t||d|y)NTrr$r<s r#r$zFindStatement.__init__Xs T95r%c |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%c |j|SzSets the sorting criteria. Args: *clauses: The expression strings defining the sort criteria. Returns: mysqlx.FindStatement: FindStatement object. rrs r#rzFindStatement.sortir>r%r )rrrrr&r')rrr&r})rrr&r})r(r)r*r+r$rrrrs@r#r}r}Ms6JN6,69F6 6 - $r%r}c<eZdZdZdfd ZddZddZd dZxZS) SelectStatementzA statement for record retrieval operations on a Table. Args: table (mysqlx.Table): The Table object. *fields: The fields to be retrieved. cDt||d|j|yra)rr$rr"tablerrs r#r$zSelectStatement.__init__}s" &f%r%c$|j|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%c |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_byr>r%c |jrd|jnd}|jrd|jnd}|jrd|j nd}|j rd|jnd}|jrd|jd|jnd}d|jxsd d |jjd |jj||||| }|S) zYReturns 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 rA)rrrrrrrrrrrrr_namerZ)r"rrvrxrrstmts r#get_sqlzSelectStatement.get_sqls 04~~'$//*+28<8I8IZ 2 234r.2oo8DLL>*248MMZ/0r~~d++,HT5G5G4H I  d**1c23KK$$%Qt{{'7'7&8ghZxz% :  r%)rrrrr&r')rrr&r)rrr&rr) r(r)r*r+r$rrrrrs@r#rrus& * $r%rc4eZdZdZdfd ZddZddZxZS)InsertStatementzA statement for insert operations on Table. Args: table (mysqlx.Table): The Table object. *fields: The fields to be inserted. c@t||dt||_yra)rr$r3_fieldsrs r#r$zInsertStatement.__init__s &+:F+C r%cZ|jjtt||S)zSet the values to be inserted. Args: *values: The values of the columns to be inserted. Returns: mysqlx.InsertStatement: InsertStatement object. )rrr0r3)r"r2s r#r2zInsertStatement.valuess% D&!9:; r%c8|jj|Srz)rTr*r]s r#rzInsertStatement.executes ++D11r%)rrrrr&r')r2rr&rr+)r(r)r*r+r$r2rrrs@r#rrsD 2r%rcLeZdZdZdfd Zd dZd dZd dZd dZd dZ 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. c6t||di|_yrr:r"rrs r#r$zUpdateStatement.__init__s 7+-r%c$|j|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%c |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_byr>r%c|jSr@rAr]s r#rBzUpdateStatement.get_update_opsrr%cZttd|||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/TrDrOs r#rGzUpdateStatement.sets6#- F G  #    r%cf|js td|jj|S)zExecute the statement. Returns: mysqlx.Result: Result object Raises: ProgrammingError: If condition was not set. z!No condition was found for updaterZr]s r#rzUpdateStatement.execute r\r%rrr&r')rrr&r)rrr&rr)rPrrerr&rr+) r(r)r*r+r$rrrBrGrrrs@r#rrs&. * $ $ 2r%rc4eZdZdZdfd ZddZddZxZS)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(t|||yr9rr<s r#r$zRemoveStatement.__init__'s  i@r%c |j|Srrrs r#rzRemoveStatement.sort*r>r%cf|js td|jj|S)rYz!No condition was found for removerrrT send_deleter]s r#rzRemoveStatement.execute5r\r%r])rrr&rr+)r(r)r*r+r$rrrrs@r#rrs A $ 2r%rc<eZdZdZdfd ZddZddZd dZxZS) DeleteStatementzA statement that drops a table. Args: table (mysqlx.Table): The Table object. .. versionchanged:: 8.0.12 The ``condition`` parameter was removed. c(t||dyrrrs r#r$zDeleteStatement.__init__Ms 7r%c$|j|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%c |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[r>r%cf|js td|jj|S)rYz!No condition was found for deleterr]s r#rzDeleteStatement.executefr\r%r)rrr&r)rrr&rr+) r(r)r*r+r$rrrrrs@r#rrCs8 * $ 2r%rc<eZdZdZ dfd ZddZxZS)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} ct||tj||_||_|jj dg|_y)N)rZr)rr$copydeepcopy _index_desc _index_namepop _fields_desc)r"r index_name index_descrs r#r$z'CreateCollectionIndexStatement.__init__sJ  ++/==+D *262B2B2F2FxQS2Tr%c |j(ttj|j t |jj j }t|tr9|dtdk7rhttj|j|jtdk7r(ttj|j|jstd|jt|jts tdi}|j|d<|j j"|d<|j j$j"|d<d|jvr|jj'd|d<nd |d<|jj'd d |d <|d r t)d g|d <|jrtd|j |jD]}i}|j'd|d<|j'd|d<|j'dd |d<|j'dd |d<t|dt*s t-dt|dt*s t-d|dj/dk(r|ds td|dj/d k(r|ddk(r tdd|vrV|dj/j1ds td|dj/d|j'd|d<d|vr5|dj/dk7r td|j'd|d<d|vr5|dj/dk7r td |j'd|d<|d j3| |jD]}|std#||j6j9d$d%d&|S#ttf$r.}ttj|j|d}~wwxYw#t4$r}td!|d"|d}~wwxYw)'r)NtypezMysqlx.Expr.Expr.Type.IDENTzCRequired member 'fields' not found in the given index description: z,Required member 'fields' must contain a listrrr_INDEXuniqueFz!Unique indexes are not supported. constraintzUnidentified fields: rPmemberrequiredarrayz'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_messager/rrrrAttributeErrorrrr0rQrr_rrr TypeErrorupper startswithrKeyErrorrTexecute_nonquery)r" parsed_identrr field_descrs r#rz&CreateCollectionIndexStatement.executes    #"#9#@#@AQAQ#RS S %d&6&67<<>JJLL,-'=9V+WW*.55d6F6FG $$ 6S(TT*.55d6F6FG  " $ 0 013  $++T2"#QR R!''V !\\..\,,11X T%% %++//7DL"DL))--h>X >#$GH H\   "%:4;K;K:L#MN N1 "//, 6  '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@@H. *6 2 8 8 :;1> /9nn[.IJ{+ *!&)//1Y>.=-7NN9,EJy)Z'!&)//1Y>.7*4)?Jv&\"))*5Y, 6d++ SJ&)DZL'QRR S00 /t  mN+ "&--d.>.>?  Z "(-G |T  s1B:P#GQ##Q 2)QQ # R,Q>>R)rrrrrrr&r'r+)r(r)r*r+r$rrrs@r#rrts>, U& U U# U  Up r%r)r2rr&zUnion[List, Tuple])r)r9rr:rr&r)r9rr:rr&r)rCz Iterable[str]r:rr&r)rHrrIrr:rr&zTuple[str, str])=r+ __future__rrrrtypingrrrrrr r constantsr dbdocr errorsrrr!rhelpersrprotobufrresultrrrrtypesrrrrrrrrr3r;r?rDrMrOrrrrr-r7r_r}rrrrrrr,r%r#rsa>$" 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%