xIf-JddlZddlZddlZddlmZdZGddeZdS)N)STATUS@ceZdZdZdZdZdZddZdZdZ d Z d Z e d Z e d Ze d Ze dZe dZejdZdS)ConnectionPoolai 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 afterwards. The maximum size of a connection pool is limited to 64 connections. Keyword Arguments: * pool_name (str) -- Name of connection pool * pool_size (int)=5 -- Size of pool. If not specified default value of 5 will be used. Maximum allowed number is 64. * pool_reset_connection (bool)=True -- Will reset the connection before returning it to the pool. Default value is True. * pool_validation_interval (int)=500 -- Specifies the validation interval in milliseconds after which the status of a connection requested from the pool is checked. The default values is 500 milliseconds, a value of 0 means that the status will always be checked. (Added in version 1.1.6) c Tg|_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}nw#tj$ret#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 default value of 5 will be used. Maximum allowed number is 64. :param bool pool_reset_connection: Will reset the connection before returning it to the pool. Default value is True. 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 ConnectionErrorcloseadd_connection)selfargskwargs key_wordskeyi connectionjs J/var/www/piapp/venv/lib/python3.11/site-packages/mariadb/connectionpool.py__init__zConnectionPool.__init__;sN"$!#!-// 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 "=   "'q#d.D*E*E!F!F::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:::sN3JG)(J)3IH=<I=I II IJJ Jc|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 r0_replace_connectionz"ConnectionPool._replace_connections  T333*00<<*1--t555*00<<*1-+/J (      ""$$$c|jr dtt|dSd|jdtt|dS)Nz:z4 >"2d88}}}}/ / > $~~~s2d88}}}}> >r8Nc|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"rrrr4timeperf_counter_ns_ConnectionPool__last_usedappend)r(r.totals r0r'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"rrCrDrErpingrr%r7_usedrrFr3r@)r(connr-dtidxs r0get_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%r7rr3rCrDrErrFr5s r0_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<r'rOrUrWr&propertyrr r_rbr setterrr8r0rrsL:LBLBLB\%%%">>>####J;;;8>>>, ! ! ! C C C''X' ''X' X X33X3!44"!444r8r)rrrCmariadb.constantsrr objectrrr8r0rmsw( $$$$$$ W4W4W4W4W4VW4W4W4W4W4r8