cCSrSSKrSSKrSSKrSSKrSSKJr SSKJr SSKJ r SSKJ r SSK J r SSKJr SS KJr SS KJr SS KJr SS KJr SS KJr SSKJr SSKr\ R4"SS5rSrSrSrSr"SS\ 5r!Sr"Sr#S&Sjr$S'Sjr%Sr&Sr'S(Sjr(Sr)S)Sjr*S*S jr+S!r,"S"S#\ 5r-"S$S%\-5r.g)++Common utility functions for sql instances.N) 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)DatabaseInstancePresentation/zKRepresents 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__2s" 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 r/__eq__#DatabaseInstancePresentation.__eq__As&%566 ]]enn ,, r2c.URU5(+$)z@Overrides the default implementation (only needed for Python 2).)r7r5s r/__ne__#DatabaseInstancePresentation.__ne__Gs{{5! !!r2)rN) __name__ __module__ __qualname____firstlineno____doc__r0r7r:__static_attributes__r2r/rr/sS - "r2rcLURS5nSRUSS5$)z>Parses and returns the region string from the gce_zone string.-N)splitjoin)gce_zonezone_componentss r/GetRegionFromZonerJLs&NN3'/ /#2& ''r2c[RRU5=(a% [R"U[R5$)zBChecks if cloud_sql_proxy_path binary is present in cloud sdk bin.)ospathexistsaccessX_OK)cloud_sql_proxy_paths r/_IsCloudSqlProxyPresentInSdkBinrRSs0 ''..- . 3 ))("'' 24r2cT[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_pathrLrMrGrR file_utilsFindExecutableOnPathr debugsql_exceptionsSqlProxyNotFound) binary_namerVrQ proxy_paths r/_GetCloudSqlProxyPathr^Ys,,,77<< B&';<< !!..{;*II{m;zl!<=   ) ) * ++r2cSR[5nU(aSR[U5n[R"U5e)Nz{}.z{}: {})format_BASE_CLOUD_SQL_PROXY_ERRORrZCloudSqlProxyError) error_msgmessages r/_RaiseProxyErrorrexs6 LL4 5'oo99EG))'22r2c^[R"URR55$)z=Reads and returns the next line from the proxy stderr stream.)rDecodestderrreadline proxy_processs r/_ReadLineFromStderrrl --668 99r2c^[R"URR55$)z=Reads and returns the next line from the proxy stdout stream.)rrgstdoutrirjs r/_ReadLineFromStdoutrprmr2cSnSnUR5c[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: )pollrpr statuswriterPROXY_ADDRESS_IN_USE_ERRORrer`"PROXY_V2_READY_FOR_CONNECTIONS_MSGtimesleeprhreadrrg splitlines startswithappendrGstrip) rkportseconds_to_timeoutrun_connection_testtotal_wait_secondsseconds_to_sleeplineerr decoded_err err_lineserror_only_linesrcs r/_WaitForProxyV2ToStartrs$ } -D  jjt  - - 5 44:F4L  #;t#C!::dB  /d $$/|$*JJ 3 $:   /d   jjt !T )  !!##//#&K&&(I  " " d#  *+113Iy!{#r2cSnSnUR5c[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. rrrNrsrt) rvrlr rwrxrryrer`PROXY_READY_FOR_CONNECTIONS_MSGr{r|)rkrrrrrs r/_WaitForProxyToStartrs$ } -D  jjt  - - 5 44:F4L B  4 4 <  /d $/|$*JJ ' $,r2c 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}]  argsrostdinrh'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)r^connectionNamestrrr VALUESapi_endpoint_overridesrGetr ArgsForExecutableToolr rwrxr`rG subprocessPopenPIPEEnvironmentErrorerrnoENOENTrZrbr)instancerrimpersonate_service_accountauto_iam_authn private_ippscauto_ip debug_logsr command_pathr proxy_argsrkes r/StartCloudSqlProxyV2rs>'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)r^r`rr rcoreaccountrr rULegacyCredentialsAdcPathr rr rwrxrGrrrrrrrZrbr) rrrrrrrrkrs r/StartCloudSqlProxyrNs<'(,  **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 r/ IsInstanceV2rs%   !>!>!Y!Y!d!d ddr2c|\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 r/ YieldInstancesWithAModifiedStateM_BaseInstances.GetDatabaseInstances..YieldInstancesWithAModifiedStates&*622s)r SqlClientAPI_VERSION_DEFAULT sql_clientrr rrrrr YieldFromList instancesSqlInstancesListRequest) rrclientrr project_idparamsdefault_batch_sizerrs @r/GetDatabaseInstances#_BaseInstances.GetDatabaseInstancess    < < =F""J&&L""''//33T3BJ F Wo , 2D <&&,,Z,@LDJLG3 , --r2c0[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.Trddefault cancel_on_nor PromptContinuerBr2r/*PrintAndConfirmAuthorizedNetworksOverwrite9_BaseInstances.PrintAndConfirmAuthorizedNetworksOverwritesM r2c0[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.FTrrrBr2r/(PrintAndConfirmSimulatedMaintenanceEvent7_BaseInstances.PrintAndConfirmSimulatedMaintenanceEvents& r2c@URR[5$)z>Returns a boolean indicating if the database version is MySQL.)rr_MYSQL_DATABASE_VERSION_PREFIXdatabase_versions r/IsMysqlDatabaseVersion%_BaseInstances.IsMysqlDatabaseVersions  + +,J KKr2c@URR[5$)zAReturns a boolean indicating if the database version is Postgres.)rr!_POSTGRES_DATABASE_VERSION_PREFIXrs r/IsPostgresDatabaseVersion(_BaseInstances.IsPostgresDatabaseVersions  + +,M NNr2c@URR[5$)zCReturns a boolean indicating if the database version is SQL Server.)rr"_SQLSERVER_DATABASE_VERSION_PREFIXrs r/IsSqlServerDatabaseVersion)_BaseInstances.IsSqlServerDatabaseVersions  + +,N OOr2rB)NN) r<r=r>r?r@ staticmethodrrrrrrrArBr2r/rrs3%.%.NLLOOPPr2rc8\rSrSrSr\S5r\S5rSrg)InstancesV1Beta4iz3Common utility functions for sql instances V1Beta4.cHURUlURUlgr)rrr)instance_resource instance_refs r/SetProjectAndInstanceFromRef-InstancesV1Beta4.SetProjectAndInstanceFromRefs , 4 4)22r2cXlgr)backupConfiguration)r backup_configs r/AddBackupConfigToSettings*InstancesV1Beta4.AddBackupConfigToSettingss#0 r2rBN) r<r=r>r?r@rrrrArBr2r/rrs+;3311r2r)cloud_sql_proxyr)F) NFFFFFF)r)/r@rrLrr{apitools.base.pyrgooglecloudsdk.api_lib.sqlrrrrZgooglecloudsdk.api_lib.utilrgooglecloudsdk.corer r r r googlecloudsdk.core.consoler googlecloudsdk.core.utilrrrWr)GetMessagesModuler!rarrrobjectrrJrRr^rerlrprrrrrrrrBr2r/rs2  '/0C,&/#*2-8   ! !% 3C!($.!%0""6":(4 +>3: : BGFR$R-/59(-$)"!&$)-2Rj1Ghe JPVJPZ 1~ 1r2