Ë
|
Wñúh-e ã óÒ U d Z ddlmZ ddlZddlZddlZddlZddlZddlm Z ddl
|
m Z m Z m Z mZmZmZmZmZ ddlmZmZ ddlmZ ddlZddlZdZd
|
d l m Z m Z m Z m!Z!m"Z" d
|
d l#m$Z$m%Z%m&Z& d dl'm(Z( e rd dl)m*Z* ejV « Z,dZ-dZ. ej^ d« Z0e(fZ1de2d< i Z3de2d< d dZ4 d dZ5 d!dZ6d"dZ7 G d d« Z8 G d d « Z9y# e $ r d ZY w xY w)#z5Implementing pooling of connections to MySQL servers.é )Ú annotationsN)Ú TracebackType)Ú TYPE_CHECKINGÚAnyÚDictÚNoReturnÚOptionalÚTupleÚTypeÚUnion)ÚUUIDÚuuid4)Ú CNX_POOL_ARGSTFé )ÚErrorÚInterfaceErrorÚNotSupportedErrorÚ PoolErrorÚProgrammingError)ÚDEFAULT_CONFIGURATIONÚgenerate_pool_nameÚread_option_filesé )ÚMySQLConnection)ÚMySQLConnectionAbstracté é@ z[^a-zA-Z0-9._:\-*$#]z Union[type, Tuple[type, ...]]ÚMYSQL_CNX_CLASSz Dict[str, MySQLConnectionPool]Ú_CONNECTION_POOLSÚPooledMySQLConnectionc ó K d| v r| d n
|
t di | ¤}|t vrLt di | ¤}|j « d{ t 4 d{ |t |< ddd« d{ nAt t | t « r*t | j }d| v r| d |k7 r t d« t | j « d{ S 7 7 7 j# 1 d{ 7 sw Y 8xY w7 # t $ r t d| d« dw xY ww)z!Return a pooled MySQL connection.Ú pool_nameNÚ pool_sizez)Size can not be changed for active pools.z%Failed getting connection from pool 'ú'© ) r r ÚMySQLConnectionPoolÚinitialize_poolÚCONNECTION_POOL_LOCKÚ
|
isinstancer# r Úget_connectionÚAttributeErrorr )Úkwargsr" ÚpoolÚ
|
check_sizes úNH:\Change_password\venv_build\Lib\site-packages\mysql/connector/aio/pooling.pyÚ_get_pooled_connectionr0 L s' è ø ð +¨fÑ 4{ÒÔ:LÑ:VÈvÑ:Vð ð
|
Ô)Ñ)Ü"Ñ, VÑ,Ø×"Ñ"Ó$×$Ð$ä'÷ 0ñ 0Ø+/Ô iÑ (÷ 0÷ 0ð 0ä Ô% iÑ0Ô2EÔ Fä& yÑ1×;Ñ;
|
Ø &Ñ V¨KÑ%8¸JÒ%FÜÐ GÓHÐ HðÜ& yÑ1×@Ñ@ÓB×BÐBð %øð 0øð 0ø÷ 0÷ 0ñ 0úð CùÜ ò Ü Ø3°I°;¸aÐ @ó
|
àð ðüs ;D½C ¾DÁ CÁ DÁ
|
CÁ DÁ%CÁ&ADÂ-C) ÃC'ÃC) Ã DÃDÃDÃC$ÃC ÃC$Ã DÃ'C) Ã)DÄDc ój K | j « } |d }|d= h d£}d}|D ]¿ }t |j « « |z
|
}|r4t |« dkD rdnd}d j |« }t d
|
| d | « t |d « r|dz }|j d d « |d < |d dk s|d d kD rt d|d « t |d t « r°t d|d « d|cxk rt |« k r t d« i } g }
|
t |d d¬« D ]> }|d | vr |g| |d < |
|
j |d « (| |d j |« @ |
|
D ] } | | } t t | « « D ] } t | « dz
|
}t! j" d|« }| j% |« }|j « }|j' |« |j% d d« t) di |¤ d{ c c S ¡ t d« # t $ r t d« dw xY w7 /# t* $ r Y ·w xY ww)aª Return a MySQL connection and try to failover if needed.
|
|
An InterfaceError is raise when no MySQL is available. ValueError is
|
raised when the failover server configuration contains an illegal
|
connection argument. Supported arguments are user, password, host, port,
|
unix_socket and database. ValueError is also raised when the failover
|
argument was not provided.
|
|
Returns MySQLConnection instance.
|
Úfailoverz failover argument not providedN> ÚhostÚportÚuserÚdatabaseÚpasswordÚpriorityr" r# Ú unix_socketr r ÚsÚ z, z Unsupported connection argument z in failover: r8 éd z9Priority value should be in the range of 0 to 100, got : zDPriority value should be an integer in the range of 0 to 100, got : z\You must either assign no priority to any of the routers or give a priority for every routerc ó | d S )Nr8 r% ©Úxs r/ ú<lambda>z*_get_failover_connection.<locals>.<lambda>« s
|
°°:± ó T)ÚkeyÚreversez,Unable to connect to any of the target hostsr% )ÚcopyÚKeyErrorÚ
|
ValueErrorÚsetÚkeysÚlenÚjoinÚhasattrÚgetr r) Úintr ÚsortedÚappendÚrangeÚrandomÚrandintÚpopÚupdateÚconnectr )r, Úconfigr2 Úsupport_cnx_argsÚpriority_countÚserverÚdiffÚargÚlstÚserver_directoryÚserver_priority_listr8 Ú failover_listÚ_ÚlastÚindexÚ
|
new_configs r/ Ú_get_failover_connectionrd i s½ è ø ð [[]FðEØ*Ñ%ð zÐò
|
Ðð NØò Ü6;;=Ó!Ð$4Ñ4Ù Ü T Q #¨BCØ))D/CÜ Ø2°3°%°~ÀcÀUÐKóð ô 6:Ô &Ø aÑ Nà #ZZ¨
|
°CÓ 8zÑØ *Ñ Ò ! V¨JÑ%7¸#Ò%=Ü ðØ
|
Ñ+Ð,ð.óð ô & Ñ,¬cÕ2Ü ð Ø $ ZÑ 0Ð 1ð3óð ð%ð. >Ô)C MÒ)Ü ð ó
|
ð
|
ð *ð ÐØ ÐÜÑ'>ÈÔMò @Ø *Ñ Ð%5Ñ 5Ø4:°8Ð V JÑ /Ñ 0Ø × 'Ñ '¨¨zÑ(:Õ ;à V JÑ /Ñ 0× 7Ñ 7¸Õ ?ð @ð )ò Ø(¨Ñ2 Üs=Ó)Ó*ò AÜ}Ó%¨Ñ)DÜNN 1 dÓ+EØ"×&Ñ& uÓ-FØ JØ × Ñ fÔ %Ø NN: tÔ ,ð Ü $Ñ 2 zÑ 2×2Ô2ñ ð ô ÐGÓ
|
HÐHøôQ ò EÜÐ9Ó:ÀÐDðEúðF 3ùÜò áð üsY H3H B:H3ÃDH3Ç$H$Ç2H"Ç3H$Ç6H3È H È H3È"H$È$ H0È-H3È/H0È0H3c óz K dv rj d« nd}t |t « s t d« |r t s t d« dv r t d« dv r t d« d v r t d
|
« d vr t
|
d d < t j j d d « d { }g }|D ]P }|j |j j d¬« |j |j |j d« R |j# d ¬« |D cg c] }|d |d d c}d < d v rt% di ¤ d { S t' fdt( D « « rt+ di ¤ d { S dv rd d< j d« dv r t/ di ¤}t1 di |¤ d { S dv rd= t3 | i ¤}|j1 « d { |S 7 :# t j j $ r t dd d« d w xY wc c}w 7 Ø7 ®# t, $ r Y ¶w xY w7 7 Ww)aþ Creates a MySQL connection object.
|
|
In its simpliest form, `connect()` will open a connection to a
|
MySQL server and return a `MySQLConnectionAbstract` subclass
|
object such as `MySQLConnection` or `CMySQLConnection`.
|
|
Args:
|
*args: N/A.
|
**kwargs: For a complete list of possible arguments, see [1]. If no arguments
|
are given, it uses the already configured or default values.
|
|
Returns:
|
A `MySQLConnectionAbstract` subclass instance (such as `MySQLConnection`)
|
or a `PooledMySQLConnection` instance.
|
|
Raises:
|
`mysql.connector.errors.NotSupportedError`: if pooled connection is not supported
|
for the Python version and OS that are being used.
|
|
Examples:
|
A connection with the MySQL server can be established using either the
|
`mysql.connector.aio.connect()` method or a `MySQLConnectionAbstract` subclass:
|
```
|
>>> from mysql.connector.aio import MySQLConnection
|
>>>
|
>>> cnx1 = await mysql.connector.aio.connect(user='joe', database='test')
|
>>> cnx2 = MySQLConnection(user='joe', database='test')
|
>>>
|
```
|
References:
|
[1]: https://dev.mysql.com/doc/connector-python/en/connector-python-connectargs.html
|
Údns_srvFz(The value of 'dns-srv' must be a booleanztMySQL host configuration requested DNS SRV. This requires the Python dnspython module. Please refer to documentationr9 z<Using Unix domain sockets with DNS SRV lookup is not allowedr4 z;Specifying a port number with DNS SRV lookup is not allowedr2 zASpecifying multiple hostnames with DNS SRV look up is not allowedr3 ÚSRVNz Unable to locate any hosts for 'r$ T)Úomit_final_dot)r3 r4 r8 Úweightc ó | d | d fS )Nr8 ri r% r> s r/ r@ zconnect.<locals>.<lambda> s Q z¡]°Q°x±[°LÐ$A rA )rB )r3 r4 c 3 ó& K | ] }|v
|
y w©Nr% )Ú.0rB r, s r/ ú <genexpr>zconnect.<locals>.<genexpr> s øè ø Ò6 sf}Ñ6ùs Úread_default_fileÚ option_filesÚuse_purer% )rS r) Úboolr ÚHAVE_DNSPYTHONr ÚdnsÚ asyncresolverÚqueryÚ exceptionÚ DNSExceptionrO ÚtargetÚto_textr4 r8 ri Úsortrd Úanyr r0 Ú NameErrorr rU r )Úargsr, rf Ú srv_recordsr2 Úsrvrc Úcnxs ` r/ rU rU Ä s øè ø ðH (1°FÑ':fjjÔ#ÀGä gtÔ $Ü Ð GÓHÐHâÝ Ü ð8óð ð
|
FÑ "Ü ØNóð ð VÑ Ü ØMóð ð Ñ Ü ØSóð ð Ñ Ü 2°6Ñ :F6Nð Ü #× 1Ñ 1× 7Ñ 7¸¸v¹ÈÓ N×NKð Ø ò CØ OOà JJ× .Ñ .¸dÐ .Ó CØ HHØ #§ ¡ Ø !jjñ õ ð ð ÑA ÔBàBJö
|
Ø;>S[¨#¨f©+Ó 6ò
|
zÑð
|
VÑÜ-Ñ7°Ñ7×7Ð7ð Ü Ó6¬ Ô6Ô 6Ü/Ñ9°&Ñ9×9Ð 9ð 7ð fÑ$Ø!'Ð(;Ñ!<~Ñ Ø
|
|
Ð&Ô'àÑ Ü&Ñ0¨Ñ0
|
Ü Ñ*zÑ*×*Ð*àVÑØ :Ð ä
|
4Ð
|
* 6Ñ
|
*CØ
|
++-×ÐØ Jða OúÜ}}×)Ñ)ò Ü Ø2°6¸&±>Ð2BÀ!ÐDóàð ð üò"
|
ð 8øð
|
:ùÜ ò á ð úð +øð ús BH;Â&G+ Â.G(Â/G+ Â3A.H;Ä!H Ä3H;Å H$Å H;Å&H( Å7H&Å8H( Å;<H;Æ7H7Æ8)H;Ç!H9Ç"H;Ç(G+ Ç+1H È H;È&H( È( H4È1H;È3H4È4H;È9H;c ó t j } t j dk( r+| j dk( r| j
|
dk r t d« yyy)zWRaises error if the Python version and OS combination is not
|
supported for Pooling.Únté é
|
zSPooled connections are not supported for Python versions lower than 3.11 on WindowsN)ÚsysÚ version_infoÚosÚnameÚmajorÚminorr )Úpy_version_infos r/ Ú_check_supportr 7 sR ô ×&Ñ&OÜ ww$?×0Ñ0°AÒ5¸/×:OÑ:OÐSUÒ:UÜ ð )ó
|
ð
|
ð ;VÐ5rA c ól e Zd ZdZd
|
dZd dZ d dZd dZddZe dd« Z
|
e dd« Z y )r a Class holding a MySQL Connection in a pool
|
PooledMySQLConnection is used by MySQLConnectionPool to return an
|
instance holding a MySQL connection. It works like a MySQLConnection
|
except for methods like close() and config().
|
The close()-method will add the connection back to the pool rather
|
than disconnecting from the MySQL server.
|
Configuring the connection have to be done through the MySQLConnectionPool
|
method set_config(). Using config() on pooled connection will raise a
|
PoolError.
|
Attributes:
|
pool_name (str): Returns the name of the connection pool to which the
|
connection belongs.
|
c ó t « t |t « s t d« t |t « s t d« || _ || _ y)zConstructor.
|
Args:
|
pool: A `MySQLConnectionPool` instance.
|
cnx: A `MySQLConnectionAbstract` subclass instance.
|
z/pool must be an instance of MySQLConnectionPoolz,cnx should be an instance of MySQLConnectionN)r r) r& r+ r Ú _cnx_poolÚ_cnx)Úselfr- r s r/ Ú__init__z PooledMySQLConnection.__init__Q sE ô Ôä$Ô 3Ô4Ü Ð!RÓSÐ SÜ#Ô/Ü Ð!OÓPÐ PØ.2Ø-0 rA c ó K | S wrl r% ©r s r/ Ú
|
__aenter__z PooledMySQLConnection.__aenter__` s è ø Ø ùs c ó@ K | j « d { y 7 wrl )Úclose)r Úexc_typeÚ exc_valueÚ tracebacks r/ Ú __aexit__z PooledMySQLConnection.__aexit__c s è ø ð jjl×Òús c ó. t | j |« S )z0Calls attributes of the MySQLConnection instance)Úgetattrr )r Úattrs r/ Ú __getattr__z!PooledMySQLConnection.__getattr__k s ätyy $Ó'Ð'rA c ór K | j } | j j r0|j « d{ r|j « d{ | j j |« d{ d| _ y7 G7 17 # | j j |« d{ 7 d| _ w xY ww)a» Do not close, but adds connection back to pool.
|
For a pooled connection, close() does not actually close it but returns it
|
to the pool and makes it available for subsequent connection requests. If the
|
pool configuration parameters are changed, a returned connection is closed
|
and reopened with the new configuration before being returned from the pool
|
again in response to a connection request.
|
N)r r Úcan_reset_sessionÚ is_connectedÚ reset_sessionÚadd_connection©r r s r/ r zPooledMySQLConnection.closeo s è ø ð iið Ø~~×/Ò/¸#×:JÑ:JÓ:L×4LÐ4LØ×'Ñ'Ó)×)Ð)à..×/Ñ/°Ó4× 4Ð 4Ø DIð 5MøØ)øà 4ù$..×/Ñ/°Ó4× 4Ñ 4Ø DIüs\ B7)B ¹BºB ÁBÁB Á B7Á4BÁ5 B7ÂB ÂB ÂB7 B4Â&B)Â' B4Â4B7c ó t d« )záConfiguration is done through the pool.
|
For pooled connections, the `config()` method raises a `PoolError`
|
exception. Configuration for pooled connections should be done
|
using the pool object.
|
zKConfiguration for pooled connections should be done through the pool itself)r )r, s r/ rV z PooledMySQLConnection.config s ô ð ó
|
ð
|
rA c ó. | j j S )zHReturns the name of the connection pool to which the connection belongs.)r r" r s r/ r" z PooledMySQLConnection.pool_name s ð ~~×'Ñ'Ð'rA N)r- r& r r ÚreturnÚNone©r© r )r zType[BaseException]r Ú BaseExceptionr r r© rª )r r r© r ©r© rª )r, r r© r ©r© Ústr) Ú__name__Ú
|
__module__Ú __qualname__Ú__doc__r r r r r Ú staticmethodrV Úpropertyr" r% rA r/ r r B sn ñ ó 1ó ðà%ðð !ðð !ð ð
|
|
ó ó(ó ð ò
|
ó ð
|
ð ò(ó ñ(rA c óº e Zd ZdZ d ddZddZedd« Zedd« Zedd« Z ddZ
|
dd Z dd
|
Z dd Z d dd Zd d ZddZddZy) r& z*Class defining a pool of MySQL connectionsNc óþ t « d| _ d| _ || _ | j |« |r| j |« || _ t j | j « | _ t « | _ y)a Constructor.
|
|
Initialize a MySQL connection pool with a maximum number of
|
connections set to `pool_size`.
|
|
NOTE: The coroutine `await cnxpool.initialize_pool(**dbconfig)` must be called
|
after initializing this class to open up the pool of required number of database
|
connections and making the instance of MySQLConnectionPool ready-to-use.
|
Contents of `dbconfig` is described in [1].
|
|
Args:
|
pool_name: The pool name. If this argument is not given, Connector/Python
|
automatically generates the name, composed from whichever of
|
the host, port, user, and database connection arguments are
|
given in kwargs, in that order.
|
pool_size: The pool size. If this argument is not given, the default is 5.
|
pool_reset_session: Whether to reset session variables when the connection
|
is returned to the pool.
|
|
Examples:
|
```
|
>>> dbconfig = {
|
>>> "database": "test",
|
>>> "user": "joe",
|
>>> }
|
>>> # initialize the MySQLConnectionPool instance
|
>>> cnxpool = mysql.connector.aio.pooling.MySQLConnectionPool(
|
>>> pool_name = "mypool",
|
>>> pool_size = 3,
|
>>> )
|
>>> # Open up the pool of connections
|
>>> await cnxpool.initialize_pool(**dbconfig)
|
>>> # cnxpool is ready to be used ...
|
```
|
References:
|
[1]: https://dev.mysql.com/doc/connector-python/en/connector-python-connectargs.html
|
N) r Ú
|
_pool_sizeÚ
|
_pool_nameÚ_reset_sessionÚ_set_pool_sizeÚ_set_pool_nameÚ _cnx_configÚasyncioÚQueueÚ
|
_cnx_queuer Ú_config_version)r r# r" Úpool_reset_sessionr, s r/ r z MySQLConnectionPool.__init__ sl ôX Ôà)-Ø)-Ø$6ÔØ ×ÑIÔ&Ù Ø × Ñ Ô *Ø+1ÔÜBIÇ-Á-Ø OOóC
|
ô &+£WÕ rA c óÄ K | j sCt 4 d{ | j t di | j ¤« ddd« d{ | j rd | j
|
di | j ¤ d{ d}|| j k r.| j « d{ |dz }|| j k r-yyy7 ©7 w# 1 d{ 7 sw Y xY w7 ^7 7w)aÉ Opens the connection pool and fill with MySQL database connections.
|
|
This coroutine must be called after initializing an instance of MySQLConnectionPool
|
to make the build the pool of connections and make the instance ready to be used.
|
|
Args:
|
**kwargs: Connection arguments, as described in [1].
|
|
References:
|
[1]: https://dev.mysql.com/doc/connector-python/en/connector-python-connectargs.html
|
Nr r r% )r¹ r( r¼ r r½ Ú
|
set_configr¸ r¥ )r Úcnts r/ r' z#MySQLConnectionPool.initialize_poolÎ sØ è ø ð Ü+÷ Lñ LØ×#Ñ#Ô$6Ñ$J¸×9IÑ9IÑ$JÔK÷ L÷ Là × Ò Ø!$//Ñ5 D×$4Ñ$4Ñ5× 5Ð 5ØCØÒ'Ø×)Ñ)Ó+×+Ð+Øqð Õ'ð ð Løð Lø÷ L÷ Lñ Lúð 6øð ,úsh C CC %CÁ C Á CÁ/C Á=C Á>(C Â&C Â'C à C ÃC ÃCà C ÃCÃC à C c ó | j S )z(Returns the name of the connection pool.)r¹ r s r/ r" z MySQLConnectionPool.pool_nameä ó ð Ð rA c ó | j S )z2Returns number of connections managed by the pool.)r¸ r s r/ r# z MySQLConnectionPool.pool_sizeé rÇ rA c ó | j S )z!Returns whether to reset session.)rº r s r/ r¢ z%MySQLConnectionPool.can_reset_sessionî s ð ×"Ñ"Ð"rA c óN K |sy t di |¤ d{ }|j « d{ t 4 d{ || _ t « | _ ddd« d{ y7 R7 <7 /7 # 1 d{ 7 sw Y yxY w# t $ r}t d| « |d}~ww xY ww)a° Set the connection configuration for `MySQLConnectionAbstract` subclass instances.
|
This method sets the configuration used for creating `MySQLConnectionAbstract`
|
subclass instances such as `MySQLConnection`. See [1] for valid
|
connection arguments.
|
Args:
|
**kwargs: Connection arguments - for a complete list of possible
|
arguments, see [1].
|
Raises:
|
PoolError: When a connection argument is not valid, missing
|
or not supported by `MySQLConnectionAbstract`.
|
References:
|
[1]: https://dev.mysql.com/doc/connector-python/en/connector-python-connectargs.html
|
Nz$Connection configuration not valid: r% )rU Ú
|
disconnectr( r½ r rÁ Ú Exceptionr )r r, r Úerrs r/ rÄ z MySQLConnectionPool.set_configó s¯ è ø ñ Ø ð Sä Ñ) &Ñ)×)CØ..Ó"× "Ð "Ü+÷ /ñ /Ø#)Ô Ü',£wÔ$÷ /÷ /ð /ð *øØ "øð /øð /ø÷ /÷ /ñ /ûô ò SÜÐ BÀ3À%Ð HÓIÈsÐ Rûð Süs B%B A(B A*®B ¼A,½B Á A0Á B Á"A.Á#B Á'B%Á(B Á*B Á,B Á.B Á0BÁ6A9 Á7BÁ>B ÂB%ÂB Â B"ÂB Â B"Â"B%c óR |dk s |t kD rt dt « || _ y)zÿSet the size of the pool
|
This method sets the size of the pool but it will not resize the pool.
|
Raises an AttributeError when the pool_size is not valid. Invalid size
|
is 0, negative or higher than pooling.CNX_POOL_MAXSIZE.
|
r z8Pool size should be higher than 0 and lower or equal to N)ÚCNX_POOL_MAXSIZEr+ r¸ )r r# s r/ r» z"MySQLConnectionPool._set_pool_size s7 ð >YÔ)9Ò 9Ü ØJÜ#Ð$ð&óð ð $rA c ó t j |« rt d| d« t |« t kD rt d| d« || _ y)a Set the name of the pool.
|
This method checks the validity and sets the name of the pool.
|
Raises an AttributeError when pool_name contains illegal characters
|
([^a-zA-Z0-9._\-*$#]) or is longer than pooling.CNX_POOL_MAXNAMESIZE.
|
z Pool name 'z ' contains illegal charactersz ' is too longN)ÚCNX_POOL_NAMEREGEXÚsearchr+ rI ÚCNX_POOL_MAXNAMESIZEr¹ )r r" s r/ r¼ z"MySQLConnectionPool._set_pool_name sO ô × $Ñ $ YÔ /Ü ;¨y¨kÐ9VÐ!WÓXÐ XÜ y>Ô 0Ò 0Ü ;¨y¨k¸ Ð!GÓHÐ HØ#rA c óÀ t |t « s t d« | j j |« y# t
|
j $ r}t d« |d}~ww xY w)zô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.
|
Raises `PoolError` on errors.
|
ú;Connection instance not subclass of MySQLConnectionAbstractú'Failed adding connection; queue is fullN)r) r r rÀ Ú
|
put_nowaitr¾ Ú QueueFull©r r rÍ s r/ Ú_queue_connectionz%MySQLConnectionPool._queue_connection' s\ ô #Ô/ÜØMóð ð PØ OO× &Ñ & sÕ +øÜ× Ñ ò PÜÐ EÓFÈCÐ Oûð Pús 9 ¹A Á AÁA c óÔ K | j s t d« | j j « r t d« |sit di | j ¤ d{ } | j
|
r-| j d r |j « dk r t d« | j |_
|
nt |t « s t d« | j |« y7 }# t $ r Y Lw xY ww) aö Adds a connection to the pool.
|
This method instantiates a `MySQLConnection` using the configuration
|
passed when initializing the `MySQLConnectionPool` instance or using
|
the `set_config()` method.
|
If cnx is a `MySQLConnection` instance, it will be added to the
|
queue.
|
Args:
|
cnx: The `MySQLConnectionAbstract` subclass object to be added to
|
the pool. If this argument is missing (aka `None`), the pool
|
creates a new connection and adds it.
|
Raises:
|
PoolError: When no configuration is set, when no more
|
connection can be added (maximum reached) or when the connection
|
can not be instantiated.
|
z&Connection configuration not availablerÖ NÚcompress)é é r z^Pool reset session is not supported with compression for MySQL server version 5.7.2 or earlierrÕ r% )r½ r rÀ ÚfullrU rº Úget_server_versionr rE rÁ Úpool_config_versionr) r rÚ r¦ s r/ r¥ z"MySQLConnectionPool.add_connection8 sã è ø ð$ × Ò ÜÐ DÓEÐ Eà ??× Ñ Ô !ÜÐ EÓFÐ FáÜ Ñ3 $×"2Ñ"2Ñ3×3Cð à×'Ò'Ø ×(Ñ(¨Ò4Ø×.Ñ.Ó0°9Ò<ä+ð%óð ð '+×&:Ñ&:CÕ #ä c¤?Ô3Ü ØQóð ð × Ñ sÕ#ð- 4ùô ò Ùð üs7 AC(ÁCÁC(Á 9C ÂA C(à C%Ã"C(Ã$C%Ã%C(c óÚ K | j j « }|j « d{ r| j |j k7 rF |j di | j ¤ |j « d{ | j |_ t | |« S # t j $ r}t d« |d}~ww xY w7 7 J# t $ r | j |« w xY ww)a Gets a connection from the pool.
|
This method returns an PooledMySQLConnection instance which
|
has a reference to the pool that created it, and the next available
|
MySQL connection.
|
When the MySQL connection is not connect, a reconnect is attempted.
|
Returns:
|
A `PooledMySQLConnection` instance.
|
Raises:
|
PoolError: On errors.
|
z)Failed getting connection; pool exhaustedNr% )rÀ Ú
|
get_nowaitr¾ Ú
|
QueueEmptyr r£ rÁ rá Ú_set_connection_optionsr½ Ú reconnectr rÚ r rÙ s r/ r* z"MySQLConnectionPool.get_connectioni sâ è ø ð RØ//×,Ñ,Ó.Cð
|
×&Ñ&Ó(×(Ð(Ø×#Ñ# s×'>Ñ'>Ò>ð Ø+×+Ñ+Ñ?¨d×.>Ñ.>Ò?Ømmo×%Ð%ð '+×&:Ñ&:CÔ #ä$ T¨3Ó/Ð/øô ×!Ñ!ò RÜÐ GÓHÈcÐ Qûð Rúð )øð
|
&ùÜ!ò Ø×&Ñ& sÔ+Øð üs[ C+B! C+±C² C+Á/C Á?C
|
 C  C+Â!CÂ4 C à CÃC+Ã
|
C Ã C(Ã(C+c ó( K d}| j }|j « r? |j « }|j « d{ |dz }|j « r?|S 7 # t j
|
$ r |cY S t $ r t $ r Y ?w xY ww)a$ Close all connections
|
This method closes all connections and returns the number of connections it closed.
|
This method should be used internally while cleaning-up the connection pool by closing each
|
and every active connection objects currently residing in the pool.
|
|
Returns:
|
An integer defining the number of open connections closed during clean-up.
|
Raises:
|
PoolError: On errors while fetching connections from the pool or while disconnecting
|
an open connection.
|
r Nr )rÀ Úqsizerã rË r¾ rä r r )r rÅ Úcnxqr s r/ Ú_remove_connectionsz'MySQLConnectionPool._remove_connections s è ø ð ØØjjlð
|
ØooÓ'ØnnÓ&×&Ð&Øqð jjlð
|
ð 'ùä×%Ñ%ò Ø
|
Ü ò ØÜò áð üsL B¢#A$ ÁA"Á A$ ÁBÁ BÁ"A$ Á$BÁ9BÁ;BÂ BÂBÂBc ó> K | j « d{ S 7 w)aÅ Cleans up the connection pool
|
This public method gracefully shuts down the connection pool by disconnecting all of the
|
open connections currently active in the pool.
|
|
Returns:
|
An integer defining the number of open connections closed while shutting down the pool.
|
Raises:
|
PoolError: On errors while fetching connections from the pool or while disconnecting
|
an open connection.
|
N)rê r s r/ Ú
|
close_poolz MySQLConnectionPool.close_pool¥ s è ø ð ×-Ñ-Ó/×/Ð/Ð/ús )rÝ NT)
|
r# rM r" z Optional[str]r rr r, r r© rª r r® )r© rM )r© rr )r, r r© rª )r# rM r© rª )r" r¯ r© rª )r r r© rª rl )r z!Optional[MySQLConnectionAbstract]r© rª r« )r° r± r² r³ r r' rµ r" r# r¢ rÄ r» r¼ rÚ r¥ r* rê rì r% rA r/ r& r& sÇ Ù4ð Ø#'Ø#'ð 8-àð8-ð !ð8-ð !ð 8-ð
|
ð 8-ð
|
ó 8-ótð, ò ó ð ð ò ó ð ð ò#ó ð#óSó6 $ó
|
$óPð$ 8<ð/$Ø4ð/$à ó/$ób 0ó>ô: 0rA r& )r, r r© r )r, r r© ú5Union[PooledMySQLConnection, MySQLConnectionAbstract])r~ r r, r r© rí r ):r³ Ú
|
__future__r r¾ r rQ Úrer Útypesr Útypingr r r r r r
|
r r Úuuidr r Úmysql.connector.constantsr Údns.asyncresolverrt Ú dns.exceptionrs Ú ImportErrorÚerrorsr r r r r Úpoolingr r r Ú
|
connectionr Ú abstractsr ÚLockr( rÏ rÓ ÚcompilerÑ r Ú__annotations__r r0 rd rU r r r& r% rA r/ ú<module>rþ s ðò: <å "ã Û Û Û Û
|
å ß S× SÓ Sß å 3ðÛ Ûð N÷õ ÷ SÑ RÝ 'áÝ2ð $w||~Ð ØÐ ØÐ Ø RZZÐ 7Ó8Ð Ø2AÐ1CÐ.Ó Cà46Ð Ð1Ó 6óð:XIØðXIà:óXIðvpØ ðpØ ðpà:ópóf
|
÷L(ñ L(÷^_0ò _0øðC ò ØNðús ÁC Ã C&Ã%C&
|
