netcore dapper mysql_.NET Core Dapper操作mysql数据库
前言
现在ORM盛行,市面上已经出现了N款不同的ORM套餐了。今天,我们不谈EF,也不聊神马黑马,就说说 Dapper。如何在.NET Core中使用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 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();
}
}
}
好了,创建完毕,我们该如何使用呢,比方说 现在有个CrewManagerRepository类用于操作数据库,我们只需要让此类继承BaseRepository ,示例如下
///
///根据赛事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;";
//此处可以根据传入的regattaId访问不同的数据库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;
}
}
那有同学可能有黑人脸出现了,如果需要事务呢(露出嘴角的微笑)?
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将执行代码块包起来,如果出现异常,在catch中 进行Rollback(回滚事务),就可以保证了数据的一致性。如果是高并发场景,可能还会需要用到锁,这里暂时不做延伸讨论。
如果是返回集合,也很容易处理:
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的示例 本文就讲到这儿,大家可以上官网浏览了解更多:
本文完
netcore dapper mysql_.NET Core Dapper操作mysql数据库相关推荐
- dapper mysql_.NET Core Dapper操作mysql数据库
.NET Core Dapper操作mysql数据库 发布时间:2019-04-25 19:48, 浏览次数:744 , 标签: NET Core Dapper mysql 前言 现在ORM盛行,市面 ...
- dapper mysql_.NET Core Dapper操作mysql数据库的实现方法
前言 现在ORM盛行,市面上已经出现了N款不同的ORM套餐了.今天,我们不谈EF,也不聊神马黑马,就说说 Dapper.如何在.NET Core中使用Dapper操作Mysql数据库呢,让我们跟随镜头 ...
- tsql和mysql_使用TSQL语句操作MySQL数据库
使用TSQL语句创建数据库 以前用的是鼠标在界面上手动创建,这样创建会比较麻烦,而且还会经常出问题.在其它电脑上要用的话还需要重复操作.所以要使用程序代码操作,能通过代码的就不用手动操作. 在数据库界 ...
- Dapper操作MySQL数据库获取JSON数据中文乱码
在项目中利用Dapper将JSON数据存储到MySQL数据库,结果发现JSON数据中的中文乱码,特此记录,希望对存储JSON的童鞋能有所帮助,文中若有错误之处,还望批评指正. 为了引出最终问题出在什么 ...
- ubuntu swift mysql_使用 Swift 3.0 操作 MySQL 数据库
作者:Joe,原文链接,原文日期:2016-09-24 译者:shanks:校对:walkingway:定稿:CMB 如果你阅读过本主其他的 Swift 文章,你会发现我们是 Swift 服务器端开发 ...
- Python FastAPI 框架 操作Mysql数据库 增删改查
2 比 1 更容易理解,可以先看2(单文件级别) 1.FastAPI 框架 操作Mysql数据库(项目多文件级别) FastAPI 可以使用任何您想要的关系型数据库. 在这里,让我们看一个使用着SQL ...
- c语言连接数据库例子,c语言操作mysql数据库小例子_互帮互助(C language MySQL database operation example _ mutual help).doc...
这是精心收集的精品经典资料,值得下载保存阅读! c语言操作mysql数据库小例子_互帮互助(C language MySQL database operation example _ mutual h ...
- c 获取mysql列数据_转 用C API 操作MySQL数据库
用C API 操作MySQL数据库 参考MYSQL的帮助文档整理 这里归纳了C API可使用的函数,并在下一节详细介绍了它们.请参见25.2.3节,"C API函数描述". 函数 ...
- php使用pdo操作mysql数据库实例_php5使用pdo连接数据库实例
本文为大家介绍下php pdo的用法. 一,pdo简介 pdo(php data object) 是php 5 中加入的东西,是php 5新加入的一个重大功能,因为在php 5以前的php4/php3 ...
最新文章
- 第六章:内核数据结构
- 一文概览主要语义分割网络:FCN,SegNet,U-Net...
- 使用CSDN的Markdown编辑器
- 【算法】一个简单的决策树(DT)原理
- 光电转换器有什么作用?光纤收发器如何保养?
- riak php7,Laravel中服务提供者的register和boot分别是干什么
- 数据分析转软件测试,(转)性能测试用户模型(三):基础数据分析、场景数据...
- cms系统和管理员系统区别_如何成为懒惰的系统管理员
- Spark-Streaming
- Linux 启动流程学习
- Git详解(1)——Git起步
- hdu 3829 最大独立集
- 知识产权代理行业公司竞争分析
- jQuery和CSS3超酷二级下拉菜单插件
- vue:高德地图的使用
- Airspace smoothing
- JS 将手机号中间四位变为****号的四种方式
- 2022最新酒桌小游戏小程序源码(附带流量主)
- 【cv君个人整理学习路线】视觉算法从入门到进阶
- 时间序列分析深入总结(一)(附代码)
热门文章
- 食品新消费的2021:站在逻辑跑通与成为品牌的隧道期
- 快手“连横”京东,是志同道合还是抱团取暖?
- mysql left day 7_day7-mysql函数
- php 半角全角,PHP 全角转半角实现代码
- mysql5.7 archive安装_对于Mysql 5.7.19 winx64 ZIP Archive的运用安装详细说明
- 爬虫 无访问权限“_Windows10电脑系统共享打印机无访问权限解决方法
- 在python函数中参数分类的详细教程
- Python基础教程:列表推导式对比For循环执行效率
- python计算文件md5值
- python装饰器实现对异常代码出现进行监控