EF Core 临时表操作

网上找了两个, 一个内存表, 一个临时表.

1 安装包: EntityFrameworkCore.MemoryJoin  //内存表 直接用select union拼接查询  http://tsherlock.tech/2018/03/20/joining-in-memory-list-to-entity-framework-query/
DbContext类中加入:  protected DbSet<QueryModelClass> QueryData { get; set; } // 注意升迁代码中 删除此表的升迁代码

2 引用:  https://dev.azure.com/pawelgerr/_git/Thinktecture.EntityFrameworkCore ; 或者:  https://github.com/yangzhinong/Thinktecture.EntityFrameworkCore 编译后的dll ConfigureServices方法中加入:            services.AddDbContext<SalesDbContext>(options => {                 options.UseSqlServer(_appConfiguration.GetConnectionString("Default"), opts => {                     opts.AddTempTableSupport();                 });             }); 3. 定义通用的Repository的接口和实现
3.1 public interface ITempTableRepository {         IQueryable<T> FromLocalList<T>(IList<T> data) where T : class;         Task<IQueryable<T>> BulkInsertIntoTempTableAsync<T>(IEnumerable<T> entities) where T : class;  }
3.2 public class TempTableRepository : SalesRepositoryBase<CodeTemplate<Guid>, Guid>, ITempTableRepository {         public TempTableRepository(IDbContextProvider<SalesDbContext> dbContextProvider) : base(dbContextProvider) {         }         public async Task<IQueryable<T>> BulkInsertIntoTempTableAsync<T>(IEnumerable<T> entities) where T : class {             var query = await Context.BulkInsertIntoTempTableAsync(entities, new SqlTempTableBulkInsertOptions() {                 PrimaryKeyCreation = PrimaryKeyCreation.None,             });             return query;         }         public IQueryable<T> FromLocalList<T>(IList<T> data) where T : class {             return Context.FromLocalList(data);         }     }
3.3 DbContext中定义
     public  DbQuery<ImpTestTemp> ImpTestTemps { get; set; }  ==========================
4使用类中  注入ITempTableRepository即可
        private readonly IObjectMapper _objectMapper;         private readonly IRepository<Area, Guid> _area;          private readonly ITempTableRepository _tempTableRepository;         public AreaService(IRepository<Area, Guid> area, IObjectMapper objectMapper,             ITempTableRepository tempTableRepository) {             _area = area;             _objectMapper = objectMapper;              _tempTableRepository = tempTableRepository;         }
          public async Task<IEnumerable<GetAreaByParentIdOutput>> GetAreaByParentIdAsync(Guid? parentId) {             var lst = new List<ImpTestTemp> {                 new ImpTestTemp { Id = 1, AreaId=new Guid("179A9943-EC6C-4923-8B75-00818198008E") ,Code = "123", Name = "yzn", Sorce=98.5m },                 new ImpTestTemp { Id = 2, AreaId= new Guid("48E8124C-789B-4158-BE9C-00507403DF7E"), Code = "456", Name = "seq" , Sorce=99.4m}             };              var queryList = await _tempTableRepository.BulkInsertIntoTempTableAsync(lst); //数据多可以用此方法
            var queryList2 =  _tempTableRepository.FromLocalList(lst); // 数据少可用此方法              var efQuery = (from t in queryList                            join a in _area.GetAll()                            on t.AreaId equals a.Id                            select new {                                t.Code,                                AreaCode = a.Code,                                a.Name                            }).ToList();          retun null;                   }     }