一聚教程网:一个值得你收藏的教程网站

                          最新下载

                          .NET Core Dapper操作mysql数据库的实现教程

                          时间:2019-05-06 17:53:09 编辑:猪哥 来源:转载

                          现在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 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;
                                }
                              }
                          
                          

                          关于Dapper的示例 本文就讲到这儿,大家可以上官网浏览了解更多:

                          https://dapper-tutorial.net/

                          文章评论

                          热门栏目

                          正版资料大全201966期 屏南县| 含山县| 浑源县| 长治市| 绵阳市| 大冶市| 五原县| 郴州市| 定州市| 江门市| 岐山县| 林口县| 诸城市| 密云县| 福鼎市| 宜阳县| 巴中市| 鸡泽县| 庆阳市| 建阳市| 卫辉市| 绩溪县| 万年县| 汾阳市| 河曲县| 佳木斯市| http://25476278.cn 苍溪县| 犍为县| 农安县| 洱源县| 淄博市| 黎城县| 兴文县| 丰县| 忻城县| 绥化市| 佛山市| 康马县| 兰溪市| 招远市| 修文县| 布拖县| 彭阳县| 桓台县| 绥宁县| 大荔县| 盈江县| 西宁市| 鸡泽县| 竹北市| 安泽县| 高尔夫| 海原县| 华蓥市| 南汇区| http://www.qbhcgl.com 治多县| 海口市| 胶州市| 拉孜县| 佳木斯市| 家居| 东平县| 霍城县| 辉南县| 岑溪市| 木里| 瑞安市| 诸城市| 囊谦县| 新竹县| 衢州市| 抚州市| 蓝山县| 四会市| 毕节市| 罗甸县| 云阳县| 石泉县| 黄龙县| 临澧县| 莱西市| 永吉县| 通化市| 丹寨县| 郑州市| 东光县| 新乡县| 华池县| 西林县| http://phzmwxb.tw 西华县| 尼木县| 辛集市| 商河县| 仁布县| 杭锦旗| 枣庄市| 双流县| 金昌市| 福建省| 抚远县| 金华市| 开化县| 漠河县| 五寨县| 石柱| 漾濞| 龙陵县| 汝城县| 固始县| 苍山县| 琼中| 仪陇县| 鄄城县| 鞍山市| 葵青区| 江北区| 德惠市| 福贡县| http://wywyvj.cn 黎平县| 滦平县| 德兴市| 华蓥市| 肃北| 元谋县| 阿拉善右旗| 怀集县| 绥德县| 改则县| 富川| 金堂县| 广东省| 内黄县| 潍坊市| 沂南县| 治县。| 长泰县| 北宁市| 平谷区| 千阳县| 淮阳县| 宝应县| 甘肃省| 新安县| 巍山| 雷州市| 鲜城| 桓台县| http://www.ahc9055.co 黎平县| 呼和浩特市| 鄢陵县| 曲松县| 观塘区| 松原市| 合肥市| 镇平县| 博白县| 天全县| 道孚县| 会东县| 巴青县| 黎平县| 吉首市| 新蔡县| 尚志市| 烟台市| 博野县| 威远县| 绍兴县| 陇南市| 烟台市| 广南县| 舒兰市| 马山县| 望都县| 临沂市| http://cag561.co 鱼台县| 玉龙| 巴彦淖尔市| 罗甸县| 盐山县| 长宁区| 扬中市| 苍南县| 亳州市| 南康市| 南汇区| 洮南市| 昌江| 古蔺县| 平顶山市| 莲花县| 彭阳县|