在本章中,將繼續介紹如何利用 EFCore 連接到 MariaDB/MySql 和 PostgreSQL 資料庫,同時,在一個項目中,如何添加多個資料庫上下文對象,併在業務中使用多個上下文對象,通過這兩章的學習,你將掌握使用 EFCore 連接 MSSQL/MariaDB/MySql/Postgre... ...
前言
在上一篇文章中(Asp.Net Core 輕鬆學-10分鐘使用EFCore連接MSSQL資料庫)[https://www.cnblogs.com/viter/p/10243577.html],介紹了 EFCore 連接 MSSQL 的使用方法,在本章中,將繼續介紹如何利用 EFCore 連接到 MariaDB/MySql 和 PostgreSQL 資料庫,同時,在一個項目中,如何添加多個資料庫上下文對象,併在業務中使用多個上下文對象,通過這兩章的學習,你將掌握使用 EFCore 連接 MSSQL/MariaDB/MySql/PostgreSQL 的能力。在 .NETCore 的時代,由於其設計的獨特性(區別於.NetFramework),使得我們非常容易的使用各種開源的、跨平臺的產品和中間件,作為普通程式員,通過廣泛參與和使用開源產品,是我們義不容辭的責任和義務,這種行為將進一步的擴大 .Net Core 的生態圈,進而影響整個開發行業。閑話說完,進入今天的正題,連接第三方資料庫和支持多個上下文對象。
1. 使用 MariaDB/MySql 資料庫
MariaDB基於MySQL並遵循GPL v2授權使用的。 她是由以Monty Program Ab為主要管理者的MariaDB社區開發的。MariaDB與另一分支MySQL最新版保持同步更新。在MariaDB工作與在MySQL下工作幾乎一模一樣,她們有相同的命令、界面,以及在MySQL中的庫與API,所以MariaDB可以說是為替換MySQL量身定做的,所以它們之間是相通用(相容),換用後連資料庫都不必轉換並可以獲得MariaDB提供的許多更好的新特性。
以上介紹來自官方文檔 https://mariadb.com/kb/zh-cn/mariadb-mariadb/
1.1
首先創建一個 Asp.Net Core WebApi 2.2 的項目 Ron.OtherDB,並從 NuGet 倉庫引用包 Pomelo.EntityFrameworkCore.MySql,我本地安裝的資料庫是 MariaDB,從介紹中得知,MariaDB 和 MySql 的使用方式幾乎是完全一致的,所以這裡使用 Pomelo.EntityFrameworkCore.MySql 連接 MariaDB 也是沒有任何問題的
1.2 項目結構和包引用如下
1.3 編寫業務實體
下麵將編寫兩個業務實體 Topic/Post,在本章中,無論是連接 MariaDB/MySql 還是 PostgreSQL,都將使用這兩個實體對象
public class Topic
{
public int Id { get; set; }
public string Title { get; set; }
public string Content { get; set; }
public DateTime CreateTime { get; set; }
public ICollection<Post> Posts { get; set; }
}
public class Post
{
public int Id { get; set; }
public int TopicId { get; set; }
public string Content { get; set; }
public DateTime CreateTime { get; set; }
public Topic Topic { get; set; }
}
1.4 編寫上下文對象
public class MySqlForumContext : DbContext
{
public MySqlForumContext(DbContextOptions<MySqlForumContext> options) : base(options) { }
public DbSet<Topic> Topics { get; set; }
public DbSet<Post> Posts { get; set; }
}
該上下文對象非常簡單,只是聲明瞭一個 MySqlForumContext 對象,然後繼承自 DbContext ,並將 Topic 和 Post 實體對象映射到該上下文中,這個使用方式和之前的文章中連接 MSSQL 資料庫的使用方式是完全一致的,這點非常難得,通過 EFCore,無論你連接到的是哪種類型的資料庫,其 API 的使用方式幾乎是沒有什麼不同的,可以讓開發人員平滑的過渡。
1.5 在 appsetting.json 中配置資料庫連接字元串
{
"Logging": {
"LogLevel": {
"Default": "Warning"
}
},
"AllowedHosts": "*",
"ConnectionStrings": {
"Mysql.Forum": "server=127.0.0.1;port=3406;uid=root;pwd=root;database=Forum;"
}
}
本來上面的連接字元串是無需指定埠的,但是因為使用 Pomelo.EntityFrameworkCore.MySql 組件連接 MySql 預設使用的埠是:3306,而我本機上指定埠為 3406,所以還是需要指定 port=3406。
1.6 在 Startup.cs 中初始化上下文對象
public void ConfigureServices(IServiceCollection services)
{
services.AddDbContext<MySqlForumContext>(options =>
{
var connectionString = this.Configuration["ConnectionStrings:Mysql.Forum"];
options.UseMySql(connectionString);
});
...
}
1.7 創建 Migrations 對象
- 在包管理器控制台輸入以下命令,創建 Migrations 對象
Add-Migration MySql.Forum.v1
- 繼續在包管理器控制臺中輸入以下命令,該命令將會在資料庫中創建實體業務對象 Topic/Post 映射的數據表
Update-Databse
- 打開 MariaDB ,可以看到,資料庫已經成功創建
非常完美,到這一步,你已經完成了使用 EFCore 連接到 MariaDB/MySql 資料庫的過程,先不要急做各種 CURD 的操作,下麵,我們繼續在項目中使用 EFCore 連接 PostgreSQL 資料庫,到最後我們再一起做一個 CURD 的 Demo
2. 使用 PostgreSQL 資料庫
PostgreSQL是一個功能強大的開源資料庫系統。經過長達15年以上的積極開發和不斷改進,PostgreSQL已在可靠性、穩定性、數據一致性等獲得了業內極高的聲譽。目前PostgreSQL可以運行在所有主流操作系統上,包括Linux、Unix(AIX、BSD、HP-UX、SGI IRIX、Mac OS X、Solaris和Tru64)和Windows。PostgreSQL是完全的事務安全性資料庫,完整地支持外鍵、聯合、視圖、觸發器和存儲過程(並支持多種語言開發存儲過程)。它支持了大多數的SQL:2008標準的數據類型,包括整型、數值值、布爾型、位元組型、字元型、日期型、時間間隔型和時間型,它也支持存儲二進位的大對像,包括圖片、聲音和視頻。PostgreSQL對很多高級開發語言有原生的編程介面,如C/C++、Java、.Net、Perl、Python、Ruby、Tcl 和ODBC以及其他語言等,也包含各種文檔
以上介紹來自 PostgreSQL 中文社區:http://www.postgres.cn/v2/about,本人公司的主要業務也是基於 .NetCore+MySql+PostgreSQL,在使用 PostgreSQL 的過程中,發現 PostgreSQL 真的是一個非常強大的資料庫,對我們的業務帶來非常大的幫助,希望大家都能深入的瞭解和使用 PostgreSQL
2.1 首先還是在項目中引用 Npgsql.EntityFrameworkCore.PostgreSQL 包
2.2 編寫上下文對象 NPgSqlForumContext
public class NPgSqlForumContext : DbContext
{
public NPgSqlForumContext(DbContextOptions<NPgSqlForumContext> options) : base(options) { }
public DbSet<Topic> Topics { get; set; }
public DbSet<Post> Posts { get; set; }
}
有沒有發現,上下文對象 NPgSqlForumContext 的結構和上面的 MySqlForumContext 幾乎是一模一樣的
2.3 在配置文件中增加 PostgreSQL 的連接字元串
{
"Logging": {
"LogLevel": {
"Default": "Warning"
}
},
"AllowedHosts": "*",
"ConnectionStrings": {
"Mysql.Forum": "server=127.0.0.1;port=3406;uid=root;pwd=root;database=Forum;",
"Pgsql.Forum": "server=127.0.0.1;port=5432;uid=postgres;pwd=postgres;database=Forum;"
}
}
註意:PostgreSQL 的偵聽的預設埠是:5432
2.4 在 Startup.cs 中初始化上下文對象
public void ConfigureServices(IServiceCollection services)
{
// MariaDB/MySql 上下文初始化
services.AddDbContext<MySqlForumContext>(options =>
{
var connectionString = this.Configuration["ConnectionStrings:Mysql.Forum"];
options.UseMySql(connectionString);
});
// PostgreSQL 上下文初始化
services.AddDbContext<NPgSqlForumContext>(options =>
{
var connectionString = this.Configuration["ConnectionStrings:Pgsql.Forum"];
options.UseNpgsql(connectionString);
});
...
}
2.5 創建 Migrations for PostgreSQL 對象
- 這裡創建 Migrations 的方式和上面的創建 Migrations for MariaDB/MySql 的方式是一樣的,在項目包管理器控制臺中輸入以下命令,創建 Migrations 對象後直接創建資料庫
Add-Migration PostgreSQL.Forum.v1 -Context NPgSqlForumContext
Update-Database -Context NpgSqlForumContext
== 註意:這裡的創建資料庫命令和上面創建 MariaDB/MySql 的命令有一點小小的不同 ==
因為我們現在是在一個項目裡面使用多個上下文對象,在創建 Migrations 的時候, EF 會自動查找匹配的 Context ,但是,由於使用了多個 Context,在執行命令時,必須指定 -Context NpgSqlForumContext,否則,將拋出 More than one DbContext was found. Specify which one to use. Use the '-Context' parameter for PowerShell commands and the '--context' parameter for dotnet commands. 的異常。
- 打開 PostgreSQL 管理工具,發現資料庫 forum 已經成功創建,表結構和 MariaDB/MySql 中創建的 forum 資料庫表完全一致,使用的都是同一個實體業務對象 Topic/Post
到這裡,我們已經完成了使用 EFCore 連接到 PostgreSQL 的過程,在 PostgreSQL 中,由於沒有指定 Schema ,所以預設數據表會被放在 Schema public 下麵,有關更多 PostgreSQL 的 Schema ,請移步官網進一步瞭解,如果希望在創建資料庫的過程中指定 Schema ,可以在實體對象 Topic中應用特性 TableAttribute 進行標記即可,也可以手動修改 Migrations 文件,像下麵這樣
- 使用特性 TableAttribute 進行標記
[Table("topic",Schema ="blogs")]
public class Topic
{
public int Id { get; set; }
public string Title { get; set; }
public string Content { get; set; }
public DateTime CreateTime { get; set; }
public ICollection<Post> Posts { get; set; }
}
- 手動修改 Migrations 文件 Migrations/20190119035709_PostgreSQL.Forum.v1.cs
// 代碼片段,僅需要增加指定 schema:"blogs" 即可
migrationBuilder.CreateTable(
name: "Topics",
schema: "blogs",
columns: table => new
{
Id = table.Column<int>(nullable: false)
.Annotation("Npgsql:ValueGenerationStrategy", NpgsqlValueGenerationStrategy.SerialColumn),
Title = table.Column<string>(nullable: true),
Content = table.Column<string>(nullable: true),
CreateTime = table.Column<DateTime>(nullable: false)
},
constraints: table =>
{
table.PrimaryKey("PK_Topics", x => x.Id);
});
3. 在項目中使用多個上下文
在 Ron.OtherDB 項目中,我們一共創建了兩個 Context ,分別是 MySqlForumContext 和 NPgSqlForumContext,這兩個 Context 可以在項目中一起使用,互不影響
3.1 在 HomeController 註入兩個 Context
private MySqlForumContext mysqlContext;
private NPgSqlForumContext pgsqlContext;
public HomeController(MySqlForumContext mysqlContext, NPgSqlForumContext pgsqlContext)
{
this.mysqlContext = mysqlContext;
this.pgsqlContext = pgsqlContext;
}
``
> 註入的方式非常簡單,和其它類型的註入使用方式沒有區別,就是簡單的在 HomeController 的構造函數中聲明這兩個 Context 對象即可
#####3.2 使用兩個上下文對象進行 CURD 操作
> 下麵將演示使用 MySqlForumContext 和 NPgSqlForumContext 進行簡單的 CURD 操作,這個操作過程和上一篇的 MSSQL 幾乎是完全相同的,代碼比較簡單,就直接貼上來了
[Route("api/[controller]"), ApiController]
public class HomeController : ControllerBase
{
private MySqlForumContext mysqlContext;
private NPgSqlForumContext pgsqlContext;
public HomeController(MySqlForumContext mysqlContext, NPgSqlForumContext pgsqlContext)
{
this.mysqlContext = mysqlContext;
this.pgsqlContext = pgsqlContext;
}
[HttpGet]
public ActionResult Get()
{
// MySql
var mysqlTopics = this.mysqlContext.Topics.ToList();
// PgSql
var pgsqlTopics = this.pgsqlContext.Topics.ToList();
return new JsonResult(new { mysql = mysqlTopics, pgsql = pgsqlTopics });
}
[HttpPost]
public async Task Post([FromBody] TopicViewModel model)
{
// MySql
this.mysqlContext.Topics.Add(new Topic()
{
Content = model.Content,
CreateTime = DateTime.Now,
Title = model.Title
});
await this.mysqlContext.SaveChangesAsync();
// PgSql
this.pgsqlContext.Topics.Add(new Topic()
{
Content = model.Content,
CreateTime = DateTime.Now,
Title = model.Title
});
await this.pgsqlContext.SaveChangesAsync();
}
[HttpPut]
public async Task Put([FromBody] TopicViewModel model)
{
// MySql
var topic = this.mysqlContext.Topics.Where(f => f.Id == model.Id).FirstOrDefault();
topic.Title = model.Title;
topic.Content = model.Content;
await this.mysqlContext.SaveChangesAsync();
// PgSql
var pgTopic = this.pgsqlContext.Topics.Where(f => f.Id == model.Id).FirstOrDefault();
pgTopic.Title = model.Title;
pgTopic.Content = model.Content;
await this.pgsqlContext.SaveChangesAsync();
}
[HttpDelete("{id}")]
public async Task Delete(int id)
{
// MySql
var topic = this.mysqlContext.Topics.Where(f => f.Id == id).FirstOrDefault();
this.mysqlContext.Topics.Remove(topic);
await this.mysqlContext.SaveChangesAsync();
// PgSql
var pgTopic = this.pgsqlContext.Topics.Where(f => f.Id == id).FirstOrDefault();
this.pgsqlContext.Topics.Remove(pgTopic);
await this.pgsqlContext.SaveChangesAsync();
}
}
```
3.3 打開控制台執行 dotnet run
3.4 分別調用 http://localhost:5000/api/home 中的 GET/POST/PUT/DELETE 介面,可以看到,資料庫中可以正常添加和修改數據
- MariaDB/MySql 資料庫結果
- PostgreSQL 資料庫結果
從結果中可以看到,代碼執行正常完成,至此,本文完成
結束語
通過本文學習,我們掌握了以下能力
- 如何在 Asp.NetCore 中使用 EFCore 連接使用 MariaDB/MySql/PostgreSQL 資料庫,
- 如何創建多個 Migrations 對象
- 如何在項目中使用多個不同的上下文對象
演示代碼下載
https://github.com/lianggx/EasyAspNetCoreDemo/tree/master/Ron.OtherDB