.0SrSSKJr SSKJr SSKJr SSKJr SSKJr SSKJ r SSKJ r SS KJ r SS K J r SS KJr S rSSjrSSjrSrSSjrSSjrSrSSjrSrSSjr"SS\5rg )z%Spanner database sessions API helper.)absolute_import)division)unicode_literals)encoding) exceptions) extra_types) http_wrapper) list_pager)apis) QueryHasDmlcURS:Xa[RRU5e[R "U5$)z5Wrap http_wrapper.CheckResponse to skip retry on 501.i) status_codeapitools_exceptions HttpError FromResponser CheckResponse)responses 7lib/googlecloudsdk/api_lib/spanner/database_sessions.pyrrs8 S  ' ' 4 4X >>  # #H --Nc6[SSS5n[R"SS5nUcURUR 5S9nO:UR UR US9S9nURUUR 5S9nURRU5$)zCreate a database session. Args: database_ref: String, The database in which the new session is created. creator_role: String, The database role which created this session. Returns: Newly created session. spannerv1N)database) creatorRole)session)createSessionRequestr) _GetClientInstancer GetMessagesModule6SpannerProjectsInstancesDatabasesSessionsCreateRequest RelativeNameCreateSessionRequestSession%projects_instances_databases_sessionsCreate) database_ref creator_roleclientmsgsreqcreate_session_requests rr$r$%s it 4&   4 0$  E E**, F .C"66  678  E E3**, F .C  5 5 <  @&,& -rc[SSU5n[R"SS5n[U5 [ UUUUUU5n UR UR 5U S9n URRU 5n [U5(aIUSLaDURU RS9n [U/U RRR5 U $)aExecute an SQL command. Args: sql: String, The SQL to execute. query_mode: String, The mode in which to run the query. Must be one of 'NORMAL', 'PLAN', 'PROFILE', 'WITH_STATS', or 'WITH_PLAN_AND_STATS'. session_ref: Session, Indicates that the repo should be created if it does not exist. read_only_options: The ReadOnly message for a read-only request. It is ignored in a DML request. request_options: The RequestOptions message that contains the priority. enable_partitioned_dml: Boolean, whether partitioned dml is enabled. http_timeout_sec: int, Maximum time in seconds to wait for the SQL query to complete. Returns: (Repo) The capture repository. rr)rexecuteSqlRequestF)metadata)rr r_RegisterCustomMessageCodec_GetQueryRequest:SpannerProjectsInstancesDatabasesSessionsExecuteSqlRequestr r# ExecuteSqlr ResultSetrACommit transactionid) sql query_moder9read_only_optionsrequest_optionsenable_partitioned_dmlr;r'r(execute_sql_requestr)resp result_sets rrErE]s* i/? @&   4 0$d#(   GG&&(>? +rct^SnU4Sjn[R"XS9"TRR5 g)zBRegister custom message code. Args: msgs: Spanner v1 messages. cf[R"[R"URS95$N)entriesrJsonProtoEncoder JsonArrayentrymsgs r_ToJson,_RegisterCustomMessageCodec.._ToJsons'  ' 'cii0 22rcr>TRR[R"U5RS9$)NrY)rFRowsValueListEntryrJsonProtoDecoderrU)datar(s r _FromJson._RegisterCustomMessageCodec.._FromJsons3 >> , ,**4088 - ::rencoderdecoderN)rRegisterCustomMessageCodecrFr`)r(r\rcs` rrBrBs22: %%* .. + +-rc^[R"SS5nUSLa [U5nO[[U5(a-UR UR 5S9nUR US9nOUR US9nUR US9nURUUURRU5US9$) aGFormats the request based on whether the statement contains DML. Args: sql: String, The SQL to execute. query_mode: String, The mode in which to run the query. Must be one of 'NORMAL', 'PLAN', 'PROFILE', 'WITH_STATS', or 'WITH_PLAN_AND_STATS'. session_ref: Reference to the session. read_only_options: The ReadOnly message for a read-only request. It is ignored in a DML request. request_options: The RequestOptions message that contains the priority. enable_partitioned_dml: Boolean, whether partitioned dml is enabled. Returns: ExecuteSqlRequest parameters rrT readWrite)begin)readOnly) singleUse)rJrequestOptions queryModerH) r r_GetPartitionedDmlTransactionr TransactionOptions ReadWriteTransactionSelectorExecuteSqlRequestQueryModeValueValuesEnum) rJrKr9rLrMrNr(rHtransaction_optionss rrCrCs*    4 0$t#/   ??rcRURRURX5S9$)aConstructs an UPDATE mutation, which updates a row in a table. Args: table: String, the name of the table. data: An ordered dictionary where the keys are the column names and values are the column values to be updated. Returns: An update mutation operation. )updaterrs rUpdateMutationFactory.UpdaterrcRURRURX5S9$)zConstructs a DELETE mutation, which deletes a row in a table. Args: table: String, the name of the table. keys: String list, the primary key values of the row to delete. Returns: A delete mutation operation. )delete)r(r _GetDelete)rrkeyss rr8MutationFactory.Deletes% 88  CNN5$?  @@rcSn[R"USS9"URRR5 UR U5nUVs/sHoUR PM nnUVs/sHoURPM nnURRUURURRR US9/S9$s snfs snf)zFConstructs Write object, which is needed for insert/update operations.cf[R"[R"URS95$rTrVrZs rr\*MutationFactory._GetWrite.._ToJson0'  ) )    244rNrer_)columnsrvalues) rrhr(WriteValuesValueListEntry GetJsonDatacol_name col_valuer6)rrrbr\ json_columnscoljson_column_namesjson_column_valuess rrMutationFactory._GetWrite,s4 ''' HHNN / /1$$T*L1=>#>3?@>!jj33:L3MN  PP?@s C -CcVSn[R"USS9"URRR5 URRURRR UR U5S9/S9nURR URUS9$)z?Constructs Delete object, which is needed for delete operation.cf[R"[R"URS95$rTrVrZs rr\+MutationFactory._GetDelete.._ToJsonFrrNrer_)r)rkeySet)rrhr(KeySetKeysValueListEntry GetJsonKeysr8r6)rrrr\key_sets rrMutationFactory._GetDeleteAs 4 ''' HHOO . .0hhoo **1B1B41H*I$oG 88??G? <rs,&'%>()',>.B0  B@D