<u id="4do2l"><sub id="4do2l"></sub></u><u id="4do2l"><sub id="4do2l"></sub></u>
<u id="4do2l"><sub id="4do2l"></sub></u>

<u id="4do2l"><sub id="4do2l"></sub></u>

<u id="4do2l"></u>

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

最新下载

.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/

文章评论

热门栏目

201967期开奖记录 佛冈县| 岗巴县| 庆元县| 庆云县| 凭祥市| 卢龙县| 永川市| 张北县| 南岸区| 双峰县| 永丰县| 辽中县| 大埔区| 望城县| 鄱阳县| 长葛市| 万安县| 通江县| 涪陵区| 黄大仙区| 顺义区| 玛沁县| 聂荣县| 西宁市| 五大连池市| 定陶县| http://lwswzch.tw 县级市| 遂川县| 庆阳市| 峨山| 工布江达县| 清水县| 疏勒县| 曲水县| 中西区| 禹城市| 隆子县| 彰化市| 万载县| 资溪县| 江西省| 阜城县| 江阴市| 重庆市| 饶平县| 麻栗坡县| 罗定市| 陕西省| 河北区| 封开县| 昌邑市| 梁平县| 平原县| 武强县| 白沙| http://qcohxfz.tw 临沭县| 郑州市| 太康县| 丽水市| 颍上县| 桃园市| 安陆市| 柳河县| 阿巴嘎旗| 寻乌县| 五莲县| 炉霍县| 泾阳县| 公主岭市| 仪陇县| 广西| 柯坪县| 乡宁县| 乌拉特后旗| 科尔| 平远县| 尉犁县| 江津市| 陵川县| 永安市| 安庆市| 长治县| 丘北县| 民丰县| 武义县| 东光县| 阿城市| 宁海县| 荔波县| http://j6n5q8.com 仙桃市| 香格里拉县| 永修县| 韶山市| 绥德县| 平山县| 腾冲县| 杭锦后旗| 资阳市| 吴旗县| 奉节县| 英超| 临海市| 宁安市| 竹北市| 尼玛县| 金堂县| 新宾| 海淀区| 延边| 廊坊市| 昭觉县| 金川县| 荆州市| 那曲县| 黑山县| 内黄县| 枣强县| 县级市| http://www.bscjvm.cn 越西县| 普宁市| 田阳县| 通河县| 黄大仙区| 库尔勒市| 罗江县| 黄骅市| 兴宁市| 鲁甸县| 栾川县| 衡阳市| 阿巴嘎旗| 那曲县| 文昌市| 光山县| 绥阳县| 黄浦区| 无为县| 厦门市| 吐鲁番市| 钟山县| 滦平县| 沾化县| 色达县| 民和| 永靖县| 青铜峡市| 滨州市| http://www.oap2862.co 九台市| 卫辉市| 静海县| 诸暨市| 稷山县| 隆回县| 鄂托克旗| 沂源县| 河曲县| 无棣县| 永顺县| 乌兰浩特市| 湄潭县| 如东县| 博湖县| 衡水市| 东海县| 若羌县| 驻马店市| 报价| 保康县| 津市市| 高碑店市| 呼图壁县| 溧阳市| 武城县| 西华县| 鄂伦春自治旗| http://5q99c1.com 壤塘县| 丹棱县| 长岭县| 镇安县| 普兰店市| 佛坪县| 阳曲县| 丘北县| 兴文县| 永清县| 昆山市| 梧州市| 青海省| 洪江市| 辽阳市| 内江市| 腾冲县|