Skip to content

Commit d40ac24

Browse files
committed
return only beginning of query to _get_statement log messages
1 parent 787e865 commit d40ac24

File tree

1 file changed

+8
-5
lines changed

1 file changed

+8
-5
lines changed

asyncpg/connection.py

+8-5
Original file line numberDiff line numberDiff line change
@@ -365,7 +365,8 @@ async def _get_statement(
365365
)
366366
if statement is not None:
367367
if self._query_logger:
368-
self._query_logger.debug('Cache hit: %s', statement.name)
368+
self._query_logger.debug('Cache hit: %s for %.40r',
369+
statement.name, query)
369370
return statement
370371

371372
# Only use the cache when:
@@ -381,7 +382,7 @@ async def _get_statement(
381382
self._query_logger.log(
382383
5,
383384
# cut query length by max_cacheable_statement_size
384-
'Uncacheable query: %.{}s...'.format(
385+
'Uncacheable query: %.{}r...'.format(
385386
self._config.max_cacheable_statement_size
386387
),
387388
query
@@ -446,9 +447,11 @@ async def _get_statement(
446447
(query, record_class, ignore_custom_codec), statement)
447448

448449
if self._query_logger:
449-
self._query_logger.debug('New cached query: %s' if use_cache
450-
else 'Prepared query: %s',
451-
statement.name)
450+
self._query_logger.debug(
451+
'New cached query: %s for %.40r' if use_cache
452+
else 'Prepared query: %s for %.40r',
453+
statement.name, query
454+
)
452455

453456
# If we've just created a new statement object, check if there
454457
# are any statements for GC.

0 commit comments

Comments
 (0)