XdCxRhDW/XdCxRhDW.Repostory/EFContext/MySqlContext.cs

using MySql.Data.EntityFramework;
using MySql.Data.MySqlClient;
using System;
using System.Collections.Generic;
using System.Configuration;
using System.Data.Common;
using System.Data.Entity;
using System.Data.Entity.ModelConfiguration.Conventions;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using XdCxRhDW.Entity;
using XdCxRhDW.Framework;

namespace XdCxRhDW.Repostory
{
    [DbConfigurationType(typeof(MySqlConfiguration))]
    public class MySqlContext: DbContext
    {
        public MySqlContext()
        : base(AppConfigHelper.GetConnectionString("MySql"))
        {
            //base的构造函数如果使用name则ConnectionString配置中必须包含providerName="MySql.Data.MySqlClient"、
            //为了方便用户配置连接这里直接使用连接字符串而不是连接字符串的name
        }
        public MySqlContext(string connectionString)
            :base(connectionString) 
        { 
        }
        public Task<List<T>> SqlQueryAsync<T>(string sql)
        {
            return this.Database.SqlQuery<T>(sql).ToListAsync();
        }
        public Task<int> ExecuteSqlCommandAsync(string sql)
        {
            return this.Database.ExecuteSqlCommandAsync(sql);
        }
        public Task<T> SqlQueryOneAsync<T>(string sql)
        {
            return this.Database.SqlQuery<T>(sql).FirstOrDefaultAsync();

        }
        protected override void OnModelCreating(DbModelBuilder modelBuilder)
        {
            //this.Database.Log = msg =>
            //{
            //};
            modelBuilder.Properties<DateTime>()
                .Configure(c => c.HasPrecision(3)); // 3 表示毫秒精度

            modelBuilder.Entity<XlInfo>()
                .HasIndex(p => new { p.SatCode, p.TimeUTC })
                .HasName("IX_XlInfo_SatCode_TimeUTC");
            modelBuilder.Entity<XlInfo>()
                .HasIndex(p => p.SatCode)
                .HasName("IX_XlInfo_SatCode");
            modelBuilder.Entity<XlInfo>()
                .HasIndex(p => p.TimeUTC)
                .HasName("IX_XlInfo_TimeUTC");

            modelBuilder.Entity<TaskInfo>()
                .HasIndex(p => p.UpdateTime)
                .HasName("IX_TaskInfo_UpdateTime");

            modelBuilder.Entity<LogRes>()
                .HasIndex(p => p.Module)
                .HasName("IX_LogRes_Module");

            modelBuilder.Entity<LogRes>()
                .HasIndex(p => p.LogTime)
                .HasName("IX_LogRes_LogTime");

            modelBuilder.Entity<LogRes>()
                .HasIndex(p => p.LogType)
                .HasName("IX_LogRes_LogType");

            modelBuilder.Entity<LogRes>()
                .HasIndex(p => p.Deleted)
                .HasName("IX_LogRes_Deleted");

            modelBuilder.Entity<StationRes>()
                .HasIndex(p => p.Deleted)
                .HasName("IX_StationRes_Deleted");
            
            modelBuilder.Entity<CxRes>()
                .HasIndex(p => p.Deleted)
                .HasName("IX_CxRes_Deleted");

            modelBuilder.Entity<CgRes>()
                .HasIndex(p => p.Deleted)
                .HasName("IX_CgRes_Deleted");

            modelBuilder.Entity<PosRes>()
                .HasIndex(p => p.Deleted)
                .HasName("IX_PosRes_Deleted");

            modelBuilder.Entity<CgXgfRes>()
                .HasIndex(p => p.Deleted)
                .HasName("IX_CgXgfRes_Deleted");

            modelBuilder.Entity<CheckRes>()
                .HasIndex(p => p.Deleted)
                .HasName("IX_CheckRes_Deleted");

            base.OnModelCreating(modelBuilder);
        }
        public DbSet<XlInfo> XlInfos { set; get; }

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

        public DbSet<TaskSig> TaskSigs { set; get; }

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

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

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

        public DbSet<SigInfo> SigInfos { get; set; }

        public DbSet<SigDelay> SigDelays { get; set; }

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

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

        public DbSet<TaskRunnningInfo> TaskRunnningInfos { get; set; }

        //以下为Range分区表
        public DbSet<LogRes> LogRes { set; get; }
        public DbSet<StationRes> StationRes { get; set; }
        public DbSet<CxRes> CxRes { get; set; }
        public DbSet<CgRes> CgRes { get; set; }
        public DbSet<CgXgfRes> CgXgfRes { get; set; }
        public DbSet<PosRes> PosRes { get; set; }
        public DbSet<CheckRes> CheckRes { get; set; }
    }
}