Как написать условные предложения с использованием языка выражения SQLAlchemy?
Итак, я написал довольно сложный запрос, который извлекает и объединяет кучу данных из двух таблиц.
SELECT /* Common attributes */ carrier.name, carrier.notes, carrier.turnaround, /* Either per-reseller price, generic reseller price or default price */ IFNULL( rsu.price, IF( ( carrier.reseller_price != IS NOT NULL AND carrier.reseller_price != 0 ), carrier.reseller_price, carrier.price ) ) AS price, IFNULL( rsu.price_barred, IF( ( carrier.reseller_price_barred IS NOT NULL AND carrier.reseller_price_barred != 0 ), carrier.reseller_price_barred, carrier.price_barred ) ) AS price_barred FROM `core_carrier` AS carrier LEFT OUTER JOIN `core_resellerunlock` AS rsu ON ( rsu.carrier_id = carrier.id AND rsu.reseller_id = 1 ) Может ли кто-то предложить способ перезаписи с помощью SQLAlchemy query builder? Я не уверен, что это возможно даже с предложениями SELECT ... IF .
- Массовое обновление в SQLAlchemy Core с использованием WHERE
- Не работает пример с директивой 'passive-deletes' в sqlalchemy doc
- Должен ли я создавать объекты mapper или использовать декларативный синтаксис в SQLAlchemy?
- Как эффективно выполнять массовое вставку или обновление с помощью SQLAlchemy?
- коллоидная sqlalchemy, запрашивающая столбец, не равный
Изменить: я не хочу делать это с помощью ORM (и, насколько я знаю, выполнение этого с использованием ORM SQLAlchemy чисто невозможно). Я просто ищу более или менее портативный способ сделать это с помощью ядра SQLAlchemy.
- Как класс SQLAlchemy наследуется должным образом, несмотря на сложность отношений ForeignKey?
- Вставка реляционных данных в SQL Alchemy с запросами API в Python
- AttributeError: объект InstrumentedList не имеет атрибута
- Flask-SQLAlchemy create_all ()
- Как обновить запись строки SQLAlchemy?
One Solution collect form web for “Как написать условные предложения с использованием языка выражения SQLAlchemy?”
Вы можете включить условие в свой запрос, используя функцию case . Это не даст точно SQL, который вы представили, но может произвести что-то функционально эквивалентное.
Вот простой пример rsu переменные- carrier и rsu ссылаются на объекты Table , а case ссылается на вышеупомянутую функцию:
join = carrier.join(rsu, (rsu.c.carrier_id == carrier.c.id) & (rsu.c.reseller_id == 1)) query = join.select([ carrier.c.name, carrier.c.notes, carrier.c.turnaround, case([ ( rsu.c.price_barred == None, case([ ( (carrier.c.reseller_price != None) & (carrier.c.reseller_price != 0), carrier.c.reseller_price ) ], else_=carrier.c.price ) ] ])
Вам может показаться удобным сделать некоторые вспомогательные функции для представления функций IFNULL и IF более высокого уровня, чтобы улучшить читаемость вашего запроса. Например:
def if_(expr, then, else_): return case([ (expr, then) ], else_=else_)