SQLAlchemy异步模式下关联表未添加记录问题求助

问题根源 #

你的代码核心问题是跨会话操作对象：

• orm_get_drug和orm_get_disease函数各自创建独立的async_session，返回的drug和disease对象属于不同会话，且会话关闭后这些对象会变为游离状态（detached）
• 在orm_add_drug_disease的当前会话中修改游离对象的关联关系，会话无法追踪到这些变更，commit时自然不会同步到数据库

修复方案 #

以下两种方式均可解决问题：

方式一：在同一个会话内完成查询与关联操作

直接在orm_add_drug_disease的当前会话中查询对象，避免跨会话传递：

async def orm_add_drug_disease(
        async_session: async_sessionmaker[AsyncSession], name_drug: str, name_disease: str
) -> None:
    async with async_session() as session:
        # 在当前会话内查询目标对象
        drug = await session.scalar(select(Drug).where(Drug.name == name_drug))
        disease = await session.scalar(select(Disease).where(Disease.name == name_disease))
        
        if drug and disease:
            drug.diseases.append(disease)
            await session.commit()
            # 可选：刷新对象以确认关联已同步
            await session.refresh(drug, attribute_names=["diseases"])

方式二：改造查询函数支持传入现有会话

如果需要复用查询逻辑，可修改查询函数，允许传入已打开的会话，避免重复创建新会话：

# 改造查询函数，接收现有会话作为参数
async def orm_get_drug(
    session: AsyncSession, name: str
) -> Drug:
    query = select(Drug).where(Drug.name == name)
    drug = await session.scalar(query)
    if drug:
        await session.refresh(drug, attribute_names=["diseases"])
    return drug

async def orm_get_disease(
        session: AsyncSession, name: str
) -> Disease:
    query = select(Disease).where(Disease.name == name)
    disease = await session.scalar(query)
    if disease:
        await session.refresh(disease, attribute_names=["drugs"])
    return disease

# 修改关联添加函数，使用当前会话查询对象
async def orm_add_drug_disease(
        async_session: async_sessionmaker[AsyncSession], name_drug: str, name_disease: str
) -> None:
    async with async_session() as session:
        drug = await orm_get_drug(session, name_drug)
        disease = await orm_get_disease(session, name_disease)
        
        if drug and disease:
            drug.diseases.append(disease)
            await session.commit()

关键注意事项 #

• SQLAlchemy仅会追踪当前会话内对象的变更，跨会话传递的游离对象修改不会被自动同步
• 操作前建议检查drug和disease是否为None，避免空对象的append操作引发异常

内容的提问来源于stack exchange，提问作者armpomor