Метод rollback
Метод rollback класса Session откатывает
текущую транзакцию. Все изменения, выполненные в рамках
этой транзакции, отменяются. Объекты, находившиеся
в сессии, переводятся в состояние expired, а их данные
при следующем обращении загружаются заново из базы.
Метод не принимает параметров и возвращает None.
Если активная транзакция отсутствует, метод просто
сбрасывает состояние сессии.
Синтаксис
Session.rollback()
Пример
Давайте создадим сессию, добавим объект и откатим
транзакцию методом rollback:
from sqlalchemy import create_engine, String
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] = mapped_column(String(100))
engine = create_engine('sqlite:///:memory:')
Base.metadata.create_all(engine)
with Session(engine) as session:
article = Article(title='article')
session.add(article)
session.rollback()
res = session.query(Article).count()
print(res)
Результат выполнения кода:
0
Пример
Давайте сохраним объект методом commit, а затем
изменим его и откатим изменения:
from sqlalchemy import create_engine, String
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] = mapped_column(String(100))
engine = create_engine('sqlite:///:memory:')
Base.metadata.create_all(engine)
with Session(engine) as session:
article = Article(title='article')
session.add(article)
session.commit()
article.title = 'user'
session.rollback()
session.refresh(article)
print(article.title)
Результат выполнения кода:
"article"
Пример
Давайте откатим транзакцию после удаления объекта:
from sqlalchemy import create_engine, String
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] = mapped_column(String(100))
engine = create_engine('sqlite:///:memory:')
Base.metadata.create_all(engine)
with Session(engine) as session:
article = Article(title='article')
session.add(article)
session.commit()
session.delete(article)
session.rollback()
res = session.query(Article).count()
print(res)
Результат выполнения кода:
1
