Как эффективно использовать SQLAlchemy с несколькими репозиториями DDD?

Question

Я пытался найти несколько примеров того, как реализовать шаблон Repository с помощью SQLAlchemy. В частности, реализация более одного репозитория.

Я полагаю, что в случае нескольких репозиториев каждый репозиторий лучше всего реализовать, поддерживая отдельный сеанс SQLAlchemy. Однако я столкнулся с проблемой, пытаясь переместить экземпляр объекта, привязанного к одному сеансу, к другому сеансу.

Во-первых, имеет ли это смысл делать? Должен ли каждый репозиторий поддерживать свое собственное UoW отдельно от любого другого репозитория, или следует считать безопасным, чтобы весь контекст разделял один и тот же сеанс?

Во-вторых, каков наилучший способ отсоединить экземпляр от одного сеанса и связать его с другим?

В-третьих, есть ли надежные примеры репозитория DDD, написанные с учетом SQLAlchemy?

Answer 1

Я не знаком с шаблоном DDD Repository, но ниже приведен пример, показывающий, как переместить объект из одного сеанса в другой:

from sqlalchemy import *
from sqlalchemy.ext.declarative import declarative_base
from sqlalchemy.orm import sessionmaker

metadata  = MetaData()
Base = declarative_base(metadata=metadata, name='Base')

class Model(Base):
    __tablename__ = 'models'
    id = Column(Integer, primary_key=True)


engine1 = create_engine('sqlite://')
metadata.create_all(engine1)
engine2 = create_engine('sqlite://')
metadata.create_all(engine2)

session1 = sessionmaker(bind=engine1)()
session2 = sessionmaker(bind=engine2)()

# Setup an single object in the first repo.
obj = Model()
session1.add(obj)
session1.commit()
session1.expunge_all() 

# Move object from the first repo to the second.
obj = session1.query(Model).first()
assert session2.query(Model).count()==0
session1.delete(obj)
# You have to flush before expunging, otherwise it won't be deleted.
session1.flush()
session1.expunge(obj)
obj = session2.merge(obj)
# An optimistic way to bind two transactions is flushing before commiting.
session2.flush()
session1.commit()
session2.commit()
assert session1.query(Model).count()==0
assert session2.query(Model).count()==1