فهرست منبع

仓储增加批量操作接口

Murphy 3 سال پیش
والد
کامیت
5781950fdb

+ 2 - 1
MicroServices/Business/Business.EntityFrameworkCore/Repository/SqlRepositories/ISqlRepository.cs

@@ -11,8 +11,9 @@ namespace Business.EntityFrameworkCore.SqlRepositories
     public interface ISqlRepository<T> where T : class, new()
     {
         Task<int> Insert(T entity);
-
+        Task<int> Insert(List<T> entitylist);
         Task<int> Update(T entity);
+        Task<int> Update(List<T> entitylist);
 
         Task<int> Update(Expression<Func<T, bool>> whereLambda, Expression<Func<T, T>> entity);
 

+ 11 - 0
MicroServices/Business/Business.EntityFrameworkCore/Repository/SqlRepositories/SqlRepository.cs

@@ -30,11 +30,22 @@ namespace Business.EntityFrameworkCore.SqlRepositories
             return await _dbContextProvider.GetDbContext().SaveChangesAsync();
         }
 
+        public async Task<int> Insert(List<T> entitylist)
+        {
+            _dbContextProvider.GetDbContext().Set<T>().AddRange(entitylist);
+            return await _dbContextProvider.GetDbContext().SaveChangesAsync();
+        }
+
         public async Task<int> Update(T entity)
         {
             _dbContextProvider.GetDbContext().Set<T>().Update(entity);
            return await _dbContextProvider.GetDbContext().SaveChangesAsync();
         }
+        public async Task<int> Update(List<T> entitylist)
+        {
+            _dbContextProvider.GetDbContext().Set<T>().UpdateRange(entitylist);
+           return await _dbContextProvider.GetDbContext().SaveChangesAsync();
+        }
 
         public  async Task<int> Update(Expression<Func<T, bool>> whereLambda, Expression<Func<T, T>> entity)
         {