XdCxRhDW/XdCxRhDW.Repostory/EFContext/RHDWContext.cs

using System;
using System.Collections.Generic;
using System.Data.Entity;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using SQLite.CodeFirst;
using System.Data.Entity.ModelConfiguration.Conventions;
using System.Data.Entity.Infrastructure.Interception;
using XdCxRhDW.Repostory.Model;
using System.IO;

namespace XdCxRhDW.Repostory.EFContext
{

    /// <summary>
    /// 基础表上下文(id为int)
    /// </summary>
    public class RHDWContext: DbContext
    {
        public RHDWContext() : base("DbCon") //配置使用的连接名
        {
        } 
    
        protected override void OnModelCreating(DbModelBuilder modelBuilder)
        {
            this.Database.Log = msg =>
            {
            };

            modelBuilder.Conventions.Remove<PluralizingTableNameConvention>();
            modelBuilder.Configurations.AddFromAssembly(typeof(RHDWContext).Assembly);

            var sqliteConnectionInitializer = new SqliteCreateDatabaseIfNotExists<RHDWContext>(modelBuilder);
            Database.SetInitializer(sqliteConnectionInitializer); 
            DbInterception.Add(new SqliteInterceptor());//拦截器
            base.OnModelCreating(modelBuilder);
        }

        public DbSet<TaskInfo> TaskInfos { set; get; }

        public DbSet<TxInfo> TxInfos { get; set; }

        public DbSet<SatInfo> SatInfos { get; set; }

        public DbSet<TargetInfo> TargetInfos { get; set; }

        //public DbSet<StationRes> StationRes { get; set; }
        //public DbSet<CxRes> CxRes { get; set; }
        //public DbSet<CgRes> CgRes { get; set; }
        //public DbSet<PosRes> PosRes { get; set; }


        public DbSet<SysSetings> SysSetings { get; set; }


    }

    /// <summary>
    /// 分区表上下文(id为long)
    /// </summary>
    public class RHDWPartContext : DbContext
    {

        /// <summary>
        /// 分区表构造函数
        /// </summary>
        /// <param name="dayStr">db文件名称(含绝对路径)</param>
        public RHDWPartContext(string dbFile)
        {
            string dayStr = Path.GetFileNameWithoutExtension(dbFile);
            FileInfo f = new FileInfo(dbFile);
            var year = Path.GetFileName(f.Directory.Parent.Name);
            Directory.CreateDirectory("DbPart");
            Directory.CreateDirectory($"DbPart\\{year}");
            base.Database.Connection.ConnectionString = $"Data Source=|DataDirectory|\\DbPart\\{year}\\{dayStr}";
        }
        /// <summary>
        /// 分区表构造函数
        /// </summary>
        /// <param name="sigTime">信号时刻</param>
        public RHDWPartContext(DateTime sigTime)
        {
            Directory.CreateDirectory("DbPart");
            Directory.CreateDirectory($"DbPart\\{sigTime.Year}");
            base.Database.Connection.ConnectionString = $"Data Source=|DataDirectory|\\DbPart\\{sigTime.Year}\\{sigTime:MMdd}.db";
        }

        protected override void OnModelCreating(DbModelBuilder modelBuilder)
        {
            this.Database.Log = msg =>
            {
            };

            modelBuilder.Conventions.Remove<PluralizingTableNameConvention>();
            modelBuilder.Configurations.AddFromAssembly(typeof(RHDWPartContext).Assembly);

            var sqliteConnectionInitializer = new SqliteCreateDatabaseIfNotExists<RHDWPartContext>(modelBuilder);
            Database.SetInitializer(sqliteConnectionInitializer);
            DbInterception.Add(new SqliteInterceptor());//拦截器
            base.OnModelCreating(modelBuilder);
        }
        public DbSet<XlInfo> XlInfos { set; get; }
        public DbSet<StationRes> StationRes { get; set; }
        public DbSet<CxRes> CxRes { get; set; }
        public DbSet<CgRes> CgRes { get; set; }
        public DbSet<PosRes> PosRes { get; set; }

    }
}