4

我正在尝试使用 SQLAlchemy 实现以下 MySQL 查询。有问题的表是嵌套集层次结构。

UPDATE category
JOIN
    (
    SELECT
        node.cat_id,
        (COUNT(parent.cat_id) - 1) AS depth
    FROM category AS node, category AS parent
    WHERE node.lft BETWEEN parent.lft AND parent.rgt
    GROUP BY node.cat_id
    ) AS depths
ON category.cat_id = depths.cat_id
SET category.depth = depths.depth

这工作得很好。

这是我开始拔头发的地方：

from sqlalchemy.orm import aliased
from sqlalchemy import func

from myapp.db import db

node = aliased(Category)
parent = aliased(Category)
stmt = db.session.query(node.cat_id,
                        func.count(parent.cat_id).label('depth_'))\
    .filter(node.lft.between(parent.lft, parent.rgt))\
    .group_by(node.cat_id).subquery()

db.session.query(Category,
                 stmt.c.cat_id,
                 stmt.c.depth_)\
    .outerjoin(stmt, 
               Category.cat_id == stmt.c.cat_id)\
    .update({Category.depth: stmt.c.depth_},
             synchronize_session='fetch')

...我明白了InvalidRequestError: This operation requires only one Table or entity be specified as the target。在我看来，它Category.depth充分指定了目标，但当然 SQLAlchemy 胜过我的想法。

难住了。有什么建议么？谢谢。

4

1 回答 1

3

我知道这个问题已经有五年了，但我今天偶然发现了它。我的回答可能对其他人有用。我知道我的解决方案不是完美的，但我没有更好的方法来做到这一点。

我只需要将最后一行更改为：

db.session.query(Category)\
    .outerjoin(stmt, 
               Category.cat_id == stmt.c.cat_id)\
    .update({Category.depth: stmt.c.depth_},
             synchronize_session='fetch')

然后，您必须提交更改：

db.session.commit()

这给出了以下警告：

SAWarning：将非映射列表达式“...”评估到 ORM 实例上；这是一个已弃用的用例。请使用 ORM 评估的 UPDATE / DELETE 表达式中的实际映射列。
“更新/删除表达式。” % 子句

为了摆脱它，我使用了这篇文章中的解决方案：关闭 sqlalchemy 中的警告

注意：由于某种原因，别名在 SQLAlchemy 更新语句中不起作用。

于 2019-05-05T21:20:15.953 回答