Класс Select
Класс Select представляет собой
SELECT-запрос к базе данных. Экземпляр
класса создается функцией select,
которая первым параметром принимает
столбцы или сущности для выборки.
Класс предоставляет множество методов
для построения запроса: фильтрации,
сортировки, группировки, соединения
таблиц и других операций.
Синтаксис
from sqlalchemy import select
stmt = select(*entities)
Пример
Давайте создадим простой SELECT-запрос
к таблице 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)
stmt = select(Article)
print(stmt)
Результат выполнения кода:
"SELECT articles.id, articles.title, articles.text, articles.status, articles.num FROM 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)
stmt = select(Article.id, Article.title)
print(stmt)
Результат выполнения кода:
"SELECT articles.id, articles.title FROM articles"
Пример
Давайте выполним SELECT-запрос через сессию и получим строки из базы данных:
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()
stmt = select(Article.title)
res = session.execute(stmt).scalars().all()
print(res)
Результат выполнения кода:
['article 1', 'article 2', 'article 3']
Пример
Давайте добавим к SELECT-запросу фильтрацию
методом where:
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()
stmt = select(Article.title).where(Article.status == 'published')
res = session.execute(stmt).scalars().all()
print(res)
Результат выполнения кода:
['article 1', 'article 3']
Пример
Давайте отсортируем результат методом
order_by и ограничим количество
строк методом limit:
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()
stmt = select(Article.title).order_by(Article.num.desc()).limit(2)
res = session.execute(stmt).scalars().all()
print(res)
Результат выполнения кода:
['article 3', 'article 2']