5

session.query(Entity1, Entity2)テーブルから直接ではなく、サブクエリからのみ、のような複数のエンティティをクエリする必要があります。ドキュメントにはサブクエリから1つのエンティティを選択する方法がありますが、ドキュメントまたは実験のいずれかで複数のエンティティを選択する方法が見つかりません。

私のユースケースは、マップされたクラスの基礎となるテーブルをウィンドウ関数でフィルタリングする必要があることです。これは、PostgreSQLではサブクエリまたはCTEでのみ実行できます。

編集：サブクエリは両方のテーブルの結合にまたがっているので、私はただ行うことはできませんaliased(Entity1, subquery)。

4

2 に答える 2

17 
from sqlalchemy import *
from sqlalchemy.orm import *
from sqlalchemy.ext.declarative import declarative_base

Base = declarative_base()

class A(Base):
    __tablename__ = "a"

    id = Column(Integer, primary_key=True)
    bs = relationship("B")

class B(Base):
    __tablename__ = "b"

    id = Column(Integer, primary_key=True)

    a_id = Column(Integer, ForeignKey('a.id'))

e = create_engine("sqlite://", echo=True)
Base.metadata.create_all(e)
s = Session(e)
s.add_all([A(bs=[B(), B()]), A(bs=[B()])])
s.commit()

# with_labels() here is to disambiguate A.id and B.id.
# without it, you'd see a warning
# "Column 'id' on table being replaced by another column with the same key."
subq = s.query(A, B).join(A.bs).with_labels().subquery()


# method 1 - select_from()
print s.query(A, B).select_from(subq).all()

# method 2 - alias them both.  "subq" renders
# once because FROM objects render based on object
# identity.
a_alias = aliased(A, subq)
b_alias = aliased(B, subq)
print s.query(a_alias, b_alias).all()
于 2013-01-24T22:39:05.647 に答える
4

元の質問のようなことをしようとしていました: 外部結合を使用して、フィルター処理されたテーブルを別のフィルター処理されたテーブルと結合します。次の方法がまったく明らかではないため、私は苦労していました。

  • 両方のテーブルからエンティティを返す SQLAlchemy クエリを作成します。@zzzeekの答えは、その方法を教えてくれました：get_session().query(A, B).
  • そのようなクエリでテーブルとしてクエリを使用します。@zzzeekの答えは、それを行う方法も教えてくれました: filtered_a = aliased(A).filter(...).subquery().
  • 2 つのエンティティ間で OUTER 結合を使用します。select_from()afterを使用outerjoin()すると、テーブル間の結合条件が破棄され、クロス結合が発生します。@zzzeek の回答から、ifaが aliased()の場合a、query() と .outerjoin(a) に含めることができ、2 回目は結合されず、動作しているように見えると推測しました。

私のモデルの1つが継承を使用し、SQLAlchemyが条件なしで内側のSELECTの外側に親テーブルを追加したため、@zzzeekの提案されたアプローチのいずれかに従うと、クロス結合（組み合わせ爆発）が直接発生しました。これは SQLAlchemy のバグだと思います。最終的に採用したアプローチは次のとおりです。

filtered_a = aliased(A, A.query().filter(...)).subquery("filtered_a")
filtered_b = aliased(B, B.query().filter(...)).subquery("filtered_b")
query = get_session().query(filtered_a, filtered_b)
query = query.outerjoin(filtered_b, filtered_a.relation_to_b)
query = query.order_by(filtered_a.some_column)

for a, b in query:
    ...
于 2015-03-30T15:14:18.940 に答える