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 Task> SqlQueryAsync(string sql) { return this.Database.SqlQuery(sql).ToListAsync(); } public Task SqlQueryOneAsync(string sql) { return this.Database.SqlQuery(sql).FirstOrDefaultAsync(); } protected override void OnModelCreating(DbModelBuilder modelBuilder) { this.Database.Log = msg => { }; //modelBuilder.Conventions.Remove(); //modelBuilder.Configurations.AddFromAssembly(typeof(RHDWContext).Assembly);//自动加载Entity-Type //var sqliteConnectionInitializer = new SqliteCreateDatabaseIfNotExists(modelBuilder); //Database.SetInitializer(sqliteConnectionInitializer); base.OnModelCreating(modelBuilder); } public DbSet XlInfos { set; get; } public DbSet TaskInfos { set; get; } public DbSet TaskSigs { set; get; } public DbSet TxInfos { get; set; } public DbSet SatInfos { get; set; } public DbSet FixedStation { get; set; } public DbSet SigInfos { get; set; } public DbSet SigDelays { get; set; } public DbSet TargetInfos { get; set; } public DbSet SysSetings { get; set; } public DbSet TaskRunnningInfos { get; set; } //以下为Range分区表 public DbSet LogRes { set; get; } public DbSet StationRes { get; set; } public DbSet CxRes { get; set; } public DbSet CgRes { get; set; } public DbSet CgXgfRes { get; set; } public DbSet PosRes { get; set; } public DbSet CheckRes { get; set; } } }