i.-JddlZddlZddlZddlmZdZGddeZdS)N)STATUS@ceZdZdZdZdZdZddZdZdZ d Z d Z e d Z e d Ze d Ze dZe dZejdZdS)ConnectionPoolaG Class defining a pool of database connections MariaDB Connector/Python supports simple connection pooling. A connection pool holds a number of open connections and handles thread safety when providing connections to threads. The size of a connection pool is configurable at creation time, but cannot be changed afterward. The maximum size of a connection pool is limited to 64 connections. Keyword Arguments: - **`pool_name`** (``str``) - Name of connection pool - **`pool_size`** (``int``) - Size of pool. The Maximum allowed number is 64. Default to 5 - **`pool_reset_connection`** (``bool``) - Will reset the connection before returning it to the pool. Default to True. - **`pool_validation_interval`** (``int``) - Specifies the validation interval in milliseconds after which the status of a connection requested from the pool is checked. A value of 0 means that the status will always be checked. Default to 500 (Added in version 1.1.6) - **\*\*kwargs** - Optional additional connection arguments, as described in mariadb.connect() method. c ng|_g|_i|_i|_t j|_d|_gd}|r6d|vr2|dtj vrtj d|dzntj d| d|jd<t| dd|jd <t| d d |jd <t| d d|jd<d|jd cxkr tksntj dtz||_|D]}||jvr|j|=t!|jdkr|j5t#d|jd D]} tjdi|j}n#tj$rrt)t#dt!|jD]@} |j|n#tj$rYnwxYw|j|=AwxYw|| dddn #1swxYwY|tj |jd<dS)a: Creates a connection pool class :param str pool_name: Name of connection pool :param int pool_size: Size of pool. If not specified, the default value of 5 will be used. The Maximum allowed number is 64. :param bool pool_reset_connection: Will reset the connection before returning it to the pool. The Default value is True. :param **kwargs kwargs: Optional additional connection arguments, as described in mariadb.connect() method. r) pool_name pool_sizepool_reset_connectionpool_validation_intervalrzPool '%s' already existszNo pool name specifiednamer sizer Treset_connectionr ivalidation_intervalz&Pool size must be in range of 1 and %sN)_connections_free_connections_used _pool_args _conn_args_threadRLock _lock_pool_ConnectionPool__closedmariadb_CONNECTION_POOLSProgrammingErrorgetintbool MAX_POOL_SIZEcopylenrange ConnectionErrorreversedcloseadd_connection)selfargskwargs key_wordskeyi connectionjs N/srv/django_bis/venv311/lib/python3.11/site-packages/mariadb/connectionpool.py__init__zConnectionPool.__init__0sV&"$!#!-// 111   EkV++k"g&???./I17 1D0EFFF@*+CDD D#)**["9"9"%fjja&@&@"A"A 3T:: ; ; *+  5s;; < < -.DOF+<<<<}<<<<*,68E,FGG G!++-- ) )Cdo%%OC( t  ! # # 4 4q$/&"9::44A%,%7%J%J$/%J%J "=   "*%3t7M3N3N*O*O!P!P::A% $ 6q 9 ? ? A A A A#*=%%%!% % !% 6q 9 9 '' 3333!4 4 4 4 4 4 4 4 4 4 4 4 4 4 4 4*>B!$/&"9:::sO3JG)(J)AI**I  I* I I*I I**JJJc|rr||jvr#|j|}|j|=n+||jvr"|j|}|j|=d|_||S)zI Removes the given connection and adds a new connection. N)rindexr_Connection__poolr'r(r)r/xs r1_replace_connectionz"ConnectionPool._replace_connections  T333*00<<*1--t555*00<<*1-+/J (      ""$$$c|jr dtt|dSd|jdtt|dS)Nz:z4 >"2d88}}}}/ / > $~~~s2d88}}}}> >r9Nc|js"tjd|jdz|3t |tjjstjd|:t|jdkr"tjd|jdzt|j |j z}||jdkr&tjd|jdd |d |j 5|tjd i|j}||_ tj|_|j ||cdddS#1swxYwYdS) u Adds a connection object to the connection pool. In case that the pool doesn’t have a free slot or is not configured, a PoolError exception will be raised. z&Couldn't get configuration for pool %sr Nz+Passed parameter is not a connection objectrz#Can't get configuration for pool %srzCan't add connection to pool z: No free slot available (z).r)rr PoolErrorr isinstance connectionsr$rr"rrrr5timeperf_counter_ns_ConnectionPool__last_usedappend)r)r/totals r1r(zConnectionPool.add_connections =#$L$(OF$;%<== =  "z7+>+IJJ #*,?@@ @  #do"6"6!";";#$I$(OF$;%<== =D*T-CCDD DOF+ + +##%)_V%<%<%<%*UU%,-- - _  !$/BB$/BB +/J (%)%9%;%;J "  " ) )* 5 5 5                  s5AEEEcnd}|j5tdt|jD]}|j|}t j|jz dz }||jdkrD |n.#tj $r| |}|sY|YnwxYw|xj dz c_ |j ||j|}|j|=|ccdddS dddn #1swxYwYtjd)z Returns a connection from the connection pool or raises a PoolError exception if a connection is not available. Nri@BrzNo connection available)rr#r"rrDrErFrpingrr%r8_usedrrGr4rA)r)connr.dtidxs r1get_connectionzConnectionPool.get_connections  _  1c$"899::  -a0*,,t/??7J(=>>>% "=%%%#77==#%$H%%%  a &--d333,22488*3/ !                        $ 9:::s7A!D,BD&B,'D+B,,ADDDc|j5 |jdr|n(|jtjzr|n*#tj$r| |YnwxYw|r]||j vrT|j |}|j |=tj |_|j|ddddS#1swxYwYdS)z_ Returns connection to the pool. Internally used by connection object. rN)rrreset server_statusrIN_TRANSrollbackrr%r8rr4rDrErFrrGr6s r1_close_connectionz ConnectionPool._close_connectionsW _ > > 5?#56*$$&&&&-?*'')))= 5 5 5((44444 5 >!777.44Z@@A.q1-1-A-C-CJ**11*=== > > > > > > > > > > > > > > > > > >s6C+A AC+$A<9C+;A<s r1rzConnectionPool.pool_namev&&r9c|jdS)z(Returns the size of the connection pool.rr\r>s r1r zConnectionPool.pool_sizer]r9ctS)z.Returns the maximum size for connection pools.)r r>s r1max_sizezConnectionPool.max_sizes r9c^ t|j|jzS#t$rYdSwxYw)z5Returns the number of connections in connection pool.r)r"rr Exceptionr>s r1connection_countzConnectionPool.connection_countsB t-0FFGG G   11 s  ,,c|jdS)z If set to true, the connection will be reset on both client and server side after .close() method was called rr\r>s r1r z$ConnectionPool.pool_reset_connection#s 122r9c||jd<dS)Nrr\)r)rRs r1r z$ConnectionPool.pool_reset_connection+s.3*+++r9)N)__name__ __module__ __qualname____doc__r2r8r?r(rPrVrXr'propertyrr r`rcr setterrr9r1rrsL$PBPBPBd%%%">>>####J;;;8>>>, ! ! ! C C C''X' ''X' X X33X3!44"!444r9r)rrrDmariadb.constantsrr objectrrr9r1rnsw( $$$$$$ P4P4P4P4P4VP4P4P4P4P4r9