0
async def insert_order(item: CreateOrderDto, session: AsyncSession):
    query = insert(order).values(**item.get_order())
    result = await session.execute(query)
    return result.all()

Я пишу простое приложение на python, использую framework FastAPI. Моя цель: записать переданный объект в бд и вернуть этот объект обратно; но я не могу получить его id, т.к. получаю пустой список.

4
  • А insert точно должен возвращать id?
    – CrazyElf
    Commented 4 мая 2023 в 19:23
  • query это запрос, а session.execute() должен вернуть вставленную запись
    – nicholas
    Commented 4 мая 2023 в 19:29
  • 1
    @CrazyElf, спасибо тебе:) твой вопрос меня побудил кое-что проверить и в итоге проблема была в запросе :) Вот такой запрос должен быть query = insert(order).values(**item.get_order()).returning(order.c.id)
    – nicholas
    Commented 4 мая 2023 в 20:02
  • Добавьте прямо ответ с этим кодом, может кому ещё поможет )
    – CrazyElf
    Commented 5 мая 2023 в 4:46

1 ответ 1

2

Надо было к query добавить функцию returning(). В итоге решение выглядит так:

async def insert_order(item: CreateOrderDto, session: AsyncSession):
    query=insert(order).values(**item.get_order()).returning(literal_column('*'))
    result = await session.execute(query)
    return result.one()

Ваш ответ

Нажимая «Отправить ответ», вы соглашаетесь с условиями пользования и подтверждаете, что прочитали политику конфиденциальности.

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