0

Простая функция для работы с базой данных

async def pg(sql):
    conn = await asyncpg.connect(user=user, password=password, host=host, port=port, database=database)
    await conn.execute(sql)
    if 'SELECT' in sql:
        await conn.fetch(sql)
    await conn.close()

Вызываю функцию

for balance, id in await pg(f'SELECT balance, id FROM client WHERE chat_id = {chat_id};'):pass

Приходит ошибка

for balance, id in await pg(f'SELECT balance, id FROM client WHERE chat_id = {chat_id};'):
TypeError: 'NoneType' object is not iterable

Причина понятна, запрос не проходит. Но он должен пройти потому что при команде /start мой chat_id автоматически добавляется в базу данных. Я думаю что причина в типах данных, chat_id использует INTEGER, но на какой тип данных можно изменить что бы все было нормально

1 ответ 1

0

Решение было простым:

async def pg(sql):
    conn = await asyncpg.connect(user=user, password=password, host=host, port=port, database=database)
    await conn.execute(sql)
    if 'SELECT' in sql:
        await conn.fetch(sql)# здесь нужно использовать return
    await conn.close()

Ваш ответ

By clicking “Отправить ответ”, you agree to our terms of service and acknowledge that you have read and understand our privacy policy and code of conduct.

Всё ещё ищете ответ? Посмотрите другие вопросы с метками или задайте свой вопрос.