Ë
|
Wñúhb ã óø U d Z ddlmZ ddlZddlZddlZddlZddlmZ ddl m
|
Z
|
m Z m Z m Z mZmZmZmZ ddlmZ ddlZddlZdZ d d
|
lmZ d d lm Z d d l m Z m Z d d l m!Z!m"Z"m#Z#m$Z$m%Z% d dl&m'Z' e
|
rd dl(m)Z) ejT « Z+dZ,dZ- ej\ d« Z/dZ0ee ne efZ1de2d< i Z3de2d< d dZ4 d!dZ5 d"dZ6d#d Z7 G d d« Z8 G d d « Z9y# e$ r dZY ¦w xY w# e$ r dZY ¬w xY w)$z5Implementing pooling of connections to MySQL servers.é )Ú annotationsN)Ú TracebackType)Ú TYPE_CHECKINGÚAnyÚDictÚNoReturnÚOptionalÚTupleÚTypeÚUnion)Úuuid4TFé )ÚCMySQLConnection)ÚMySQLConnection)Ú CNX_POOL_ARGSÚDEFAULT_CONFIGURATION)ÚErrorÚInterfaceErrorÚNotSupportedErrorÚ PoolErrorÚProgrammingError)Úread_option_files)ÚMySQLConnectionAbstracté é@ z[^a-zA-Z0-9._:\-*$#]z0MySQL Connector/Python C Extension not availablez Union[type, Tuple[type, ...]]ÚMYSQL_CNX_CLASSz Dict[str, MySQLConnectionPool]Ú_CONNECTION_POOLSÚPooledMySQLConnectionc óÒ d| v r| d n
|
t d i | ¤}| j d« du rt t t « t
|
5 |t vrt d i | ¤t |< nAt t | t « r*t | j }d| v r| d |k7 r t d« ddd« t | j « S # 1 sw Y !xY w# t $ r t d| d« dw xY w)
|
z!Return a pooled MySQL connection.Ú pool_nameÚuse_pureFNÚ pool_sizez)Size can not be changed for active pools.z%Failed getting connection from pool 'ú'© )Úgenerate_pool_nameÚgetr Ú ImportErrorÚ ERROR_NO_CEXTÚCONNECTION_POOL_LOCKr ÚMySQLConnectionPoolÚ
|
isinstancer" r Úget_connectionÚAttributeErrorr )Úkwargsr Ú
|
check_sizes úJH:\Change_password\venv_build\Lib\site-packages\mysql/connector/pooling.pyÚ_get_pooled_connectionr1 P s ð +¨fÑ 4{ÒÔ:LÑ:VÈvÑ:Vð ð zz*Ó Ñ&Ô+;Ð+CÜ-Ó(Ð(ô
|
ñ MØ Ô -Ñ -Ü+>Ñ+HÀÑ+HÔ iÒ (Ü Ô)¨)Ñ4Ô6IÔ Jä*¨9Ñ5×?Ñ?JØfÑ$¨° Ñ)<À
|
Ò)JÜ Ð KÓLÐL÷MðÜ Ñ+×:Ñ:Ó<Ð<÷Mð Mûô ò Ü Ø3°I°;¸aÐ @ó
|
àð ðús ÁA C Â)C à C à C&c ó` | j « } |d }|d= t g 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 ]y } t | « dz
|
}t! j" d|« }| j% |« }|j « }|j' |« |j% d d« t) di |¤c c S t d« # t $ r t d« dw xY w# t* $ r Y w xY w)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) ÚuserÚpasswordÚhostÚportÚ unix_socketÚdatabaser r" Úpriorityr r ÚsÚ z, z Unsupported connection argument z in failover: r: é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 )Nr: r$ ©Úxs r0 ú<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Úhasattrr& r r+ Úintr ÚsortedÚappendÚrangeÚrandomÚrandintÚpopÚupdateÚconnectr )r. Úconfigr3 Úsupport_cnx_argsÚpriority_countÚserverÚdiffÚargÚlstÚserver_directoryÚserver_priority_listr: Ú failover_listÚ_ÚlastÚindexÚ
|
new_configs r0 Ú_get_failover_connectionrd m 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Ô ,ð Ü Ñ, Ñ,Ô,ñ ð ô ÐGÓ
|
HÐHøôU ò EÜÐ9Ó:ÀÐDðEûôL ò áð ús H Ç+
|
H!ÈH È! H-È,H-c ó^ 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 « }g }|D ]P }|j |j j d¬« |j |j |j d« R |j# d ¬« |D cg c] }|d |d d c}d < dv rd d< j d« dv rt% di ¤}t' di |¤S d v r t) di ¤S t+ fdt, D « « r t/ di ¤S j3 dd« }dv rd= |st4 t7 t8 « t4 r |s t5 | i ¤S t; | i ¤S # t j j $ r t d d d« dw xY wc c}w # t0 $ r Y w xY w)aá Creates or gets 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`.
|
|
When any connection pooling arguments are given, for example `pool_name`
|
or `pool_size`, a pool is created or a previously one is used to return
|
a `PooledMySQLConnection`.
|
|
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
|
`CMySQLConnection`) or a `PooledMySQLConnection` instance.
|
|
Examples:
|
A connection with the MySQL server can be established using either the
|
`mysql.connector.connect()` method or a `MySQLConnectionAbstract` subclass:
|
```
|
>>> from mysql.connector import MySQLConnection, HAVE_CEXT
|
>>>
|
>>> cnx1 = mysql.connector.connect(user='joe', database='test')
|
>>> cnx2 = MySQLConnection(user='joe', database='test')
|
>>>
|
>>> cnx3 = None
|
>>> if HAVE_CEXT:
|
>>> from mysql.connector import CMySQLConnection
|
>>> cnx3 = CMySQLConnection(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 documentationr8 z<Using Unix domain sockets with DNS SRV lookup is not allowedr7 z;Specifying a port number with DNS SRV lookup is not allowedr3 zASpecifying multiple hostnames with DNS SRV look up is not allowedr6 ÚSRVz Unable to locate any hosts for 'r# NT)Úomit_final_dot)r6 r7 r: Úweightc ó | d | d fS )Nr: ri r$ r? s r0 rA zconnect.<locals>.<lambda> s Q z¡]°Q°x±[°LÐ$A rB )rC )r6 r7 Úread_default_fileÚ option_filesc 3 ó& K | ] }|v
|
y w©Nr$ )Ú.0rC r. s r0 ú <genexpr>zconnect.<locals>.<genexpr>4 s øè ø Ò6 sf}Ñ6ùs r! r$ ) rS r+ Úboolr ÚHAVE_DNSPYTHONr ÚdnsÚresolverÚqueryÚ exceptionÚ DNSExceptionrO ÚtargetÚto_textr7 r: ri Úsortr rU rd Úanyr r1 Ú NameErrorr& r r' r( r )Úargsr. rf Ú srv_recordsr3 Úsrvrc r! s ` r0 rU rU Ê s ø ðR (1°FÑ':fjjÔ#ÀGä gtÔ $Ü Ð GÓHÐHáÝ Ü ð8óð ð
|
FÑ "Ü ØNóð ð VÑ Ü ØMóð ð Ñ Ü ØSóð ð Ñ Ü 2°6Ñ :F6Nð Ü ,,×,Ñ,¨V°F©^¸UÓCKð Ø ò CØ OOà JJ× .Ñ .¸dÐ .Ó CØ HHØ #§ ¡ Ø !jjñ õ ð ð ÑA ÔBàBJö
|
Ø;>S[¨#¨f©+Ó 6ò
|
zÑð
|
fÑ$Ø!'Ð(;Ñ!<~Ñ Ø
|
|
Ð&Ô'àÑ Ü&Ñ0¨Ñ0
|
ÜÑ$Ñ$Ð$ð VÑÜ'Ñ1¨&Ñ1Ð1ð Ü Ó6¬ Ô6Ô 6Ü)Ñ3¨FÑ3Ð 3ð 7ð zz* eÓ,HØVÑØ :Ð ÙÔ ,Ð 4Ü mÓ,Ð ,å¡Ü Ð0¨Ñ0Ð0Ü DÐ + FÑ +Ð+øôg }}×)Ñ)ò Ü Ø2°6¸&±>Ð2BÀ!ÐDóàð ð üò"
|
øô* ò á ð ús$ Â#G' ÄHÅ5"H Ç'1HÈ H,È+H,c óª g }dD ] } |j t | | « « " |s t d« dj |« S # t $ r Y Lw xY w)zøGenerate a pool name
|
|
This function takes keyword arguments, usually the connection
|
arguments for MySQLConnection, and tries to generate a name for
|
a pool.
|
|
Raises PoolError when no name can be generated.
|
|
Returns a string.
|
)r6 r7 r4 r9 z.Failed generating pool name; specify pool_namer` )rO ÚstrrF r rK )r. ÚpartsrC s r0 r% r% F se ð EØ3ò ð Ø LLV C[Ó)Õ *ðñ ÜÐHÓIÐIà 88E?Ðøô ò Ù ð ús AÁ AÁAc ó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 « s t d« t |t « s t d« || _ || _ y)zConstructor.
|
|
Args:
|
pool: A `MySQLConnectionPool` instance.
|
cnx: A `MySQLConnectionAbstract` subclass instance.
|
z$pool should be a MySQLConnectionPoolz cnx should be a MySQLConnectionN)r+ r* r- r Ú _cnx_poolÚ_cnx)ÚselfÚpoolÚcnxs r0 Ú__init__z PooledMySQLConnection.__init__q s? ô $Ô 3Ô4Ü Ð!GÓHÐ HÜ#Ô/Ü Ð!BÓCÐ CØ.2Ø-0 rB c ó | S rn r$ ©r s r0 Ú __enter__z PooledMySQLConnection.__enter__ s Ø rB c ó$ | j « y rn )Úclose)r Úexc_typeÚ exc_valueÚ tracebacks r0 Ú__exit__z PooledMySQLConnection.__exit__ s ð
|
|
rB c ó. t | j |« S )z0Calls attributes of the MySQLConnection instance)Úgetattrr )r Úattrs r0 Ú __getattr__z!PooledMySQLConnection.__getattr__ s ätyy $Ó'Ð'rB c óü | j }| j j r|j « | j j |« d| _ y# | j j « d| _ w xY w)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
Ú reset_sessionÚadd_connection©r r s r0 r zPooledMySQLConnection.close s_ ð Ø))CØ~~×+Ò+Ø×!Ñ!Ô#à NN× )Ñ )¨#Ô .Ø DIøð NN× )Ñ )¨#Ô .Ø DIús 2A Á$A;c ó 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 r0 rV z PooledMySQLConnection.config s ô ð ó
|
ð
|
rB c ó. | j j S )zHReturns the name of the connection pool to which the connection belongs.)r
r r s r0 r z PooledMySQLConnection.pool_name¬ s ð ~~×'Ñ'Ð'rB 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 r ) Ú__name__Ú
|
__module__Ú __qualname__Ú__doc__r r r r r Ú staticmethodrV Úpropertyr r$ rB r0 r r ^ sn ñó$ 1ó ðà%ðð !ðð !ð ð
|
|
ó ó(ó ð" ò
|
|
ó ð
|
|
ð ò(ó ñ(rB c ó¢ e Zd ZdZ d ddZedd« Zedd« Zedd« ZddZ ddZ
|
dd Z dd
|
Z ddd Z dd Zdd Zy)r* z*Class defining a pool of MySQL connectionsNc ó d| _ d| _ || _ | j |« | j |xs t di |¤« i | _ t j | j « | _ t « | _ |rJ | j di |¤ d}|| j k r&| j « |dz }|| j k r%yyy)a£ Constructor.
|
|
Initialize a MySQL connection pool with a maximum number of
|
connections set to `pool_size`. The rest of the keywords
|
arguments, kwargs, are configuration arguments for MySQLConnection
|
instances.
|
|
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.
|
**kwargs: Optional additional connection arguments, as described in [1].
|
|
Examples:
|
```
|
>>> dbconfig = {
|
>>> "database": "test",
|
>>> "user": "joe",
|
>>> }
|
>>> cnxpool = mysql.connector.pooling.MySQLConnectionPool(pool_name = "mypool",
|
>>> pool_size = 3,
|
>>> **dbconfig)
|
```
|
|
References:
|
[1]: https://dev.mysql.com/doc/connector-python/en/connector-python-connectargs.html
|
Nr r r$ )Ú
|
_pool_sizeÚ
|
_pool_nameÚ_reset_sessionÚ_set_pool_sizeÚ_set_pool_namer% Ú _cnx_configÚqueueÚQueueÚ
|
_cnx_queuer Ú_config_versionÚ
|
set_configr )r r" r Úpool_reset_sessionr. Úcnts r0 r z MySQLConnectionPool.__init__µ s¾ ðL *.Ø)-Ø 0ÔØ ×ÑIÔ&Ø ×ÑIÒ EÔ);Ñ)E¸fÑ)EÔFØ+-ÔÜ@EÇ Á Ø OOóA
|
ô %wÔ á Ø DOOÑ %fÒ %ØCØÒ'Ø×#Ñ#Ô%Øqð Õ'ð rB c ó | j S )z(Returns the name of the connection pool.)r¬ r s r0 r z MySQLConnectionPool.pool_nameí ó ð Ð rB c ó | j S )z2Returns number of connections managed by the pool.)r« r s r0 r" z MySQLConnectionPool.pool_sizeò r¹ rB c ó | j S )z!Returns whether to reset session.)r r s r0 r z!MySQLConnectionPool.reset_session÷ s ð ×"Ñ"Ð"rB c óè |syt 5 t « } |j di |¤ || _ t « | _ ddd« y# t $ r}t d| « |d}~ww xY w# 1 sw Y yxY w)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$ )r) rU rV r° r r´ r- r )r r. Útest_cnxÚerrs r0 rµ z MySQLConnectionPool.set_configü s ñ$ Ø ä !ñ Wð WÜ"9Ø Ñ) &Ò)Ø#)Ô Ü',£wÕ$÷ Wð Wøô "ò WÜ Ð"FÀsÀeÐ LÓMÐSVÐVûð Wú÷ Wð Wús( A(2AÁ A%ÁA Á A%Á%A(Á(A1c óR |dk s |t kD rt dt « || _ y)a 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 r0 r® z"MySQLConnectionPool._set_pool_size s7 ð >YÔ)9Ò 9Ü ØJÜ#Ð$ð&óð ð $rB 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- rJ ÚCNX_POOL_MAXNAMESIZEr¬ )r r s r0 r¯ z"MySQLConnectionPool._set_pool_name) sO ô × $Ñ $ YÔ /Ü ;¨y¨kÐ9VÐ!WÓXÐ XÜ y>Ô 0Ò 0Ü ;¨y¨k¸ Ð!GÓHÐ HØ#rB c óÄ t |t « s t d« | j j |d¬« 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 MySQLConnectionAbstractF©Úblockú'Failed adding connection; queue is fullN)r+ r r r³ Úputr± ÚFull©r r r¾ s r0 Ú_queue_connectionz%MySQLConnectionPool._queue_connection7 s_ ô #Ô/ÜØMóð ð PØ OO× Ñ ¨5Ð Õ 1øÜzzò PÜÐ EÓFÈCÐ Oûð Pús ; »A Á AÁA c óæ t 5 | j s t d« | j j « r t d« |s]t di | j ¤} | j r)| j d r|j dk r t d« | j |_ nt |t « s t d« | j |« ddd« y# t $ r Y Rw xY w# 1 sw Y yxY w) 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É Úcompress)é é é z^Pool reset session is not supported with compression for MySQL server version 5.7.2 or earlierrÆ Nr$ )r) r° r r³ ÚfullrU r Úserver_versionr rF r´ Úpool_config_versionr+ r rÍ r s r0 r z"MySQLConnectionPool.add_connectionJ sò ô& "ñ (Ø×#Ò#Ü Ð HÓIÐIà×#Ñ#Ô%Ü Ð IÓJÐJáÜ Ñ1 × 0Ñ 0Ñ1ð à ×+Ò+Ø × ,Ñ ,¨ZÒ 8Ø × .Ñ .°Ò :ä /ð )ó ð ð +/×*>Ñ*>Õ'ä! #¤Ô7Ü#ØUóð ð × "Ñ " 3Ô '÷= (ð (øô( ò Ùðú÷) (ð (ús0 AC'Á 5CÂ>C'à C$Ã!C'Ã#C$Ã$C'Ã'C0c óæ t 5 | j j d¬« }|j « r| j |j k7 r> |j di | j ¤ |j « | j |_ t | |« cddd« S # t j $ r}t d« |d}~ww xY w# t $ r | j |« w xY w# 1 sw Y yxY w)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.
|
FrÇ z)Failed getting connection; pool exhaustedNr$ )r) r³ r& r± ÚEmptyr Ú is_connectedr´ rÕ rV r° Ú reconnectr rÍ r rÌ s r0 r, z"MySQLConnectionPool.get_connection} sç ô "ñ 4ð VØoo×)Ñ)°Ð)Ó6ð
|
×$Ñ$Ô&Ø×'Ñ'¨3×+BÑ+BÒBà
|
|
Ñ.T× -Ñ -Ò.ðØMMOð
|
+/×*>Ñ*>Ô'ä(¨¨sÓ3÷' 4ñ 4øô ;;ò VÜ Ð KÓLÐRUÐUûð Vûô &ò à×*Ñ*¨3Ô/Øðú÷ 4ð 4úsF C' B!¥AC'Á+CÁ; C'Â!CÂ4 C à CÃC'à C$Ã$C'Ã'C0c óZ t 5 d}| j }|j « r9 |j d¬« }|j « |dz }|j « r9|cddd« S # t
|
j $ r |cY cddd« S t $ r t $ r Y Ow xY w# 1 sw Y yxY w)z¹Close all connections
|
|
This method closes all connections. It returns the number
|
of connections it closed.
|
|
Used mostly for tests.
|
|
Returns int.
|
r FrÇ r N) r) r³ Úqsizer& Ú
|
disconnectr± r× r r )r r· Úcnxqr s r0 Ú_remove_connectionsz'MySQLConnectionPool._remove_connections¡ s¬ ô "ñ ØCØ??DØ**,ð
|
Ø ((¨(Ó/CØNNÔ$Ø1HCð **,ð ÷! ñ øô {{ò Ø J÷ ñ ô !ò ØÜ ò áðú÷ ð ús@ B!§'A*ÁB!Á B!Á*B Á?B!Â
|
B ÂB! B  B!Â!B*)rÐ NT)
|
r" rM r z Optional[str]r¶ rq r. r r r r¢ )r rM )r rq )r. r r r )r" rM r r )r r r r )r r r r rn )r z!Optional[MySQLConnectionAbstract]r r r )r£ r¤ r¥ r¦ r r¨ r r" r rµ r® r¯ rÍ r r, rÞ r$ rB r0 r* r* ² s© Ù4ð Ø#'Ø#'ð 6àð6ð !ð6ð !ð 6ð
|
ð 6ð
|
ó 6ðp ò ó ð ð ò ó ð ð ò#ó ð#ó Wó< $ó $ó Pô&1(óf"4ôHrB r* )r. r r r )r. r r ú5Union[PooledMySQLConnection, MySQLConnectionAbstract])r} r r. r r rß )r. r r r ):r¦ Ú
|
__future__r r± rQ ÚreÚ threadingÚtypesr Útypingr r r r r r
|
r r Úuuidr Ú dns.exceptionrs Ú dns.resolverrr r' Úconnection_cextr Ú
|
connectionr Ú constantsr r Úerrorsr r r r r Ú optionfilesr Ú abstractsr ÚRLockr) rÀ rÄ Úcompiler r( r Ú__annotations__r r1 rd rU r% r r* r$ rB r0 ú<module>rñ sJ ðò: <Ý "ã Û Û Û å ß S× SÓ SÝ ðÛÛð Nð Ý1õ (ß ;÷õ õ +áÝ2à&yÓ(Ð ØÐ ØÐ Ø RZZÐ 7Ó8Ð ØB à'Ð/O°oÐGWÐ5Xð Ð.ó ð 57Ð Ð1Ó 6óð:ZIØðZIà:óZIðzy,Ø ðy,Ø ðy,à:óy,óx÷0Q(ñ Q(÷hIò IøðM ò ØNðûð ò ØÒð ús# »C" ÁC/ Ã"C,Ã+C,Ã/C9Ã8C9
|
