Skip to content

Commit 9129cab

Browse files
authored
try fix
1 parent 9fc56a7 commit 9129cab

File tree

1 file changed

+4
-2
lines changed

1 file changed

+4
-2
lines changed

frameworks/Python/blacksheep/app-socketify.py

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -95,7 +95,8 @@ async def multiple_db_queries_test(request):
9595
async def fortunes_test(request):
9696
async with db_pool.acquire() as connection:
9797
fortunes_fetch = await connection.fetch("SELECT * FROM Fortune")
98-
fortunes = results.result()
98+
# fortunes = fortunes_fetch.result()
99+
fortunes = [list(item.values()) for item in fortunes_fetch.result()]
99100
fortunes.append(ADDITIONAL_ROW)
100101
fortunes.sort(key=lambda row: row[1])
101102
data = fortune_template.render(fortunes=fortunes)
@@ -110,8 +111,9 @@ async def db_updates_test(request):
110111
), key=lambda x: x[1])
111112
worlds = [{"id": row_id, "randomNumber": number} for row_id, number in updates]
112113
async with db_pool.acquire() as connection:
114+
statement = await connection.prepare(READ_ROW_SQL)
113115
for row_id, _ in updates:
114-
await connection.fetch_val(READ_ROW_SQL, [row_id])
116+
await statement.fetch_val([row_id])
115117
# await db_conn.executemany(WRITE_ROW_SQL, updates)
116118
await connection.execute_many(WRITE_ROW_SQL, updates)
117119
raise Exception("connect error")

0 commit comments

Comments
 (0)