如何解决sqlalchemy 获取上次插入的 ID|创建记录asyncpg 适配器
我知道这个问题被问过很多次了,但是现在sqlalchemy有了新的版本和语法,所以这些答案主要是过时的
#sqlAlchemy 1.4.4
#asyncpg 0.22.0
#Postgresql 12.6
from sqlalchemy.ext.asyncio import AsyncSession,create_async_engine
from sqlalchemy.orm import sessionmaker
from fastapi import Depends
engine = create_async_engine(url=config.sqlALCHEMY_PG_ASYNC_URL,echo=False,future=True)
async_session = sessionmaker(bind=engine,autoflush=True,expire_on_commit=False,class_=AsyncSession)
async def get_db():
session = async_session()
try:
yield session
await session.commit()
except sqlAlchemyError as ex:
await session.rollback()
raise ex
finally:
await session.close()
async def foo(postgres_session: AsyncSession = Depends(database.get_db)):
r = await postgres_session.execute(models.users.insert().values(full_name='s',phone_number='s',hashed_password='s'))
await postgres_session.flush()
await postgres_session.commit()
return r
我试过: print(r.fetchone()) # 无 r.lastrowid # AttributeError: 'AsyncAdapt_asyncpg_cursor' 对象没有属性 'lastrowid'
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。