sSrSSKJr SSKJr SSKJr SSKrSSKrSSKJr SSKJ r SSK J r SS K J r SS KJr SSKJ r SS KJr SS KJr SS KJr SSKr"SS\R05r"SS\5rg)z5Database Migration Service conversion workspaces API.)absolute_import)division)unicode_literalsN)api_util)filter_rewrite) exceptions) api_helper) labels_util)log)resource_property)filesc\rSrSrSrSrg))UnsupportedConversionWorkspaceDBTypeError$zHError raised when the conversion workspace database type is unsupported.N)__name__ __module__ __qualname____firstlineno____doc____static_attributes__rMlib/googlecloudsdk/api_lib/database_migration/conversion_workspaces_client.pyrr$sPrrc*\rSrSrSrS/rSrSrSrSr Sr S r S r S r S rS rSrSrSrSrSrSrSrSrS+SjrS+SjrSrS+SjrSrS+SjrS+SjrS+SjrS+Sjr S r!S+S!jr"S"r#S+S#jr$S$r%S%r&S+S&jr'S'r(S(r)S+S)jr*S*r+g),ConversionWorkspacesClient(z2Client for connection profiles service in the API. display_namec[R"U5Ul[R"U5Ul[R "U5UlURRUlURRUl URRUl Xl [UR RR R"UR RR R$/5UlgN)r GetApiVersion _api_versionGetClientInstanceclientGetMessagesModulemessages'projects_locations_conversionWorkspaces_serviceprojects_locations_location_service4projects_locations_conversionWorkspaces_mappingRules_mapping_rules_service_release_track frozenset EntityIssueSeverityValueValuesEnumISSUE_SEVERITY_WARNINGISSUE_SEVERITY_ERRORhigh_severity_issues)self release_tracks r__init__#ConversionWorkspacesClient.__init__-s ..}=D,,];DK..}=DMKKGGDM![[;;D HH ( ) !!99PP !!99NN+!Drc`URRRRU5$r)r%DatabaseEngineInfoEngineValueValuesEnumlookup_by_name)r3database_engines r_GetDatabaseEngine-ConversionWorkspacesClient._GetDatabaseEngine=s( ((>>MM  rcTURRURU5US9$)N)engineversion)r%r8r<)r3r;database_versions r_GetDatabaseEngineInfo1ConversionWorkspacesClient._GetDatabaseEngineInfoDs/ == + +&&7  , rcURRnURc0UlSURS'SURS'[R"XR S5nUR URUR5nUR URUR5nU"UURUUS9$)zReturns a conversion workspace.*filtertruev2global_settings)globalSettings displayNamesource destination) r%ConversionWorkspacerIr ParseCreateArgsGlobalSettingsValuerBsource_database_enginesource_database_versiondestination_database_enginedestination_database_versionr)r3argsconversion_workspace_typerIrLrMs r_GetConversionWorkspace2ConversionWorkspacesClient._GetConversionWorkspaceJs $ A A #d%(D"!'D!11 ;;=NO ( ( ##T%A%AF-- (($*K*KK %&%%  rc[UR5Vs/sH1nURU5(dM[R"U5PM3 nnU$s snf)z)Returns update mask for specified fields.)sorted _FIELDS_MAP IsSpecifiedr ConvertToCamelCase)r3rUfield update_fieldss r_GetUpdateMask)ConversionWorkspacesClient._GetUpdateMaskbsXD,,--E   E " 4,,U3-  s AAcxURU5nURS5(aURUlX4$)z@Returns updated conversion workspace and list of updated fields.r)r`r\rrK)r3conversion_workspacerUr_s r_GetUpdatedConversionWorkspace9ConversionWorkspacesClient._GetUpdatedConversionWorkspaceks;''-M '')-):):&  ..rcjURRUS9nURRU5$)Nnamer%ConversionWorkspacesClient._GetApplyConversionWorkspaceRequestsrMMAA<IIKBM ))#1#:#:#<#D#D ++$ dk=+ rcUS:Xa*URRRR$US:Xa*URRRR$URRRR $)z,Returns the tree type for database entities.SOURCEDRAFT)r%QDatamigrationProjectsLocationsConversionWorkspacesDescribeDatabaseEntitiesRequestTreeValueValuesEnum SOURCE_TREE DRAFT_TREEDB_TREE_TYPE_UNSPECIFIED)r3 tree_types r _GetTreeType'ConversionWorkspacesClient._GetTreeTypesH -- i i } } J JG -- i i } } I I gg{{ U Urc URRURUURUR UR 5UUURRR RS9nURS5(a<[R"5RUR5uUl nXel U$)zHReturns request to describe database entities in a conversion workspace.)commitIdconversionWorkspace uncommittedtreepageSize pageTokenviewrF) r%r commit_idrrrViewValueValuesEnumDATABASE_ENTITY_VIEW_FULLrrrrrF)r3conversion_workspace_ref page_size page_tokenrUdescribe_entities_reqrs r_GetDescribeEntitiesRequest6ConversionWorkspacesClient._GetDescribeEntitiesRequests!MM{{4$$   t~~ . ]] l lAA[[| ))#1#:#:#<#D#D ++$ dk=&3"  rc *URRURUURURRRR UUS9nUR S5(a!URUR5Ul O/URRRRUl UR S5(a<[R"5RUR5uUlnXelU$)z2Returns describe ddl conversion workspace request.)rrrrrrrrF)r%rrrrrrrrrrrrrrrF)r3rrrrUdescribe_ddl_reqrs r_GetDescribeDDLsRequest2ConversionWorkspacesClient._GetDescribeDDLsRequests}}vv4$$ ]] l lAA[[ w  ,,"//? -- i i } } I I ))#1#:#:#<#D#D ++$ dk=!. rc `URRURUURUURRRR UUS9nUR S5(a<[R"5RUR5uUl nXvl U$)z5Returns describe issues conversion workspace request.)rrrrrrrrF) r%rrrrrrrrrrF)r3rrrrUrdescribe_issues_reqrs r_GetDescribeIssuesRequest4ConversionWorkspacesClient._GetDescribeIssuesRequests--yy4$$  ]] l lAA[[z ))#1#:#:#<#D#D ++$ dk=$1 rNcURU5n[R"5nURRnU"UUUUS9nUR R U5$)aCreates a conversion workspace. Args: parent_ref: a Resource reference to a parent datamigration.projects.locations resource for this conversion workspace. conversion_workspace_id: str, the name of the resource to create. args: argparse.Namespace, The arguments that this command was invoked with. Returns: Operation: the operation for creating the conversion workspace. )rconversionWorkspaceIdparent requestId)rWrGenerateRequestIdr%?DatamigrationProjectsLocationsConversionWorkspacesCreateRequestr'Create)r3 parent_refconversion_workspace_idrUrc request_idcreate_req_type create_reqs rr!ConversionWorkspacesClient.Create)sd 77=++-J UU!05 J ==   ++rcURU5nURX25upE[R"5nURR nU"UUUSR U5S9nURRU5$)aUpdates a conversion workspace. Args: name: str, the reference of the conversion workspace to update. args: argparse.Namespace, The arguments that this command was invoked with. Returns: Operation: the operation for updating the conversion workspace ,)rrhr updateMask) rmrdrrr%>DatamigrationProjectsLocationsConversionWorkspacesPatchRequestjoinr'Patch) r3rhrU current_cwrcr_rupdate_req_type update_reqs rUpdate!ConversionWorkspacesClient.UpdateEs55d;J*.*M*M+'++-J TT!0 88M* J ==  z **rc[R"5nURRnU"XS9nURR U5$)zDeletes a conversion workspace. Args: name: str, the name of the resource to delete. Returns: Operation: the operation for deleting the conversion workspace. )rhr)rrr%?DatamigrationProjectsLocationsConversionWorkspacesDeleteRequestr'Delete)r3rhrdelete_req_type delete_reqs rr!ConversionWorkspacesClient.DeletecsE++-J UU!dAJ ==   ++rcURRnU"URU5US9nURR U5$)aCommits a conversion workspace. Args: name: str, the reference of the conversion workspace to commit. args: argparse.Namespace, the arguments that this command was invoked with. Returns: Operation: the operation for committing the conversion workspace ) commitConversionWorkspaceRequestrh)r%?DatamigrationProjectsLocationsConversionWorkspacesCommitRequestrtr'Commit)r3rhrUcommit_req_type commit_reqs rr!ConversionWorkspacesClient.CommitusO UU!)-)R)R *  J ==   ++rcURRnU"UURR5S9nURR U5$)zRollbacks a conversion workspace. Args: name: str, the reference of the conversion workspace to rollback. Returns: Operation: the operation for rollbacking the conversion workspace )rh"rollbackConversionWorkspaceRequest)r%ADatamigrationProjectsLocationsConversionWorkspacesRollbackRequest"RollbackConversionWorkspaceRequestr'Rollback)r3rhrollback_req_type rollback_reqs rr#ConversionWorkspacesClient.RollbacksL WW% +/==+[+[+]L == ! !, //rcURRnU"UURUUU5S9nURR U5$)acSeeds a conversion workspace from a connection profile. Args: name: str, the reference of the conversion workspace to seed. source_connection_profile_ref: a Resource reference to a datamigration.projects.locations.connectionProfiles resource for source connection profile. destination_connection_profile_ref: a Resource reference to a datamigration.projects.locations.connectionProfiles resource for destination connection profile. args: argparse.Namespace, The arguments that this command was invoked with. Returns: Operation: the operation for seeding the conversion workspace )rhseedConversionWorkspaceRequest)r%=DatamigrationProjectsLocationsConversionWorkspacesSeedRequestrr'Seed)r3rhr~rrU seed_req_typeseed_reqs rr ConversionWorkspacesClient.SeedsS0 SS '+'N'N ) . ( H ==  h ''rcURRnU"UURU5S9nURR U5$)a!Import rules in a conversion workspace. Args: name: str, the reference of the conversion workspace to import rules in. args: argparse.Namespace, The arguments that this command was invoked with. Returns: Operation: the operation for importing rules in the conversion workspace )rimportMappingRulesRequest)r%KDatamigrationProjectsLocationsConversionWorkspacesMappingRulesImportRequestrr+Import)r3rhrUimport_rules_req_typeimport_rules_reqs r ImportRules&ConversionWorkspacesClient.ImportRulessN aa-"&"D"DT"J  & & - -.> ??rcURRnU"UURU5S9nURR U5$)a0Converts the source entities to draft entities in a conversion workspace. Args: name: str, the reference of the conversion workspace to seed. args: argparse.Namespace, The arguments that this command was invoked with. Returns: Operation: the operation for converting the conversion workspace )rh!convertConversionWorkspaceRequest)r%@DatamigrationProjectsLocationsConversionWorkspacesConvertRequestrr'Convert)r3rhrUconvert_req_type convert_reqs rr"ConversionWorkspacesClient.ConvertsM VV# *.*T*T + K ==  --rcURRnU"UURX#5S9nURR U5$)aapplies a conversion workspace onto the destination database. Args: name: str, the reference of the conversion workspace to seed. destination_connection_profile_ref: a Resource reference to a datamigration.projects.locations.connectionProfiles resource for destination connection profile. args: argparse.Namespace, The arguments that this command was invoked with. Returns: Operation: the operation for applying the conversion workspace )rhapplyConversionWorkspaceRequest)r%>DatamigrationProjectsLocationsConversionWorkspacesApplyRequestrr'Apply)r3rhrrUapply_req_type apply_reqs rr ConversionWorkspacesClient.ApplysM TT (,(P(P .) I ==  y ))rcjURRUS9nURRU5$)zDescribe a conversion worksapce. Args: name: str, the name for conversion worksapce being described. Returns: Described conversion worksapce Resource. rgri)r3rh describe_reqs rDescribe#ConversionWorkspacesClient.Describe s8==]] ^L ==  \ **rc /nSn[5nURXXR5nURRU5nURnUHun UR U R U RU R[R"U R5RSS5URU 5S.5 Mw UR(dU$URUlM)a Describes database entities in a conversion worksapce. Args: name: str, the name for conversion worksapce being described. args: argparse.Namespace, The arguments that this command was invoked with. Returns: Described entities for the conversion worksapce. DATABASE_ENTITY_TYPE_) parentEntity shortNamer entityTypestatus)strrr'DescribeDatabaseEntitiesdatabaseEntitiesrr+r,rsix text_typer-replace_GetEntityStatus nextPageTokenr) r3rhrU entity_resultrrr$responseentitiesentitys rDescribeEntities+ConversionWorkspacesClient.DescribeEntitiessMIJ33 L 77 Eh**h&"//))KK--(9(9:BB'++F3   # #   (55l rcSnURHynURURRRR :Xa gURURRRR :XdMwSnM{ U$)zBGet entity status (Action required/review recommended/ no issues). NO_ISSUESACTION_REQUIREDREVIEW_RECOMMENDED)issuesseverityr%r.r/r1r0)r3r:r.issues rr5+ConversionWorkspacesClient._GetEntityStatus=st F .. ]] & & > > S S T! .. ]] & & > > U U V& MrcL/nSnURX[5U5nURRU5nURH3nUR H nUR SUR05 M" M5 UR(dU$URUl M)aDescribe DDLs in a conversion worksapce. Args: name: str, the name for conversion worksapce being described. args: argparse.Namespace, the arguments that this command was invoked with. Returns: DDLs for the entities of the conversion worksapce. r(ddl) rr/r'r0r1 entityDdlrrFr6r) r3rhrU entity_ddlsrr$r8r: entity_ddls r DescribeDDLs'ConversionWorkspacesClient.DescribeDDLsMsKI//ML 77 Eh--& **J   Z^^  +.  # #   (55l rc /nURHnURUR;dMURURUR [ R"UR5RSS5[ R"UR5RSS5[ R"UR5RSS5URURS.5 M U$)z%Get issues in a conversion worksapce.r)r* ISSUE_TYPE_ISSUE_SEVERITY_)r+r,r- issueType issueSeverity issueCode issueMessage) rArBr2rr+r,r2r3r-r4typecodemessage)r3r: entity_issuesrCs rGetIssuesHelper*ConversionWorkspacesClient.GetIssuesHelperhsM 444 4"//))--(9(9:BB'uzz2::="M ]]5>>:BB!2!MM   rc,/nURUU[5UU5nURRU5nURH#nUR UR U55 M% UR(dU$URUlMu)z*Describe issues in a conversion worksapce.) rr/r'r0r1extendrWr6r) r3rhrrUrrVr$r8r:s rDescribeIssuesHelper/ConversionWorkspacesClient.DescribeIssuesHelper}sM11    L 77 Eh--&T11&9:.  # #   (55l rcSnURUUUURRRR5nUR URUUUURRRR 55 U$)a$Describe database entity issues in a conversion worksapce. Args: name: str, the name for conversion worksapce being described. args: argparse.Namespace, The arguments that this command was invoked with. Returns: Issues found for the database entities of the conversion worksapce. r()r[r%rrrrZr)r3rhrUrrVs rDescribeIssues)ConversionWorkspacesClient.DescribeIssuessI--   gg{{ H H M  !!    MM k k   K K   rc[R"U5nUR RUUR RUS9S9n[RRSU-S-5 URRU5n[R"X#5nSnUR (aXr:XakU["R"R%5R'S5-S -n [R("X5 [RRS U -5 S n[R("XvR 5 [RRS U-S -U-5 O"[RRSU-5 UR*(a,[RRSUR*-5 U$![Ra' [R"SSR U55ef=f)aConverts application code. Args: name: str, the name of the location. source_file: str, the path of the source file to be converted. target_path: str, the path of the target file to be written. Returns: True if the file was converted, False otherwise. z --source-filer) sourceCode)rhconvertApplicationCodeRequestz Sending file z for conversionFz_%Y%m%d_%H%M%Sz.bakz'The original file content was saved to TzFile z was converted and saved in z No changes were made to the filezResult message: )r rrrrrr%;DatamigrationProjectsLocationsConvertApplicationCodeRequestConvertApplicationCodeRequestr r.Printr)ConvertApplicationCoder #GetTargetFileNameForApplicationCoderadatetimenowstrftimeWriteFileContents resultMessage) r3rh source_file target_path source_codeconvert_application_code_reqconvert_application_code_resp target_file converted backup_files r ConvertApplicationCodeSingleFile;ConversionWorkspacesClient.ConvertApplicationCodeSingleFiles**;7k$(==#l#l &*mm&Q&Q"'R' $m$ JJ_{25FFG 55 ( " @@KI$//  # ##%../?@ A    9  5 C i  ?? jj K "@ @; N jj9KGH$22 jj <JJ J g  ! !  + +  / 6 6{ C s G;H c[R"USS9nURU5 SSS5 g!,(df  g=f)NT)r)r FileWriterwrite)r3 audit_file audit_contentfs rWriteAuditContent,ConversionWorkspacesClient.WriteAuditContents7     ggm    s1 ?c UR(aNURR5S:wa0[R"SSR UR55eUR (aNUR R5S:wa0[R"SSR UR 55eUR (a'URXR UR5 g[RRUR5(d0[R"SS R UR55eUR(a^[RRUR5(d0[R"S S R UR55eUR(dURUlS nS n[RRURS 5nURUS5 [R"UR5Vs/sHSn[RR![RRURU55(dMQUPMU nn[#U5GH.nUS :XaM UR%S5(aUS- nURU[RRURU5UR5(aN[&R&R)5R+S5S-U-S-n URXY5 US- nM[&R&R)5R+S5S-U-S-n URXY5 GM [,R.R1SU-S-5 GM1 US :XaA[&R&R)5R+S5S-n URXY5 [,R.R1S[3U5-S-[3U5-S-5 gs snf)zConverts application code. Args: name: str, the name of the location. args: argparse.Namespace, The arguments that this command was invoked with. Returns: None. POSTGRESQLz--target-dialectzLspecified target dialect [{}] is not supported. Only POSTGRESQL is supportedORACLEz--source-dialectzHspecified source dialect [{}] is not supported. Only ORACLE is supportedNz--source-folderz0specified source folder [{}] is not a directory.z --target-pathzOspecified target path [{}] is not a directory while source folder is specified.rzConversion-Audit.txtz -------- z.javaz%Y-%m-%d %H:%M:%Sz: File z converted z not converted zSkipping file z since it is not a java filez): No files found eligible for conversion zSent z files for conversion, z files were actually converted.)target_dialectupperrrrsource_dialectrmrurnrrisdir source_folderrr}listdirisfilerZendswithrhrirjr r.rer/) r3rhrU total_filesconverted_filesrzr| source_filesfiler{s rrf1ConversionWorkspacesClient.ConvertApplicationCodes t2288:lJ  + +  vd112   t2288:hF  + +  vd112    ++   $"2"2 WW]]4-- . .--  > E E""     "''--0@0@"A"A--  #VD$4$45    --ko77<< 2 24JKj Z6::d0011a WW^^BGGLL););Q? @ 1 &$ ) )  == ! !  +  2 2BGGLL!3!3T:DrsY<&' >D.Z<=#:* Q0E0EQw w r