ctrl_c + ctrl_v 出来的四不像 （二） -- 连接Mysql

 1  public class DbConnection
 2     {
 3         [System.ComponentModel.DataAnnotations.Key]
 4         public string Key { get; set; }
 5         
 6         public string Server { get; set; }
 7 
 8         public string Userid { get; set; }
 9 
10         public string Pwd { get; set; }
11 
12         public string Port { get; set; }
13 
14         public string Database { get; set; }
15 
16         public string Timeout { get; set; }
17 
18         public string MaximumPoolSize { get; set; }
19 
20         public string MinimumPoolSize { get; set; }
21     }

 1     public class MySqlConnectionFormat : IDbConnectionFormat
 2     {
 3         /// <summary>
 4         /// 默认的MySQL的链接字符串
 5         /// </summary>
 6         private const string DefaultMySqlConnectionString = "server={0};userid={1};pwd={2};port={3};database={4};SslMode=none;DefaultCommandTimeout={5};ConnectionTimeout={5};MaximumPoolSize={6};MinimumPoolSize={7};";
 7 
 8         
 9         public string GetConnection(DbConnection dbConnection)
10         {
11             return string.Format(
12                 DefaultMySqlConnectionString,
13                 dbConnection.Server,
14                 dbConnection.Userid,
15                 dbConnection.Pwd,
16                 dbConnection.Port,
17                 dbConnection.Database,
18                 dbConnection.Timeout,
19                 dbConnection.MaximumPoolSize,
20                 dbConnection.MinimumPoolSize);
21         }
22 
23         public DbContextOptions<DbConnectionContext> GetDbContextOptions(string context)
24         {
25             // 暂时不实现
26             throw new System.NotImplementedException();
27         }
28     }

 1     public class DbConnectionContext : DbContext
 2     {
 3         public DbConnectionContext(DbContextOptions<DbConnectionContext> options)
 4             : base(options)
 5         {
 6              this.Database.EnsureCreated();
 7         }
 8 
 9         public DbConnectionContext(string connectionStirng)
10             : this(new DbContextOptionsBuilder<DbConnectionContext>().UseMySQL(connectionStirng).Options)
11         {
12         }
13 
14         public DbSet<DbConnection> DbConnection { get; set; }
15         public DbSet<RedisConnection> RedisConnection { get; set; }
16     }