dZddlmZddlmZddlmZddlmZddlmZddl m Z ddl m Z dd lmZd Zd Zej$ej&ej(j*Gd d ej,Zy)z3Command to lookup a stream object for a datastream.)absolute_import)division)unicode_literals)stream_objects)base) resource_args)flags) propertieszJLookup a stream object by its source object identifier (e.g. schema.table)a0 To lookup an existing Mysql stream object: $ {command} --stream=my-stream --location=us-central1 --mysql-database=my-db --mysql-table=my-table To lookup an existing Oracle stream object: $ {command} --stream=my-stream --location=us-central1 --oracle-schema=my-schema --oracle-table=my-table To lookup an existing PostgreSQL stream object: $ {command} --stream=my-stream --location=us-central1 --postgresql-schema=my-schema --postgresql-table=my-table To lookup an existing SQL Server stream object: $ {command} --stream=my-stream --location=us-central1 --sqlserver-schema=my-schema --sqlserver-table=my-table To lookup an existing Salesforce stream object: $ {command} --stream=my-stream --location=us-central1 --salesforce-object-name=my-object c0eZdZdZeedZedZdZ y)Lookupz"Lookup a Datastream stream object.) DESCRIPTIONEXAMPLESc&tj||jdd}tj|tj |tj |tj|tj|y)zArgs is called by calliope to gather arguments for this command. Args: parser: An argparse parser that you can use to add arguments that go on the command line after this command. Positional arguments are allowed. T)requiredmutexN) rAddStreamObjectResourceArg add_groupso_flagsAddOracleObjectIdentifierAddMysqlObjectIdentifierAddPostgresqlObjectIdentifierAddSqlServerObjectIdentifierAddSalesforceObjectIdentifier)parserobject_identifier_parsers (lib/surface/datastream/objects/lookup.pyArgsz Lookup.Args;ss,,V4%//T/J &&'?@ %%&>? **+CD ))*BC **+CDctjjjj d}|j j jj}tj}|j|||S)zLookup a Datastream stream object. Args: args: argparse.Namespace, The arguments that this command was invoked with. Returns: A dict object representing the looked up stream object if the lookup was successful. T)r) r VALUEScoreprojectGetCONCEPTSstreamParse streamsIdrStreamObjectsClientr )selfargs project_id stream_id so_clients rRunz Lookup.RunLsj""''//33T3BJ $$**,66I224I   J 4 88rN) __name__ __module__ __qualname____doc__r r detailed_help staticmethodrr.rrr r 5s*+"-8D-EE 9rr N)r2 __future__rrr!googlecloudsdk.api_lib.datastreamrgooglecloudsdk.callioper%googlecloudsdk.command_lib.datastreamr-googlecloudsdk.command_lib.datastream.objectsr rgooglecloudsdk.corer r rDefaultUniverseOnly ReleaseTracks ReleaseTrackGACommandr r5rrrAsz:&'<(?K*Q  .D%%(()#9T\\#9*#9r