.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的示例 本文就讲到这儿,大家可以上官网浏览了解更多:

https://dapper-tutorial.net/

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

(0)

相关推荐

  • .net core利用orm如何操作mysql数据库详解

    前言 众所周知Mysql数据库由于其体积小.速度快.总体拥有成本低,尤其是开放源码这一特点,许多中小型网站为了降低网站总体拥有成本而选择了MySQL作为网站数据库.MySQL是一个多用户.多线程的关系型数据库管理系统. 工作模式是基于客户机/服务器结构.目前它可以支持几乎所有的操作系统. 简单的来说 ,MySql是一个开放的.快速的.多线程的.多用户的SQL数据库服务器. 下面讲解如何在.net core中使用mysql数据库,分享出来供大家参考学习,下面话不多说了,来一起看看详细的介绍吧. 操

  • Asp.net Core 1.1 升级后操作mysql出错的解决办法

    遇到问题 core的版本从1.0升级到1.1,操作mysql数据库,查询数据时遇到MissingMethodException问题,更新.插入操作没有问题. 如果你也遇到这个问题,请参照以下步骤进行升级操作. 操作步骤及内容 如果你的项目已经引用过以下几部分内容,请依次升级内容: PM> Update-Package Microsoft.EntityFrameworkCore PM> Update-Package Microsoft.EntityFrameworkCore.SqlServer

  • .NET Core Dapper操作mysql数据库的实现方法

    前言 现在ORM盛行,市面上已经出现了N款不同的ORM套餐了.今天,我们不谈EF,也不聊神马黑马,就说说 Dapper.如何在.NET Core中使用Dapper操作Mysql数据库呢,让我们跟随镜头(手动下翻)一看究竟. 配置篇 俗话说得好,欲要善其事必先利其器.首先,我们要引入MySql.Data 的Nuget包.有人可能出现了黑人脸,怎么引入.也罢,看在你骨骼惊奇的份上,我就告诉你,两种方式: 第一种方式 Install-Package MySql.Data -Version 8.0.15

  • 在.NetCore(C#)中使用ODP.NET Core+Dapper操作Oracle数据库

    前言 虽然一直在说"去IOE化",但是在国企和政府,Oracle的历史包袱实在太重了,甚至很多业务逻辑都是写在Oracle的各种存储过程里面实现的-- 我们的系统主要的技术栈是Django / Spring / AspNetCore,Java的不必说对Oracle支持肯定没问题,关键在于Django对Oracle版本有要求,兼容性不是特别好,Oracle版本没办法随意升级的,所以我想到用.Net Core来写个中间层,让其他系统可以方便的使用Oracle的数据和存储过程- ODP.NE

  • PHP使用mysqli操作MySQL数据库的简单方法

    PHP的 mysqli 扩展提供了其先行版本的所有功能,此外,由于 MySQL 已经是一个具有完整特性的数据库服务器 , 这为PHP 又添加了一些新特性 . 而 mysqli 恰恰也支持了这些新特性. 一. 建立和断开连接 与 MySQL数据库交互时,首先要建立连接,最后要断开连接,这包括与服务器连接并选择一个数据库 , 以及最后关闭连接 .与 mysqli 几乎所有的特性一样 , 这一点可以使用面向对象的方法来完成,也可以采用过程化的方式完成. 1. 创建一个 mysqli 的对象 $_mys

  • 用C语言操作MySQL数据库的通用方法

    在我们的web应用中,虽然PHP.JSP等脚本均提供了MySQL的接口,但是显然直接使用C语言具有更好的安全性和性能,在这篇文章中能够有所体现. 先看结构体: 以下代码块是用来连接数据库的通讯过程,要连接MYSQL,必须建立MYSQL实例,通过mysql_init初始化方能开始进行连接. typedef struct st_mysql { NET net; /* Communication parameters */ gptr connector_fd; /* ConnectorFd for S

  • Spring Boot中使用jdbctemplate 操作MYSQL数据库实例

    最近在学习使用Spring Boot连接数据库,今天学习了使用jdbctemplate 操作MYSQL数据库,下面就留个笔记 不废话,先来代码 pom文件: <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org

  • 详解spring开发_JDBC操作MySQL数据库

    本文介绍spring开发_JDBC操作MySQL数据库,具体如下: 项目结构: 数据库表: /spring_1100_spring+jdbc/src/com/b510/bean/Person.java package com.b510.bean; /** * 普通的javaBean类Person * * @author Hongten * */ public class Person { /** * id号 */ private int id; /** * 姓名 */ private Strin

  • Python操作MySQL数据库的两种方式实例分析【pymysql和pandas】

    本文实例讲述了Python操作MySQL数据库的两种方式.分享给大家供大家参考,具体如下: 第一种 使用pymysql 代码如下: import pymysql #打开数据库连接 db=pymysql.connect(host='1.1.1.1',port=3306,user='root',passwd='123123',db='test',charset='utf8') cursor=db.cursor()#使用cursor()方法获取操作游标 sql = "select * from tes

  • ASP.NET操作MySql数据库的实例代码讲解

    一.把MySql.Data.dll放到BIN目录下. 二.这是aspx.cs的全部源码,修改参数直接运行即可!   using MySql.Data.MySqlClient; using System; using System.Collections.Generic; using System.Data; using System.Linq; using System.Web; using System.Web.UI; using System.Web.UI.WebControls; publ

  • php简单操作mysql数据库的类

    本文实例讲述了php简单操作mysql数据库的类.分享给大家供大家参考.具体如下: <?php /** * Database class * * @version: 2.2 * @revised: 27 may 2007 * **/ class Database { var $host; var $name; var $user; var $pass; var $prefix; var $linkId; function Database($mysql) { foreach($mysql as

随机推荐