Этот пример иллюстрирует загадку, с которой я столкнулся в приложении, которое я создаю. Приложение должно поддерживать опцию, позволяющую пользователю выполнять код без фактического внесения изменений в БД. Однако, когда я добавил эту опцию, я обнаружил, что изменения сохранялись в БД, даже если я не вызывал метод commit().
Мой конкретный вопрос можно найти в комментариях к коду. Основная цель состоит в том, чтобы иметь более четкое представление о том, когда и почему SQLAlchemy будет фиксироваться в БД.
Мой более широкий вопрос заключается в том, должно ли мое приложение (а) использовать глобальный экземпляр Session или (б) использовать глобальный класс Session, из которого будут создаваться экземпляры конкретных экземпляров. Основываясь на этом примере, я начинаю думать, что правильный ответ (б). Это правильно? Изменить: эта документация SQLAlchemy предполагает, что (b) рекомендуется.
import sys
from sqlalchemy import create_engine, Column, Integer, String
from sqlalchemy.orm import sessionmaker
from sqlalchemy.ext.declarative import declarative_base
Base = declarative_base()
class User(Base):
__tablename__ = 'users'
id = Column(Integer, primary_key = True)
name = Column(String)
age = Column(Integer)
def __init__(self, name, age = 0):
self.name = name
self.age = 0
def __repr__(self):
return "<User(name='{0}', age={1})>".format(self.name, self.age)
engine = create_engine('sqlite://', echo = False)
Base.metadata.create_all(engine)
Session = sessionmaker()
Session.configure(bind=engine)
global_session = Session() # A global Session instance.
commit_ages = False # Whether to commit in modify_ages().
use_global = True # If True, modify_ages() will commit, regardless
# of the value of commit_ages. Why?
def get_session():
return global_session if use_global else Session()
def add_users(names):
s = get_session()
s.add_all(User(nm) for nm in names)
s.commit()
def list_users():
s = get_session()
for u in s.query(User): print ' ', u
def modify_ages():
s = get_session()
n = 0
for u in s.query(User):
n += 10
u.age = n
if commit_ages: s.commit()
add_users(('A', 'B', 'C'))
print '\nBefore:'
list_users()
modify_ages()
print '\nAfter:'
list_users()
