与存储库设计模式的交易

Question

我使用 Entity Framework 6.0 和存储库设计模式开发了一个 ASP.NET MVC 应用程序来管理项目。现在我想集成事务以确保某些 insert/update 数据库操作遵守 ACID 原则，尤其是原子性原则。

下面是我的通用存储库的片段：

1.通用存储库界面

    public interface IGenericRepository<T> : IRepository  where T : BaseEntity
    {
        void Create(T entity);
        void Delete(T entity);
        IEnumerable<T> GetAll();
        void Update(T entity);
    }

2。通用存储库 class

public abstract class GenericRepository<T> : IGenericRepository<T> where T : BaseEntity
        {
            protected IContext _context;
            protected IDbSet<T> _dbset;

            public GenericRepository(IContext context)
            {
                _context = context;
                _dbset = _context.Set<T>();
            }


            public virtual void Create(T entity)
            {
                if (entity == null)
                {
                    throw new ArgumentNullException("entity");
                }

                _dbset.Add(entity);
                _context.SaveChanges();
            }


            public virtual void Update(T entity)
            {
                if (entity == null) throw new ArgumentNullException("entity");
                _context.Entry(entity).State = System.Data.Entity.EntityState.Modified;
                _context.SaveChanges();
            }

            public virtual void Delete(T entity)
            {
                if (entity == null) throw new ArgumentNullException("entity");
                _dbset.Remove(entity);
                _context.SaveChanges();
            }

            public virtual IEnumerable<T> GetAll()
            {
                return _dbset.AsEnumerable<T>();
            }
        }

3。我的 Icontext 实现

public interface IContext
    {
        IDbSet<Projet> Projects { get; set; }     
        IDbSet<Task> Tasks{ get; set; }
        IDbSet<Entite> Entities { get; set; }

        DbSet<TEntity> Set<TEntity>() where TEntity : class;
        DbEntityEntry<TEntity> Entry<TEntity>(TEntity entity) where TEntity : class;

        int SaveChanges();
    }

4.项目实体

public class ProjectRepository : GenericRepository<Projet>, IProjectRepository
    {

        IContext _context;

        public ProjectRepository(IContext context) : base(context)
        {
            _context = context;
            _dbset = _context.Set<Projet>();
        }

        public Projet GetProjectById(int Id) 
        {
            return _dbset.FirstOrDefault(x=>x.Id == Id);
        }

    }

所以，我想做的是让交易与上面的模型一起工作。例如，当使用他的任务创建项目时，我想使用事务来保存项目和任务实体，因此我确信插入这些实体将是一个原子操作。

感谢您的帮助和建议。

Answer 1

通常，您的存储库被注入引擎/服务类。我假设我们有一个 ProjectEngine.cs，其中注入了 ProjectRepo 和 TaskRepo。代码如下所示：

     public class ProjectEngine : IProjectEngine
        {
            IProjectRepository projectRepository;
            ITaskRepository taskRepository;

            public ProjectEngine(
                IProjectRepository ProjectRepository,
                ITaskRepository TaskRepository)
            {
                projectRepository = ProjectRepository;
                taskRepository = TaskRepository;
            }

            public void CreateProject(CreateProjectRequest createProjectRequest)
            {

            using (TransactionScope scope = new TransactionScope())
                    {

                       // these operations are atomic since they below to same transactionscope
                        projectRepository.Add([project]);
                        taskRepository.Add([tasks]);
                        // data will not be affected until complete operation is called. Any database exception would rollback the transaction.
                        scope.Complete();
                    }

              } 

         }

回顾一下，最好的方法是在同一事务范围内包含多个存储库操作。

与存储库设计模式的交易

Transaction with the Repository Design patterns

asp.net-mvc

transactionscope

repository-pattern

c#-4.0

entity-framework-6