Функция union_all

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

Синтаксис

select1.union_all(select2)

Пример

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

from sqlalchemy import create_engine, select
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()
	
	select1 = select(Article.title).where(Article.status == 'published')
	select2 = select(Article.title).where(Article.num > 1)
	
	res = session.execute(select1.union_all(select2)).all()
	print(res)

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

[('article 1',), ('article 3',), ('article 2',), ('article 3',)]

Пример

Давайте посмотрим итоговый SQL-запрос, который формирует union_all:

from sqlalchemy import create_engine, select
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:
	select1 = select(Article.title).where(Article.status == 'published')
	select2 = select(Article.title).where(Article.num > 1)
	
	print(select1.union_all(select2))

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

SELECT articles.title
FROM articles
WHERE articles.status = :status_1
UNION ALL
SELECT articles.title
FROM articles
WHERE articles.num > :num_1

Пример

Давайте объединим три запроса и отсортируем результат:

from sqlalchemy import create_engine, select
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()
	
	select1 = select(Article.title).where(Article.status == 'published')
	select2 = select(Article.title).where(Article.num > 1)
	select3 = select(Article.title).where(Article.num == 1)
	
	combined = select1.union_all(select2, select3).order_by('title')
	res = session.execute(combined).all()
	print(res)

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

[('article 1',), ('article 1',), ('article 2',), ('article 3',), ('article 3',)]

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

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