@@ -308,7 +308,7 @@ class Pool:
308
308
309
309
__slots__ = (
310
310
'_queue' , '_loop' , '_minsize' , '_maxsize' ,
311
- '_init' , '_connect_args' , '_connect_kwargs' ,
311
+ '_init' , '_connect_args' , '_connect_kwargs' , '_query_logging' ,
312
312
'_working_addr' , '_working_config' , '_working_params' ,
313
313
'_holders' , '_initialized' , '_initializing' , '_closing' ,
314
314
'_closed' , '_connection_class' , '_record_class' , '_generation' ,
@@ -325,6 +325,7 @@ def __init__(self, *connect_args,
325
325
loop ,
326
326
connection_class ,
327
327
record_class ,
328
+ query_logging = False ,
328
329
** connect_kwargs ):
329
330
330
331
if len (connect_args ) > 1 :
@@ -393,6 +394,7 @@ def __init__(self, *connect_args,
393
394
self ._max_queries = max_queries
394
395
self ._max_inactive_connection_lifetime = \
395
396
max_inactive_connection_lifetime
397
+ self ._query_logging = query_logging
396
398
397
399
async def _async__init__ (self ):
398
400
if self ._initialized :
@@ -479,6 +481,7 @@ async def _get_new_connection(self):
479
481
loop = self ._loop ,
480
482
connection_class = self ._connection_class ,
481
483
record_class = self ._record_class ,
484
+ query_logging = self ._query_logging ,
482
485
** self ._connect_kwargs )
483
486
484
487
self ._working_addr = con ._addr
@@ -496,6 +499,7 @@ async def _get_new_connection(self):
496
499
params = self ._working_params ,
497
500
connection_class = self ._connection_class ,
498
501
record_class = self ._record_class ,
502
+ query_logging = self ._query_logging ,
499
503
)
500
504
501
505
if self ._init is not None :
0 commit comments