急切地加载一个循环关联
我以下是多对多关联的一个简单例子。我的目标是要加载的X
单个记录,也急切地加载它们在记录的ys
列表以及这是在任何情况下这些公司xs
名单的X
实例的Y
的实例。急切地加载一个循环关联
class X(db.Model): __tablename__ = 'x'
xid = db.Column(db.Integer, primary_key=True)
ys = relationship('Z', back_populates='x', lazy='joined')
class Y(db.Model):
__tablename__ = 'y'
yid = db.Column(db.Integer, primary_key=True)
xs = relationship('Z', back_populates='y', lazy='joined')
class Z(db.Model):
__tablename__ = 'z'
xid = db.Column(db.Integer, db.ForeignKey('x.xid'), primary_key=True)
yid = db.Column(db.Integer, db.ForeignKey('y.yid'), primary_key=True)
x = relationship('X', back_populates='ys', lazy='joined')
y = relationship('Y', back_populates='xs', lazy='joined')
我的目标是产生如下结果:
expected = [{ 'xid': 1,
'ys': [
{'yid': 101, 'xs': [{'xid': 1}, {'xid': 2}, {'xid': 3}]},
{'yid': 102, 'xs': [{'xid': 1}, {'xid': 2}]},
{'yid': 104, 'xs': [{'xid': 1}, {'xid': 4}]},
],
}]
的SQL语句来实现,这是相当简单:
SELECT x.xid, y.yid, x2.xid FROM x JOIN z ON z.xid = x.xid JOIN y ON z.yid = y.yid ; Fetch Ys
JOIN z as z2 ON z2.yid = y.yid JOIN x as x2 ON z2.xid = x2.xid ; Fetch Xs (depth 2)
WHERE x.xid = 1
我的问题是确定如何创建SQLAlchemy的查询(a)允许我执行这个原始查询并将其正确映射到正确的模型实例,或者(b)按照查询(使用join和contains_eager调用的某种组合s),以便它知道如何使用生成的连接,以便它不会分解为n + 1个查询。
正确的查询是由以下生成的,但我无法设法从这个查询中加载深度2个X实例(数据是由第二个选择器懒洋洋地加载的)。
a = aliased(Z) b = aliased(X)
q = X.query.filter(X.xid==1).join(X.ys).join(Z.y).join(a, Y.xs).join(b, Z.x)
回答:
热切加载机制的工作方式是,你需要指定要和加载,只要你想如何加载它的关系路径。路径基本上是按顺序跟随的关系,以便找到你想要的关系。在您的具体的例子,做正确的事情是这样的:
q = session.query(X).filter(X.xid == 1) \ .join(X.ys) \
.join(Z.y) \
.join(a, Y.xs) \
.join(b, Z.x) \
.options(
contains_eager(X.ys),
contains_eager(X.ys, Z.y),
contains_eager(X.ys, Z.y, Y.xs, alias=a),
contains_eager(X.ys, Z.y, Y.xs, Z.x, alias=b),
)
每个contains_eager
指定单个关系的负荷,与指定路径(X.ys, Z.y, Y.xs, Z.x
)式的关系,和contains_eager
以及alias
指定如何加载关系。这是相当冗长,但幸运的SQLAlchemy提供了一条捷径,让你把它们连在一起,就像这样:
.options(contains_eager(X.ys).contains_eager(Z.y).contains_eager(Y.xs, alias=a).contains_eager(Z.x, alias=b))
如果您使用.join
对于然后做contains_eager
明确的目标,你可能也只是使用joinedload
而不是:
q = session.query(X).filter(X.xid==1) \ .options(joinedload(X.ys).joinedload(Z.y).joinedload(Y.xs).joinedload(Z.x))
你的具体情况,加入这样可以不,如果你的分支系数高是有效的,也就是说,如果你的X.ys
和Y.xs
包含最多n
条目,那么你的数据库中有你发副本X中的每一行都是。出于这个原因,subqueryload
通常是一对多关系的正确选择(情况并非总是如此;折衷在查询的数量即延迟与每个查询中的数据量(即吞吐量)之间,所以轮廓找出):
q = session.query(X).filter(X.xid==1) \ .options(subqueryload(X.ys).joinedload(Z.y).subqueryload(Y.xs).joinedload(Z.x))
最后,如果你想要的是一个多一对多的关系,为什么不直接配置在首位很多一对多的关系?
以上是 急切地加载一个循环关联 的全部内容, 来源链接: utcz.com/qa/259039.html