netcore dapper mysql_.NET Core Dapper操作mysql数据库
前言
現(xiàn)在ORM盛行，市面上已經(jīng)出現(xiàn)了N款不同的ORM套餐了。今天，我們不談EF，也不聊神馬黑馬，就說說 Dapper。如何在.NET Core中使用Dapper操作Mysql數(shù)據(jù)庫呢，讓我們跟隨鏡頭(手動下翻)一看究竟。
配置篇
俗話說得好，欲要善其事必先利其器。首先，我們要引入MySql.Data 的Nuget包。有人可能出現(xiàn)了黑人臉，怎么引入。也罷，看在你骨骼驚奇的份上，我就告訴你，兩種方式：
第一種方式
Install-Package MySql.Data -Version 8.0.15
復制上面命令行 在程序包管理控制臺中執(zhí)行，什么？你不知道什么是程序包管理控制臺？OMG，也罷，看在你骨骼驚奇的份上，我就告訴你
手點路徑：工具 → NuGet包管理器?→ 程序包管理控制臺
第二種方式
手點路徑：右鍵你需要引入包的項目的依賴項 → 管理NuGet程序包?→ 瀏覽里面輸入MySql.Data
?
直接安裝即可，因為我已經(jīng)安裝過了，所以這里是卸載或者更新
同樣的方式你需要引入：
Microsoft.AspNetCore.All
MySql.Data.EntityFrameworkCore、
Dapper
Microsoft.Extensions.Configuration.Abstractions
Microsoft.Extensions.Configuration.FileExtensions
Microsoft.Extensions.Configuration.Json
教學篇
玩兒過.NET Core 的都知道配置文件我們一般都放在appsettings.json 文件中，但是有個問題，如果我們使用數(shù)據(jù)庫連接字符串，直接存放明文的user name和password，真的安全嗎？這里我們不對安全性做討論，我們在連接字符串中 用占位符控制我們的多數(shù)據(jù)庫情況，然后用userName以及passWord充當我們密碼(后面會被替換掉)，所以看起來是這個樣子：
"ConnectionStrings": {
"DefaultConnection": "server=服務器;port=端口號;database=regatta{0};SslMode=None;uid=userName;pwd=passWord;Allow User Variables=true"
},
接下來，我們新建一個BaseRepository 用于讀取Configuration，以及設置MySqlConnection：
public classBaseRepository : IDisposable
{public static IConfigurationRoot Configuration { get; set; }privateMySqlConnection conn;public MySqlConnection GetMySqlConnection(int regattaId = 0, bool open = true,bool convertZeroDatetime = false, bool allowZeroDatetime = false)
{
IConfigurationBuilder builder= newConfigurationBuilder()
.SetBasePath(Directory.GetCurrentDirectory())
.AddJsonFile("appsettings.json");
Configuration=builder.Build();string cs = Configuration.GetConnectionString("DefaultConnection");
cs= regattaId == 0 ? string.Format(cs, string.Empty) : string.Format(cs, "_" +regattaId.ToString());
cs= cs.Replace("userName", "真正的賬號").Replace("passWord", "真正的密碼");var csb = newMySqlConnectionStringBuilder(cs)
{
AllowZeroDateTime=allowZeroDatetime,
ConvertZeroDateTime=convertZeroDatetime
};
conn= newMySqlConnection(csb.ConnectionString);returnconn;
}
public voidDispose()
{if (conn != null && conn.State !=System.Data.ConnectionState.Closed)
{
conn.Close();
}
}
}
好了，創(chuàng)建完畢，我們該如何使用呢，比方說 現(xiàn)在有個CrewManagerRepository類用于操作數(shù)據(jù)庫，我們只需要讓此類繼承BaseRepository ，示例如下
///
///根據(jù)賽事Id、用戶Id獲取用戶基本信息///
/// 賽事Id
/// 用戶Id
///
public async Task FindUserByAccount(int regattaId, intuserId)
{try{var cmdText =
@"select b.id_number as IdentifierId,b.isvalid as Isvalid,a.name as Name,a.userid as InternalId,a.sex as Sexual,a.sex as SexTypeId,a.age as Age,
c.isprofessional as IsProfessional,c.role_type as RoleTypeId,a.weight as Weight,a.height as Height, a.phone as PhoneNumber,a.thumb_image as ThubmnailImage,
a.image as Image,c.athlete_id as AthleteId from 表1 a left join 表2 b on a.userid=b.id
left join 表3 c on b.id=c.centralid where a.userid=@userId;";
//此處可以根據(jù)傳入的regattaId訪問不同的數(shù)據(jù)庫using (var conn =GetMySqlConnection(regattaId))
{if (conn.State ==ConnectionState.Closed)
{awaitconn.OpenAsync();
}var memberModel =conn
.Query(cmdText, new { userId =userId }, commandType: CommandType.Text)
.FirstOrDefault();return memberModel ?? newMemberDetail();
}
}catch(Exception ex)
{
_logger.LogError(ex,"FindUserByAccount by Id Failed!");throw;
}
}
那有同學可能有黑人臉出現(xiàn)了，如果需要事務呢(露出嘴角的微笑)？
public async Task DeleteXXX(int regattaId, int id, intuserId)
{var result = false;using (var conn =GetMySqlConnection(regattaId))
{if (conn.State ==ConnectionState.Closed)
{awaitconn.OpenAsync();
}using (var transaction =conn.BeginTransaction())
{try{const string sqlDelClub =
@"delete from 表名 where 字段1=@clubId;
delete from 表名2 where 字段2=@clubId;
delete from 表名3 where 字段3=@userId and clubinfo_id=@clubId;";await conn.QueryAsync(sqlDelClub, new{
clubId=id,
userId=userId,
}, commandType: CommandType.Text);
transaction.Commit();
result= true;
}catch(Exception e)
{
Console.WriteLine(e);
transaction.Rollback();
result= false;throw;
}
}returnresult;
}
}
這樣，用Transaction將執(zhí)行代碼塊包起來，如果出現(xiàn)異常，在catch中 進行Rollback(回滾事務)，就可以保證了數(shù)據(jù)的一致性。如果是高并發(fā)場景，可能還會需要用到鎖，這里暫時不做延伸討論。
如果是返回集合，也很容易處理：
public async Task> GetClubsByUserId(int regattaId, intuserId)
{using (var conn =GetMySqlConnection(regattaId))
{if (conn.State ==ConnectionState.Closed)
{awaitconn.OpenAsync();
}const string sql =
@"select b.club_id as id,c.name,c.image as ImageData,c.year,c.address,c.creator,c.description,b.contact ,b.phone,b.isvalid from 表1 a left join 表2 b on
a.clubinfo_id=b.club_id left join 表3 c on
b.clubbase_id=c.club_id where a.authorize_userid=@user_Id";
List clubDetailList =(await conn.QueryAsync(sql, new { user_Id =userId }, commandType: CommandType.Text))
.ToList();returnclubDetailList;
}
}
關于Dapper的示例 本文就講到這兒，大家可以上官網(wǎng)瀏覽了解更多：
本文完
總結
以上是生活随笔為你收集整理的netcore dapper mysql_.NET Core Dapper操作mysql数据库的全部內容，希望文章能夠幫你解決所遇到的問題。
- 上一篇： navicat 8 mysql生成关系_
- 下一篇： mysql 线程缓存_浅析MySQL内存