Как осуществлять поиск по таблице?

Question

[Владимир Бобровский]

Перешел с SQLite3 на PosgreSQL. Ранее, работая с SQLite3 я осуществлял поиск по таблице следующим образом:

cursor.execute(f'SELECT post_id FROM users WHERE user_id = {call.from_user.id}')
post_id = cursor.fetchone()[0]
cursor.execute(f'SELECT * FROM callback WHERE department={post_id} AND status="no"')
result = cursor.fetchone()

То есть мне нужно осуществить поиск по таблице и получить данные с условием, что у этих данных в столбце department значение = {post_id} (полученное запросом ранее) и в столбце status значение = "no".
Но база данных PostgreSQL ругается на такой запрос, выдавая ошибку в cmd:

cursor.execute(f'SELECT * FROM callback WHERE department={post_id} AND status="no"')
psycopg2.errors.UndefinedColumn: column "no" does not exist
LINE 1: SELECT * FROM callback WHERE department=2 AND status="no"

Подскажите пожалуйста, как теперь мне осуществлять поиск по таблице, исходя из моих требований к условиям?

Comments

[Akina]

Ну так кавычки надо ставить правильные...

[Владимир Бобровский]

Akina,

cursor.execute(f'''SELECT * FROM callback WHERE department={post_id} AND status='no' ''')

Правильно понимаю?)

[Владимир Бобровский]

Akina,

cursor.execute(f"SELECT * FROM callback WHERE department={post_id} AND status='no'")

Как было, с точностью наоборот.. Спасибо за ответ! Можете ответить на вопрос - отмечу решением.

[rPman]

если не секрет, в каком месте у тебя sqlite3 перестал удовлетворять потребностям что пришлось перейти на postgres?

[Владимир Бобровский]

rPman, я задавал вопрос на Хабре на тему Какую БД выбрать после SQLite3?. В нём я подробно описал причину по которой мне стало необходимо сменить БД.

[igor6130]

Не используйте форматирование строк при создании запроса. Это классическая ошибка. Пользуйтесь шаблонами.

[rPman]

igor6130, для констант это оверкил, не нужно делать лишние операции там где они не нужны

[igor6130]

rPman, автору нужно привыкать оформлять запросы в коде правильно. Сейчас он подставляет заранее известные данные, а потом начнет динамические.

[rPman]

точно, не обратил на это внимание
само собой это плохая практика

[Владимир Бобровский]

igor6130, не подскажите, если не сложно, как в моем случае будет правильно оформить запрос?

[igor6130]

cursor.execute("SELECT * FROM callback WHERE department=%s AND status='no'", (post_id, ))

И дальше по аналогии.

[Владимир Бобровский]

igor6130, спасибо большое! Буду придерживаться данных стандартов.

[Elvis]

Владимир Бобровский, и изучите JOIN. Ваши два запроса превратятся в один.

[Владимир Бобровский]

Elvis,

cursor.execute("SELECT identification, client_number, client_name, comment FROM users INNER JOIN callback ON post_id = department WHERE status='no'")

Спасибо! Задал всего один вопрос, а в ответ получил столько новой и полезной информации для себя :)
Но в моём коде далее идут условия:

if post_id == 2:
    if result is None:
            await call.message.edit_text('<b>Все заявки обработаны.</b>\nКак только появится новая заявка - '
                                         'Вы получите соответствующие уведомление.')
    else:
            await call.message.edit_text('Заявки, по которым Вы ещё не звонили: ')
            cursor.execute(f"SELECT * FROM callback WHERE department=%s AND status='no'", (post_id, ))
            application = cursor.fetchall()
            for ret in application:
                mes = await bot.send_message(call.message.chat.id, f'<b>Заявка №{ret[0]}</b>\n'
                                                                   f'<b>Н/Д №</b> <i>{ret[2]}</i>;\n<b>Телефон:</b> <i>{ret[3]}</i>;\n'
                                                                   f'<b>Имя:</b> <i>{ret[4]}</i>;\n<b>Комментарий:</b> <i>{ret[5]}</i>.',
                                                                   reply_markup=InlineKeyboardMarkup().add(
                                     InlineKeyboardButton(f'Заявка №{ret[0]} обработана', callback_data=f'processed {ret[0]}')
                          ))
                message_obj = mes.message_id
                cursor.execute('INSERT INTO message (application_number, message_obj) VALUES (%s, %s);',
                               (ret[0], message_obj, ))
                await asyncio.sleep(0.5)
elif post_id == 3:  # Далее по аналогии для post_id = department = 3
    if result is None:
        pass
    else:
        pass
else:
    pass

Answer 1

[Владимир Бобровский]

Спасибо за ответ, Akina, igor6130, Elvis.

cursor.execute("SELECT identification, client_number, client_name, comment FROM users INNER JOIN callback ON post_id = department WHERE status='no'")