Skip to content

Commit 8df4a0c

Browse files
author
David Erb
committed
adds format_debug
1 parent 65568d8 commit 8df4a0c

File tree

1 file changed

+23
-4
lines changed

1 file changed

+23
-4
lines changed

src/dls_normsql/aiosqlite.py

Lines changed: 23 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -445,6 +445,27 @@ async def execute(self, sql, subs=None, why=None):
445445
else:
446446
raise RuntimeError(f"failed to execute {why}: {sql}")
447447

448+
# ----------------------------------------------------------------------------------------
449+
def __format_debug(self, why, rows, sql, subs):
450+
parts = ""
451+
452+
if rows is not None:
453+
parts += f"{len(rows)} records from"
454+
455+
if why is not None:
456+
parts += " " + why
457+
458+
if len(parts) > 0:
459+
parts += ": "
460+
461+
parts += sql
462+
463+
if subs is not None and len(subs) > 0:
464+
parts += "\n "
465+
parts += str(subs)
466+
467+
return parts
468+
448469
# ----------------------------------------------------------------------------------------
449470
async def query(self, sql, subs=None, why=None):
450471

@@ -460,10 +481,8 @@ async def query(self, sql, subs=None, why=None):
460481
for col in cursor.description:
461482
cols.append(col[0])
462483

463-
if why is None:
464-
logger.debug("%d records from: %s" % (len(rows), sql))
465-
else:
466-
logger.debug("%d records from %s: %s" % (len(rows), why, sql))
484+
logger.debug(self.__format_debug(why, rows, sql, subs))
485+
467486
records = []
468487
for row in rows:
469488
record = OrderedDict()

0 commit comments

Comments
 (0)