PostgreSQL（SQLAlchemy）中级联删除失效问题排查

问题描述 #

我尝试在PostgreSQL中通过SQLAlchemy实现Product表的级联删除，但操作无效。相关代码如下：

seller_product = Table(
        "seller_product",
        Base.metadata,
        Column("start_id", Integer, nullable=False),
        Column("id_product", ForeignKey("product.ozon_id", ondelete="CASCADE"), nullable=False),
        Column("id_seller", ForeignKey("seller.ozon_id", ondelete="CASCADE"), nullable=False),
        Column("date_parse", DateTime(), nullable=False, default=datetime.utcnow)
    )


class Product(Base):
    __tablename__ = "product"
    
    id: Mapped["int"] = mapped_column(primary_key=True, autoincrement=True)
    ozon_id: Mapped["int"] = mapped_column(primary_key=True, unique=True)
    title: Mapped["str"] = mapped_column()
    link: Mapped["str"] = mapped_column()
    seller_id: Mapped["int"] = mapped_column(ForeignKey("seller.ozon_id"))
    seller: Mapped["Seller"] = relationship(back_populates="products")

尝试了两种删除方式：

DELETE FROM seller_product CASCADE WHERE id_product = 4720943812

以及：

DELETE FROM seller_product CASCADE WHERE start_id = 1

但Product表中的对应数据仍未被删除。

原因分析 #

• 级联方向完全搞反：你在seller_product表的外键上设置的ondelete="CASCADE"，作用是当被引用的Product/Seller表数据被删除时，自动删除seller_product中关联的记录，而非删除seller_product记录去触发Product表的删除。
• DELETE语句的CASCADE用法错误：PostgreSQL中DELETE ... CASCADE是删除当前表记录时，级联删除依赖它的其他表记录，但Product表并不依赖seller_product，所以这条指令只会删除seller_product的目标行，不会影响Product表。

解决方案 #

如果要实现删除seller_product记录时同时删除关联的Product数据，可通过以下方式处理：

1. 调整ORM关系的级联规则
   修改Product类的关联定义，添加级联规则，确保删除seller_product时触发Product的删除（需同时配置双向关联）：

class Product(Base):
    __tablename__ = "product"
    
    id: Mapped["int"] = mapped_column(primary_key=True, autoincrement=True)
    ozon_id: Mapped["int"] = mapped_column(primary_key=True, unique=True)
    title: Mapped["str"] = mapped_column()
    link: Mapped["str"] = mapped_column()
    seller_id: Mapped["int"] = mapped_column(ForeignKey("seller.ozon_id"))
    seller: Mapped["Seller"] = relationship(back_populates="products")
    # 添加与中间表的关联并配置级联
    seller_products: Mapped[List["seller_product"]] = relationship(back_populates="product", cascade="all, delete")

之后通过SQLAlchemy的ORM会话执行删除操作，而非直接操作中间表。

2. 使用数据库触发器（原生SQL场景）
   如果坚持用原生SQL实现，可在PostgreSQL中创建触发器：

CREATE OR REPLACE FUNCTION delete_product_on_seller_product_delete()
RETURNS TRIGGER AS $$
BEGIN
    DELETE FROM product WHERE ozon_id = OLD.id_product;
    RETURN OLD;
END;
$$ LANGUAGE plpgsql;

CREATE TRIGGER trigger_delete_product
AFTER DELETE ON seller_product
FOR EACH ROW
EXECUTE FUNCTION delete_product_on_seller_product_delete();

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