Объединение таблиц в SQLAlchemy Core с помощью join()

• 25.09.2023
• 485
• Библиотеки Python
• SQLAlchemy

Объединение таблиц — это основная операция в реляционных базах данных, позволяющая комбинировать строки из двух или более таблиц на основе связанных столбцов между ними.

В SQLAlchemy Core объединение таблиц реализуется с помощью метода join(). Давайте подробно рассмотрим, как это работает.

Основные типы объединений

Прежде чем переходить к примерам, давайте рассмотрим основные типы объединений:

1. Inner Join: Возвращает строки, когда есть соответствующее значение в обеих таблицах.
2. Left (Outer) Join: Возвращает все строки из левой таблицы и соответствующие строки из правой таблицы.
3. Right (Outer) Join: Аналогично Left Join, но для правой таблицы.
4. Full (Outer) Join: Возвращает строки, когда есть хотя бы одно соответствующее значение в одной из таблиц.

Примеры объединений

Примеры объединений с использованием SQLAlchemy Core

Подготовка к примерам

Перед началом работы нам понадобятся две базовые таблицы: users и orders.

from sqlalchemy import create_engine, MetaData, Table, Column, Integer, String, ForeignKey

metadata = MetaData()

users = Table('users', metadata,
              Column('id', Integer, primary_key=True),
              Column('name', String)
              )

orders = Table('orders', metadata,
               Column('id', Integer, primary_key=True),
               Column('user_id', Integer, ForeignKey('users.id')),
               Column('item', String)
               )

engine = create_engine('sqlite:///example.db')
metadata.create_all(engine)

Inner Join

Описание: Возвращает только те строки, где есть совпадения в обеих таблицах.

Пример: Найдем всех пользователей и их заказы, где у пользователя есть хотя бы один заказ.

from sqlalchemy import select

s = select([users, orders]).where(users.c.id == orders.c.user_id)

В этом запросе мы выбираем все колонки из таблицы users и orders, где ID пользователя соответствует user_id из таблицы orders.

Left Join

Описание: Возвращает все строки из левой таблицы и соответствующие строки из правой таблицы. Если совпадений нет, будет NULL.

Пример: Получим всех пользователей и их заказы. Если у пользователя нет заказов, он все равно будет показан в результатах, но информация о заказах будет NULL.

s = select([users, orders]).select_from(users.outerjoin(orders, users.c.id == orders.c.user_id))

Здесь outerjoin используется для выполнения левого объединения. В результате этот запрос покажет всех пользователей, даже тех, у кого нет заказов.

Сложные объединения

Описание: Иногда может потребоваться объединить несколько таблиц.

Пример: Добавим еще одну таблицу shipments, которая относится к доставке заказов, и объединим все три таблицы.

shipments = Table('shipments', metadata,
                  Column('id', Integer, primary_key=True),
                  Column('order_id', Integer, ForeignKey('orders.id')),
                  Column('ship_date', String)
                  )

s = select([users, orders, shipments]).select_from(
    users.join(orders, users.c.id == orders.c.user_id).join(shipments, orders.c.id == shipments.c.order_id))

Здесь мы используем метод join() дважды для выполнения внутренних объединений между users, orders и shipments.

После создания запросов вы можете выполнить их с помощью:

result = engine.connect().execute(s)
for row in result:
    print(row)

Заключение

Объединение таблиц — ключевая операция при работе с реляционными базами данных. SQLAlchemy Core предоставляет эффективные и гибкие инструменты для выполнения этой задачи, упрощая жизнь разработчикам.