fix: update select query in get_withdraw_links (#52)
This commit is contained in:
parent
432ed5299a
commit
f05169f994
1 changed files with 14 additions and 5 deletions
19
crud.py
19
crud.py
|
|
@ -69,12 +69,21 @@ async def get_withdraw_links(
|
||||||
wallet_ids: list[str], limit: int, offset: int
|
wallet_ids: list[str], limit: int, offset: int
|
||||||
) -> tuple[list[WithdrawLink], int]:
|
) -> tuple[list[WithdrawLink], int]:
|
||||||
q = ",".join([f"'{w}'" for w in wallet_ids])
|
q = ",".join([f"'{w}'" for w in wallet_ids])
|
||||||
links = await db.fetchall(
|
|
||||||
f"""
|
query_str = f"""
|
||||||
SELECT * FROM withdraw.withdraw_link WHERE wallet IN ({q})
|
SELECT * FROM withdraw.withdraw_link WHERE wallet IN ({q})
|
||||||
ORDER BY open_time DESC LIMIT :limit OFFSET :offset
|
ORDER BY open_time DESC
|
||||||
""",
|
"""
|
||||||
{"limit": limit, "offset": offset},
|
|
||||||
|
if limit > 0:
|
||||||
|
query_str += """ LIMIT :limit OFFSET :offset"""
|
||||||
|
query_params = {"limit": limit, "offset": offset}
|
||||||
|
else:
|
||||||
|
query_params = {}
|
||||||
|
|
||||||
|
links = await db.fetchall(
|
||||||
|
query_str,
|
||||||
|
query_params,
|
||||||
WithdrawLink,
|
WithdrawLink,
|
||||||
)
|
)
|
||||||
|
|
||||||
|
|
|
||||||
Loading…
Add table
Add a link
Reference in a new issue