_SrSSKJr SSKJr SSKJr SSKrSSKrSSKrSSKJ r SSK J r SSK J r SS K Jr SS KJr SS KJr SS KJr SS KJr SSKJr SSKJr SSKrSS0rSr\R>\R@"\RBRD\RBRF\RBRH5\RJ"SS\RL5555r'g)zGCommand to query metadata against Dataproc Metastore services database.)absolute_import)division)unicode_literalsN) exceptions)operations_util) services_util)util) storage_api) storage_util)base) resource_args)log)resource_printerEXAMPLESa) To query metadata against a Dataproc Metastore service with the name `my-metastore-service` in location `us-central1`, and the sql query "show tables;", run: $ {command} my-metastore-service --location=us-central1 --query="show tables;" cV[R"USSSSS9 URSSSS9 g) zvParses provided arguments to add base arguments used for Alpha/Beta/GA. Args: parser: an argparse argument parser. zto query metadataFT)pluralrequired positionalz--queryz Use Google Standard SQL query for Cloud Spanner and MySQL query syntax for Cloud SQL. Cloud Spanner SQL is described at https://cloud.google.com/spanner/docs/query-syntax)" )rhelpN)r AddServiceResourceArg add_argumentparsers 0lib/surface/metastore/services/query_metadata.py AddBaseArgsr3s= %% !%$4Q c8\rSrSrSr\r\S5rSr Sr Sr g)QueryFzDExecute a SQL query against a Dataproc Metastore Service's metadata.cX[U5 [RRU5 g)zSee base class.N)rr FORMAT_FLAG AddToParserrs rArgs Query.ArgsPs   (rc XURRR5nSn[R"UR 5UR UR5S9n[RRSRUR55 Sn["R$"USRUR 55UR5S9nUb*UR.(a[1UR.5S :agSnUR.H+nUR2S :XdMUR4R6nM- Ucg[8R:"5n[<R>"[@RB"URE[FRHRKUS 55S S 95n [RRU SSU5 U S(dg[1U S5S:a[RRS5 U SSn [<R>"[@RB"URE[FRHRK[LRN"[LRP"U5U 5S 55S S 95$![Ra [R "S5ef=f![R&aDn[R("UR 5SS[*R,"U5S9 SnAGNDSnAff=f)zRuns this command. Args: args: an argparse namespace. All the arguments that were provided to this command invocation. Returns: Some value that we want to have printed later. N) release_trackzwith operation [{}]zQuery did not succeed.zWaiting for [{}] to queryserviceF)kindis_asyncfailedresultManifestUriTzutf-8)encodingstatusmessage filenameszcThe number of rows exceeds 1000 to display. Please find more results at the cloud storage location.r))CONCEPTSr'Parseservices_api_util QueryMetadata RelativeNamequery ReleaseTrackroutPrintformatnameapitools_exceptions HttpErrorapi_utilQueryMetadataErrorrPollAndReturnOperationOperationErrorUpdatedResourcesix text_typeadditionalPropertieslenkeyvalue string_valuer StorageClientjsonloadio TextIOWrapper ReadObjectr ObjectReferenceFromUrl posixpathjoindirname) selfargsenv_ref operationoperation_resulteresult_manifest_urir/ gcs_clientresult_manifest_jsonquery_result_file_names rRun Query.RunVsmm##))+GIB#11    $**DqA 99   ! !,,44NN!))*=>.    S  ( (B  ' '(@ AAB  " "#     q! ###s%A4J#AK#+KL)%9L$$L)cpU(aSU;dSUS;dSU;agUSSVs/sHnUS=(d SPM nnSRS[U555nUSVs/sHnS U0PM nn[R"US R U5[ R S 9 gs snfs snf) a,Displays the server response to a query. This is called higher up the stack to over-write default display behavior. What gets displayed depends on the mode in which the query was run. Args: args: The arguments originally passed to the command. result: The output of the command before display. metadatacolumnsrowsNr<z (Unspecified),c3H# UHupSRX5v M g7f)z!row.slice({0}).join():label="{1}"N)r;).0ifs r Query.Display..s(;(9@FFqLL(9s "rowz table({0}))r9)rT enumeraterr:r;rr9)rVrWresultfieldfields table_formatrmres rDisplay Query.Displays Zv-&C2V+ J' 22E f ((2  88;(1&(9;;L$*6N 3NSUCLND 34!4!4\!BP 4s B.*B3N) __name__ __module__ __qualname____firstlineno____doc__ DETAILED_HELP detailed_help staticmethodr#r`rs__static_attributes__rurrrrFs, M-)) GRQrr)(rz __future__rrrrNrLrSapitools.base.pyrr= googlecloudsdk.api_lib.metastorerrr4r r?googlecloudsdk.api_lib.storager r googlecloudsdk.callioper $googlecloudsdk.command_lib.metastorer googlecloudsdk.corergooglecloudsdk.core.resourcerrDr{rUnicodeIsSupported ReleaseTracksr8ALPHABETAGADefaultUniverseOnlyCommandrrurrrsN&' ><O=67(>#9    &T..33T5F5F5I5IjQDLLjQ jQr