CSrSSKJr SSKJr SSKJr SSKrSSKrSSKrSSKrSSK J r SSK J r SSK J r SS K Jr SS KJr SS KJr SS KJr SS KJr SSKJr SSKJr SSKJr SSKJr SSKr\R<"SS5rSr Sr!Sr"Sr#"SS\$5r%Sr&Sr'S)Sjr(S*Sjr)Sr*Sr+S+S jr,S!r-S,S"jr.S-S#jr/S$r0"S%S&\$5r1"S'S(\15r2g).+Common utility functions for sql instances.)absolute_import)division)unicode_literalsN) list_pager)api_util) constants) exceptions)apis)config)execution_utils)log) properties) console_io)encoding)filessqlv1beta4z#Failed to start the Cloud SQL ProxyMYSQLPOSTGRES SQLSERVERc*\rSrSrSrSrSrSrSrg)DatabaseInstancePresentation2zKRepresents a DatabaseInstance message that is modified for user visibility.c<UR5GHnURS:XaiUR(aEURR[R R R:Xa SUlMjURUlM}[XR5nUcM[U[5(a U(dMURS;a,[XR[R"U55 M[XRU5 GM g)NstateSTOPPED)currentDiskSize maxDiskSize) all_fieldsnamesettingsactivationPolicymessagesSettingsActivationPolicyValueValuesEnumNEVERrgetattr isinstancelistsetattrsix text_type)selforigfieldvalues +lib/googlecloudsdk/api_lib/sql/instances.py__init__%DatabaseInstancePresentation.__init__5s" w  ==T]];;x?P?P?p?p?v?vv $*zz$*jj)  j&=&=ee ZZ= = D**cmmE&: ; D**e ,#c`[U[5(aURUR:H$g)zAOverrides the default implementation by checking attribute dicts.F)r)r__dict__r.others r2__eq__#DatabaseInstancePresentation.__eq__Ds&%566 ]]enn ,, r5c.URU5(+$)z@Overrides the default implementation (only needed for Python 2).)r:r8s r2__ne__#DatabaseInstancePresentation.__ne__Js{{5! !!r5)rN) __name__ __module__ __qualname____firstlineno____doc__r3r:r=__static_attributes__r5r2rr2sS - "r5rcLURS5nSRUSS5$)z>Parses and returns the region string from the gce_zone string.-N)splitjoin)gce_zonezone_componentss r2GetRegionFromZonerMOs&NN3'/ /#2& ''r5c[RRU5=(a% [R"U[R5$)zBChecks if cloud_sql_proxy_path binary is present in cloud sdk bin.)ospathexistsaccessX_OK)cloud_sql_proxy_paths r2_IsCloudSqlProxyPresentInSdkBinrUVs0 ''..- . 3 ))("'' 24r5cT[R"5RnU(a1[RR X5n[ U5(aU$[R"U5nU(a[R"SUSUS35 U$[R"S5e)zDetermines the path to the Cloud SQL Proxy binary. Args: binary_name: Name of Cloud SQL Proxy binary to look for in path. (v1: 'cloud_sql_proxy', v2: 'cloud-sql-proxy') Returns: str: The path to the Cloud SQL Proxy binary. zUsing z found at []zbA Cloud SQL Proxy SDK root could not be found, or access is denied.Please check your installation.) r Paths sdk_bin_pathrOrPrJrU file_utilsFindExecutableOnPathrdebugsql_exceptionsSqlProxyNotFound) binary_namerYrT proxy_paths r2_GetCloudSqlProxyPathra\s,,,77<< B&';<< !!..{;*II{m;zl!<=   ) ) * ++r5cSR[5nU(aSR[U5n[R"U5e)Nz{}.z{}: {})format_BASE_CLOUD_SQL_PROXY_ERRORr]CloudSqlProxyError) error_msgmessages r2_RaiseProxyErrorrh{s6 LL4 5'oo99EG))'22r5c^[R"URR55$)z=Reads and returns the next line from the proxy stderr stream.)rDecodestderrreadline proxy_processs r2_ReadLineFromStderrro --668 99r5c^[R"URR55$)z=Reads and returns the next line from the proxy stdout stream.)rrjstdoutrlrms r2_ReadLineFromStdoutrsrpr5cSnSnUR5c[U5nU(a[RR U5 [ R U;a[SRU55 O,U(aSU;aU$U(d[ RU;aU$[U5nU(aMXB:a [S5 XE- n[R"U5 UR5cMU(a=[U5nU(dO)[RR U5 SU;aU$M<URR5nU(a[R"U5nUR!5n /n U H,nUR#S5(a OU R%U5 M. SR'U 5R)5n U (a [U 5 g[U5 g[5 g) aWait for the proxy to be ready for connections, then return proxy_process. Args: proxy_process: The Process corresponding to the Cloud SQL Proxy (v2). port: int, the port that the proxy was started on. seconds_to_timeout: Seconds to wait before timing out. run_connection_test: if true, waits for connection test success message. Returns: The Process object corresponding to the Cloud SQL Proxy (v2). r皙?NePort already in use. Exit the process running on port {} or try connecting again on a different port.zConnection test passed Timed out.zUsage: )pollrsrstatuswriter PROXY_ADDRESS_IN_USE_ERRORrhrc"PROXY_V2_READY_FOR_CONNECTIONS_MSGtimesleeprkreadrrj splitlines startswithappendrJstrip) rnportseconds_to_timeoutrun_connection_testtotal_wait_secondsseconds_to_sleeplineerr decoded_err err_lineserror_only_linesrfs r2_WaitForProxyV2ToStartrs$ } -D  jjt  - - 5 44:F4L  #;t#C!::dB  /d $$/|$*JJ 3 $:   /d   jjt !T )  !!##//#&K&&(I  " " d#  *+113Iy!{#r5cSnSnUR5c[U5nU(ax[RR U5 [ R U;a[SRU55 O[ RU;aU$[U5nU(aMxX2:a [S5 X4- n[R"U5 UR5cM[5 g)aQWait for the proxy to be ready for connections, then return proxy_process. Args: proxy_process: Process, the process corresponding to the Cloud SQL Proxy. port: int, the port that the proxy was started on. seconds_to_timeout: Seconds to wait before timing out. Returns: The Process object corresponding to the Cloud SQL Proxy. rruNrvrw) ryrorrzr{r r|rhrcPROXY_READY_FOR_CONNECTIONS_MSGr~r)rnrrrrrs r2_WaitForProxyToStartrs$ } -D  jjt  - - 5 44:F4L B  4 4 <  /d $/|$*JJ ' $,r5c H[SS9n URS[U5/n U(aU RS5 U(aU RS5 U(aU RS5 U(aU RS5 U(aU RS5 [R R RR5(a7U S [R R RR5/- n U (aU RS 5 U(aU S U/- n [R"U /U Q76n [RRS RS RU 5S95 [ R""U [ R$[ R$[ R$S9n [1XX)5$![&aInUR([(R*:Xa%[,R."SRU 55eeSnAff=f)aStarts the Cloud SQL Proxy (v2) for instance on the given port. Args: instance: The instance to start the proxy for. port: The port to bind the proxy to. seconds_to_timeout: Seconds to wait before timing out. impersonate_service_account: Service account to impersonate. auto_iam_authn: Whether to use IAM DB Authentication. private_ip: Whether to use private IP. psc: Whether to use PSC. auto_ip: Whether to use auto IP detection. debug_logs: Whether to enable verbose logs in proxy. run_connection_test: Whether to run connection test. Returns: The Process object corresponding to the Cloud SQL Proxy. Raises: CloudSqlProxyError: An error starting the Cloud SQL Proxy. SqlProxyNotFound: An error finding a Cloud SQL Proxy installation. zcloud-sql-proxy)r_z--portz --private-ipz--pscz --auto-ipz --debug-logsz--auto-iam-authnz--sqladmin-api-endpointz--run-connection-testz--impersonate-service-accountz#Starting Cloud SQL Proxy: [{args}]  argsrrstdinrk'Failed to start Cloud SQL Proxy. Please make sure it is available in the PATH [{}]. Learn more about installing the Cloud SQL Proxy here: https://cloud.google.com/sql/docs/mysql/connect-auth-proxy#install. If you would like to report this issue, please run the following command: gcloud feedbackN)raconnectionNamestrrrVALUESapi_endpoint_overridesrGetr ArgsForExecutableToolrrzr{rcrJ subprocessPopenPIPEEnvironmentErrorerrnoENOENTr]rer)instancerrimpersonate_service_accountauto_iam_authn private_ippscauto_ip debug_logsr command_pathr proxy_argsrnes r2StartCloudSqlProxyV2rs>'3DE,  ! !8SY 7$KKKK KK KKKK"#--115577!004488: DKK'(  ,.I JJD44\IDI***,33*9M3N $$oo M( -    ww%,,  - - %&,VL%9     sAG H!AHH!c[5nSSRURU5/n[RR R RSS9nUS[R"5RU5/- n[R"U/UQ76n[RRSRSR!U5S95 ["R$"U["R&["R&["R&S 9n[3XqU5$![(aInUR*[*R,:Xa%[.R0"S RU55eeS nAff=f) aStarts the Cloud SQL Proxy (v1) for instance on the given port. Args: instance: The instance to start the proxy for. port: The port to bind the proxy to. seconds_to_timeout: Seconds to wait before timing out. Returns: The Process object corresponding to the Cloud SQL Proxy. Raises: CloudSqlProxyError: An error starting the Cloud SQL Proxy. SqlProxyNotFound: An error finding a Cloud SQL Proxy installation. z -instancesz {}=tcp:{}Trequiredz-credential_filez$Starting Cloud SQL Proxy: [{args}]] rrrrN)rarcrrrcoreaccountrr rXLegacyCredentialsAdcPathr rrrzr{rJrrrrrrr]rer) rrrrrrrrnrs r2StartCloudSqlProxyrQs<'(,  **8+B+BDI J$    " " * * . . . =' v||~FFwO PP$44\IDI***-44#((::N4O $$oo M* m3E FF   ww%,,  - - & '-f\&:     sAD## E6-AE11E6c\URURRR:H$)zDReturns a boolean indicating if the database instance is second gen.) backendTypeDatabaseInstanceBackendTypeValueValuesEnum SECOND_GEN) sql_messagesrs r2 IsInstanceV2rs%   !>!>!Y!Y!d!d ddr5c|\rSrSrSr\S Sj5r\S5r\S5r\S5r \S5r \S 5r S r g) _BaseInstancesirNc^ [R"[R5nURnURn[ R RRRSS9n0nUbXS'SnUbUOUUS'[R"URURUS940UD6m U 4SjnU"5$)a~Gets SQL instances in a given project. Modifies current state of an individual instance to 'STOPPED' if activationPolicy is 'NEVER'. Args: limit: int, The maximum number of records to yield. None if all available records should be yielded. batch_size: int, The number of items to retrieve per request. Returns: List of yielded DatabaseInstancePresentation instances. Trlimiti batch_size)projectc3:># THn[U5v M g7fN)r)resultyieldeds r2 YieldInstancesWithAModifiedStateM_BaseInstances.GetDatabaseInstances..YieldInstancesWithAModifiedStates&*622s)r SqlClientAPI_VERSION_DEFAULT sql_clientrrrrrrr YieldFromList instancesSqlInstancesListRequest) rrclientrr project_idparamsdefault_batch_sizerrs @r2GetDatabaseInstances#_BaseInstances.GetDatabaseInstancess    < < =F""J&&L""''//33T3BJ F Wo , 2D <&&,,Z,@LDJLG3 , --r5c0[R"SSSS9 g)NzWhen adding a new IP address to authorized networks, make sure to also include any IP addresses that have already been authorized. Otherwise, they will be overwritten and de-authorized.Trgdefault cancel_on_norPromptContinuerEr5r2*PrintAndConfirmAuthorizedNetworksOverwrite9_BaseInstances.PrintAndConfirmAuthorizedNetworksOverwritesM r5c0[R"SSSS9 g)NzThis request will trigger a simulated maintenance event and will not change the maintenance version on the instance. Downtime will occur on the instance.FTrrrEr5r2(PrintAndConfirmSimulatedMaintenanceEvent7_BaseInstances.PrintAndConfirmSimulatedMaintenanceEvents& r5c@URR[5$)z>Returns a boolean indicating if the database version is MySQL.)r!r_MYSQL_DATABASE_VERSION_PREFIXdatabase_versions r2IsMysqlDatabaseVersion%_BaseInstances.IsMysqlDatabaseVersions  + +,J KKr5c@URR[5$)zAReturns a boolean indicating if the database version is Postgres.)r!r!_POSTGRES_DATABASE_VERSION_PREFIXrs r2IsPostgresDatabaseVersion(_BaseInstances.IsPostgresDatabaseVersions  + +,M NNr5c@URR[5$)zCReturns a boolean indicating if the database version is SQL Server.)r!r"_SQLSERVER_DATABASE_VERSION_PREFIXrs r2IsSqlServerDatabaseVersion)_BaseInstances.IsSqlServerDatabaseVersions  + +,N OOr5rE)NN) r?r@rArBrC staticmethodrrrrrrrDrEr5r2rrs3%.%.NLLOOPPr5rc8\rSrSrSr\S5r\S5rSrg)InstancesV1Beta4iz3Common utility functions for sql instances V1Beta4.cHURUlURUlgr)rrr!)instance_resource instance_refs r2SetProjectAndInstanceFromRef-InstancesV1Beta4.SetProjectAndInstanceFromRefs , 4 4)22r5cXlgr)backupConfiguration)r" backup_configs r2AddBackupConfigToSettings*InstancesV1Beta4.AddBackupConfigToSettingss#0 r5rEN) r?r@rArBrCrrrrDrEr5r2rrs+;3311r5r)cloud_sql_proxyr)F) NFFFFFF)r)3rC __future__rrrrrOrr~apitools.base.pyrgooglecloudsdk.api_lib.sqlrr r r]googlecloudsdk.api_lib.utilr googlecloudsdk.corer r rrgooglecloudsdk.core.consolergooglecloudsdk.core.utilrrrZr,GetMessagesModuler$rdrrrobjectrrMrUrarhrorsrrrrrrrrEr5r2rs2&'  '/0C,&/#*2-8   ! !% 3C!($.!%0""6":(4 +>3: : BGFR$R-/59(-$)"!&$)-2Rj1Ghe JPVJPZ 1~ 1r5