这期内容当中小编将会给大家带来有关怎么在.NET中使用Dapper操作mysql数据库，文章内容丰富且以专业的角度为大家分析和叙述，阅读完这篇文章希望大家可以有所收获。
创新互联建站网站建设服务商，为中小企业提供成都网站设计、做网站、
成都外贸网站建设公司服务，网站设计，
绵阳服务器托管等一站式综合服务型公司，专业打造企业形象网站，让您在众多竞争对手中脱颖而出
创新互联建站。
引入MySql.Data 的Nuget包。有人可能出现了黑人脸，怎么引入。也罢，看在你骨骼惊奇的份上，我就告诉你，两种方式：
第一种方式
Install-Package MySql.Data -Version 8.0.15
复制上面命令行 在程序包管理控制台中执行，什么？你不知道什么是程序包管理控制台？OMG，也罢，看在你骨骼惊奇的份上，我就告诉你
手点路径：工具 → NuGet包管理器 → 程序包管理控制台
第二种方式
手点路径：右键你需要引入包的项目的依赖项 → 管理NuGet程序包 → 浏览里面输入 MySql.Data
直接安装即可，因为我已经安装过了，所以这里是卸载或者更新
同样的方式你需要引入：
Microsoft.AspNetCore.All
MySql.Data.EntityFrameworkCore、
Dapper
Microsoft.Extensions.Configuration.Abstractions
Microsoft.Extensions.Configuration.FileExtensions
Microsoft.Extensions.Configuration.Json
教学篇
玩儿过.NET Core 的都知道配置文件我们一般都放在appsettings.json 文件中，但是有个问题，如果我们使用数据库连接字符串，直接存放明文的user name和password，真的安全吗？这里我们不对安全性做讨论，我们在连接字符串中 用占位符控制我们的多数据库情况，然后用userName以及passWord充当我们密码（后面会被替换掉），所以看起来是这个样子：
"ConnectionStrings": {
"DefaultConnection": "server=服务器;port=端口号;database=regatta{0};SslMode=None;uid=userName;pwd=passWord;Allow User Variables=true"
},接下来，我们新建一个BaseRepository 用于读取Configuration，以及设置MySqlConnection：
public class BaseRepository : IDisposable
{
public static IConfigurationRoot Configuration { get; set; }
private MySqlConnection conn;
public MySqlConnection GetMySqlConnection(int regattaId = 0, bool open = true,
bool convertZeroDatetime = false, bool allowZeroDatetime = false)
{
IConfigurationBuilder builder = new ConfigurationBuilder()
.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 = new MySqlConnectionStringBuilder(cs)
{
AllowZeroDateTime = allowZeroDatetime,
ConvertZeroDateTime = convertZeroDatetime
};
conn = new MySqlConnection(csb.ConnectionString);
return conn;
}
public void Dispose()
{
if (conn != null && conn.State != System.Data.ConnectionState.Closed)
{
conn.Close();
}
}
}好了，创建完毕，我们该如何使用呢，比方说 现在有个CrewManagerRepository类用于操作数据库，我们只需要让此类继承BaseRepository ， 示例如下
///
/// 根据赛事Id、用户Id获取用户基本信息
///
/// 赛事Id
/// 用户Id
///
public async Task<实体对象> FindUserByAccount(int regattaId, int userId)
{
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;";
//此处可以根据传入的regattaId访问不同的数据库
using (var conn = GetMySqlConnection(regattaId))
{
if (conn.State == ConnectionState.Closed)
{
await conn.OpenAsync();
}
var memberModel = conn
.Query<实体对象>(cmdText, new { userId = userId }, commandType: CommandType.Text)
.FirstOrDefault();
return memberModel ?? new MemberDetail();
}
}
catch (Exception ex)
{
_logger.LogError(ex, "FindUserByAccount by Id Failed!");
throw;
}
}
那有同学可能有黑人脸出现了，如果需要事务呢（露出嘴角的微笑）？
public async Task DeleteXXX(int regattaId, int id, int userId)
{
var result = false;
using (var conn = GetMySqlConnection(regattaId))
{
if (conn.State == ConnectionState.Closed)
{
await conn.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;
}
}
return result;
}
}
这样，用Transaction将执行代码块包起来，如果出现异常，在catch中 进行Rollback(回滚事务)，就可以保证了数据的一致性。如果是高并发场景，可能还会需要用到锁，这里暂时不做延伸讨论。
如果是返回集合，也很容易处理：
public async Task> GetClubsByUserId(int regattaId, int userId)
{
using (var conn = GetMySqlConnection(regattaId))
{
if (conn.State == ConnectionState.Closed)
{
await conn.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();
return clubDetailList;
}
}
上述就是小编为大家分享的怎么在.NET中使用Dapper操作mysql数据库了，如果刚好有类似的疑惑，不妨参照上述分析进行理解。如果想知道更多相关知识，欢迎关注创新互联行业资讯频道。
网站栏目：怎么在.NET中使用Dapper操作mysql数据库-创新互联
链接URL：
http://bzwzjz.com/article/djsddo.html
