Skip to content

Commit 3605c57

Browse files
committed
return only beginning of query to _get_statement log messages
1 parent 8c28612 commit 3605c57

File tree

1 file changed

+8
-5
lines changed

1 file changed

+8
-5
lines changed

asyncpg/connection.py

Lines changed: 8 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -368,7 +368,8 @@ async def _get_statement(
368368
)
369369
if statement is not None:
370370
if self._query_logger:
371-
self._query_logger.debug('Cache hit: %s', statement.name)
371+
self._query_logger.debug('Cache hit: %s for %.40r',
372+
statement.name, query)
372373
return statement
373374

374375
# Only use the cache when:
@@ -384,7 +385,7 @@ async def _get_statement(
384385
self._query_logger.log(
385386
5,
386387
# cut query length by max_cacheable_statement_size
387-
'Uncacheable query: %.{}s...'.format(
388+
'Uncacheable query: %.{}r...'.format(
388389
self._config.max_cacheable_statement_size
389390
),
390391
query
@@ -449,9 +450,11 @@ async def _get_statement(
449450
(query, record_class, ignore_custom_codec), statement)
450451

451452
if self._query_logger:
452-
self._query_logger.debug('New cached query: %s' if use_cache
453-
else 'Prepared query: %s',
454-
statement.name)
453+
self._query_logger.debug(
454+
'New cached query: %s for %.40r' if use_cache
455+
else 'Prepared query: %s for %.40r',
456+
statement.name, query
457+
)
455458

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

0 commit comments

Comments
 (0)