Учебники

SQLAlchemy ORM — энергичная загрузка

Декабрь 18, 2018

Стремительная загрузка уменьшает количество запросов. SQLAlchemy предлагает активные функции загрузки, вызываемые через параметры запроса, которые дают дополнительные инструкции для запроса. Эти параметры определяют, как загружать различные атрибуты с помощью метода Query.options ().

Загрузка подзапроса

Мы хотим, чтобы Customer.invoices загружались с нетерпением. Опция orm.subqueryload () дает второй оператор SELECT, который полностью загружает коллекции, связанные с только что загруженными результатами. Имя «подзапрос» приводит к тому, что оператор SELECT создается непосредственно через повторно используемый запрос и внедряется как подзапрос в SELECT для связанной таблицы. 

from sqlalchemy.orm import subqueryload
c1 = session.query(Customer).options(subqueryload(Customer.invoices)).filter_by(name = 'Govind Pant').one()

Это приводит к следующим двум выражениям SQL — 

SELECT customers.id 
AS customers_id, customers.name 
AS customers_name, customers.address 
AS customers_address, customers.email 
AS customers_email
FROM customers
WHERE customers.name = ?
('Govind Pant',)

SELECT invoices.id 
AS invoices_id, invoices.custid 
AS invoices_custid, invoices.invno 
AS invoices_invno, invoices.amount 
AS invoices_amount, anon_1.customers_id 
AS anon_1_customers_id
FROM (
   SELECT customers.id 
   AS customers_id
   FROM customers
   WHERE customers.name = ?) 
   
AS anon_1 
JOIN invoices 
ON anon_1.customers_id = invoices.custid 
ORDER BY anon_1.customers_id, invoices.id 2018-06-25 18:24:47,479 
INFO sqlalchemy.engine.base.Engine ('Govind Pant',)

Для доступа к данным из двух таблиц мы можем использовать следующую программу: 

print (c1.name, c1.address, c1.email)

for x in c1.invoices:
   print ("Invoice no : {}, Amount : {}".format(x.invno, x.amount))

Вывод вышеуказанной программы следующий: 

Govind Pant Gulmandi Aurangabad gpant@gmail.com
Invoice no : 3, Amount : 10000
Invoice no : 4, Amount : 5000

Объединенная нагрузка

Другая функция называется orm.joinedload (). Это испускает левое внешнее соединение. Ведущий объект, а также связанный объект или коллекция загружаются за один шаг. 

from sqlalchemy.orm import joinedload
c1 = session.query(Customer).options(joinedload(Customer.invoices)).filter_by(name='Govind Pant').one()

Это выдает следующее выражение, дающее тот же результат, что и выше — 

SELECT customers.id 
AS customers_id, customers.name 
AS customers_name, customers.address 
AS customers_address, customers.email 
AS customers_email, invoices_1.id 
AS invoices_1_id, invoices_1.custid 
AS invoices_1_custid, invoices_1.invno 
AS invoices_1_invno, invoices_1.amount 
AS invoices_1_amount

FROM customers 
LEFT OUTER JOIN invoices 
AS invoices_1 
ON customers.id = invoices_1.custid

WHERE customers.name = ? ORDER BY invoices_1.id
('Govind Pant',)

В результате OUTER JOIN появилось две строки, но он возвращает один экземпляр Customer. Это связано с тем, что Query применяет «уникальную» стратегию, основанную на идентичности объекта, к возвращаемым объектам. Присоединенная готовая загрузка может быть применена, не затрагивая результаты запроса.

Функция subqueryload () больше подходит для загрузки связанных коллекций, в то время как joinload () лучше подходит для отношений «многие к одному».

45
Share: