:?h tSrSSKJr SSKJr SSKrSr\R\R\RS.r \ "\S5(a \RO \R\ S'\ "\S 5=(a \RrSSKrSSKrSSKrSSKrSSKrSSKrSSKrSSKrSSKrSSKrSSKrSS KJrJrJrJ r J!r!J"r"J#r#J$r$J%r% SSK&r'SSK(r'Sr)SS K*J*r*J+r+ SS K,J-r- SSK.J/r/ SSK0J1r1J2r2J3r3 SSK4J5r5J6r6J7r7 SSK8J9r9J:r:J;r;Jr>J?r?J@r@ SSKAJBrB SSKCJDrDJErEJFrFJGrGJHrHJIrI SSKJJKrKJLrLJMrM SSKNJNrN SSKOJPrP SSKQJRrRJSrSJTrTJUrUJVrV SSKWJXrXJYrYJZrZJ[r[J\r\ SSK]J^r^J_r_J`r`JaraJbrbJcrcJdrdJereJfrfJgrgJhrh SSKJiriJjrjJkrkJlrl \RRS5 SSKoJprpJqrqJrrrJsrs SSKtJuru SSKvJwrwJxrx S S!S"S#.ryS$rzS%r{S&r|S'r}S(r~S)rS*r\GR"S+5rS,rS,rS-rS.rS/rS/rS0rS.r\\\\\\\\S1.rS2\0r\GR"S35r\GR"S4\GR5r\GR"S5\GR5r\GR"S65r/S7Qr\/S8Q-rSXS9jrSYS:jr"S;S<5rSZS=jr"S>S?\5r"S@SA5r"SBSC5r"SDSE\5r"SFSG\GR:5r"SHSI5r"SJSK5r"SLSM5rS[SNjrS\SOjrS]SPjrS^S_SQjjrS]SRjrS]SSjrS]STjrS`SUjrSaSVjrSbSWjrg!\a S rS r0r GNf=f!\a S r)GNjf=f)cz4Implementation of communication for MySQL X servers.) annotations) TracebackTypeNT)TLSv1TLSv1.1TLSv1.2 PROTOCOL_TLSTLSv1.3 HAS_TLSv1_3F) AnyCallableDictListMappingOptionalTupleTypeUnion)datetime timedeltawraps)JSONDecodeError) parse_qslunquoteurlparse)MySQL41AuthPluginPlainAuthPluginSha256MemoryAuthPlugin)COMPRESSION_ALGORITHMSDEPRECATED_TLS_VERSIONSOPENSSL_CS_NAMESSUPPORTED_TLS_VERSIONSTLS_CIPHER_SUITESAuth CompressionSSLModeSchema)InterfaceErrorNotSupportedErrorOperationalError PoolErrorProgrammingError TimeoutError)escapeget_item_or_attriani_to_openssl_cs_name)logger)Protobuf)HAVE_LZ4 HAVE_ZSTD MessageReader MessageWriterProtocol) BaseResult DocResultResult RowResult SqlResult) AddStatementDeleteStatement FindStatementInsertStatementModifyStatement ReadStatementRemoveStatementSelectStatement SqlStatementUpdateStatementquote_identifier) ColumnType MessageTypeResultBaseType StatementType..)DUPLICATED_IN_LIST_ERRORTLS_VER_NO_SUPPORTEDTLS_VERSION_DEPRECATED_ERRORTLS_VERSION_ERROR)linux_distribution)LICENSEVERSIONzThis session was closed because the connection has been idle for too long. Use 'mysqlx.getSession()' or 'mysqlx.getClient()' to create a new one.zGenerate a pool name. This function takes keyword arguments, usually the connection arguments and tries to generate a name for the pool. Args: **kwargs: Arbitrary keyword arguments with the connection arguments. Raises: PoolError: If the name can't be generated. Returns: str: The generated pool name. )rcrdr`database client_idz.Failed generating pool name; specify pool_name_)appendstrKeyErrorr-join)kwargspartskeys Y/var/www/ev-aguas/ev-aguas-proceso/venv/lib/python3.13/site-packages/mysqlx/connection.pygenerate_pool_namer{s_ E@  LLV[) *A HII 88E?    sA  AAcjU(a,[U[5(a[RU5 ggg)zUpdate the timeout penalties directory. Update the timeout penalties by error dictionary used to deactivate a pool. Args: penalty_dict (dict): The dictionary with the new timeouts. N) isinstancedict_TIMEOUT_PENALTIES_BY_ERR_NOupdate) penalty_dicts rz!update_timeout_penalties_by_errorrs( <66$++L97|c\rSrSrSrSSjr\4SSjjrSSjrSSjr SSjr SSjr SS jr SS jr SS jrSS jrSS jrSrg) SocketStreamzImplements a socket stream.c<SUlSUlSUlSUlg)NF)_socket_is_ssl _is_socket_hostselfs rz__init__SocketStream.__init__s04 " %$( rcUbUS- n[R"X5UlUSUlURR S5 g![a [R"[R 5UlURR U5 URRU5 SUlN![a [S5Sef=ff=f)zConnects to a TCP service. Args: params (tuple): The connection parameters. Raises: :class:`mysqlx.InterfaceError`: If Unix socket is not supported. NrTzUnix socket unsupported) rfcreate_connectionrr ValueErrorAF_UNIX settimeoutconnectrAttributeErrorr*)rparamsconnect_timeouts rzrSocketStream.connects  &-4O J!33DL DJ % J J%}}V^^<  ''8 $$V,"&! J$%>?TI J  Js%A CA&B>>CCc URc [S5e/nUS:aSURRU5nUS:Xa [S5eUR U5 U[ U5-nUS:aMSSR U5$)zkReceive data from the socket. Args: count (int): Buffer size. Returns: bytes: The data received. MySQLx Connection not availablerrzUnexpected connection close)rr,recv RuntimeErrorrslenrv)rcountbufdatas rzreadSocketStream.read"s << "#DE Eai<<$$U+Ds{"#@AA JJt  SY E ai xx}rcURc [S5eURRU5 g![an[SU35UeSnAff=f)zGSend data to the socket. Args: data (bytes): The data to be sent. NrzUnexpected socket error: )rr,sendallOSError)rrerrs rzrSocketStream.sendall6sY << "#DE E O LL  & O"%>se#DE3 N Os6 AAAcUR(dgURR[R5 URR 5 SUlg![ a Nf=f)zClose the socket.N)rshutdownrf SHUT_RDWRcloserrs rzrSocketStream.closeCsV||   LL ! !&"2"2 3 LL       sAA A,+A,c$UR5 gNrrs rz__del__SocketStream.__del__Os  rc: [(dUR5 [S5eUbU(dZ[R"5nU[ R :waSUlU[ R:Xa[RUl OURSS9 USn [(dU S:Xa[U5S:aUSn [U n [R"U 5nU S:Xa{S U;a#U=R [R"-slS U;a#U=R [R$-slS U;a#U=R [R&-slU(a'UR)U5 [R*Ul U(a'UR)U5 [R2UlU(aUR7XV5 U(a-UR9SR;[=USU555 UR?UR@URBS9Ul U[ R :XaSUl/n [FRHS:XaURBS;aSS/n [JRL"URB5n U ROU S/U S-5 Sn/nU H5n[RP"UR@RS5U5 Sn O U(d-UR5 [1SSR;U535eSUl,UR@R[5n U S;a"SU S3n[\R^"U[`5 gg![,[R.4a$n UR5 [1S U 35U eSn A ff=f![,[R.4a$n UR5 [1S U 35U eSn A ff=f![,[R.4a$n UR5 [1SU 35U eSn A ff=f![RDan [1U 5U eSn A ff=f![RDa&n URU[WU 55 Sn A GMSn A ff=f)aSet SSL parameters. Args: ssl_protos (list): SSL protocol to use. ssl_mode (str): SSL mode. ssl_ca (str): The certification authority certificate. ssl_crl (str): The certification revocation lists. ssl_cert (str): The certificate. ssl_key (str): The certificate key. ssl_ciphers (list): SSL ciphersuites to use. Raises: :class:`mysqlx.RuntimeError`: If Python installation has no SSL support. :class:`mysqlx.InterfaceError`: If the parameters are invalid. z&Python installation has no SSL supportNFTreverserr rrrrzInvalid CA Certificate: z Invalid CRL: zInvalid Certificate/Key: :)server_hostnament) localhost 127.0.0.1rrz"Unable to verify server identity: , )rrzThis connection is using zZ which is now deprecated and will be removed in a future release of MySQL Connector/Python)1 SSL_AVAILABLErrsslcreate_default_contextr'VERIFY_IDENTITYcheck_hostnameREQUIRED CERT_NONE verify_modesortTLS_V1_3_SUPPORTEDr TLS_VERSIONS SSLContextoptions OP_NO_TLSv1_2 OP_NO_TLSv1_1 OP_NO_TLSv1load_verify_locations CERT_REQUIREDIOErrorSSLErrorr*VERIFY_CRL_CHECK_LEAF verify_flagsload_cert_chain set_ciphersrvr2 wrap_socketrrCertificateErrorosnamerf gethostbyaddrextendmatch_hostname getpeercertrsrtrversionwarningswarnDeprecationWarning)r ssl_protosssl_modessl_cassl_crlssl_certssl_key ssl_cipherscontext tls_version ssl_protocolr hostnamesaliases match_founderrshostnamewarn_msgs rzset_sslSocketStream.set_sslRs4} JJLGH H  Z002G7222).&7+++&)mm# OODO )$Q-K&&9, Oa'(m ' 4Lnn\2Gi'J.OOs'8'88OJ.OOs'8'88O*,OOs6O  P--f5&)&7&7#  E--g6'*'@'@$  Q'':    0A LM  4"..t||TZZ.XDL w.. .%)G "Iww$4::1K#K(+6 **4::6G   gaj\GAJ6 7KD%  &&t||'?'?'A8L #'K& $848IJ ll**, . .+K=9))  MM($6 7 /yS\\* P $'?u%EFCO PS\\* E $}SE%:;D ES\\* Q $'@%FGSP Q## 4 C5* 3 4(++*KKC))*sx,&M4&N5O6)P7/Q 4N2N--N25O3O..O36P4P//P47Q QQ R4RRcUR$)zXVerifies if SSL is being used. Returns: bool: Returns `True` if SSL is being used. )rrs rzis_sslSocketStream.is_ssls ||rcUR$)ztVerifies if socket connection is being used. Returns: bool: Returns `True` if socket connection is being used. )rrs rz is_socketSocketStream.is_sockets rc@UR=(d UR$)z^Verifies if connection is secure. Returns: bool: Returns `True` if connection is secure. )rrrs rz is_secureSocketStream.is_secures ||.t.rcURSL$)zZVerifies if connection is open. Returns: bool: Returns `True` if connection is open. N)rrs rzis_openSocketStream.is_opens ||4''r)rrrrNreturnNone)rrrfloatrr)rintrbytes)rrrr)r List[str]rrtrrtrrtrrtrrtrrrrrbool)__name__ __module__ __qualname____firstlineno____doc__r_CONNECT_TIMEOUTrrrrrrrrrr__static_attributes__rrzrrs%) ?O&4( O ~8~8~8 ~8  ~8  ~8~8~8 ~8@/(rrc4^[T5SU4Sjj5nU$)zDecorator used to catch OSError or RuntimeError. Raises: :class:`mysqlx.InterfaceError`: If `OSError` or `RuntimeError` is raised. cF>[U[[45(a+UR5(a[ UR 56eT "U/UQ70UD6n[U[ 5(aqUR5nUH[nUS[;dM[USnSUSSU3US4n[U[[45(aURU5 U$ U$![[[[4Ga(nT RS:XGaU(a[US[5(aUSR5nU(aUSn[USnSUSSU3US4n[U[5(aMURR!5 USS:Xa*[#5R%UR[ U65 [U[[45(aURU5 UR'5 [ U6UeUR'5 eSnAff=f) zWrapper function.codezConnection close: msgz: get_column_metadatarrVN)r} ConnectionPooledConnectionis_server_disconnectedr*get_disconnected_reasonr: get_warningsCONNECTION_CLOSED_ERRORset_server_disconnectedrrr/rr>poolremove_connections PoolsManagerset_pool_unavailable disconnect) rargsrwresultwarnsr error_msgreasonrfuncs rzwrapper(catch_network_exception..wrappers. 4*.>!?@@//11$d&B&B&DEE$000F&*--#002!DF|'>>$;DL$I 0e R {K L"&dZ9I,JKK 88@M"M|D  !66tAw 22Q,,. 8D 7V EI,T%[MI;GV F"$(899 446<4/(N?? $ >6+B"$5E(FGG44V<OO%(&1s: OO  5 s&BCA CCH 8D#HH )rr r!r rwr rr r)r&r's` rzcatch_network_exceptionr)s# 4[00d NrcN^\rSrSrSrSU4SjjrS SjrS SjrS SjrSr U=r $) Routeri1zRepresents a set of connection parameters. Args: settings (dict): Dictionary with connection settings .. versionadded:: 8.0.20 cn>[TU]5 URU5 URSS5US'g)N availableT)superrrget)rconnection_params __class__s rzrRouter.__init__9s0  %& HH[$7[rc US$)zzVerifies if the Router is available to open connections. Returns: bool: True if this Router is available else False. r-rrs rzr-Router.available>s K  rcSUS'g)z1Sets this Router unavailable to open connections.Fr-Nrrs rzset_unavailableRouter.set_unavailableFs ![rc,SU;aUS$USUS4$)zyVerifies if the Router is available to open connections. Returns: tuple: host and port or socket information tuple. rfrcrdrrs rzget_connection_paramsRouter.get_connection_paramsJs) t > !V d6l++rr)r0Mapping[str, Any]rrrr)rz%Union[str, Tuple[str, Optional[int]]]) rr r r r rr-r6r9r __classcell__r1s@rzr+r+1s!8 !",,rr+c^\rSrSrSrS SjrS SjrSSjrSSjrSSjr SSjr SS jr S r g ) RouterManageriUzManages the connection parameters of all the routers. Args: Routers (list): A list of Router objects. settings (dict): Dictionary with connection settings. .. versionadded:: 8.0.20 ctXlX lSUlSUl0Ul/UlUR 5 g)NrT)_routers _settings_cur_priority_idx _can_failover_routers_directoryrouters_priority_list_ensure_priorities)rresettingss rzrRouterManager.__init__^s8 !&'#';=02" !rc0SnURH6nURSS5nUc US- nSUS'M$US:dM,[SS5e SUs=:a[UR5:aO O [SS 5eURR S S S 9 URHtnUSnX0R ;a6[ U5/UR U'URRU5 MMUR UR[ U55 Mv g) z]Ensure priorities. Raises: :class:`mysqlx.ProgrammingError`: If priorities are invalid. rpriorityNrdz(The priorities must be between 0 and 100\You must either assign no priority to any of the routers or give a priority for every routerc US$)NrKrxs rz2RouterManager._ensure_priorities..s:rT)ryr) rAr/r.rrrEr+rFrs)rpriority_countrouterrKs rzrG RouterManager._ensure_prioritieshs mmFzz*d3H!#%(z"C&'QSWXX $ ~ 2DMM 2 2"   6EmmFj)H6665;F^4D''1**11(;''188H $rc|URUnUVs/sHo3R5(dMUPM nnU$s snf)zGet a list of the current available routers that shares the given priority. Returns: list: A list of the current available routers. )rEr-)rrK router_listrVs rz_get_available_routers$RouterManager._get_available_routerss= --h7 ,7NK&;K;K;MvK NOs99cURU5nU(dg[U5S:XaUS$[U5S- n[R"SU5nX$$)zcGet a random router from the group with the given priority. Returns: Router: A random router. Nrr)rZrrandomrandint)rrKrYlastindexs rz_get_random_connection_params+RouterManager._get_random_connection_paramssY 11(;  { q q> !;!#q$'!!rcUR$)ztReturns the next connection parameters. Returns: bool: True if there is more server to failover to else False. )rDrs rz can_failoverRouterManager.can_failovers !!!rcUR(djSUlURR5nURR SS5US'URR SS5US'[ U5$UR URn[UR 5nSnU(aURU5nUcURU:a;URUS- :Xa%[URU55S:aSUlU$U=RS- slURU:aUR URnU(aMW$) z^Returns the next connection parameters. Returns: Router: with the connection parameters. Frcrrd$Tr) rArDrBcopyr/r+rFrCrrarZ)rrouter_settings cur_priorityrouters_priority_lensearchrVs rzget_next_routerRouterManager.get_next_routers= }}!&D "nn113O&*nn&8&8&MOF #&*nn&8&8&GOF #/* *11$2H2HI "4#=#=>77 EF!T%;%;?S%S**.BQ.FFD77 EFJ).D&  " "a ' "%%(<<#99$:P:PQ f  rcUR$)zReturns the directory containing all the routers managed. Returns: dict: Dictionary with priorities as connection settings. )rErs rzget_routers_directory#RouterManager.get_routers_directorys &&&r)rDrCrArErBrFN)re List[Router]rHDict[str, Any]rrr)rKrrrs)rKrrr+r)rr+)rzDict[int, List[Router]]) rr r r r rrGrZrardrnrqrrrrzr?r?Us-"!IF" "!F'rr?c$\rSrSrSrS&SjrS'SjrS(SjrS'SjrS)Sjr S*S+S jjr S'S jr S'S jr S'S jr S'S jrS,SjrS-SjrS-Sjr\S.Sj5r\S/Sj5r\S0Sj5r\S1Sj5r\S2Sj5r\S*S3Sjj5r\S4Sj5r\S5Sj5r\S6Sj5r\S7Sj5r\S8Sj5rS9SjrS:SjrS;Sjr S:Sjr!S ##002D4I4I't{{3&t{{3 ( 8  MM99;HH !LUU9C%c6288:C?9U**40 4==0!%|!>!B!B4==!Q&"""&"7"7!88HJ"3345""  t}}  " #;E7!CD DKTRR]V4\* )&&(( )M!!..00s+B7J $J?C&J J J7J22J7c URRS5[R:XagURR 5(a7URRS5(a[ R"S5 gSU;aUR5 [S5eSn[R"5S:Xa1[5up4nSU;=(a URS 5S S :Hn[R S :a"U(dUR5 [#S 5eUR$R'SS9 URR)URRSS5URRS[R*5URRS5URRS5URRS5URRS5URRS55 SUR;a)URSnUR$R'US9 gg![a SnGNxf=f)aaSet the TLS capabilities. Args: caps (dict): Dictionary with the server capabilities. Raises: :class:`mysqlx.OperationalError`: If SSL is not enabled at the server. :class:`mysqlx.RuntimeError`: If support for SSL is not available in Python. .. versionadded:: 8.0.21 rgNz(SSL not required when using Unix socket.tlszSSL not enabled at serverFLinuxz Oracle Linux.r7)rh z? ? ??  '#5#7 Hq '83T c8J18MQT8T   i '  ! ! #N  &&4&0  MM  nd 3 MM  j'*:*: ; MM  h ' MM  i ( MM  j ) MM  i ( MM  0 1  4== (|4J MM * * * L )'  s#I I+*I+NcURS5nUc8SnU[R:Xa [U5e[R "U5 g0n[ U[5(aKUSSSH;nUSSSVs/sHnUSS SRS 5PM snXgS 'M= OURRRHlnURRRVs/sH2nURRRRS 5PM4 snXgR'Mn URS /5n Sn U(a}UV s/sHn U [ ;dM[ U PM n n U V s/sH oU ;dM U PM n n U (a[ R"U S 5n O U[R:Xa [#S5egU c*[$(a SU ;aSn O[&(a SU ;aSn OSn X;a8SnU[R:Xa [#U5e[R "U5 gUR(R+S U 0S9 U $s snfs snfs sn fs sn f)a{Set the compression capabilities. If compression is available, negociates client and server algorithms. By trying to find an algorithm from the requested compression algorithms list, which is supported by the server. If no compression algorithms list is provided, the following priority is used: 1) zstd_stream 2) lz4_message 3) deflate_stream Args: caps (dict): Dictionary with the server capabilities. compression (str): The compression connection setting. algorithms (list): List of requested compression algorithms. Returns: str: The compression algorithm. .. versionadded:: 8.0.21 .. versionchanged:: 8.0.22 rlNz8Compression requested but the server does not support itvalueobjfldarrayscalarv_stringzutf-8ryrrzmThe connection compression is set as required, but none of the provided compression algorithms are supported. zstd_stream lz4_messagedeflate_streamzFCompression requested but the compression algorithm negotiation failed)rl)r/r&rr+r3rr}r~decoderrrrrrryr r*r6r5ryr)rrrlrcompression_datarcompression_dictrrserver_algorithmsritemclient_algorithmsmatcheds rzr(Connection._set_compression_capabilitiess|< 88M2  #LCk222',, NN3  & - -'07>"%Wg!6w!?0!?(OJ/8??H!?0 U,? (--1155"%!6!6-!6LL))//66w?!6- )6 -00bA  '!&D11-&t,& ! ):W(9EV=Vt(9GW266wqzB  4 44$<   y].??) m/@@) ,  -% k222$S)) NN3  &&K3K&Lq0 -! Xs$?#I48I# I(/ I(I-I-c0URRS5nU(apU[R:XaUR 5 gU[R :XaUR 5 gU[R:XaUR5 ggURR5(aUR 5 gUR5 g![a Of=fUR 5 g![an[SU35UeSnAff=f)z#Authenticate with the MySQL server.rhNzrAuthentication failed using MYSQL41 and SHA256_MEMORY, check username and password or try a secure connection err:) rHr/r%PLAIN_authenticate_plain SHA256_MEMORY_authenticate_sha256_memoryMYSQL41_authenticate_mysql41rxrr*)rrhrs rzrConnection._authenticates}}  ( tzz!((*+++002%**,& [[ " " $ $  $ $ & **,"    002! $??BeE  s*C C"!C"&C77 DDDcR[URUR5nURR UR 55 URR 5nURRURU55 URR5 g)z=Authenticate with the MySQL server using `MySQL41AuthPlugin`.N) rr{r|rysend_auth_start auth_nameread_auth_continuesend_auth_continue auth_data read_auth_okrplugin extra_datas rzr Connection._authenticate_mysql41sp"4::t~~> %%f&6&6&89]]557  (()9)9*)EF ""$rc8URR5(d [S5e[URUR 5nUR RUR5UR5S9 UR R5 g)z;Authenticate with the MySQL server using `PlainAuthPlugin`.z>PLAIN authentication is not allowed via unencrypted connection)rN) rxrr*rr{r|ryrrrr)rrs rzrConnection._authenticate_plainst{{$$&& P !T^^< %%f&6&6&8FDTDTDV%W ""$rcR[URUR5nURR UR 55 URR 5nURRURU55 URR5 g)zBAuthenticate with the MySQL server using `Sha256MemoryAuthPlugin`.N) rr{r|ryrrrrrrrs rzr&Connection._authenticate_sha256_memory#sp' DNNC %%f&6&6&89]]557  (()9)9*)EF ""$rcUR(aRURRUR5 URR UR5 SUlgg)zZDeallocates statement. Args: statement (Statement): A `Statement` based type object. FN)preparedrysend_prepare_deallocatestmt_idrremove)r statements rz_deallocate_statement Connection._deallocate_statement+sL    MM 1 1)2C2C D  # # * *9+<+< =!&I  rcUR5 URRXU5 UR R UR5 SUlg![a SUlgf=f)zPrepares a statement. Args: msg_type (str): Message ID string. msg (mysqlx.protobuf.Message): MySQL X Protobuf Message. statement (Statement): A `Statement` based type object. FNT) rrysend_prepare_preparer+rrrsrrrmsg_typerrs rz_prepare_statementConnection._prepare_statement6sg(   $ $ & MM . .xi H &&y'8'89!  ! ,1D )  s,AA/.A/cUR(dURRXU5 gUR(aUR U5 UR XU5 UR(dURRXU5 gURR XU5 SUlUR5 GOUR(a/UR(dURR XU5 GO]UR(aVUR(dEUR U5 URRXU5 SUl UR5 OUR(dUR(dnUR(dUR XU5 UR(dURRXU5 gURR XU5 OfUR(aUUR(aDUR U5 URRXU5 SUl UR5 UR5 g)zExecutes the prepared statement pipeline. Args: msg_type (str): Message ID string. msg (mysqlx.protobuf.Message): MySQL X Protobuf Message. statement (Statement): A `Statement` based type object. NF) rrysend_msg_without_psdeallocate_prepare_executerrsend_prepare_executereset_exec_counterrchangedrepeatedincrement_exec_counterrs rz_execute_prepared_pipeline%Connection._execute_prepared_pipelineSs*,, MM - -hY G   / /  & &y 1  # #H9 =00 11(K MM . .xi H38I 0  ( ( *    (9(9 MM . .xi H   y'9'9  & &y 1 MM - -hY G %I   ( ( *""9+=+=%%''yA00 11(K MM . .xi H   9#5#5  & &y 1 MM - -hY G %I   ( ( *((*rcURnURc [S5e[U[5(d [ S5eURR SU5up4URRX4U5 [U5$)zExecute a SQL statement. Args: sql (str): The SQL statement. Raises: :class:`mysqlx.ProgrammingError`: If the SQL statement is not a valid string. rz'The SQL statement is not a valid stringsql) rryr,r}rtr.build_execute_statementrr>)rrrrrs rzsend_sqlConnection.send_sqlsrmm == "#DE E#s##"#LM M ==eSI  ))(CrcURc [S5eURRU5up#URRX#5 Sn[ U[ 5(a UR n[X5$)zSend an insert statement. Args: statement (`Statement`): It can be :class:`mysqlx.InsertStatement` or :class:`mysqlx.AddStatement`. Returns: :class:`mysqlx.Result`: A result object. Nr)ryr, build_insertsend_msgr}r?idsr<)rrrrrs rz send_insertConnection.send_insertsh == "#DE E 229=  x- i . .--Cd  rcURRU5up#URX#U5 UR5(a [ U5$[ U5$)a Send an find statement. Args: statement (`Statement`): It can be :class:`mysqlx.SelectStatement` or :class:`mysqlx.FindStatement`. Returns: `Result`: It can be class:`mysqlx.DocResult` or :class:`mysqlx.RowResult`. )ry build_findr is_doc_basedr;r=rrrrs rz send_findConnection.send_findsK 00;  ''yA"+"8"8":":yO $OrcvURRU5up#URX#U5 [U5$)zSend an delete statement. Args: statement (`Statement`): It can be :class:`mysqlx.RemoveStatement` or :class:`mysqlx.DeleteStatement`. Returns: :class:`mysqlx.Result`: The result object. )ry build_deleterr<r s rz send_deleteConnection.send_delete4 229=  ''yAd|rcvURRU5up#URX#U5 [U5$)zSend an delete statement. Args: statement (`Statement`): It can be :class:`mysqlx.ModifyStatement` or :class:`mysqlx.UpdateStatement`. Returns: :class:`mysqlx.Result`: The result object. )ry build_updaterr<r s rz send_updateConnection.send_updaterrcURRXU5upVURRXV5 [U5$![a U(aegf=f)a;Execute a non query command. Args: namespace (str): The namespace. cmd (str): The command. raise_on_fail (bool): `True` to raise on fail. fields (Optional[dict]): The message fields. Raises: :class:`mysqlx.OperationalError`: On errors. Returns: :class:`mysqlx.Result`: The result object. N)ryrrr<r,)r namespacecmd raise_on_failfieldsrrs rzexecute_nonqueryConnection.execute_nonquerys],  MMAAMH MM " "8 1$<   sAAAAcURRSU5up#URRX#5 [U5nUR 5 UR S:Xa [ S5eUSS$)zExecute a SQL scalar. Args: sql (str): The SQL statement. Raises: :class:`mysqlx.InterfaceError`: If no data found. Returns: :class:`mysqlx.Result`: The result. rrz No data found)ryrrr=rrr*)rrrrr"s rzexecute_sql_scalarConnection.execute_sql_scalar sh ==eSI  x-4 <<1  1 1ay|rcURRSX5up4URRX45 [U5$)zReturns the row result. Args: cmd (str): The command. fields (dict): The message fields. Returns: :class:`mysqlx.RowResult`: The result object. mysqlx)ryrrr=)rrrrrs rzget_row_resultConnection.get_row_results8 ==hT  x-rc8URRU5$)zLRead row. Args: result (:class:`mysqlx.RowResult`): The result object. )ryread_rowrs rzr%Connection.read_row.s}}%%f--rc:URRU5 g)zMClose result. Args: result (:class:`mysqlx.Result`): The result object. N)ry close_resultrs rzr(Connection.close_result7s ""6*rc8URRU5$)zTGet column metadata. Args: result (:class:`mysqlx.Result`): The result object. )ryrrs rzrConnection.get_column_metadata@s}}0088rcDU=RS- slUR$)z\Returns the next statement ID. Returns: int: A statement ID. .. versionadded:: 8.0.16 r)rrs rzget_next_statement_id Connection.get_next_statement_idIs! a!!!rc6URR5$)zOCheck if connection is open. Returns: bool: `True` if connection is open. )rxrrs rzrConnection.is_openTs {{""$$rcSUlXlg)znSet the disconnection message from the server. Args: reason (str): disconnection reason from the server. TN)rr)rr%s rzr"Connection.set_server_disconnected\s %)!+1(rcUR$)zVerify if the session has been disconnect from the server. Returns: bool: `True` if the connection has been closed from the server otherwise `False`. )rrs rzr!Connection.is_server_disconnectedes(((rcUR$)znGet the disconnection message sent by the server. Returns: string: disconnection reason from the server. )rrs rzr"Connection.get_disconnected_reasonns ///rcdUR5(dgURR5 g)zDisconnect from server.N)rrxrrs rzr Connection.disconnectvs ||~~  rc*UR5(dgUR5 UR(a5URHnURR U5 M SUlURR5 URR5 URR5 g![[[4a!n[R"SU5 SnANLSnAff=f!URR5 f=f)z*Close a sucessfully authenticated session.NrzGWarning: An error occurred while attempting to close the connection: %s)rrrrryrr send_closeread_okr*r,rr3rrxr)rrrs rz close_sessionConnection.close_session|s||~~   $ $ &,,#66GMM99'B 7%&" MM $ $ & MM ! ! # KK    0':  NN!    KK   s*B B==C3C.)C6.C33C66Dc<UR5(dgURbURR5 URR UR 5Ulg![ [4a!n[R"SU5 SnAgSnAff=f)z*Reset a sucessfully authenticated session.NzDWarning: An error occurred while attempting to reset the session: %s) rr~rry send_resetrzr*r,r3r)rrs rz reset_sessionConnection.reset_sessions|||~~     *    ) ) + !]]55dnnEDN 01  NN   s*A**B:BBcUR5(dgURbURR5 URR 5 URR 5 UR R5 g)zpAnnounce to the server that the client wants to close the connection. Discards any session state of the server. N)rr~rrysend_connection_closer;rxrrs rzrConnection.close_connections`||~~     *    ) ) + ++-  r)r~rr|rrrAr}rrrr{rzryrrHrxrHrtrrr)r"rLrr)rrtrrr)rrtrlrtrzOptional[List[str]]r Optional[str])rrMrr)rrtrrKrzgUnion[FindStatement, DeleteStatement, ModifyStatement, ReadStatement, RemoveStatement, UpdateStatement]rr)rrGrr>)rz$Union[AddStatement, InsertStatement]rr<)rz%Union[FindStatement, SelectStatement]rzUnion[DocResult, RowResult])rz'Union[DeleteStatement, RemoveStatement]rr<)rz'Union[ModifyStatement, UpdateStatement]rr<) rrtrrtrrrOptional[Dict[str, Any]]rzOptional[Result])rrMrr)rrtrrtrr=)r"r=rzOptional[MessageType])r"r<rr)r"r<rzList[ColumnType]rrr)r%zUnion[str, Tuple[str, int]]rr)rz%Optional[Union[str, Tuple[str, int]]])(rr r r r rrrrrrrrrrrrrr)rrr rrrrr"r%r(rr-rrrrr r<r@rrrrrzrrs  WD' %DSL4Mt+/ aaa( a  aF>%%% '""" " ":<+<+<+ <+ <+|&!!&P>P $PP"     ,0   )   @(  ..++99 "%2)0  6  rrch^\rSrSrSrS U4SjjrS U4SjjrS SjrS SjrS Sjr S Sjr S r U=r $) riaSClass to hold :class:`Connection` instances in a pool. PooledConnection is used by :class:`ConnectionPool` to facilitate the connection to return to the pool once is not required, more specifically once the close_session() method is invoked. It works like a normal Connection except for methods like close() and sql(). The close_session() method will add the connection back to the pool rather than disconnecting from the MySQL server. The sql() method is used to execute sql statements. Args: pool (ConnectionPool): The pool where this connection must return. .. versionadded:: 8.0.13 c>[U[5(d [S5e[TU]UR 5 XlUR SUlUR SUlg)Nz&pool should be a ConnectionPool objectrcrd) r}ConnectionPoolrr.r cnx_configrrcrd)rrr1s rzrPooledConnection.__init__sR$// !IJ J )$( 0 0 rc">[TU]5 g)z7Closes the connection. This method closes the socket. N)r.r<)rr1s rzr!PooledConnection.close_connections rc:URRU5 g)a[Do not close, but add connection back to pool. The close_session() method does not close the connection with the MySQL server. The connection is added back to the pool so it can be reused. When the pool is configured to reset the session, the session state will be cleared by re-authenticating the user once the connection is get from the pool. N)radd_connectionrs rzr<PooledConnection.close_sessions   &rcrURbURR5 UR5 g)zReconnect this connection.N)r~rrrs rz reconnectPooledConnection.reconnects,    *    ) ) + rc$UR5 g)zAReset the connection. Resets the connection by re-authenticate. N)rTrs rzresetPooledConnection.resets rc[X5$zCreates a :class:`mysqlx.SqlStatement` object to allow running the SQL statement on the target MySQL Server. Args: sql (string): The SQL statement to be executed. Returns: mysqlx.SqlStatement: SqlStatement object. )rGrrs rzrPooledConnection.sqlsD&&r)rcrrd)rrKrrrrrtrrG) rr r r r rrr<rTrWrrr<r=s@rzrrs+$1  '  ' 'rrc\rSrSrSrSSjrSSjr\SSj5rSSSjjr SSjr SSS jjr SS jr SS jr SS jrSS jrSSSjjrSSjrSSjrSSjrSrg) rKia]This class represents a pool of connections. Initializes the Pool with the given name and settings. Args: name (str): The name of the pool, used to track a single pool per combination of host and user. **kwargs: max_size (int): The maximun number of connections to hold in the pool. reset_session (bool): If the connection should be reseted when is taken from the pool. max_idle_time (int): The maximum number of milliseconds to allow a connection to be idle in the queue before being closed. Zero value means infinite. queue_timeout (int): The maximum number of milliseconds a request will wait for a connection to become available. A zero value means infinite. priority (int): The router priority, to choose this pool over other with lower priority. Raises: :class:`mysqlx.PoolError` on errors. .. versionadded:: 8.0.13 c  URU5 SUl/UlSUlSUl[ R "5UlURSS5Ul [RRXR5 URSS5Ul URSS5UlX lURSS5UlURSS5UlX lUS UlUS Ulg) NrTmax_sizer@ max_idle_time queue_timeoutrKrcrd)_set_pool_name_open_sessions_connections_openned _available_timeoutrnow_timeout_stampr/ pool_max_sizequeueQueuerr@rbrHrcrKrLrcrd)rrrws rzrConnectionPool.__init__s D!#$<>! $ (0 "(**Z"< T#5#56#)::ot#D"(**_b"A(. "(**_b"A#ZZ A6 *0  rc[RU5(a[SUS35e[U5[:a[SUS35eXlg)aCSet the name of the pool. This method checks the validity and sets the name of the pool. Args: pool_name (str): The pool name. Raises: AttributeError: If the pool_name contains illegal characters ([^a-zA-Z0-9._\-*$#]) or is longer than connection._CNX_POOL_MAX_NAME_SIZE. z Pool name 'z' contains illegal charactersz ' is too longN)_CNX_POOL_NAME_REGEXrmrr_CNX_POOL_MAX_NAME_SIZEr)r pool_names rzrdConnectionPool._set_pool_name,sP & &y 1 1 ;yk9V!WX X y>3 3 ;yk!GH H rc,[UR5$)zDReturns the number of open connections that can return to this pool.)rrfrs rzopen_connectionsConnectionPool.open_connections?s4,,--rNc:URRU5 g)z_Removes a connection from this pool. Args: cnx (PooledConnection): The connection object. N)rfrrcnxs rzremove_connection ConnectionPool.remove_connectionDs !!((-rcjUR5S:aTURSURS9nUR5 URU5 UR5S:aMSgg![[ [ 4a N@f=f!URU5 f=f![Ra N_f=f)z*Removes all the connections from the pool.rTblockrN) qsizer/rcrrrr*rzrlEmptyrxs rzr!ConnectionPool.remove_connectionsLsjjlQ 0hhT43E3EhF0((***3/jjlQ%g~>**3/;;  s4BA**B?BBBBB21B2cUR(d [S5eUR5(a [S5eU(d[U5nUR [ 5R 5R5SSn[SURS5SRS555S:a,UR SUR35R 5 URRU5 OU[U[5(d [S 5eUR5(a UR5 UR!5 UR#U5 g ) aAdds a connection to this pool. This method instantiates a Connection using the configuration passed when initializing the ConnectionPool instance or using the set_config() method. If cnx is a Connection instance, it will be added to the queue. Args: cnx (PooledConnection): The connection object. Raises: PoolError: If no configuration is set, if no more connection can be added (maximum reached) or if the connection can not be instantiated. z&Connection configuration not available'Failed adding connection; queue is fullrc36# UHn[U5v M g7frr.0ns rz 0ConnectionPool.add_connection..uB%ASVV%A-rr set mysqlx_wait_timeout = z1Connection instance not subclass of PooledSessionN)rLr-fullrr_SELECT_VERSION_QUERYexecutertuplerrbrfrsr}rrrqueue_connection)rryvers rzrQConnectionPool.add_connection[s DE E 99;;EF F"4(C''/088:DDFqI!LCBSYYs^A%6%<%.)sAjMAEE(A4F3F#Gr)ryrKrr)rir/poprsrr{)rH pool_settingsrerrVconnection_settingss rzr&PoolsManager._get_connections_settings s !  ##Ir2!  %   i ( ] "v'> NN #)&1)&1    G HF"/"4"4"6 *0.  '*0.  '.4Z.@  +,2JJx,C  ) ' '&=)<='  $#rcURU5nURSS5UR;a/URURSS5'UHuup4URURSS5U5(aM.URRURSS5/5nUR [ U40UD65 Mw g)zCreates a `ConnectionPool` instance to hold the connections. Creates a `ConnectionPool` instance to hold the connections only if no other pool exists with the same configuration. Args: cnx_settings (dict): The configuration for the connections. rqrN)rr/rrrsrK)r cnx_settingsrrrHrs rz create_poolPoolsManager.create_pool8s $==lK   K 1 ECEDLL))+w? @&: !K  !1!1+w!GUU<<##L$4$4['$JBOD KK{?h? @ &:rcU(dg[U5S:XaUS$[U5S- n[R"SU5nX$)z}Get a random router from the group with the given priority. Returns: Router: a random router. .. versionadded:: 8.0.20 Nrr)rr]r^) pool_listr_r`s rz_get_random_poolPoolsManager._get_random_poolNsG y>Q Q< 9~!q$'rc/nSnU[U5:a\XRnX$:Xa+XR5(aURX5 OX$:waU$US- nU[U5:aM\U$)Nr)rrKr-rs)rr`rksublist next_prioritys rz _get_sublistPoolsManager._get_sublist`sy c%j !L11M,1G1G1I1Iu|,. QJE c%j rcSnUH.nUR5(aX$R:Xa O US- nM0 /nU(d>U[U5:a/URXU5nUS- nU(dU[U5:aM/UR U5$)Nrr)r-rKrrr)rrrkr`rsubpools rz_get_next_poolPoolsManager._get_next_poolosD~~LMM$A QJEec%j0''lCG QJEec%j0$$W--rcUcU(aUSR$UH(nUR5(dMURnUs $ USR$)Nr)rKr-)rrkt_pools rz_get_next_priorityPoolsManager._get_next_priority}sV  E8$$ $F!!% ##Qx   rcURU5nUHjnUR5(aMUR5upVU(aUn[R"5U[ US9-:dMZUR 5 Ml g)N)seconds)rr-rrrirr)rrHreviverrr timeout_stamps rz_check_unavailable_pools%PoolsManager._check_unavailable_poolssi)D~~%)%;%;%= "G ||~71K!KL""$rc  ^ SU 4SjjnURU5nURSS5n/nURU5 URX45nUc [ S5eXAS'UR X45m [ R"5nT GbT R5S:axU T RST RS9nUR5(aT R5 UR(dUR5 U"U5 UsSSS5 $T R0T R2:a6[+T 5nT R-U5 UR/5 U"U5 U$U T RST RS9nUR5 U"U5 UsSSS5 $[ S5e![Ra [ S5Sef=f![ ["[$4Gah UR'5 O![ ["[$4a Of=fT R)U5 O!T R)U5 f=fT R5S:aT RST RS9nUR'5 O![ ["[$4a Of=fT R)U5 O0!T R)U5 f=f![Ra Of=fT R5S:aM[+T 5nT R-U5 UR/5 U"U5 O![ ["[$4a Of=fT R5S:anT RST RS9nUR'5 T R)U5 O![ ["[$4a Of=fT R5S:aMnGN!T R5S:aoT RST RS9nUR'5 T R)U5 O![ ["[$4a Of=fT R5S:aMnff=ff=f!,(df  GO=f![Ra [ S 5Sef=f!,(df  O=f![$[4[4anUR7S T S U35 [9U[5(aT R;S 5 OUR=T U5 URU5 UR X45m T cJURX45nXAS'UR X45m T c!S R?U5n [ SU S35UeSnAGMSnAff=fT bGMGN)a^Get a connection from the pool. This method returns an `PooledConnection` instance which has a reference to the pool that created it, and can be used as a normal Connection. When the MySQL connection is not connected, a reconnect is attempted. Raises: :class:`PoolError`: On errors. Returns: PooledConnection: A pooled connection object. c<>UR[5R5R5SSn[ SUR S5SR S555S:a-URSTR 35R5 gg)Nrc36# UHn[U5v M g7frrrs rzrOPoolsManager.get_connection..set_mysqlx_wait_timeout..rrrrrr)rrrrrrrb)ryrrs rzset_mysqlx_wait_timeout.set_mysqlx_wait_timeouts''/088:DDFqI!LCBSYYs^A%6%<%#J% $%!% 6 6s ; 6 6s ;#'**,"2 !D*.((.2D,8'>+R%-(,%-)-(>(>s(C(>(>s(C(-{{!)$(!) #'**,"2-&6t&< $ 5 5c : # 7 <$0'>#J% $% '+jjlQ&6%-.2hh26484F4F/7/*),(<(<(>(,(>(>s(C,8'>+R%-(,%-'+jjlQ&6djjlQ&6%-.2hh26484F4F/7/*),(<(<(>(,(>(>s(C,8'>+R%-(,%-'+jjlQ&6G,-!Z %{{X"+,L"MSWWX #L)< !!F4&">?c9--((+--dC8--h7**5?<#'#:#:5#OL/;^,..uCD|$kk*5'$$'5- ##/ isR"$Q&F6AGQ R"AR"*R",R.3Q-! R"6!GQQ1HH/HH/HH/Q/IQK 5JJ3JJ3JJ3!Q3KQ K QK  Q:4L/.O/MOMO Q;NQN30Q2N33Q QQ%;P! Q!P9 6Q8P9 9QQQQ Q*%R"*R"-!RR RR"R""V7B?U==VcURU5nUHjnUR5 URSS5cM(URRURS55nX4;dMYUR U5 Ml [ U5$)zRCloses the connections in the pools Returns: int: The number of closed pools rqN)rrr/rrr)rrrr client_poolss rz close_poolPoolsManager.close_pool+sw  -D JJL T2>#||// 0@0@0MN ' ''- 5zrc&SnURn[UnU(d2URn[ R 5HupVXT;dM UnM U(aURU5 gURS5 g![[4a Nvf=f)a$Sets a pool as unavailable. The time a pool is set unavailable depends on the given error message or the error number. Args: pool (ConnectionPool): The pool to set unavailable. err (Exception): The raised exception raised by a connection belonging to the pool. Ni)errnorrrur_TIMEOUT_PENALTIESitemsr6)rrpenaltyerr_noerr_msgryrs rzr!PoolsManager.set_pool_unavailable;s YYF26:GggG0668 >#G9    )   ()   sA==BBr)rr)rqrtrrrtrr)rHrtrr)rHrtrz List[Tuple[str, Dict[str, Any]]])rrtrr)rList[ConnectionPool]rrK)rrr`rrkrrr)rrrkrrrKr)rrrk Optional[int]rr)rHrtrzOptional[bool]rr)rHrtrr)rrtrr)rrKrz#Union[InterfaceError, TimeoutError]rr)rr r r r r__annotations__rrrr staticmethodrrrrrrrrrrrrrrzrrsH $J # G^ '  .*$ *$ )*$*$XA,  " # ,/ ?B     .) .9< .  .CG !# !3@ !  ! !BF %& %0> %  %RHh ))#F) ))rrc0\rSrSrSrSSjrSSjrSSjrSSjr\ SSj5r \ RS Sj5r SS jr S!S jr S"S jrS#S jrS$S jrS%SjrS&SjrS$SjrSSjrSSjrSSjrS'S(SjjrS&SjrS&SjrSSjrSSjrSrg))Sessioni[aEnables interaction with a X Protocol enabled MySQL Product. The functionality includes: - Accessing available schemas. - Schema management operations. - Retrieval of connection information. Args: settings (dict): Connection data used to connect to the database. cTURS[R5UlXlURS5(aURS5(a[(d [ S5e[ RRUSS5n/URS'UH[nURSRURRS S 9URURUR S .5 M] S UR;dURS S La0URS'UR#5 SU;aZUS(aP[%5R'U5 [%5R)U5UlUR*c [-S5eO4[/UR5UlUR*R15 URRS5nU(a-UR3S[5U535R75 gg![ RRan[ SUSS35UeSnAff=f![8a=nUR:S:Xa UR<OSUS3n[ XcR:5UeSnAff=f)NrircrnztMySQL host configuration requested DNS SRV. This requires the Python dnspython module. Please refer to documentationSRVz Unable to locate any hosts for ''reT)omit_final_dot)rcrdrKrrkFrpoolingz+Connection could not be retrieved from poolrbzUSE iDefault schema '' does not exists)r/r4use_purerBHAVE_DNSPYTHONr*dnsresolverquery exception DNSExceptionrstargetto_textrdrKr_init_attributesrrr _connectionr-rrrrIrr,rr)rrH srv_recordsrsrvrberrmsgs rzrSession.__init__hsY&ll:x7H7HI )1 <<  HLL$;$;!>$<  !ll00&1A5I )+DNN9 %"y)00 # 2 2$ 2 G #$'LL"%** # $4>> 9~~56eC+-DNN< (  ! ! #  Xi%8 N & &x 0+7>+H+H+RD ' MNN( *$..9D     $ $ &##H-  A4 0 89:;CCE C==-- $6x7G6HJ H$ AyyD(GG+F83DE %VYY7S@ As0/#H':+I 'III J'*8J""J'cU$rrrs rz __enter__Session.__enter__ rc$UR5 grrrexc_type exc_value tracebacks rz__exit__Session.__exit__ rc $[RS:XaoS[R"5S;aSnO4S[R"5S;aSnO[R"5nS[R"5S3nOf[R "5n[R "5S :XaS [R"5S3nOS R[5SS 5n[R"S 5nUSS:XaSnOSn[[R"55UU[R"5SSR[ SSVs/sHn[U5PM sn5US.nUR"SR%U5 SUR";aUR"SHnUR"SUn['U[5(d[)SUS35e[+U5S:a[)SUS35eUR-S5(a[)SU35e['U[5(d[)SUSUS35e[+U5S:a[)SUS US!35eXR"SU'M g"g"s snf)#z5Setup default and user defined connection-attributes.r64rx86_6432i386zWindows-rDarwinzmacOS-rrh GPLv2zGPL-2.0 Commercialzmysql-connector-pythonr)_pid _platform_os _source_host _client_name_client_version_client_licenserrkAttribute name '' must be a string type "' exceeds 32 characters limit sizerrzHKey names in 'session-connect-attributes' cannot start with '_', found: z ' value 'z' must be a string type ' value: '$' exceeds 1024 characters limit sizeN)rrr architecture win32_vermachinermac_verrvrSrTrrtgetpidrf gethostnamerUrBrr}r*r startswith) r platform_archos_verlicense_chunksclient_licenserRdefault_attributes attr_name attr_values rzrSession._init_attributess 77d?x,,.q11=E ..033 & ( 5 5 7  2 2 4Q 789F$,,.M H,!("2"2"4Q"7!89"4"6q";< s+ !  '&N)N $&"..04"xx1(FAQ(FG-  |$++,>? "dnn 4!^^,CD !^^,CDYO !)S11(*9+5LMy>B&(*9+6%% '',,(22;> "*c22(*9+YzlK11 z?T)(*9+Z |L== ;E|,Y7CE 5 )GsJ c"[R$)z8bool: `True` to use pure Python Protobuf implementation.)r4rrs rzrSession.use_pures   rcp[U[5(d [S5e[R"U5 g)Nz)'use_pure' option should be True or False)r}rr.r4 set_use_pure)rrs rzrrT s)%&&"#NO Oe$rcJURRR5$)zbReturns `True` if the session is open. Returns: bool: Returns `True` if the session is open. )rrxrrs rzrSession.is_open s &&..00rc.[URU5$rZ)rGrr[s rzr Session.sql sD,,c22rcUR$)zfReturns the underlying connection. Returns: mysqlx.connection.Connection: The connection object. )rrs rzrSession.get_connection s rcURS5R5nUR5Vs/sHo"SPM sn$s snf)zReturns the list of schemas in the current session. Returns: `list`: The list of schemas in the current session. .. versionadded:: 8.0.12 zSHOW DATABASESr)rrr)rr"rows rz get_schemasSession.get_schemas" sA*+335"("2"2"45"43A"4555s Ac[X5$)zRetrieves a Schema object from the current session by it's name. Args: name (string): The name of the Schema object to be retrieved. Returns: mysqlx.Schema: The Schema object with the given name. r(rrs rz get_schemaSession.get_schema- sd!!rc^URRRS5nU(acUR[R [ U555R5R5nUSSU:Xa [X5$gg![a [SUS35Sef=f)aRetrieves a Schema object from the current session by the schema name configured in the connection settings. Returns: mysqlx.Schema: The Schema object with the given name at connect time. None: In case the default schema was not provided with the initialization data. Raises: :class:`mysqlx.ProgrammingError`: If the provided default schema does not exists. rbrrrN) rrHr/r_SELECT_SCHEMA_NAME_QUERYformatr0rrr)rr.)rrbress rzget_default_schemaSession.get_default_schema8 s!!**..x8 299&.IJ   q6!9&!$//'   &&vh.?@ s 7BB,cvURRS[R[ U55S5 g)zsDrops the schema with the specified name. Args: name (string): The name of the Schema object to be retrieved. rTN)rr_DROP_DATABASE_QUERYrgrIrbs rz drop_schemaSession.drop_schemaV s1 )) '../?/EF rcURRS[R[ U55S5 [ X5$)zCreates a schema on the database and returns the corresponding object. Args: name (string): A string value indicating the schema name. rT)rr_CREATE_DATABASE_QUERYrgrIr)rbs rz create_schemaSession.create_schema` s> )) )001A$1GH$ d!!rc>URRSSS5 g)z+Starts a transaction context on the server.rzSTART TRANSACTIONTNrrrs rzstart_transactionSession.start_transactionl s ))%1DdKrc>URRSSS5 g)zHCommits all the operations executed after a call to startTransaction(). rCOMMITTNrtrs rzcommitSession.commitp s ))%4@rc>URRSSS5 g)zIDiscards all the operations executed after a call to startTransaction(). rROLLBACKTNrtrs rzrollbackSession.rollbackv s ))%TBrNcUc[R"5nO=[U[5(a[ UR 55S:Xa [ S5eURRSS[U53S5 U$)zCreates a transaction savepoint. If a name is not provided, one will be generated using the uuid.uuid1() function. Args: name (Optional[string]): The savepoint name. Returns: string: The savepoint name. rInvalid SAVEPOINT namerz SAVEPOINT T) uuiduuid1r}rtrstripr.rrrIrbs rz set_savepointSession.set_savepoint| sq <jjl^DD#&&#djjl*;q*@"#;< < )) Z 0 678$  rc[U[5(a[UR55S:Xa [ S5eUR R SS[U53S5 g)zgRollback to a transaction savepoint with the given name. Args: name (string): The savepoint name. rrrzROLLBACK TO SAVEPOINT TNr}rtrrr.rrrIrbs rz rollback_toSession.rollback_to sZ $$$DJJL(9Q(>"#;< < )) $%5d%;$< =  rc[U[5(a[UR55S:Xa [ S5eUR R SS[U53S5 g)zcRelease a transaction savepoint with the given name. Args: name (string): The savepoint name. rrrzRELEASE SAVEPOINT TNrrbs rzrelease_savepointSession.release_savepoint sZ $$$DJJL(9Q(>"#;< < ))  !1$!7 8 9  rclURR5 [UR5Ulg)zCloses the session.N)rr<rrBrs rzr Session.close s% &&(%dnn5rc8URR5 g)z8Closes all underliying connections as pooled connectionsN)rrrs rzclose_connectionsSession.close_connections s ))+r)rrBrrErr r&zType[BaseException]r' BaseExceptionr(rrrrr)rrrrr])rr)rr)rrtrr))rzOptional[Schema])rrtrrr)rrFrrt)rr r r r rr!r)rrrsetterrrrr_rcrirmrqruryr}rrrrrrrrrzr r [s 9Av%!!   KEZ!!__%% 1 3  6 "<  "LA C *    6 ,rr c\rSrSrSrSSSjjrSSjrSSjrSSjrSSjr SS jr SS jr SS jr SS jr S rg)Clienti aClass defining a client, it stores a connection configuration. Args: connection_dict (dict): The connection information to connect to a MySQL server. options_dict (dict): The options to configure this client. .. versionadded:: 8.0.13 NcXlUc0n/Ul[R"5UlUR UR SS55 URUR SS55 URUR SS55 URUR SS55 URURS'URURS'URURS 'g) Nr`rarbrrcenabledTrrq) rHsessionsruuid4rq_set_pool_sizer/_set_max_idle_time_set_queue_timeout_set_pool_enabledpooling_enabledr`)rconnection_dict options_dicts rzrClient.__init__ s )8  L') $(JJL L,,Z<=  0 0! DE  0 0! DE |// 4@A#'#7#7 i $(MM j!%)^^ k"rcU$rrrs rzr!Client.__enter__ r#rc$UR5 grrr%s rzr)Client.__exit__ r+rc[U[5(d[U[5(aUS:d[SUS35eUS:Xa [UlgUUlg)aSSet the size of the pool. This method sets the size of the pool but it will not resize the pool. Args: pool_size (int): An integer equal or greater than 0 indicating the pool size. Raises: :class:`AttributeError`: If the pool_size value is not an integer greater or equal to 0. rzGPool max_size value must be an integer greater than 0, the given value is not validN)r}rrr_CNX_POOL_MAXSIZEr`)r pool_sizes rzrClient._set_pool_size sY y$ ' 'i--q= (k8  .7!^)  rc[U[5(d[U[5(aUS:d[SUS35eXlUS:Xa[ O [US- 5UR S'g)a=Set the max idle time. This method sets the max idle time. Args: max_idle_time (int): An integer equal or greater than 0 indicating the max idle time. Raises: :class:`AttributeError`: If the max_idle_time value is not an integer greater or equal to 0. rzYConnection max_idle_time value must be an integer greater or equal to 0, the given value rrrrbN)r}rrrrb_CNX_POOL_MAX_IDLE_TIMErH)rrbs rzrClient._set_max_idle_time ss }d + +mS11 2% //? ? I MMu~~EJJM ? v/ 2 >-C -- *   $)Iw 8gaj8 I"]3%#8$?S H Is$G  G,G''G,chSS0n[RU5nU(aUR5OSU4up0US;a[SUS35eUS:XaSUS 'UR S 5S S S 2upEUR S 5S S S 2upgUR S5nXhS R S5S:XaUS:aURSS5uoaS'URS5nU(a U(aSU;a[SUS35eURSS5up[U 5[U 5sUS'US'URS5(a[U5US'O;URS5(a [S5eUR[U55 Sn [US5HupU RSS5R!5nX;a[S U S35eU[";a[U RS55X'MaU R!5nUS!;aSX'M}US";aS#X'MXU'M U$)$aMParses the connection string and returns a dictionary with the connection settings. Args: uri: mysqlx URI scheme to connect to a MySQL server/farm. Returns: Returns a dict with parsed values of credentials and address of the MySQL server/farm. Raises: :class:`mysqlx.InterfaceError`: If contains a invalid option. rbrr!)r! mysqlx+srvzScheme 'z' is not validrTrn@Nrh?/)rrrz()rzMalformed URI 'r r`ra)rrNrrfz\.zWindows Pipe is not supported)r`rarnrrrzInvalid option: ')1true)0falseF)_URI_SCHEME_RErgroupsr* partitionrfindfindrsplitrrrrJrrrrr _SSL_OPTS)urirHrschemeuserinfotmprc query_strposr`rainvalid_optionsryvaloptval_strs rz_parse_connection_urir s!)"~H   %E$)%,,.#KF --xx~>?? "MM#&ss+MHmmC(1-OD **S/C Dzsr!cAg#';;sA#6 x ::d D x3h#6se1566^^C+ND-4T]GHL"KK 534E3FaHIIHy)F FE ** 8 !XJ' X#*,6x,E,E &&(8$HZ 8 #(<  # #   A ) !!BC CH!9:;;H8!;>??8 Z 8A! CDD  P#(24(=(= ""$4 HV   }-  &1k3//!!#))+ 'H] # 8+ h78# > >1288:@@F #&5K5Q5QRU5V125912H%=>u NN R  << &+*>*> >15H- .(*'1H$ (#45s;;.1(;L2M.N*+x(9:C@@-.2  3H(9-t44 !KL L << ! ! N  <<   M  << " " S  # 8 HLL$8$8 !x(X%"8,&I + X #5hz6J5K1!MNTW W X6 + P >(62B1C1!EFC O P +  ]+,,?A   F (  sXAPAP=#AQ(/ARP:"P55P:=Q% Q  Q%(R8R  RR*cSU;a;US(a1[US5US'USS:d USS:a [SS5eS U;aUS (a[US 5US 'gS U;a U(aXS 'ggg![a [SS5Se[a [SUS3S5Sef=f![a [ S 5Sef=f) zValidate hosts. Args: settings (dict): Settings dictionary. default_port (int): Default connection port. Raises: :class:`mysqlx.InterfaceError`: If priority or port are invalid. rKrrLz1Invalid priority value, must be between 0 and 100rMzInvalid priorityNzInvalid priority: rdz Invalid portrc)rr. NameErrorrr*)rH default_ports rzrrS s X(:"6 #&x ';#r?r@rrzBKey names in connection-attributes cannot start with '_', found: 'z Attribute 'rBrArC) r}rtrJrr*rrr~reprrrrr) rHrrconn_attributesattr attr_name_valrPattr_valrQs rzrrw sJh.12J*c""  02H, -   ! !# & &:+>+>s+C+C BB 44>)3 $%rc,/nSU;agUSn[U[5(aURS5(aURS5(d[ SUS35eUSSR S 5nUHOnUR 5nUS :XaMXQ;a[ [R"S US 95eURU5 MQ O[U[5(aPU(d [ S 5eUH7nXA;a[ [R"S US 95eURU5 M9 OU[U[5(aUHnURU5 M O%[ SSR[5SUS35eU(d [ S 5e/n/n/nUHLnU[;aURU5 U[;aURU5 M;URU5 MN U(aKUS/:Xa/[(d$[!["R"U[55eUR%5 X`S'gU(a$[![&R"U[55eU(a$[ [(R"W[55eg)zValidate tls-versions. Args: settings (dict): Settings dictionary. Raises: :class:`mysqlx.InterfaceError`: If tls-versions name is not valid. r^Nrrz%tls-versions must be a list, found: 'r rrrr tls_versionsrrzKAt least one TLS protocol version must be specified in 'tls-versions' list.z>tls-versions should be a list with one or more of versions in rz . found: 'r )r}rtrJrr*rrrOrgrsrrrvr#r!rr+rPrrQrR) rHrtls_versions_settingstls_verstls_verruse_tls_versionsdeprecated_tls_versionsnot_tls_versionss rzrr sLX%$^4'-- ! , ,S 1 1%..s33 78M7NaP )2.44S9G!--/Kb *$,33+;    ,  )4 0 0$ 4 -G&$,33wW    ( - )3 / /,G    (- Lyy/01L> L   #    , ,  # #G , - - # * *7 3  # #G ,    { *3E3E#$++L:PQ  #3  ( / /')?   .55g?UVWW rc^/nSU;agUSn[U[5(aURS5(aURS5(d[ SUS35eUSSR S 5nU(d [ S 5eUH;nUR 5R5nU(dM*URU5 M= OD[U[[45(aUVs/sH oD(dM UPM nnO[ S US35eURS S5c [SSOUS SSnURS S9 USn/n0n/n [S[R"U5S-H3n UR[ U 5 U R#[$U 5 M5 UHmn SU ;aX;aURU 5 M!X;a:Xn X;a['[(R*"SU S95eURU 5 M`[ SU S35e U(d [ S 5eXpS'gs snf)zValidate tls-ciphersuites. Args: settings (dict): Settings dictionary. Raises: :class:`mysqlx.InterfaceError`: If tls-ciphersuites name is not valid. r_Nrrz)tls-ciphersuites must be a list, found: 'r rrrz:No valid cipher suite found in the 'tls-ciphersuites' listzItls-ciphersuites should be a list with one or more ciphersuites. Found: 'r^Trrrtls_ciphersuitesrz The value 'z.' in cipher suites is not a valid cipher suite)r}rtrJrr*rrupperrsrrr/r#rr`rr$rr"rrOrg) rHrtls_ciphersuites_settingstls_csstls_csr newer_tls_vertranslated_namesiani_cipher_suites_namesossl_cipher_suites_namesr rtranslated_names rzrrB sw) (); <+S11 % 0 0 5 5)22377 -.a1 ,Ab177< L F\\^))+Fv ''/ -c{ ; ;1JU1JvfF1JU 01 4   << - 5 q! n %a (d# OM!*,*9 & &} 5 9 !''(9'(BC ''(8(AB  ! $;4;  # #D )  -6?M nsDk 2 2JKK.#&& ::n5L  (..0JC27S#. /1 lD ) ) O  L &**95/D22 N +:*=*=i*NY'+:+>+>z2+NZ(0?0C0COUV0W_-0?0C0COUV0W_-  ! # #A/AR!ST T | q  3L4E4E4G3HI  - 66G  S  s.F44 G> G  G)rwr rrt)rr;rr)r&r rr )rrtrz"Union[Dict[str, List[Dict]], Dict])rrtrrtrEr)rHrtrrrr)r!r rwr rrt)r!r rwr rr )rUnion[str, Dict[str, Any]]rr$rr)r  __future__rtypesrrrPROTOCOL_TLSv1PROTOCOL_TLSv1_1PROTOCOL_TLSv1_2rhasattrrPROTOCOL_SSLv23r r ImportErrorrrrrlr]rerfrrrrtypingr r r rrrrrr dns.exceptionr dns.resolverrrr functoolsr json.decoderr urllib.parserrrauthenticationrrr constantsr r!r"r#r$r%r&r'crudr)errorsr*r+r,r-r.r/helpersr0r1r2r3protobufr4ryr5r6r7r8r9r"r:r;r<r=r>rr?r@rArBrCrDrErFrGrHrIrJrKrLrMrrsmysql.connector.abstractsrOrPrQrRmysql.connector.utilsrSmysql.connector.versionrTrUrr rlrprfrrrqcompilerprr_PENALTY_SERVER_OFFLINE_PENALTY_MAXED_OUT_PENALTY_NO_ADD_INFO_PENALTY_CONN_TIMEOUT_PENALTY_WRONG_PASSW_PENALTY_RESTARTINGrrrVERBOSErrrrrr{rrr)r~r+r?rrrmrKrr rrrrrrrrrrr#rrrzrEs>;"M##''''L 3 ' '    !m4H    SSSN((55VV   GFQQGG    JI 54  I  3;R+zz"9:!!"#+$/*-)&)!%&9: JJ) * zz> K ZZ12:: > AB   &8:q(q(h;|!,T!,HA'A'HW W tF'zF'RT#U[[T#nE)E)P Z,Z,z ](](@49n<~B-L=A!(!(,9!( !(Hm3`XXvV4r!H"c71c7.c7 c7wdML,Ns$A/LL+ L('L(+L76L7