Функция intersect

Функция intersect создает запрос, который возвращает только те строки, которые есть одновременно в результате первого и второго запроса. Она принимает один или несколько запросов, с которыми нужно пересечь исходный запрос. По умолчанию дубликаты строк удаляются.

Синтаксис

select(...).intersect(select(...), [select(...), ...])

Пример

Давайте создадим таблицу articles и добавим в нее несколько записей:

from sqlalchemy import create_engine, select, intersect
from sqlalchemy.orm import DeclarativeBase, Mapped, mapped_column, Session

class Base(DeclarativeBase):
	pass

class Article(Base):
	__tablename__ = 'articles'

	id: Mapped[int] = mapped_column(primary_key=True)
	title: Mapped[str]
	text: Mapped[str]
	status: Mapped[str]
	num: Mapped[int]

engine = create_engine('sqlite:///:memory:')
Base.metadata.create_all(engine)

with Session(engine) as session:
	session.add_all([
		Article(title='article 1', text='text 1', status='published', num=1),
		Article(title='article 2', text='text 2', status='draft', num=2),
		Article(title='article 3', text='text 3', status='published', num=3),
	])
	session.commit()

Пример

Давайте получим заголовки статей, которые одновременно имеют статус published и номер больше единицы:

from sqlalchemy import create_engine, select, intersect
from sqlalchemy.orm import DeclarativeBase, Mapped, mapped_column, Session

class Base(DeclarativeBase):
	pass

class Article(Base):
	__tablename__ = 'articles'

	id: Mapped[int] = mapped_column(primary_key=True)
	title: Mapped[str]
	text: Mapped[str]
	status: Mapped[str]
	num: Mapped[int]

engine = create_engine('sqlite:///:memory:')
Base.metadata.create_all(engine)

with Session(engine) as session:
	session.add_all([
		Article(title='article 1', text='text 1', status='published', num=1),
		Article(title='article 2', text='text 2', status='draft', num=2),
		Article(title='article 3', text='text 3', status='published', num=3),
	])
	session.commit()

	stmt1 = select(Article.title).where(Article.status == 'published')
	stmt2 = select(Article.title).where(Article.num > 1)
	res = session.execute(stmt1.intersect(stmt2)).scalars().all()
	print(res)

Результат выполнения кода:

['article 3']

Итоговый SQL запрос:

SELECT articles.title
FROM articles
WHERE articles.status = 'published'
INTERSECT
SELECT articles.title
FROM articles
WHERE articles.num > 1

Пример

Давайте пересечем три запроса: статьи со статусом published, статьи с номером больше единицы и статьи, содержащие слово article в заголовке:

from sqlalchemy import create_engine, select, intersect
from sqlalchemy.orm import DeclarativeBase, Mapped, mapped_column, Session

class Base(DeclarativeBase):
	pass

class Article(Base):
	__tablename__ = 'articles'

	id: Mapped[int] = mapped_column(primary_key=True)
	title: Mapped[str]
	text: Mapped[str]
	status: Mapped[str]
	num: Mapped[int]

engine = create_engine('sqlite:///:memory:')
Base.metadata.create_all(engine)

with Session(engine) as session:
	session.add_all([
		Article(title='article 1', text='text 1', status='published', num=1),
		Article(title='article 2', text='text 2', status='draft', num=2),
		Article(title='article 3', text='text 3', status='published', num=3),
	])
	session.commit()

	stmt1 = select(Article.title).where(Article.status == 'published')
	stmt2 = select(Article.title).where(Article.num > 1)
	stmt3 = select(Article.title).where(Article.title.like('%article%'))
	res = session.execute(stmt1.intersect(stmt2, stmt3)).scalars().all()
	print(res)

Результат выполнения кода:

['article 3']

Смотрите также

функцию intersect_all,
которая оставляет дубликаты при пересечении
функцию union,
которая объединяет результаты двух запросов
функцию except_,
которая вычитает один запрос из другого
функцию select,
которая создает запрос на выборку данных