4

我有一个多对多关联的数据库关系，但是关联表本身包含很多需要访问的属性，所以我做了三个类：

class User(Base):
    id = Column(Integer, primary_key=True)
    attempts = relationship("UserAttempt", backref="user", lazy="subquery")

class Challenge(Base):
    id = Column(Integer, primary_key=True)
    attempts = relationship("UserAttempt", backref="challenge", lazy='subquery')

class UserAttempt(Base):
    challenge_id = Column(Integer, ForeignKey('challenge.id'), primary_key=True)
    user_id = Column(Integer, ForeignKey('user.id'), primary_key=True)

当然，这是一个简化的案例，我忽略了需要访问的其他属性。这里的目的是，每个人都User可以尝试任意数量的Challenges，因此该UserAttempt表描述了一个特定用户完成一项挑战。

现在的问题：当我查询所有用户然后查看每次尝试时，我完全没问题。但是当我看到这个尝试的挑战时，它会在无数子查询中爆炸。当然，这对性能不利。

我真正想从 SQLAlchemy 中提取所有（或所有相关）挑战，然后将其与相关尝试相关联。如果所有挑战都被取消或仅在以后有实际关联的挑战被取消，这没什么大不了的，因为挑战的数量仅在 100-500 之间。

我现在的解决方案实际上不是很优雅：我分别提取所有相关的尝试、挑战和用户，然后手动关联：循环所有尝试并将添加分配给挑战和用户，然后将挑战和用户也添加到尝试. 在我看来，这似乎是一个不必要的残酷解决方案。

然而，每种方法（例如，不同的“惰性”参数、更改的查询等）都导致了数百到数千个查询。我还尝试编写简单的SQL查询来产生我想要的结果，并提出了一些类似的东西SELECT * FROM challenge WHERE id IN (SELECT challenge_id FROM attempts)并且效果很好，但我无法将它翻译成SQLAlchemy

非常感谢您提前提供的任何指导。

4

1 回答 1

10

我真正想从 SQLAlchemy 中提取所有（或所有相关）挑战，然后将其与相关尝试相关联。如果所有的挑战都被拉出来或者只是在以后有实际关联的时候，这没什么大不了的，

您首先要先从 relationship() 中删除“lazy='subquery'”指令；修复关系以始终加载所有内容是您获得大量查询的原因。特别是在这里，您将得到 Challenge->attempts eagerload 正是针对 UserAttempt->Challenge 的每个延迟加载，因此您在这里设计了最糟糕的加载组合:)。

有了这个固定，有两种方法。

一是要记住，通常情况下的多对一关联首先通过主键从内存中的 Session 中获取，如果存在，则不会发出任何 SQL。因此，我认为您可以使用我经常使用的技术获得您所描述的效果：

all_challenges = session.query(Challenge).all()

for user in some_users:    # however you got these
    for attempt in user.attempts:   # however you got these
        do_something_with(attempt.challenge)  # no SQL will be emitted

如果您想将上述方法与“Select * from challenge where id in (select challenge_id from attempt)”完全匹配：

all_challenges = session.query(Challenge).\
                  filter(Challenge.id.in_(session.query(UserAttempt.challenge_id))).all()

尽管这作为 JOIN 可能更有效：

all_challenges = session.query(Challenge).\
                  join(Challenge.attempts).all()

或 DISTINCT，我想加入会返回与 UserAttempt 中显示的相同的 challenge.id：

all_challenges = session.query(Challenge).distinct().\
                  join(Challenge.attempts).all()

另一种方法是更具体地使用急切加载。您可以在一个查询中查询一组用户/尝试/挑战，这些查询将发出三个 SELECT 语句：

users = session.query(User).\
              options(subqueryload_all(User.attempts, UserAttempt.challenge)).all()

或者因为 UserAttempt->Challenge 是多对一的，加入可能会更好：

users = session.query(User).\
                  options(subqueryload(User.attempts), joinedload(UserAttempt.challenge)).all()

仅来自用户尝试：

attempts = session.query(UserAttempt).\
                  options(joinedload(UserAttempt.challenge)).all()
于 2013-03-05T03:58:40.860 回答