jN 8SSKrSSKrSSKrSSKr"SS5rg)Nc8\rSrSrSrSrSrSrSrSr Sr g ) ConnectionPoolc,XlX lX0lX@lXPlX`l[ R"US9Ul[R"5Ul [U5H.nUR5nURRU5 M0 g)a1 Initialize the connection pool with the given parameters. :param pool_name: Name of the pool (for identification purposes) :param pool_size: Maximum number of connections to maintain :param host: Database host :param user: Database user :param password: Database password :param database: Database name )maxsizeN) pool_name pool_sizehostuserpassworddatabasequeueQueuepool threadingLocklockrange_create_new_connectionput) selfrr r r r r _conns M/var/www/releases/bee-ed7eb6e/beeDataHandler/ConnectionPool/ConnectionPool.py__init__ConnectionPool.__init__sq#"    KK 2 NN$ y!A..0D IIMM$ "c>[RRURURUR UR S9nU$![RRa2n[[RR5SU35 eSnAff=f)z"Creates a new database connection.)r r r r z | Error creating connection: N) mysql connectorconnectr r r r Errorprintdatetimenow)rres rr%ConnectionPool._create_new_connections ??**YYYY +D K$$  X&&**,--KA3O P  sA A B*-BBcXUR URRSS9nUR5(dUR 5nUsSSS5 $![ R a, [[RR5S35 ef=f!,(df  g=f)z Retrieve a connection from the pool. If no connections are available, wait until one is. :return: A connection from the pool T)blockNz( | No connections available in the pool!) rrget is_connectedrrEmptyr#r$r%rrs rget_connectionConnectionPool.get_connection-s YY yy}}4}0((**668DY;; **..011YZ[ YsB?AABB B)cUR URRU5 SSS5 g!,(df  g=f)zZ Return a connection back to the pool. :param conn: The connection to return to the pool N)rrrr-s rrelease_connection!ConnectionPool.release_connectionAs% YY IIMM$ YYs 2 Ac$UR URR5(dKURR5nUR 5 URR5(dMKSSS5 g!,(df  g=f)z"Close all connections in the pool.N)rremptyr*closer-s rclose_all_connections$ConnectionPool.close_all_connectionsKsO YYiioo''yy}} iioo''YYs A)B Bc$UR5 g)z=Ensure all connections are closed when the pool is destroyed.N)r6)rs r__del__ConnectionPool.__del__Rs ""$r)r r rr rrr r N) __name__ __module__ __qualname____firstlineno__rrr.r1r6r9__static_attributes__rrrrs  6 ( %rr)rmysql.connectorrrr$rr@rrrBs22Q%Q%r