U
|
¤ý°d®à ã @ s d Z ddlmZ ddlmZ zLddlZdZejejej dZ
|
e edrLej nej e
|
d< e ed odejZW n ek
|
r d
|
Zd
|
Zi Z
|
Y nX ddlZddlZddlZddlZddlZddlZddlZddlZddlZddlZddlZdd l m Z m Z m Z m Z m!Z!m"Z"m#Z#m$Z$m%Z% zddl&Z'ddl(Z'W n ek
|
r< d
|
Z)Y nX dZ)dd l*m*Z*m+Z+ dd l,m-Z- ddl.m/Z/ ddl0m1Z1m2Z2m3Z3 ddl4m5Z5m6Z6m7Z7 ddl8m9Z9m:Z:m;Z;m<Z<m=Z=m>Z>m?Z?m@Z@ ddlAmBZB ddlCmDZDmEZEmFZFmGZGmHZHmIZI ddlJmKZKmLZLmMZM ddlNmNZN ddlOmPZP ddlQmRZRmSZSmTZTmUZUmVZV ddlWmXZXmYZYmZZZm[Z[m\Z\ ddl]m^Z^m_Z_m`Z`maZambZbmcZcmdZdmeZemfZfmgZgmhZh ddlmiZimjZjmkZkmlZl ejm nd ¡ dd lompZpmqZqmrZrmsZs dd ltmuZu dd lvmwZwmxZx d d!d"d#Zyd$Zzd%Z{d&Z|d'Z}d(Z~d)Zd*Ze d+¡Zd,Zd,Zd-Z
d.Zd/Zd/Zd0Zd.Zeee
e
eeeed1Zd2eiZe d3¡Ze d4ej¡Ze d5ej¡Ze d6¡Zd7d8d9d:d;d<gZed=d>d?d@dAdBdCdDdEdFdGdHdIdJdKg ZdLdMdNdOdPZdQdRdSdTdUZG dVdW dWZdXdXdYdZd[ZG d\d] d]eZG d^d_ d_ZG d`da daZG dbdc dceZG ddde deejZG dfdg dgZG dhdi diZ G djdk dkZ¡dMdldmdndoZ¢dMdpdqdrdsZ£dpdRdtdudvZ¤ddpdwdRdxdydzZ¥dpdRdtd{d|Z¦dpdRdtd}d~Z§dpdRdtddZ¨dLdLdpdddZ©dLdLdiddd
ZªdddkdddZ«dS )z4Implementation of communication for MySQL X servers.é )Ú annotations)Ú TracebackTypeNT)ÚTLSv1úTLSv1.1úTLSv1.2Ú PROTOCOL_TLSúTLSv1.3Ú HAS_TLSv1_3F) ÚAnyÚCallableÚDictÚListÚMappingÚOptionalÚTupleÚTypeÚUnion)ÚdatetimeÚ timedelta©Úwraps)ÚJSONDecodeError)Ú parse_qslÚunquoteÚurlparseé )ÚMySQL41AuthPluginÚPlainAuthPluginÚSha256MemoryAuthPlugin)ÚCOMPRESSION_ALGORITHMSÚDEPRECATED_TLS_VERSIONSÚOPENSSL_CS_NAMESÚSUPPORTED_TLS_VERSIONSÚTLS_CIPHER_SUITESÚAuthÚ CompressionÚSSLMode©ÚSchema)ÚInterfaceErrorÚNotSupportedErrorÚOperationalErrorÚ PoolErrorÚProgrammingErrorÚ TimeoutError)ÚescapeÚget_item_or_attrÚiani_to_openssl_cs_name)Úlogger)ÚProtobuf)ÚHAVE_LZ4Ú HAVE_ZSTDÚ MessageReaderÚ MessageWriterÚProtocol)Ú
|
BaseResultÚ DocResultÚResultÚ RowResultÚ SqlResult) Ú AddStatementÚDeleteStatementÚ FindStatementÚInsertStatementÚModifyStatementÚ ReadStatementÚRemoveStatementÚSelectStatementÚ SqlStatementÚUpdateStatementÚquote_identifier)Ú
|
ColumnTypeÚ MessageTypeÚResultBaseTypeÚ StatementTypeú..)ÚDUPLICATED_IN_LIST_ERRORÚTLS_VER_NO_SUPPORTEDÚ TLS_VERSION_DEPRECATED_ERRORÚTLS_VERSION_ERROR)Úlinux_distribution)ÚLICENSEÚVERSIONzThis session was closed because the connection has been idle for too long. Use 'mysqlx.getSession()' or 'mysqlx.getClient()' to create a new one.z<This session was closed because the server is shutting down.zThis session was closed because the connection has been killed in a different session. Use 'mysqlx.getSession()' or 'mysqlx.getClient()' to create a new one.)i é ia i' zDROP DATABASE IF EXISTS {}z CREATE DATABASE IF NOT EXISTS {}zLSELECT SCHEMA_NAME FROM INFORMATION_SCHEMA.SCHEMATA WHERE SCHEMA_NAME = '{}'zSELECT @@versionéc éx z[^a-zA-Z0-9._:\-*$#]iÄ i@B é< i iQ )z[WinError 10053]z
|
[Errno 32]z[WinError 10061]z [Errno 111]z[WinError 10060]z [Errno 11001]z
|
[Errno -2]z Access deniedrU z,(?![^\(\)]*\))z!^\(address=(.+),priority=(\d+)\)$z^\(address=(.+)[,]*\)$z"^([a-zA-Z][a-zA-Z0-9+\-.]+)://(.*)ússl-certússl-caússl-keyússl-crlú tls-versionsútls-ciphersuitesÚuserÚpasswordÚschemaÚhostÚportÚroutersÚsocketússl-modeÚauthúuse-pureúconnect-timeoutúconnection-attributesÚ compressionúcompression-algorithmsúdns-srvr
|
Ústr)ÚkwargsÚreturnc K sP g }dD ]0}z| t| | ¡ W q tk
|
r6 Y qX q|sFtdd |¡S )ab Generate 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.
|
)rb rc r_ ZdatabaseÚ client_idz.Failed generating pool name; specify pool_nameÚ_)Úappendrn ÚKeyErrorr, Újoin)ro ÚpartsÚkey© rx úHd:\z\workplace\vscode\pyvenv\venv\Lib\site-packages\mysqlx/connection.pyÚgenerate_pool_nameØ s rz úMapping[str, Any]ÚNone)Ú penalty_dictrp c C s | rt | trt | ¡ dS )zÊUpdate 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)Ú
|
isinstanceÚdictÚ _TIMEOUT_PENALTIES_BY_ERR_NOÚupdate)r} rx rx ry Ú!update_timeout_penalties_by_errorô s r c @ sÄ e Zd ZdZddddZefddddd d
|
Zd d d ddZd ddddZddddZ ddddZ
|
dddddddddddZ d dd d Z d dd d Z d dd!d"Zd dd#d$Zd%S )&Ú SocketStreamzImplements a socket stream.r| ©rp c C s d | _ d| _d| _d | _d S )NF)Ú_socketÚ_is_sslÚ
|
_is_socketÚ_host©Úselfrx rx ry Ú__init__ s zSocketStream.__init__r Úfloat)ÚparamsÚconnect_timeoutrp c C s¢ |dk r|d }z t ||¡| _|d | _W nd tk
|
r z0t t j¡| _| j |¡ | j |¡ d| _W n t k
|
r t
|
ddY nX Y nX | j d¡ dS )zÇConnects to a TCP service.
|
|
Args:
|
params (tuple): The connection parameters.
|
|
Raises:
|
:class:`mysqlx.InterfaceError`: If Unix socket is not supported.
|
Néè r TzUnix socket unsupported) re Úcreate_connectionr
r Ú
|
ValueErrorÚAF_UNIXÚ
|
settimeoutÚconnectr ÚAttributeErrorr) )r r r rx rx ry r s" ÿ
|
zSocketStream.connectÚintÚbytes)Úcountrp c C s\ | j dkrtdg }|dkrR| j |¡}|dkr:td| |¡ |t|8 }qd |¡S )zReceive data from the socket.
|
|
Args:
|
count (int): Buffer size.
|
|
Returns:
|
bytes: The data received.
|
Nú MySQLx Connection not availabler ó zUnexpected connection close)r
r+ ÚrecvÚ RuntimeErrorrs Úlenru )r r ÚbufÚdatarx rx ry Úread" s
|
|
zSocketStream.read)r rp c
|
C sZ | j dkrtdz| j |¡ W n2 tk
|
rT } ztd| |W 5 d}~X Y nX dS )z_Send data to the socket.
|
|
Args:
|
data (bytes): The data to be sent.
|
Nr zUnexpected socket error: )r
r+ ÚsendallÚOSError)r r Úerrrx rx ry r¡ 6 s
|
zSocketStream.sendallc C sF | j s
|
dS z | j tj¡ | j ¡ W n tk
|
r: Y nX d| _ dS )zClose the socket.N)r
Úshutdownre Ú SHUT_RDWRÚcloser¢ r rx rx ry r¦ C s zSocketStream.closec C s | ¡ d S ©N©r¦ r rx rx ry Ú__del__O s zSocketStream.__del__ú List[str]rn )Ú
|
ssl_protosÚssl_modeÚssl_caÚssl_crlÚssl_certÚssl_keyÚ ssl_ciphersrp c C s t s| ¡ td|dks |sLt ¡ }|tjkr8d|_|tjkrâtj |_
|
n|j dd |d } t s| dkrt |dkr|d } t| }
|
t |
|
¡}| dkrâd |kr²| jtjO _d
|
|krÊ| jtjO _d |krâ| jtjO _|rBz| |¡ tj|_
|
W nB ttjfk
|
r@ } z | ¡ td | | W 5 d} ~ X Y nX |r¢z| |¡ tj|_W nB ttjfk
|
r } z | ¡ td | | W 5 d} ~ X Y nX |rüz| ||¡ W nB ttjfk
|
rú } z | ¡ td| | W 5 d} ~ X Y nX |r | d t |d |¡¡ z|j | j | j!d| _ W n2 tj"k
|
rf } zt| | W 5 d} ~ X Y nX |tjkrNd|_g } t#j$dkr| j!dkrddg} t% &| j!¡} | '| d g| d ¡ d}g }| D ]\}zt (| j )¡ |¡ W n4 tj"k
|
r } z| *t+| ¡ W 5 d} ~ X Y n X d} q,qÎ|sN| ¡ tdd |¡ d| _,| j -¡ } | dkrd| d}t. /|t0¡ dS )ax Set 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 supportNFT©Úreverser r r r r r zInvalid CA Certificate: z Invalid CRL: zInvalid Certificate/Key: ú:)Úserver_hostnameÚnt)Ú localhostú 127.0.0.1r· r¸ z"Unable to verify server identity: ú, )r r zThis connection is using zZ which is now deprecated and will be removed in a future release of MySQL Connector/Python)1Ú SSL_AVAILABLEr¦ r ÚsslÚcreate_default_contextr& ÚVERIFY_IDENTITYÚcheck_hostnameÚREQUIREDÚ CERT_NONEÚ verify_modeÚsortÚTLS_V1_3_SUPPORTEDr Ú TLS_VERSIONSÚ
|
SSLContextÚoptionsÚ OP_NO_TLSv1_2Ú OP_NO_TLSv1_1Ú OP_NO_TLSv1Úload_verify_locationsÚ CERT_REQUIREDÚIOErrorÚSSLErrorr) ÚVERIFY_CRL_CHECK_LEAFÚ verify_flagsÚload_cert_chainÚ set_ciphersru r1 Ú wrap_socketr
r ÚCertificateErrorÚosÚnamere Ú gethostbyaddrÚextendÚmatch_hostnameÚ getpeercertrs rn r ÚversionÚwarningsÚwarnÚDeprecationWarning)r r« r¬ r r® r¯ r° r± ÚcontextÚ tls_versionZ ssl_protocolr£ Z hostnamesÚaliasesZ match_foundZerrsÚhostnameZwarn_msgrx rx ry Úset_sslR s¤
|
|
|
ÿþ
|
ý
|
|
"
|
""ÿ
|
ÿ
|
|
|
ÿzSocketStream.set_sslÚboolc C s | j S )zpVerifies if SSL is being used.
|
|
Returns:
|
bool: Returns `True` if SSL is being used.
|
)r r rx rx ry Úis_sslÒ s zSocketStream.is_sslc C s | j S )zVerifies if socket connection is being used.
|
|
Returns:
|
bool: Returns `True` if socket connection is being used.
|
)r r rx rx ry Ú is_socketÚ s zSocketStream.is_socketc C s | j p
|
| jS )zvVerifies if connection is secure.
|
|
Returns:
|
bool: Returns `True` if connection is secure.
|
)r r r rx rx ry Ú is_secureâ s zSocketStream.is_securec C s
|
| j dk S )zrVerifies if connection is open.
|
|
Returns:
|
bool: Returns `True` if connection is open.
|
N)r
r rx rx ry Úis_openê s zSocketStream.is_openN)Ú__name__Ú
|
__module__Ú __qualname__Ú__doc__r Ú_CONNECT_TIMEOUTr r r¡ r¦ r© râ rä rå ræ rç rx rx rx ry r ÿ s r r )Úfuncrp c s$ t ddddd fdd }|S )z¼Decorator used to catch OSError or RuntimeError.
|
|
Raises:
|
:class:`mysqlx.InterfaceError`: If `OSError` or `RuntimeError`
|
is raised.
|
r
|
)r Úargsro rp c s¨ z¤t | ttfr$| ¡ r$t| ¡ | f||}t |tr | ¡ }|D ]T}|d tkrJt|d }d|d d| |d f}t | ttfr| |¡ q qJ|W S tt
|
t t fk
|
r¢ } zÖ j dkr|rt |d tr|d ¡ }|r|d }t|d }d|d d| |d f}t | tr\| j ¡ |d dkr\t | jt| ¡ t | ttfrv| |¡ | ¡ t| || ¡ W 5 d}~X Y nX dS ) zWrapper function.ÚcodezConnection close: Úmsgz: Úget_column_metadatar rU N)r~ Ú
|
ConnectionÚPooledConnectionÚis_server_disconnectedr) Úget_disconnected_reasonr9 Z get_warningsÚCONNECTION_CLOSED_ERRORÚset_server_disconnectedr¢ r r. rè r= ÚpoolÚremove_connectionsÚ PoolsManagerÚset_pool_unavailableÚ
|
disconnect) r rî ro ÚresultZwarnsrÜ Ú error_msgÚreasonr£ ©rí rx ry Úwrapperû s\ ÿþ
|
þ
|
ÿþ ý þ
|
ÿ
|
|
z(catch_network_exception.<locals>.wrapperr )rí r rx r ry Úcatch_network_exceptionó s 2r c sR e Zd ZdZddd fdd Zddd d
|
Zddd d Zd dddZ ZS )ÚRouterzRepresents a set of connection parameters.
|
|
Args:
|
settings (dict): Dictionary with connection settings
|
.. versionadded:: 8.0.20
|
r{ r| )Úconnection_paramsrp c s( t ¡ | |¡ | dd¡| d< d S )NÚ availableT)Úsuperr r Úget)r r ©Ú __class__rx ry r 9 s
|
|
zRouter.__init__rã r c C s | d S )zVerifies if the Router is available to open connections.
|
|
Returns:
|
bool: True if this Router is available else False.
|
r rx r rx rx ry r > s zRouter.availablec C s d| d< dS )z1Sets this Router unavailable to open connections.Fr Nrx r rx rx ry Úset_unavailableF s zRouter.set_unavailablez%Union[str, Tuple[str, Optional[int]]]c C s d| kr| d S | d | d fS )zVerifies if the Router is available to open connections.
|
|
Returns:
|
tuple: host and port or socket information tuple.
|
re rb rc rx r rx rx ry Úget_connection_paramsJ s z Router.get_connection_params) rè ré rê rë r r r
|
r Ú __classcell__rx rx r ry r 1 s
|
r c @ sz e Zd ZdZddddddZddd d
|
Zd dd d dZd dd ddZddddZddddZ ddddZ
|
dS )Ú RouterManagerzÒManages 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
|
z List[Router]úDict[str, Any]r| )rd Úsettingsrp c C s0 || _ || _d| _d| _i | _g | _| ¡ d S )Nr T)Ú_routersÚ _settingsÚ_cur_priority_idxÚ _can_failoverÚ_routers_directoryÚrouters_priority_listÚ_ensure_priorities)r rd r rx rx ry r ^ s zRouterManager.__init__r c C sØ d}| j D ]<}| dd¡}|dkr4|d7 }d|d< q
|
|dkr
|
tddq
|
d| k rbt| j k rpn n
|
tdd | j jd
|
d d d | j D ]H}|d }|| jkr¾t|g| j|< | j |¡ q| j| t|¡ qdS )zuEnsure priorities.
|
|
Raises:
|
:class:`mysqlx.ProgrammingError`: If priorities are invalid.
|
r ÚpriorityNr éd z(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 routeré c S s | d S )Nr rx ©Úxrx rx ry Ú<lambda> r z2RouterManager._ensure_priorities.<locals>.<lambda>T)rw r³ ) r r r- r r r r r rs )r Úpriority_countÚrouterr rx rx ry r h s(
|
|
ü
|
|
z RouterManager._ensure_prioritiesr )r rp c C s | j | }dd |D }|S )z¡Get a list of the current available routers that shares the given priority.
|
|
Returns:
|
list: A list of the current available routers.
|
c S s g | ]}| ¡ r|qS rx )r )Ú.0r rx rx ry Ú
|
<listcomp> s z8RouterManager._get_available_routers.<locals>.<listcomp>©r )r r Ú router_listrx rx ry Ú_get_available_routers s
|
z$RouterManager._get_available_routersr c C sF | |¡}|sdS t|dkr&|d S t|d }t d|¡}|| S )z{Get a random router from the group with the given priority.
|
|
Returns:
|
Router: A random router.
|
Nr r )r% r ÚrandomÚrandint)r r r$ ÚlastÚindexrx rx ry Ú _get_random_connection_params s
|
z+RouterManager._get_random_connection_paramsrã c C s | j S )zReturns the next connection parameters.
|
|
Returns:
|
bool: True if there is more server to failover to else False.
|
)r r rx rx ry Ú can_failover¥ s zRouterManager.can_failoverc C sÎ | j sBd| _| j ¡ }| j dd¡|d< | j dd¡|d< t|S | j| j }t| j}d}|rÊ| |¡}|dk s|| j|kr¤| j|d krÊt|
|
|¡d k rÊd| _qÊ| jd7 _| j|k r\| j| j }q\|S )
|
zvReturns the next connection parameters.
|
|
Returns:
|
Router: with the connection parameters.
|
Frb r· rc é$ TNr é ) r r r Úcopyr r r r r r* r% )r Zrouter_settingsÚ cur_priorityZrouters_priority_lenÚsearchr rx rx ry Úget_next_router s,
|
|
|
ÿþ
|
z RouterManager.get_next_routerzDict[int, List[Router]]c C s | j S )zReturns the directory containing all the routers managed.
|
|
Returns:
|
dict: Dictionary with priorities as connection settings.
|
r# r rx rx ry Úget_routers_directoryÐ s z#RouterManager.get_routers_directoryN) rè ré rê rë r r r% r* r+ r1 r2 rx rx rx ry r U s
|
#
|
#r c @ sH e Zd ZdZdddddZdddd Zd
|
dd d d ZddddZdddddZdjdddddddZ ddddZ
|
ddd d Z ddd d Z ddd d!Z d"dd#d$d%Zdd&d'dd(d)d*Zdd&d'dd(d+d,Zed-d.d#d/d0Zed1d2d#d3d4Zed5d6d#d7d8Zed9d2d#d:d;Zed<d2d#d=d>Zedkddd?d@dAdBdCdDZed"dEdFdGdHZedddIdJdKdLZedIdMd dNdOZed2dd dPdQZed2dRd dSdTZ dEddUdVZ d?ddWdXZ dYddZd[d\Z d?dd]d^Z d_dd`daZ!dddbdcZ"dddddeZ#dddfdgZ$dddhdiZ%dS )lrò zkConnection to a MySQL Server.
|
|
Args:
|
settings (dict): Dictionary with connection settings.
|
r r| ©r rp c C sÐ || _ t | _d | _d | _| d¡| _| d¡| _| d¡| _d | _ | dg ¡| _
|
d|kr|d r| j
|
| d¡| dd ¡d¡ t | j
|
|| _ | dt¡| _| jd kr®d | _d | _g | _d
|
| _d | _d | _d S ) Nr_ r` ra rd rb rc ©rb rc ri r TF)r r ÚstreamÚprotocolÚ keep_openr Ú_userÚ _passwordZ_schemaÚ_active_resultr rs r Úrouter_managerrì Ú_connect_timeoutÚ _stmt_counterÚ_prepared_stmt_idsÚ_prepared_stmt_supportedÚ_server_disconnectedÚ_server_disconnected_reason)r r rx rx ry r à s6
|
þÿ ÿ
|
zConnection.__init__r c C s | j dk r| j ¡ d| _ dS )zFetch active result.N)r: Ú fetch_allr rx rx ry Úfetch_active_result s
|
|
z Connection.fetch_active_resultrK )rý rp c C s
|
|| _ dS )a Set active result.
|
|
Args:
|
`Result`: It can be :class:`mysqlx.Result`,
|
:class:`mysqlx.BufferingResult`,
|
:class:`mysqlx.RowResult`, :class:`mysqlx.SqlResult` or
|
:class:`mysqlx.DocResult`.
|
N)r: ©r rý rx rx ry Úset_active_result s z Connection.set_active_resultc
|
C s d}| j ¡ r&zÞ| j ¡ }| j | ¡ | j¡ t| j}t| j}t ||| _
|
| j
|
¡ j }|rndd |D ni }| |¡ d| jkr| jd }| j
|
j|d | j dtj¡}| j d¡} |tjkrÈdn | ||| ¡}
|
| ¡ | j
|
|
|
¡ W dS ttfk
|
r" } z| }| ¡ W 5 d} ~ X Y qX q|dk rrt|tj rrt | j dkr`t d | j d
|
t d | j d t | j dkrt d | t dddS )a Attempt to connect to the MySQL server.
|
|
Raises:
|
:class:`mysqlx.InterfaceError`: If fails to connect to the MySQL
|
server.
|
:class:`mysqlx.TimeoutError`: If connect timeout was exceeded.
|
Nc S s i | ]}t |d ¡ |qS ©rÕ )r0 Úlower)r! Úcaprx rx ry Ú
|
<dictcomp>) s z&Connection.connect.<locals>.<dictcomp>Ú
|
attributes©Zsession_connect_attrsrk rl r z9Connection attempt to the server was aborted. Timeout of z ms was exceededz8All server connection attempts were aborted. Timeout of z) ms was exceeded for each selected serverzCannot connect to host: ú,Unable to connect to any of the target hostsi¡ )!r; r+ r1 r5 r r r< r6 r7 r8 r6 Zget_capabilitesZ capabilitiesÚ_set_tls_capabilitiesr Úset_capabilitiesr r% Z PREFERREDÚDISABLEDÚ _set_compression_capabilitiesÚ _authenticateZset_compressionr¢ r r
|
r~ re Útimeoutr r r. r) ) r Úerrorr ÚreaderÚwriterZ caps_dataÚcapsÚ
|
conn_attrsrk Ú
|
algorithmsÚ algorithmr£ rx rx ry r s^
|
ÿ
|
|
ÿý
|
|
|
ÿ ÿý ÿ ÿzConnection.connect)rV rp c C sP | j d¡tjkrdS | j ¡ r:| j d¡r6t d¡ dS d|krR| ¡ t dd}t
|
¡ dkr¦t \}}}z d|ko| d ¡d
|
d k}W n tk
|
r¤ d}Y nX tjd k rÄ|sÄ| ¡ td | jjdd | j | j dd¡| j dtj¡| j d¡| j d¡| j d¡| j d¡| j d¡¡ d| j krL| j d }| jj|d dS )a© Set 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
|
rf Nz(SSL not required when using Unix socket.ÚtlszSSL not enabled at serverFÚLinuxz Oracle LinuxÚ.r Ú7)r- é é z<The support for SSL is not available for this Python versionT)rZ r] rZ r\ rY r[ r^ rJ rK )r r r& rO r5 rå r2 ÚwarningÚclose_connectionr+ ÚplatformÚsystemrR ÚsplitÚ
|
IndexErrorÚsysÚ version_infor r6 rN râ r¿ )r rV Zis_ol7ÚdistnamerÚ rr rW rx rx ry rM Y sD
|
|
|
ÿ
|
|
|
|
|
ù
|
z Connection._set_tls_capabilitiesNrn zOptional[List[str]]ú Optional[str])rV rk rX rp c s | d¡}|dkr6d}|tjkr(t|t |¡ dS i }t|tr~|d d d D ]&}dd |d d d D ||d
|
< qTn*|jj j
|
D ] }d d |jj jD ||j < q| d g ¡ d}|r d d |D } fdd| D }
|
|
|
ròt |
|
d ¡}n|tjkrtdndS |dkrFtr,d kr,d}ntrBd krBd}nd}| krvd}|tjkrht|t |¡ dS | jjd |id |S )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
|
rk Nz8Compression requested but the server does not support itÚvalueÚobjÚfldc S s" g | ]}|d d d d¡qS )ÚscalarÚv_stringrj úutf-8)Údecode©r! rj rx rx ry r" ¸ s ÿz<Connection._set_compression_capabilities.<locals>.<listcomp>Úarrayrw c S s g | ]}|j jj d ¡qS )ro )rm rn rj rp rq rx rx ry r" ¾ s ÿrY c S s g | ]}|t krt | qS rx )r ©r! Úitemrx rx ry r" Ê s þc s g | ]}| kr|qS rx rx rs ©Zserver_algorithmsrx ry r" Ï s r zmThe connection compression is set as required, but none of the provided compression algorithms are supported.Z zstd_streamZ lz4_messageZdeflate_streamzFCompression requested but the compression algorithm negotiation failed)rk )r r% r¿ r* r2 r` r~ r rj rk rl rr rw r r) r5 r4 r6 rN ) r rV rk rX Zcompression_datarð Zcompression_dictrl rY Zclient_algorithmsÚmatchedrx ru ry rP s\
|
|
|
|
þþ þ ÿ
|
|
ÿ
|
z(Connection._set_compression_capabilitiesc
|
C sÊ | j d¡}|rL|tjkr$| ¡ qÆ|tjkr8| ¡ qÆ|tjkrÆ| ¡ nz| j
|
¡ r`| ¡ nfz | ¡ W n t k
|
r Y nX dS z | ¡ W n2 t k
|
rÄ } zt d| |W 5 d}~X Y nX dS )z#Authenticate with the MySQL server.rg NzrAuthentication failed using MYSQL41 and SHA256_MEMORY, check username and password or try a secure connection err:) r r r$ ZPLAINÚ_authenticate_plainZ SHA256_MEMORYÚ_authenticate_sha256_memoryZMYSQL41Ú_authenticate_mysql41r5 ræ r) )r rg r£ rx rx ry rQ ò s.
|
|
|
|
|
|
|
|
ÿüzConnection._authenticatec C sH t | j| j}| j | ¡ ¡ | j ¡ }| j | |¡¡ | j ¡ dS )z=Authenticate with the MySQL server using `MySQL41AuthPlugin`.N)
|
r r8 r9 r6 Úsend_auth_startÚ auth_nameÚread_auth_continueÚsend_auth_continueÚ auth_dataÚ read_auth_ok©r ÚpluginÚ
|
extra_datarx rx ry ry s
|
|
z Connection._authenticate_mysql41c C sF | j ¡ stdt| j| j}| jj| ¡ | ¡ d | j
|
¡ dS )z;Authenticate with the MySQL server using `PlainAuthPlugin`.z>PLAIN authentication is not allowed via unencrypted connection)r~ N) r5 ræ r) r r8 r9 r6 rz r{ r~ r )r r rx rx ry rw s
|
ÿz Connection._authenticate_plainc C sH t | j| j}| j | ¡ ¡ | j ¡ }| j | |¡¡ | j ¡ dS )zBAuthenticate with the MySQL server using `Sha256MemoryAuthPlugin`.N)
|
r r8 r9 r6 rz r{ r| r} r~ r r rx rx ry rx # s
|
|
z&Connection._authenticate_sha256_memoryrL )Ú statementrp c C s, |j r(| j |j¡ | j |j¡ d|_ dS )zrDeallocates statement.
|
|
Args:
|
statement (Statement): A `Statement` based type object.
|
FN)Úpreparedr6 Úsend_prepare_deallocateÚstmt_idr> Úremove)r r rx rx ry Ú_deallocate_statement+ s z Connection._deallocate_statementrJ zgUnion[FindStatement, DeleteStatement, ModifyStatement, ReadStatement, RemoveStatement, UpdateStatement])Úmsg_typerð r rp c C sR z | ¡ | j |||¡ W n tk
|
r8 d| _Y dS X | j |j¡ d|_dS )zåPrepares 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) rC r6 Zsend_prepare_preparer* r? r> rs r r ©r r rð r rx rx ry Ú_prepare_statement6 s z Connection._prepare_statementc C s\ | j s| j |||¡ dS |jrr| |¡ | |||¡ | j sR| j |||¡ dS | j |||¡ d|_| ¡ nÞ|jr|j s| j |||¡ nÀ|j rÆ|j
|
sÆ| |¡ | j |||¡ d|_ | ¡ n|j s|j
|
s|jsê| |||¡ | j s| j |||¡ dS | j |||¡ n8|j rP|j
|
rP| |¡ | j |||¡ d|_ | ¡ | ¡ dS )zùExecutes 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) r? r6 Úsend_msg_without_psZdeallocate_prepare_executer r Zsend_prepare_executeZreset_exec_counterr ÚchangedZrepeatedZincrement_exec_counterr rx rx ry Ú_execute_prepared_pipelineS s@
|
|
|
|
|
z%Connection._execute_prepared_pipelinerF r= c C sT |j }| jdkrtdt|ts*td| j d|¡\}}| j |||¡ t| S )zóExecute a SQL statement.
|
|
Args:
|
sql (str): The SQL statement.
|
|
Raises:
|
:class:`mysqlx.ProgrammingError`: If the SQL statement is not a
|
valid string.
|
Nr z'The SQL statement is not a valid stringÚsql) r r6 r+ r~ rn r- Úbuild_execute_statementr r= )r r r r rð rx rx ry Úsend_sql s
|
|
zConnection.send_sqlz$Union[AddStatement, InsertStatement]r; c C sN | j dkrtd| j |¡\}}| j ||¡ d}t|trD|j}t| |S )a Send an insert statement.
|
|
Args:
|
statement (`Statement`): It can be :class:`mysqlx.InsertStatement`
|
or :class:`mysqlx.AddStatement`.
|
|
Returns:
|
:class:`mysqlx.Result`: A result object.
|
Nr )r6 r+ Z build_insertÚsend_msgr~ r> Úidsr; )r r r rð r rx rx ry Ú send_insert¥ s
|
|
zConnection.send_insertz%Union[FindStatement, SelectStatement]zUnion[DocResult, RowResult]c C s6 | j |¡\}}| |||¡ | ¡ r.t| S t| S )aD 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`.
|
)r6 Z
|
build_findr Z is_doc_basedr: r< ©r r r rð rx rx ry Ú send_find¹ s zConnection.send_findz'Union[DeleteStatement, RemoveStatement]c C s& | j |¡\}}| |||¡ t| S )a Send an delete statement.
|
|
Args:
|
statement (`Statement`): It can be :class:`mysqlx.RemoveStatement`
|
or :class:`mysqlx.DeleteStatement`.
|
|
Returns:
|
:class:`mysqlx.Result`: The result object.
|
)r6 Ú build_deleter r; r rx rx ry Ú send_deleteË s zConnection.send_deletez'Union[ModifyStatement, UpdateStatement]c C s& | j |¡\}}| |||¡ t| S )a Send an delete statement.
|
|
Args:
|
statement (`Statement`): It can be :class:`mysqlx.ModifyStatement`
|
or :class:`mysqlx.UpdateStatement`.
|
|
Returns:
|
:class:`mysqlx.Result`: The result object.
|
)r6 Z build_updater r; r rx rx ry Ú send_updateÚ s zConnection.send_updaterã úOptional[Dict[str, Any]]zOptional[Result])Ú namespaceÚcmdÚ raise_on_failÚfieldsrp c C sL z,| j |||¡\}}| j ||¡ t| W S tk
|
rF |rB Y nX dS )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)r6 r r r; r+ )r r r r r r rð rx rx ry Úexecute_nonqueryé s ÿ
|
zConnection.execute_nonqueryr ©r rp c C sN | j d|¡\}}| j ||¡ t| }| ¡ |jdkrBtd|d d S )zèExecute a SQL scalar.
|
|
Args:
|
sql (str): The SQL statement.
|
|
Raises:
|
:class:`mysqlx.InterfaceError`: If no data found.
|
|
Returns:
|
:class:`mysqlx.Result`: The result.
|
r r z No data found)r6 r r r< rB r r) )r r r rð rý rx rx ry Úexecute_sql_scalar
|
s
|
z Connection.execute_sql_scalarr< )r r rp c C s* | j d||¡\}}| j ||¡ t| S )zÎReturns the row result.
|
|
Args:
|
cmd (str): The command.
|
fields (dict): The message fields.
|
|
Returns:
|
:class:`mysqlx.RowResult`: The result object.
|
Úmysqlx)r6 r r r< )r r r r rð rx rx ry Úget_row_result s zConnection.get_row_resultzOptional[MessageType]c C s | j |¡S )zdRead row.
|
|
Args:
|
result (:class:`mysqlx.RowResult`): The result object.
|
)r6 Úread_rowrD rx rx ry r¤ . s zConnection.read_rowc C s | j |¡ dS )zeClose result.
|
|
Args:
|
result (:class:`mysqlx.Result`): The result object.
|
N)r6 Ú close_resultrD rx rx ry r¥ 7 s zConnection.close_resultzList[ColumnType]c C s | j |¡S )zlGet column metadata.
|
|
Args:
|
result (:class:`mysqlx.Result`): The result object.
|
)r6 rñ rD rx rx ry rñ @ s z Connection.get_column_metadatac C s | j d7 _ | j S )z|Returns the next statement ID.
|
|
Returns:
|
int: A statement ID.
|
|
.. versionadded:: 8.0.16
|
r )r= r rx rx ry Úget_next_statement_idI s z Connection.get_next_statement_idc C s
|
| j ¡ S )zgCheck if connection is open.
|
|
Returns:
|
bool: `True` if connection is open.
|
)r5 rç r rx rx ry rç T s zConnection.is_openzUnion[str, Tuple[str, int]])rÿ rp c C s d| _ || _dS )zSet the disconnection message from the server.
|
|
Args:
|
reason (str): disconnection reason from the server.
|
TN)r@ rA )r rÿ rx rx ry r÷ \ s z"Connection.set_server_disconnectedc C s | j S )zÅVerify if the session has been disconnect from the server.
|
|
Returns:
|
bool: `True` if the connection has been closed from the server
|
otherwise `False`.
|
)r@ r rx rx ry rô e s z!Connection.is_server_disconnectedz%Optional[Union[str, Tuple[str, int]]]c C s | j S )zGet the disconnection message sent by the server.
|
|
Returns:
|
string: disconnection reason from the server.
|
)rA r rx rx ry rõ n s z"Connection.get_disconnected_reasonc C s | ¡ s dS | j ¡ dS )zDisconnect from server.N)rç r5 r¦ r rx rx ry rü v s zConnection.disconnectc
|
C s | ¡ s dS z~zD| ¡ | jr<| jD ]}| j |¡ q$d| _| j ¡ | j
|
¡ W n4 t t t fk
|
r } zt d|¡ W 5 d}~X Y nX W 5 | j ¡ X dS )z*Close a sucessfully authenticated session.Nr zGWarning: An error occurred while attempting to close the connection: %s)rç r5 r¦ rC r? r> r6 r
r= Z
|
send_closeÚread_okr) r+ r¢ r2 r` )r r r£ rx rx ry Ú close_session| s
|
|
ýzConnection.close_sessionc
|
C sl | ¡ s dS | jdk r | j ¡ z| j | j¡| _W n2 ttfk
|
rf } zt d|¡ W 5 d}~X Y nX dS )z*Reset a sucessfully authenticated session.NzDWarning: An error occurred while attempting to reset the session: %s)
|
rç r: rB r6 Z
|
send_resetr7 r) r+ r2 r` )r r£ rx rx ry Ú reset_session s
|
|
ýzConnection.reset_sessionc C sB | ¡ s dS | jdk r | j ¡ | j ¡ | j ¡ | j ¡ dS )zAnnounce to the server that the client wants to close the
|
connection. Discards any session state of the server.
|
N)rç r: rB r6 Zsend_connection_closer§ r5 r¦ r rx rx ry ra ¦ s
|
|
|
|
zConnection.close_connection)N)N)&rè ré rê rë r rC rE r rM rP rQ ry rw rx r r r r r r r r r r r¡ r£ r¤ r¥ rñ r¦ rç r÷ rô rõ rü r¨ r© ra rx rx rx ry rò Ù s^ " F: üc
|
> û rò c st e Zd ZdZddd fdd Zdd fdd Zddd
|
d Zddd d ZddddZdddddZ Z
|
S )ró a Class 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
|
ÚConnectionPoolr| )rø rp c sB t |tstdt |j¡ || _|jd | _|jd | _d S )Nz&pool should be a ConnectionPool objectrb rc ) r~ rª r r r Ú
|
cnx_configrø rb rc )r rø r rx ry r Æ s
|
zPooledConnection.__init__r c s t ¡ dS )zGCloses the connection.
|
|
This method closes the socket.
|
N)r r¨ r r rx ry ra Î s z!PooledConnection.close_connectionc C s | j | ¡ dS )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)rø Úadd_connectionr rx rx ry r¨ Õ s z PooledConnection.close_sessionc C s | j dk r| j ¡ | ¡ dS )zReconnect this connection.N)r: rB rQ r rx rx ry Ú reconnectâ s
|
|
zPooledConnection.reconnectc C s | ¡ dS )zQReset the connection.
|
|
Resets the connection by re-authenticate.
|
N)r r rx rx ry Úresetè s zPooledConnection.resetrn rF r c C s
|
t | |S ©a Creates 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.
|
)rF ©r r rx rx ry r ï s
|
zPooledConnection.sql) rè ré rê rë r ra r¨ r r® r r rx rx r ry ró ³ s ró c @ sî e Zd ZdZddddddZdddd d
|
Zed d d dZd.dddddZdd ddZ d/dddddZ
|
dddddZ dddd d Z dd d d Z d d d!d"Zd0d dd$d%d&Zdd d'd(Zd)d d*d+Zdd d,d-ZdS )1rª aµ 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
|
rn r
|
r| )rÕ ro rp c K s¦ | |¡ d| _g | _d| _d| _t ¡ | _| dd¡| _ t
|
j | | j ¡ | dd¡| _ | dd¡| _|| _| dd¡| _| dd¡| _|| _|d | _|d
|
| _d S ) Nr TÚmax_sizeé r© Ú max_idle_timeÚ queue_timeoutr rb rc )Ú_set_pool_nameZ_open_sessionsÚ_connections_opennedÚ
|
_availableÚ_timeoutr ÚnowÚ_timeout_stampr Ú pool_max_sizeÚqueueÚQueuer r© r³ r r´ r r« rb rc )r rÕ ro rx rx ry r s
|
|
|
zConnectionPool.__init__)Ú pool_namerp c C s@ t |¡rtd| dt|tkr6td| d|| _dS )a Set 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_REGEXr0 r r Ú_CNX_POOL_MAX_NAME_SIZErÕ )r r¾ rx rx ry rµ , s
|
|
z ConnectionPool._set_pool_namer r c C s
|
t | jS )zDReturns the number of open connections that can return to this pool.)r r¶ r rx rx ry Úopen_connections? s z ConnectionPool.open_connectionsNzOptional[PooledConnection]©Úcnxrp c C s | j |¡ dS )zwRemoves a connection from this pool.
|
|
Args:
|
cnx (PooledConnection): The connection object.
|
N)r¶ r ©r rà rx rx ry Úremove_connectionD s z ConnectionPool.remove_connectionc
|
C sx | ¡ dkrtz| jd| jd}W n tjk
|
r6 Y q X z,z | ¡ W n ttt fk
|
r` Y nX W 5 | |¡ X q dS )z*Removes all the connections from the pool.r T©ÚblockrR N)
|
Úqsizer r´ r¼ ÚEmptyrÅ ra r r¢ r) rÄ rx rx ry rù L s
|
z!ConnectionPool.remove_connectionsc C sÆ | j std| ¡ r td|st| }| t¡ ¡ ¡ d d }tdd | d¡d d¡D dkr| d | j
|
¡ ¡ | j |¡ n*t |ts td
|
| ¡ r¸| ¡ | ¡ | |¡ d S ) a= Adds 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 fullr c s s | ]}t |V qd S r§ ©r ©r! Únrx rx ry Ú <genexpr>u s z0ConnectionPool.add_connection.<locals>.<genexpr>ú-r\ ©é r é
|
úset mysqlx_wait_timeout = z1Connection instance not subclass of PooledSessionN)r« r, Úfullró r Ú_SELECT_VERSION_QUERYÚexecuterB Útuplerd r³ r¶ rs r~ rô rù r¦ Úqueue_connection)r rà Úverrx rx ry r¬ [ s &
|
z ConnectionPool.add_connectionró c
|
C sf t |tstd| jr | ¡ z| j|dd W n. tjk
|
r` } ztd|W 5 d}~X Y nX dS )aG Put connection back in the queue:
|
|
This method is putting a connection back in the queue.
|
It will not acquire a lock as the methods using _queue_connection() will
|
have it set.
|
|
Args:
|
PooledConnection: The connection object.
|
|
Raises:
|
PoolError: On errors.
|
z2Connection instance not subclass of PooledSession.F)rÇ rÊ N)r~ ró r, r© Úputr¼ ÚFull)r rà r£ rx rx ry rØ
s
|
z ConnectionPool.queue_connection)Ú
|
connectionrp c C s | j |¡ dS )zETracks connection in order of close it when client.close() is invoke.N)r¶ rs )r rÜ rx rx ry Útrack_connection s z ConnectionPool.track_connectionc C s | j S r§ rF r rx rx ry Ú__str__¡ s zConnectionPool.__str__rã c C s | j S )z¸Returns if this pool is available for pool connections from it.
|
|
Returns:
|
bool: True if this pool is available else False.
|
.. versionadded:: 8.0.20
|
)r· r rx rx ry r ¤ s zConnectionPool.availableéÿÿÿÿ)Útime_outrp c C s. | j r*t d| |¡ d| _ t ¡ | _|| _dS )zhSets this pool unavailable for a period of time (in seconds).
|
|
.. versionadded:: 8.0.20
|
z4ConnectionPool.set_unavailable pool: %s time_out: %sFN)r· r2 r` r r¹ rº r¸ )r rà rx rx ry r
|
s ý
|
z ConnectionPool.set_unavailablec C s d| _ t ¡ | _dS )zaSets this pool available for pool connections from it.
|
|
.. versionadded:: 8.0.20
|
TN)r· r r¹ rº r rx rx ry Ú set_available¼ s z ConnectionPool.set_availablezTuple[int, datetime]c C s | j | jfS )zÎReturns the penalized time (timeout) and the time at the penalty.
|
|
Returns:
|
tuple: penalty seconds (int), timestamp at penalty (datetime object)
|
.. versionadded:: 8.0.20
|
)r¸ rº r rx rx ry Úget_timeout_stampÄ s z ConnectionPool.get_timeout_stampc C s | j D ] }| ¡ qdS )zEmpty this ConnectionPool.N)r¶ ra rÄ rx rx ry r¦ Í s
|
zConnectionPool.close)N)N)rß )rè ré rê rë r rµ ÚpropertyrÁ rÅ rù r¬ rØ rÝ rÞ r r
|
rá râ r¦ rx rx rx ry rª ü s * rª c @ s e Zd ZU dZdZd ed< i Zded< d dddZd d d
|
d d d ZdddddZ e
|
dddddZ dddddZ e
|
dddd d Z e
|
dd d dd d d!Zdd dd"d#d$Ze
|
d5dd%d d"d&d'Zd6dd(dd)d*d+Zdd,dd-d.Zdd dd/d0Ze
|
dd1dd2d3d4ZdS )7rú zManages a pool of connections for a host or hosts in routers.
|
|
This class handles all the pools of Connections.
|
|
.. versionadded:: 8.0.13
|
NÚ_PoolsManager__instancer Ú_PoolsManager__poolsr c C s" t jd kr t | ¡t _i t _t jS r§ )rú rä ÚobjectÚ__new__rå )Úclsrx rx ry rç Þ s
|
zPoolsManager.__new__rn rã )rq r¾ rp c C s, | j |g ¡}|D ]}|j|kr dS qdS )zþVerifies if a pool exists with the given name.
|
|
Args:
|
client_id (str): The client id.
|
pool_name (str): The name of the pool.
|
|
Returns:
|
bool: Returns `True` if the pool exists otherwise `False`.
|
TF)rå r rÕ )r rq r¾ Úpoolsrø rx rx ry Ú _pool_existsä s
|
|
|
zPoolsManager._pool_existsr r3 c C s^ g }g }| |¡}|D ]\}}| |¡ q| j | dd¡g ¡D ]}|j|kr@| |¡ q@|S )záRetrieves a list of pools that shares the given settings.
|
|
Args:
|
settings (dict): the configuration of the pool.
|
|
Returns:
|
list: A list of pools that shares the given settings.
|
rq úNo id)Ú_get_connections_settingsrs rå r rÕ )r r Zavailable_poolsZ
|
pool_namesÚconnections_settingsÚ router_namerr rø rx rx ry Ú
|
_get_poolsô s
|
|
zPoolsManager._get_poolsz List[Tuple[str, Dict[str, Any]]]c C sÄ | ¡ }| dg ¡}g }d|kr*| d¡ d|krVd|krV| dd|d |d d¡ |jdd d |D ]T}| ¡ }|d |d< |d |d< |d
|
|d
|
< | d d¡|d < | tf ||f¡ qj|S ) aH Generates a list of separated connection settings for each host.
|
|
Gets a list of connection settings for each host or router found in the
|
given settings.
|
|
Args:
|
settings (dict): The configuration for the connections.
|
|
Returns:
|
list: A list of connections settings
|
rd rb rc r r )r Úweightrb rc c S s | d | dd¡ fS )Nr rð r )r r rx rx ry r ) r z8PoolsManager._get_connections_settings.<locals>.<lambda>)rw r rð )r. r Úpoprs r rz )r Z pool_settingsrd rí r Zconnection_settingsrx rx ry rì s4
|
üÿ þÿz&PoolsManager._get_connections_settingsr| )Ú cnx_settingsrp c C s~ | |¡}| dd¡| jkr.g | j| dd¡< |D ]F\}}| | dd¡|¡rPq2| j | dd¡g ¡}| t|f|¡ q2dS )a# Creates 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.
|
rq rë N)rì r rå rê rs rª )r rò rí rî r rø rx rx ry Ú create_pool8 s
|
zPoolsManager.create_poolzList[ConnectionPool]rª )Ú pool_listrp c C s< | sdS t | dkr | d S t | d }t d|¡}| | S )zGet a random router from the group with the given priority.
|
|
Returns:
|
Router: a random router.
|
|
.. versionadded:: 8.0.20
|
Nr r )r r& r' )rô r( r) rx rx ry Ú_get_random_poolN s z PoolsManager._get_random_poolr )ré r) r/ rp c C sZ g }d }|t | k rV| | j}||krB| | ¡ rB| | | ¡ n
|
||krLqV|d7 }q|S )Nr )r r r rs )ré r) r/ ZsublistZ next_priorityrx rx ry Ú _get_sublist` s
|
|
zPoolsManager._get_sublist)ré r/ rp c C sb d}|D ]"}| ¡ r"||jkr" q,|d7 }qg }|sX|t|k rX| |||¡}|d7 }q0| |¡S )Nr r )r r r rö rõ )r ré r/ r) rø Zsubpoolrx rx ry Ú_get_next_poolo s
|
|
zPoolsManager._get_next_poolú Optional[int]c C s@ |d kr| r| d j S | D ]}| ¡ r|j }| S q| d j S )Nr )r r )ré r/ Zt_poolrx rx ry Ú_get_next_priority} s
|
|
z PoolsManager._get_next_priorityzOptional[bool])r Úreviverp c C sT | |¡}|D ]@}| ¡ r q| ¡ \}}|r0|}t ¡ |t|d kr| ¡ qd S )N)Úseconds)rï r râ r r¹ r rá )r r rú ré rø rR Z timeout_stamprx rx ry Ú_check_unavailable_pools s
|
z%PoolsManager._check_unavailable_poolsró c
|
s
|
ddd fdd }| |¡}| dd¡}g }| |¡ | ||¡}|dkrTtd||d< | ||¡ t ¡ } dk rþz¬ ¡ d kr|î z jd
|
j d }W n t
|
j k
|
rÈ td dY nX z,| ¡ rÜ ¡ |jsê| ¡ || W nv tttfk
|
rl z.z | ¡ W n tttfk
|
r8 Y nX W 5 |¡ X ¡ d krÆz jd
|
j d }W n t
|
j k
|
r Y n>X z.z | ¡ W n tttfk
|
r° Y nX W 5 |¡ X qJzHz&t } |¡ | ¡ || W n tttfk
|
r
|
Y nX W 5 ¡ d krfz& jd
|
j d }| ¡ |¡ W n tttfk
|
r` Y nX qX Y nX |W 5 Q R £ W S Q R X n j jk r¾t } |¡ | ¡ || |W S |^ z4 jd
|
j d }| ¡ || |W W 5 Q R £ W S t
|
j k
|
r td dY nX W 5 Q R X W qp tttfk
|
rú } z¬| d d| ¡ t |trp d¡ n | |¡ | |¡ | ||¡ dkrâ| ||¡}||d< | ||¡ dkrâd |¡} td| d|W Y ¢qpW 5 d}~X Y qpX qptddS )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.
|
ró r| r c sZ | t¡ ¡ ¡ d d }tdd | d¡d d¡D dkrV| d j ¡ ¡ d S )Nr c s s | ]}t |V qd S r§ rË rÌ rx rx ry rÎ © s zOPoolsManager.get_connection.<locals>.set_mysqlx_wait_timeout.<locals>.<genexpr>rÏ r\ rÐ rÓ )r rÕ rÖ rB r× rd r³ )rà rÙ ©rø rx ry Úset_mysqlx_wait_timeout¦ s &z<PoolsManager.get_connection.<locals>.set_mysqlx_wait_timeoutr/ NzBUnable to connect to any of the target hosts. No pool is availabler TrÆ z)Failed getting connection; pool exhaustedz pool max size has been reachedzpool: z error: r- z
|
z2Unable to connect to any of the target hosts: [
|
z
|
]rL ) rï r rü rù r, r÷ Ú threadingÚRLockrÈ r´ r¼ rÉ rô rù r7 r® r r¢ r) rÅ ra ró rÝ r rÁ r» r. rs r~ r
|
rû ru )
|
r r rþ ré r/ Z
|
error_listÚlockrà r£ rð rx rý ry Úget_connection sÌ
|
|
|
ÿ
|
ÿþ
|
ÿ
|
|
|
|
þ
|
|
|
|
|
|
ÿý zPoolsManager.get_connectionc C sX | |¡}|D ]@}| ¡ | dd¡dk r| j | d¡¡}||kr| |¡ qt|S )zjCloses the connections in the pools
|
|
Returns:
|
int: The number of closed pools
|
rq N)rï r¦ r rå r r )r rò ré rø Z client_poolsrx rx ry Ú
|
close_pool+ s
|
zPoolsManager.close_poolz#Union[InterfaceError, TimeoutError])rø r£ rp c C sv d}z|j }t| }W n ttfk
|
r. Y nX |sX|j}t ¡ D ]\}}||krB|}qB|rh| |¡ n
|
| d¡ dS )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 )Úerrnor r rt rð Ú_TIMEOUT_PENALTIESÚitemsr
|
)rø r£ ZpenaltyZerr_noÚerr_msgrw rj rx rx ry rû ; s z!PoolsManager.set_pool_unavailable)N)N)rè ré rê rë rä Ú__annotations__rå rç rê rï Ú staticmethodrì ró rõ rö r÷ rù rü r r rû rx rx rx ry rú Ó s0
|
, ÿ ÿ rú c @ sh e Zd ZdZdddddZd ddd Zd
|
d d dd ddZddddZeddddZ e j
|
dddddZ ddddZ dddd d Z d dd d Z d!dd"d#Zdd$d%d&d'Zd(dd)d*Zddd%d+d,Zdd$d%d-d.Zddd/d0Zddd1d2Zddd3d4ZdAd6dd%d7d8Zddd%d9d:Zddd%d;d<Zddd=d>Zddd?d@Zd5S )BÚSessiona* Enables 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.
|
r r| r3 c
|
C sÐ | dtj¡| _|| _| d¡rÈ| d¡rÈts6tdztj |d d¡}W n< tj j
|
k
|
r } ztd|d d|W 5 d }~X Y nX g | jd< |D ].}| jd |j j d d
|
|j|j|jd ¡ qd | jksà| jd d k ròi | jd< | ¡ d|kr6|d r6t |¡ t |¡| _| jd krLtdnt| j| _| j ¡ | j d¡}|rÌz | dt| ¡ ¡ W nP t k
|
rÊ } z0|j dkr |j n
|
d| d}t||j |W 5 d }~X Y nX d S )Nrh rb rm ztMySQL host configuration requested DNS SRV. This requires the Python dnspython module. Please refer to documentationZSRVz Unable to locate any hosts for 'ú'rd T)Zomit_final_dot)rb rc r rð rj FrJ Úpoolingz+Connection could not be retrieved from poolra zUSE i úDefault schema 'ú' does not exists) r r3 Úuse_purer ÚHAVE_DNSPYTHONr) ÚdnsÚresolverÚqueryÚ exceptionZ DNSExceptionrs ÚtargetZto_textrc r rð Ú_init_attributesrú ró r Ú _connectionr, rò r r rH rÖ r+ r rð )r r Z srv_recordsr£ Zsrvra Úerrmsgrx rx ry r h s^ ÿÿþ
|
|
üÿ
|
ÿ þ
|
|
|
ÿ
|
|
ýzSession.__init__r c C s | S r§ rx r rx rx ry Ú __enter__£ s zSession.__enter__úType[BaseException]Ú BaseExceptionr ©Úexc_typeÚ exc_valueÚ tracebackrp c C s | ¡ d S r§ r¨ ©r r r r rx rx ry Ú__exit__¦ s zSession.__exit__c C sÎ t jdkrRdt ¡ d kr d}n dt ¡ d kr6d}nt ¡ }dt ¡ d }n<t ¡ }t ¡ d krzd
|
t ¡ d }nd t dd
¡}t
|
d ¡}|d dkrªd}nd}t t ¡ ||t ¡ dd dd tdd
D ¡|d}| jd |¡ d| jkrÊ| jd D ]¼}| jd | }t|t s:td| dt|dkrXtd| d | d ¡rrtd | t|t std| d | d t|d!kr¸td| d"| d#|| jd |< q d$S )%z5Setup default and user defined connection-attributes.r¶ Ú64r Úx86_64Ú32Úi386zWindows-r ÚDarwinzmacOS-rÏ r- ú ZGPLv2zGPL-2.0Z
|
Commercialzmysql-connector-pythonr\ c S s g | ] }t |qS rx )rn )r! r rx rx ry r" Ñ s z,Session._init_attributes.<locals>.<listcomp>é )Z_pidÚ _platformÚ_osZ _source_hostZ _client_nameZ_client_versionZ_client_licenserJ rj úAttribute name 'ú' must be a string typeé ú"' exceeds 32 characters limit sizerr zHKey names in 'session-connect-attributes' cannot start with '_', found: z ' value 'z' must be a string typeé ú
|
' value: 'ú$' exceeds 1024 characters limit sizeN)rÔ rÕ rb Ú architectureÚ win32_verÚmachinerc Úmac_verru rR rS rd rn Úgetpidre Ú gethostnamerT r r r~ r) r Ú
|
startswith)r Z platform_archZos_verZlicense_chunksZclient_licenseZdefault_attributesÚ attr_nameÚ
|
attr_valuerx rx ry r ® s`
|
|
|
ò
|
ÿ
|
ÿ ÿ ÿÿzSession._init_attributesrã c C s t jS )z8bool: `True` to use pure Python Protobuf implementation.)r3 r r rx rx ry r û s zSession.use_pure)rj rp c C s t |tstdt |¡ d S )Nz)'use_pure' option should be True or False)r~ rã r- r3 Z set_use_pure)r rj rx rx ry r s
|
c C s | j j ¡ S )zzReturns `True` if the session is open.
|
|
Returns:
|
bool: Returns `True` if the session is open.
|
)r r5 rç r rx rx ry rç s zSession.is_openrn rF r c C s t | j|S r¯ )rF r r° rx rx ry r s
|
z Session.sqlrò c C s | j S )z~Returns the underlying connection.
|
|
Returns:
|
mysqlx.connection.Connection: The connection object.
|
)r r rx rx ry r s zSession.get_connectionrª c C s | d¡ ¡ }dd | ¡ D S )z°Returns the list of schemas in the current session.
|
|
Returns:
|
`list`: The list of schemas in the current session.
|
|
.. versionadded:: 8.0.12
|
zSHOW DATABASESc S s g | ] }|d qS )r rx )r! Úrowrx rx ry r" + s z'Session.get_schemas.<locals>.<listcomp>)r rÖ rB rD rx rx ry Ú get_schemas" s zSession.get_schemasr( )rÕ rp c C s
|
t | |S )zöRetrieves 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' ©r rÕ rx rx ry Ú
|
get_schema- s zSession.get_schemazOptional[Schema]c C sz | j j d¡}|rv| t t|¡¡ ¡ ¡ }z |d d |krLt | |W S W n& t
|
k
|
rt t d| ddY nX dS )a Retrieves 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.
|
ra r r r N) r r r r Ú_SELECT_SCHEMA_NAME_QUERYÚformatr/ rÖ rB r( re r- )r ra Úresrx rx ry Úget_default_schema8 s ÿ
|
ÿþzSession.get_default_schemac C s | j dt t|¡d¡ dS )zDrops the schema with the specified name.
|
|
Args:
|
name (string): The name of the Schema object to be retrieved.
|
r TN)r r Ú_DROP_DATABASE_QUERYr@ rH r= rx rx ry Ú drop_schemaV s
|
ÿzSession.drop_schemac C s$ | j dt t|¡d¡ t| |S )z¬Creates a schema on the database and returns the corresponding
|
object.
|
|
Args:
|
name (string): A string value indicating the schema name.
|
r T)r r Ú_CREATE_DATABASE_QUERYr@ rH r( r= rx rx ry Ú create_schema` s ÿzSession.create_schemac C s | j ddd¡ dS )z+Starts a transaction context on the server.r zSTART TRANSACTIONTN©r r r rx rx ry Ústart_transactionl s zSession.start_transactionc C s | j ddd¡ dS )zXCommits all the operations executed after a call to
|
startTransaction().
|
r ZCOMMITTNrG r rx rx ry Úcommitp s zSession.commitc C s | j ddd¡ dS )zYDiscards all the operations executed after a call to
|
startTransaction().
|
r ZROLLBACKTNrG r rx rx ry Úrollbackv s zSession.rollbackNri c C sT |dkrt ¡ }n"t|tr.t| ¡ dkr6td| j ddt | d¡ |S )a Creates 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.
|
Nr úInvalid SAVEPOINT namer z
|
SAVEPOINT T)
|
ÚuuidÚuuid1r~ rn r Ústripr- r r rH r= rx rx ry Ú set_savepoint| s ÿzSession.set_savepointc C s@ t |trt| ¡ dkr"td| j ddt| d¡ dS )zRollback to a transaction savepoint with the given name.
|
|
Args:
|
name (string): The savepoint name.
|
r rK r zROLLBACK TO SAVEPOINT TN©r~ rn r rN r- r r rH r= rx rx ry Ú rollback_to s ýzSession.rollback_toc C s@ t |trt| ¡ dkr"td| j ddt| d¡ dS )z{Release a transaction savepoint with the given name.
|
|
Args:
|
name (string): The savepoint name.
|
r rK r zRELEASE SAVEPOINT TNrP r= rx rx ry Úrelease_savepoint s ýzSession.release_savepointc C s | j ¡ t| j| _ dS )zCloses the session.N)r r¨ rò r r rx rx ry r¦ s
|
z Session.closec C s | j ¡ dS )z8Closes all underliying connections as pooled connectionsN)r ra r rx rx ry Úclose_connections³ s zSession.close_connections)N)rè ré rê rë r r r! r rã r Úsetterrç r r r< r> rB rD rF rH rI rJ rO rQ rR r¦ rS rx rx rx ry r
|
[ s2 ;M
|
r
|
c @ s¢ e Zd ZdZd%ddddddZd d d
|
d Zd d dddddZdddddZdddddZddddd Z ddd d d Z
|
d d d!d"Z dd d#d$Z dS )&ÚClienta( Class 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
|
Nr r r| )Úconnection_dictÚ options_dictrp c C s || _ |d kri }g | _t ¡ | _| | dd¡¡ | | dd¡¡ | | dd¡¡ | | dd¡¡ | j
|
| j d< | j | j d< | j| j d < d S )
|
Nr± r² r³ r r´ ÚenabledTr rq ) r ÚsessionsrL Úuuid4rq Ú_set_pool_sizer Ú_set_max_idle_timeÚ_set_queue_timeoutÚ_set_pool_enabledÚpooling_enabledr± )r rV rW rx rx ry r à s
|
zClient.__init__r c C s | S r§ rx r rx rx ry r Ø s zClient.__enter__r r r r c C s | ¡ d S r§ r¨ r rx rx ry r! Û s zClient.__exit__r )Ú pool_sizerp c C sB t |ts t |tr |dks,td| d|dkr8tn|| _dS )a Set 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.
|
r zGPool max_size value must be an integer greater than 0, the given value ú is not validN)r~ rã r r Ú_CNX_POOL_MAXSIZEr± )r r` rx rx ry r[ ã s ÿþý
|
ÿzClient._set_pool_size)r³ rp c C sT t |ts t |tr |dks,td| d|| _|dkr>tn
|
t|d | jd< dS )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.
|
rß zYConnection max_idle_time value must be an integer greater or equal to 0, the given value ra r r r³ N)r~ rã r r r³ Ú_CNX_POOL_MAX_IDLE_TIMEr )r r³ rx rx ry r\ ü s ÿþý
|
ÿÿzClient._set_max_idle_timerã )rX rp c C s t |tstd|| _dS )a Set if the pool is enabled.
|
|
This method sets if the pool is enabled.
|
|
Args:
|
enabled (bool): True if to enabling the pool.
|
|
Raises:
|
:class:`AttributeError`: If the value of enabled is not a bool type.
|
z*The enabled value should be True or False.N)r~ rã r r_ )r rX rx rx ry r^
|
s
|
zClient._set_pool_enabled)r´ rp c C sj t |ts t |tr |dks,td| d|| _|dkr>tn
|
t|d | jd< d| jkrf| j| jd< dS ) a} Set the queue timeout.
|
|
This method sets the queue timeout.
|
|
Args:
|
queue_timeout (int): An integer equal or greater than 0 indicating
|
the queue timeout.
|
|
Raises:
|
:class:`AttributeError`: If the queue_timeout value is not an
|
integer greater or equal to 0.
|
rß zYConnection queue_timeout value must be an integer greater or equal to 0, the given value ra r r r´ ri N)r~ rã r r r´ Ú_CNX_POOL_QUEUE_TIMEOUTr )r r´ rx rx ry r] '
|
s ÿþý
|
ÿÿ
|
zClient._set_queue_timeoutr
|
c C s t | j}| j |¡ |S )z~Creates a Session instance using the provided connection data.
|
|
Returns:
|
Session: Session object.
|
)r
|
r rY rs ©r Úsessionrx rx ry Ú get_sessionG
|
s
|
zClient.get_sessionc C s& t | j¡ | jD ] }| ¡ qdS )z*Closes the sessions opened by this client.N)rú r r rY rS re rx rx ry r¦ Q
|
s
|
z Client.close)N) rè ré rê rë r r r! r[ r\ r^ r] rg r¦ rx rx rx ry rU ¸ s ý
|
rU z"Union[Dict[str, List[Dict]], Dict])Úpathrp c C s | dd¡} d| ko.| d¡dko.| d¡dk oD| d¡oD| d¡}g }t |r^| dd
n| ¡}d }|D ]Ö}i }t |¡}|r¨| d¡}t | d
|
¡|d < |d7 }n t
|
|¡}|rÈ| d¡}d |d < t d | }|j sêt d| z|j|j |jd W n6 tk
|
r6 } ztd| d|W 5 d}~X Y nX | |¡ qld | k r`t|k rnn n
|
tdd|r|d|iS |d S )zÜParses a list of host, port pairs.
|
|
Args:
|
path: String containing a list of routers or just router
|
|
Returns:
|
Returns a dict with parsed values of host, port and priority if
|
specified.
|
r' Ú ú,r´ r ú[ú]rß r r- r r z//zInvalid address: r4 z Invalid URI: i¢ Nr r rd )Úreplacer r8 ÚendswithÚ _SPLIT_RErd Ú _PRIORITY_REÚmatchÚgroupr Ú
|
_ROUTER_REr rá r) r rc r r- rs r ) rh rr rd Z address_listr Úaddressr rq r£ rx rx ry Ú_parse_address_listX
|
sD
|
&ÿý
|
|
|
|
|
$ ýru r )Úurirp c C sî ddi}t | ¡}|r | ¡ nd| f\}} |dkrBtd| d|dkrRd|d < | d
|
¡d d d
\}}| d ¡d d d
\}}| d¡}||d
d¡dkr¾|dkr¾| dd¡\}|d< | d¡}|rØ|rØd|krètd| d| dd¡\} }
|
t
|
| t
|
|
|
|d< |d< | d¡r,t
|
||d< n$| d¡rBtd n| t |¡ d } t|dD ]\} } | d d ¡ ¡ }|| krtd | d|tkr®t
|
| d¡||< n8| ¡ }|d!krÊd||< n |d"krÞd#||< n|||< q^|S )$aq Parses 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.
|
ra ri r¢ )r¢ ú
|
mysqlx+srvzScheme 'z' is not validrw Trm ú@Nr- ú?ú/ú)rß r r z()r´ zMalformed URI 'r r_ r` )rz rM r\ re z\.z Windows Pipe is not supported)r_ r` rm rr rÏ zInvalid option: ')Ú1Útrue)Ú0ÚfalseF)Ú_URI_SCHEME_RErq Úgroupsr) Ú partitionÚrfindÚfindÚrsplitrN rd r r8 r ru r rm rG Ú _SSL_OPTS)rv r rq ÚschemeÚuserinfoÚtmprb Z query_strÚposr_ r` Zinvalid_optionsrw ÚvalÚoptZval_strrx rx ry Ú_parse_connection_uri
|
sH
|
|
|
|
|
|
|
|
|
|
r r3 c
|
C s t | ¡ t¡}|r0d |¡}td| dd| krR| d D ]}t|d q@nd| krbt| d| krú| d }z&tt|t r|
|
¡ ¡ n|| d< W n< t t fk
|
rÔ } ztd| d d|W 5 d }~X Y nX d
|
| krú| d tjtjfkrútd d | krd
|
| krtd d| kr2d| kr2tdd
|
| kr`| d¡tjtjtjfkr`tdd| krÚ| d }z(tt|t r|
|
¡ ¡ n|| d< W n> t t fk
|
rØ } ztd| d d|W 5 d }~X Y nX d| krT| d }z(tt|t r|
|
¡ ¡ n|| d< W n> t t fk
|
rR } ztd| d d|W 5 d }~X Y nX d| krÖt| d t r | d ¡ d¡}|r| d¡| d< nd | d< n t| d ttfs¼td| d¡tjkrÖd | d< d| krèt| d | krZzFt| d t rt| d | d < t| d tr2| d d k r6t W n t k
|
rX td d Y nX d | krºt| d ts|td | d!¡rtd"| d#¡r¤td$| d¡rØtd%n d| krØ| d#¡sØd| d#< d&| krêt| d'| krüt | d S )(an Validates the settings to be passed to a Session object
|
the port values are converted to int if specified or set to 33060
|
otherwise. The priority values for each router is converted to int
|
if specified.
|
|
Args:
|
settings: dict containing connection settings.
|
|
Raises:
|
:class:`mysqlx.InterfaceError`: On any configuration issue.
|
z', 'zInvalid option(s): 'r rd r, rb rf zInvalid SSL Mode 'NrZ z Cannot verify Server without CAr\ zCA Certificate not providedr[ rY z Client Certificate not providedz$Must verify Server if CA is providedrg zInvalid Auth 'rk zpThe connection property 'compression' acceptable values are: 'preferred', 'required', or 'disabled'. The value 'z' is not acceptablerl z[]rj z@Invalid type of the connection property 'compression-algorithms'rj ri r zEThe connection timeout value must be a positive integer (including 0)rm z(The value of 'dns-srv' must be a booleanre z<Using Unix domain sockets with DNS SRV lookup is not allowedrc z;Specifying a port number with DNS SRV lookup is not allowedzASpecifying multiple hostnames with DNS SRV look up is not allowedr] r^ ) ÚsetÚkeysÚ
|
differenceÚ
|
_SESS_OPTSru r) Ú_validate_hostsr& r~ rn rG rN r r r½ Z VERIFY_CAr rO r$ r% rd Úlistr× Ú _validate_connection_attributesr Ú TypeErrorrã Ú_validate_tls_versionsÚ_validate_tls_ciphersuites) r Z invalid_optsZinvalid_opts_listr r¬ r£ rg rk Zcompression_algorithmsrx rx ry Ú_validate_settingsÎ
|
sÒ
|
ÿ (þý
|
ÿ (
|
ÿý ÿü
|
ÿ
|
ÿ
|
|
ÿ
|
þÿý
|
ÿ ÿ ÿ
|
|
r rø )r Ú default_portrp c C sî d| kr| d rz6t | d | d< | d dk s:| d dkrDtddW nH tk
|
rf tdddY n* tk
|
r td| d ddY nX d | krÖ| d rÖzt | d | d < W qê tk
|
rÒ td
|
dY qêX nd | krê|rê|| d < dS ) zØValidate hosts.
|
|
Args:
|
settings (dict): Settings dictionary.
|
default_port (int): Default connection port.
|
|
Raises:
|
:class:`mysqlx.InterfaceError`: If priority or port are invalid.
|
r r r z1Invalid priority value, must be between 0 and 100r zInvalid priorityNzInvalid priority: rc z Invalid portrb )r r- Ú NameErrorr r) )r r rx rx ry r S s0 þ ÿþ r c C sâ i }d| krdS | d }t |trü|dkr6i | d< dS | d¡rJ| d¡sb|dkrbtd| d|dkr|d kr|d
|
| d< ni | d< dS |d d
d ¡}|D ]X}|dkr¬q| d¡}|d }t|d krÒ|d nd}||krîtd| d|||< qn$t |tr:|D ]*}|| }t |ts,t|}|||< q næt |t sP|dkrl|r`i | d< nd
|
| d< dS t |t
|
r|D ]}d||< q|nt |t r|D ]b}|dkr°q| d¡}|d }t|d krØ|d nd}||krötd| d|||< qn t |t s td| d|rÖ| ¡ D ]¦\}}t |tsRtd| dt|dkrptd| d| d¡rtd| dt |ts®td| d| dt|d kr.td| d| d q.|| d< dS ) z»Validate connection-attributes.
|
|
Args:
|
settings (dict): Settings dictionary.
|
|
Raises:
|
:class:`mysqlx.InterfaceError`: If attribute name or value exceeds size.
|
rj Nri rk rl )ÚFalser ÚTruer} z]The value of 'connection-attributes' must be a boolean or a list of key-value pairs, found: 'r )r r Fr rß rj ú=r zDuplicate key 'z ' used in connection-attributes)r r zLconnection-attributes must be Boolean or a list of key-value pairs, found: 'r+ r, r- r. rr zBKey names in connection-attributes cannot start with '_', found: 'z Attribute 'r0 r/ r1 ) r~ rn r8 rn r) rd r r Úreprrã r r r ) r rJ rW Zconn_attributesÚattrZ attr_name_valr9 Zattr_valr: rx rx ry r w s®
|
ÿÿþ
|
ÿ
|
|
|
ÿ
|
|
|
|
|
ÿ
|
ÿ
|
ÿ
|
ÿ
|
ÿ ÿÿr c C sä g }d| krdS | d }t |tr| d¡r6| d¡sFtd| d|dd
d ¡}|D ]:}| ¡ }|d
|
krrq\||krttjd |d | |¡ q\nt |t
|
rà|s°td |D ](}||krÒttjd |d | |¡ q´n>t |t r|D ]}| |¡ qðn tdd t ¡ d| d|s,td g }g }g }|D ]:}|t krT| |¡ |tkrj| |¡ n
|
| |¡ q<|r²|dgkr ts tt |t ¡| ¡ || d< n.|rÊtt |t ¡n|ràtt |t ¡dS )z¬Validate tls-versions.
|
|
Args:
|
settings (dict): Settings dictionary.
|
|
Raises:
|
:class:`mysqlx.InterfaceError`: If tls-versions name is not valid.
|
r] Nrk rl z%tls-versions must be a list, found: 'r r rß rj ri Ú tls_versions©r rj zKAt 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 r¹ z
|
. found: 'r )r~ rn r8 rn r) rd rN rN r@ rs r r ru r" r rà r* rO r rP rQ ) r r Ztls_versions_settingsZtls_versÚtls_verrß Zuse_tls_versionsZdeprecated_tls_versionsZnot_tls_versionsrx rx ry r ç s
|
ÿþ
|
ÿ ÿÿ
|
ÿ ÿ ÿÿ
|
|
|
|
ÿ
|
ÿÿr c C sÎ g }d| krdS | d }t |tr| d¡r6| d¡sFtd| d|dd
d ¡}|sdtd
|
|D ] }| ¡ ¡ }|rh| |¡ qhn.t |t t
|
fr¨d d |D }ntd | d| dd¡dkrÔt dd
n| d dd
}|j dd |d }g }i }g } t dt |¡d
D ]"}
|
| t|
|
¡ | t|
|
¡ q|D ]p} d| krf| | krf| | ¡ nJ| |kr || } | |krttjd| d| | ¡ ntd| dqB|sÂtd
|
|| d< dS )z´Validate tls-ciphersuites.
|
|
Args:
|
settings (dict): Settings dictionary.
|
|
Raises:
|
:class:`mysqlx.InterfaceError`: If tls-ciphersuites name is not valid.
|
r^ Nrk rl z)tls-ciphersuites must be a list, found: 'r r rß rj z:No valid cipher suite found in the 'tls-ciphersuites' listc S s g | ] }|r|qS rx rx )r! Útls_csrx rx ry r" d s z._validate_tls_ciphersuites.<locals>.<listcomp>zItls-ciphersuites should be a list with one or more ciphersuites. Found: 'r] Tr² r rÏ Útls_ciphersuitesr¡ z The value 'z.' in cipher suites is not a valid cipher suite)r~ rn r8 rn r) rd rN Úupperrs r r r r" r r) r r# r× r! r rN r@ ) r r¤ Ztls_ciphersuites_settingsZtls_cssr£ r Z newer_tls_verZtranslated_namesZiani_cipher_suites_namesZossl_cipher_suites_namesr¢ rÕ Ztranslated_namerx rx ry r B sz
|
ÿþ
|
ÿÿ
|
ÿÿý ÿ
|
|
|
ÿÿ
|
ÿÿr )rî ro rp c O s i }| rZt | d tr$t| d }qt | d tr| d ¡ D ]\}}||| dd¡< q>n&|r| ¡ D ]\}}||| dd¡< qf|stdt| |S )aZ Parses the connection string and returns a dictionary with the
|
connection settings.
|
|
Args:
|
*args: Variable length argument list with the connection data used
|
to connect to the database. It can be a dictionary or a
|
connection string.
|
**kwargs: Arbitrary keyword arguments with connection data used to
|
connect to the database.
|
|
Returns:
|
mysqlx.Session: Session object.
|
|
Raises:
|
TypeError: If connection timeout is not a positive integer.
|
:class:`mysqlx.InterfaceError`: If settings not provided.
|
r rr rÏ zSettings not provided)r~ rn r r r rm r) r )rî ro r rw r rx rx ry Ú_get_connection_settings s r¦ c O s t | |}t|S )a° Creates a Session instance using the provided connection data.
|
|
Args:
|
*args: Variable length argument list with the connection data used
|
to connect to a MySQL server. It can be a dictionary or a
|
connection string.
|
**kwargs: Arbitrary keyword arguments with connection data used to
|
connect to the database.
|
|
Returns:
|
mysqlx.Session: Session object.
|
)r¦ r
|
)rî ro r rx rx ry rg ¿ s
|
rg zUnion[str, Dict[str, Any]])Úconnection_stringÚoptions_stringrp c
|
C sd t | ttfstdt| }t |ttfs4tdt |tr|zt |¡}W q¢ tk
|
rx } ztd|W 5 d}~X Y q¢X n&i }| ¡ D ]\}}||| dd¡< qt |ts´tdi }d|krZ|
|
d¡}t |tsÞtd|
|
d d
|
¡|d < |
|
d d ¡|d < |
|
d d¡|d < |
|
dd¡|d< t |dkr:td| t |dkrZtd| ¡ t ||S )a8 Creates a Client instance with the provided connection data and settings.
|
|
Args:
|
connection_string: A string or a dict type object to indicate the connection data used to connect to a MySQL server.
|
|
The string must have the following uri format::
|
|
cnx_str = 'mysqlx://{user}:{pwd}@{host}:{port}'
|
cnx_str = ('mysqlx://{user}:{pwd}@['
|
' (address={host}:{port}, priority=n),'
|
' (address={host}:{port}, priority=n), ...]'
|
' ?[option=value]')
|
|
And the dictionary::
|
|
cnx_dict = {
|
'host': 'The host where the MySQL product is running',
|
'port': '(int) the port number configured for X protocol',
|
'user': 'The user name account',
|
'password': 'The password for the given user account',
|
'ssl-mode': 'The flags for ssl mode in mysqlx.SSLMode.FLAG',
|
'ssl-ca': 'The path to the ca.cert'
|
"connect-timeout": '(int) milliseconds to wait on timeout'
|
}
|
|
options_string: A string in the form of a document or a dictionary type with configuration for the client.
|
|
Current options include::
|
|
options = {
|
'pooling': {
|
'enabled': (bool), # [True | False], True by default
|
'max_size': (int), # Maximum connections per pool
|
"max_idle_time": (int), # milliseconds that a
|
# connection will remain active while not in use.
|
# By default 0, means infinite.
|
"queue_timeout": (int), # milliseconds a request will
|
# wait for a connection to become available.
|
# By default 0, means infinite.
|
}
|
}
|
|
Returns:
|
mysqlx.Client: Client object.
|
|
.. versionadded:: 8.0.13
|
z(connection_data must be a string or dictz+connection_options must be a string or dictzA'pooling' options must be given in the form of a document or dictNrÏ rr r z<'pooling' options must be given in the form document or dictrX Tr± r² r³ r r´ z Unrecognized pooling options: z!Unrecognized connection options: )r~ rn r r) r¦ ÚjsonÚloadsr r rm rñ r r rU ) r§ r¨ Z settings_dictrW r£ rw rj Zpooling_options_dictZpooling_optionsrx rx ry Ú
|
get_clientÐ sN 5
|
ÿþ
|
ÿ
|
|
|
ÿ ÿr« )N)¬rë Ú
|
__future__r Útypesr r» rº ÚPROTOCOL_TLSv1ÚPROTOCOL_TLSv1_1ÚPROTOCOL_TLSv1_2rÄ Úhasattrr ÚPROTOCOL_SSLv23r rÃ Ú ImportErrorr© rÔ rb r¼ r& Úrere rf rÿ rL rÛ Útypingr
|
r r r r r r r r Z dns.exceptionr Z dns.resolverr r r Ú functoolsr Z json.decoderr Ú urllib.parser r r Zauthenticationr r r Ú constantsr r r! r" r# r$ r% r& Zcrudr( Úerrorsr) r* r+ r, r- r. Zhelpersr/ r0 r1 r2 Zprotobufr3 r6 r4 r5 r6 r7 r8 rý r9 r: r; r< r= r r> r? r@ rA rB rC rD rE rF rG rH rI rJ rK rL rh rs Zmysql.connector.abstractsrN rO rP rQ Zmysql.connector.utilsrR Zmysql.connector.versionrS rT rö rì rC rE r? rÕ rb rÀ Úcompiler¿ rc rd Z_PENALTY_SERVER_OFFLINEZ_PENALTY_MAXED_OUTZ_PENALTY_NO_ADD_INFOZ_PENALTY_CONN_TIMEOUTZ_PENALTY_WRONG_PASSWZ_PENALTY_RESTARTINGr r ro ÚVERBOSErp rs r r r rz r r r r r r rò ró r½ rª rú r
|
rU ru r r r r r r r¦ rg r« rx rx rx ry Ú<module> s0 ýÿý
|
,
|
(
|
4 û
|
ÿ
|
ó
|
|
úñ u>$ _I X _ !7? ÿ$p[Y$
|
