SQLALCHEMY: выключить декларативное полиморфное соединение?
-
26-09-2019 - |
Вопрос
Есть ли путь в SQLALCHEMY, чтобы отключить декларативный полиморфный присоединиться, в одном запросе? Большую часть времени это хорошо, но у меня есть:
class A(Base) :
discriminator = Column('type', mysql.INTEGER(1), index=True, nullable=False)
__mapper_args__ = { 'polymorphic_on' : discriminator }
id = Column(Integer, primary_key=True)
p = Column(Integer)
class B(A) :
__mapper_args__ = { 'polymorphic_identity' : 0 }
id = Column(Integer, primary_key=True)
x = Column(Integer)
class C(A) :
__mapper_args__ = { 'polymorphic_identity' : 1 }
id = Column(Integer, primary_key=True)
y = Column(String)
Я хочу сделать запрос такой, что я получаю все a.ids, для которого Bx> 10, если это на самом деле является B, или где Cy == «Blah», если что A - это на самом деле C, все заказано p.
Чтобы сделать это итеративно, я начинаю только с первой частью - «Получить все A.ID, для которой BX> 10, если это на самом деле является B». Поэтому я думал, что начну с внешнего соединения:
session.query(A.id).outerjoin((B, B.id == A.id)).filter(B.x > 10)
... За исключением того, что, кажется, никаких способов избежать того, чтобы избежать этого, пункт перемещения ((b, b.id == a.id)), генерируют полное соединение всего во всем на все в B в подселении. Если B не наследует от A, то это не происходит, поэтому я думаю, что это полиморфное декларативное поколение кода, которое это делает. Есть ли способ отключить это? Или заставить внешность делать то, что я хочу?
Что я хочу, это что-то вроде этого:
select a.id from A a left outer join B b on b.id == a.id where b.x > 10
Но вместо этого я получаю что-то вроде:
select a.id from A a left outer join (select B.id, B.x, A.id from B inner join A on B.id == A.id)
... как в сторону, если это невозможно, то последнее менее эффективно, чем первый? Будет ли двигатель SQL на самом деле Выполните это внутреннее присоединение, или это будет в этом элиде?
Решение
Вы можете попробовать построить запросы для каждого подкласса индивидуально, а затем объединить их вместе. При запросе B.id
, SQLalchemy неявно присоединяется к суперкласс и возвращается A.id
вместо этого, поэтому принимая профсоюз выбора для B.id
и C.id
возвращает только один столбец.
>>> b_query = session.query(B.id).filter(B.x > 10)
>>> c_query = session.query(C.id).filter(C.y == 'foo')
>>> print b_query.union(c_query)
SELECT anon_1."A_id" AS "anon_1_A_id"
FROM (SELECT "A".id AS "A_id"
FROM "A" JOIN "B" ON "A".id = "B".id
WHERE "B".x > ? UNION SELECT "A".id AS "A_id"
FROM "A" JOIN "C" ON "A".id = "C".id
WHERE "C".y = ?) AS anon_1
Вы все еще получаете подселово, но только один «слой» соединений - внешний выбор просто переименован в столбце.
Другие советы
Вы должны использовать с_polymorphic () вместо Oudrejoin (), который, похоже, возвращает ожидаемые результаты:
session.query(A).with_polymorphic(B).filter(B.x > 10).all()
# BEGIN
# SELECT "A".type AS "A_type", "A".id AS "A_id", "A".p AS "A_p", "B".id AS "B_id", "B".x AS "B_x"
# FROM "A" LEFT OUTER JOIN "B" ON "A".id = "B".id
# WHERE "B".x > ?
# (10,)
# Col ('A_type', 'A_id', 'A_p', 'B_id', 'B_x')
В сравнении с:
session.query(A.id).outerjoin((B, B.id == A.id)).filter(B.x > 10)
# BEGIN
# SELECT "A".id AS "A_id"
# FROM "A" LEFT OUTER JOIN (SELECT "A".type AS "A_type", "A".id AS "A_id", "A".p AS "A_p", "B".id AS "B_id", "B".x AS "B_x"
# FROM "A" JOIN "B" ON "A".id = "B".id) AS anon_1 ON anon_1."A_id" = "A".id
# WHERE anon_1."B_x" > ?
# (10,)
# Col ('A_id',)
Код, который я использовал для тестирования этого, в случае, если кто-то хочет проверить этот аккуратный бит SQLALCHEMY:
#!/usr/bin/env python
import logging
from sqlalchemy import *
from sqlalchemy.ext.declarative import declarative_base
from sqlalchemy.orm import sessionmaker
Base = declarative_base()
class A(Base) :
__mapper_args__ = { 'polymorphic_on' : discriminator }
__tablename__ = 'A'
id = Column(Integer, primary_key=True)
discriminator = Column('type', Integer, index=True, nullable=False)
p = Column(Integer)
class B(A) :
__mapper_args__ = { 'polymorphic_identity' : 0 }
__tablename__ = 'B'
id = Column(Integer, ForeignKey('A.id'), primary_key=True)
x = Column(Integer)
class C(A) :
__mapper_args__ = { 'polymorphic_identity' : 1 }
__tablename__ = 'C'
id = Column(Integer, ForeignKey('A.id'), primary_key=True)
y = Column(String)
meta = Base.metadata
meta.bind = create_engine('sqlite://')
meta.create_all()
Session = sessionmaker()
Session.configure(bind=meta.bind)
session = Session()
log = logging.getLogger('sqlalchemy')
log.addHandler(logging.StreamHandler())
log.setLevel(logging.DEBUG)
session.query(A.id).outerjoin((B, B.id == A.id)).filter(B.x > 10).all()
session.query(A).with_polymorphic(B).filter(B.x > 10).all()
Я провел это на Python 2.7 с SQLalchemy 0.6.4.