.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 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 ， 示例如下

  /// <summary>
    /// 根据赛事id、用户id获取用户基本信息
    /// </summary>
    /// <param name="regattaid">赛事id</param>
    /// <param name="userid">用户id</param>
    /// <returns></returns>
    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<bool> 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<list<实体>> 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的示例 本文就讲到这儿，大家可以上官网浏览了解更多：

以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持。