如何解决sqlalchemy (vesrion 1.4 !) - 获取最后插入的 id
如何获取最后插入的 ID?
请注意 sqlalchemy
版本,所以 this 问题不是我的情况。
我试过了:
async def foo(db_session: AsyncSession,login):
r1 = await db_session.execute(statement=models_users.insert().values(login=login))
r2 = await db_session.flush()
# r3 = await db_session.fetchval(...) # Error,no such method for async
r4 = await db_session.commit()
print(r2,r4,r1.fechone()) # None,None,None
print(r1.lastrowid) # 'AsyncAdapt_asyncpg_cursor' object has no attribute 'lastrowid'
sqlAlchemy 1.4.4
asyncpg 0.22.0
解决方法
SQLAlchemy 对 lastrowid 的支持取决于底层 DB-API 实现,因此依赖此属性是不安全的。然而,SQLAlchemy 在 CursorResult
对象上提供了一个 inserted_primary_key 属性,该属性应该是可靠的。
返回值是插入行的主键值的元组。
问题中这个版本的代码:
async def foo(db_session: AsyncSession,login):
r1 = await db_session.execute(statement=models_users.insert().values(login=login))
print(r1)
print('Last pk',r1.inserted_primary_key)
await db_session.flush()
await db_session.commit()
将产生如下输出:
<sqlalchemy.engine.cursor.CursorResult object at 0x7f0215966bb0>
Last pk (17,)
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。