用轻量级ORM--Dapper实现泛型仓储

2023-12-29 20:44
文章标签 实现 泛型 轻量级 orm 仓储 dapper

本文主要是介绍用轻量级ORM--Dapper实现泛型仓储，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

阅读本文你的收获

  1. 了解Dapper的适用场景
  2. 了解Dapper的本质其实是一些扩展方法
  3. 学会使用Dapper的扩展Domel来实现泛型仓储

一、什么是Dapper？

Dapper是一个轻量级的ORM（对象关系映射）工具，用于简化数据库操作。它和Entity Framework 不同，它属于轻量级的，并且是半自动的。

Dapper的优势：

  • Dapper非常小巧，只有一个帮助类，完全开源。
  • Dapper以性能优异著称。一般的ORM框架，性能和直接写原生的SQL语句比都差不少，但是Dapper执行SQL语句的性能非常好。

Dapper的使用场景：

  1. 快速的数据访问：Dapper提供了简单、快速的方法来执行数据库查询操作，可以有效地减少代码量和开发时间。

  2. 大数据量的操作：Dapper在处理大数据量的操作时表现出色，相比其他ORM工具，它具有更低的内存占用和更高的性能。

  3. 原始SQL查询：Dapper允许开发人员编写和执行原生SQL查询，可以灵活地处理复杂的查询需求。

  4. 存储过程的调用：Dapper支持存储过程的调用，并提供了简便的方式来执行存储过程并获取返回结果。

总之，Dapper适用于需要快速、高性能的数据访问的场景，尤其适用于对数据库操作要求较高的应用程序。

二、Dapper的本质

Dapper库对IDbConnection接口扩展了许多方法，使得与数据库交互变得更加方便和高效。下面是Dapper中定义的Query方法，它是一个扩展方法，扩展的目标类型是IDbConnection。

public static IEnumerable<T> Query<T>(this IDbConnection cnn, string sql, object param = null, IDbTransaction transaction = null, bool buffered = true, int? commandTimeout = null, CommandType? commandType = null)

以下是Dapper扩展的一些常用方法（包括但不限于）：

  1. Query方法：用于执行SQL查询并返回结果集。
  2. QueryFirstOrDefault方法：用于执行SQL查询并返回结果集中的第一行记录，如果结果集为空则返回默认值。
  3. QuerySingleOrDefault方法：用于执行SQL查询并返回唯一一条记录，如果结果集为空则返回默认值。
  4. Execute方法：用于执行SQL语句并返回受影响的行数。
  5. ExecuteScalar方法：用于执行SQL语句并返回受影响的行数。

这些方法还有与之对应的异步方法（Async结尾的方法）。

此外，Dapper还提供了一些类型用于处理与参数有关的操作，例如：DynamicParameters类：用于动态创建参数。该类的Add方法：用于向参数集合中添加参数，而Get方法：用于获取参数的值。

三、Dapper的入门案例

开发环境：

平台版本是：.NET6
开发框架：ASP.NET Core WebApi
开发工具：Visual Studio 2022
数据库版本：MS SQL Server 2014

3.1 安装Dapper

通过NuGet包管理器安装Dapper
安装Dapper

3.2 用Dapper执行SQL语句

以下案例用Dapper实现查询用户是否存在。

//头上引用命名空间
using Dapper;//获取连接字符串（本例中是硬编码的，最好写在appsettings.json中）
private const string CONNECT_STRING = "Data Source=.;Initial Catalog=shoppingdb1;User ID=sa;Password=123abc!";/// <summary>
/// 检查登录的账号和密码
/// </summary>
/// <param name="UserName"></param>
/// <param name="Password"></param>
/// <returns></returns>
public bool Login(string userName, string password)
{using(var conn = new SqlConnection(CONNECT_STRING)){string sql = "select * from [dbo].[User] where UserName=@UserName and Password=@Password";//Query<>方法用户执行select语句，获取结果集List<User> users = conn.Query<User>(sql, new { UserName=userName, Password=password}).ToList();return users.Count > 0;}
}//或者也可以使用ExecuteScalar扩展方法
public bool Login(string userName, string password)
{using (var conn = new SqlConnection(CONNECT_STRING)){string sql = "select count(*) from [dbo].[User] where UserName=@UserName and Password=@Password";//ExecuteScalar<>方法用于执行返回标量类型的sql语句如count(*)返回的就是标量值int count  = conn.ExecuteScalar<int>(sql, new { UserName = userName, Password = password});return count > 0;}
}

四、Dapper的常用扩展库

看了以上案例，是不是觉得Dapper不就是一个执行SQL语句的帮助类，哪里是一个ORM？ORM不是应该可以减少开发人员手动编写SQL语句的工作量，提高开发效率吗？

对的，作为ORM的Dapper本身并没有带太多的功能，但是Dapper有很多扩展库（官方的和第三方的），使用这些扩展库可以自动映射对象到数据库表、自动生成CRUD操作语句、批量操作等。

Dapper的扩展库有：

  • Dapper.SimpleCRUD ： 提供了一套CRUD方法，可以直接传对象，不用自己写SQL
  • Dapper.FluentMap ： 提供了一套方法，可以实现实体类与数据库类型之间的映射
  • Dapper.FluentMap.Dommel ： 使用Dapper进行CRUD操作变得更为简单
  • Dapper.Contrib ： 是Dapper官方提供的扩展库，提供了一些实用的功能和扩展方法，使得在使用Dapper和数据库进行操作时更加方便和高效

五、用Dapper实现仓储模式

ASP.NET Core WebApi的项目中，我们可以用EF/EF Core来实现仓储模式，当然作为轻量级的ORM之王，Dapper也可以实现仓储模式；

下面我们将用Dapper和他的扩展组件Domel来封装仓储模式；

  1. 在基础设施层，NuGet包里面添加Dapper和Dapper.FluentMap.Dommel
    安装Dommel

  2. 用工厂模式和单例模式，来创建一个DapperFactory工厂类，实现灵活切换MySql和SqlServer，后续还可以支持更多数据库

    //需要引用一下命名空间
using System.Data;
using MySql.Data.MySqlClient;
using Microsoft.Extensions.Configuration;
using Microsoft.Extensions.Configuration.Json;
using System.Data.SqlClient;/// <summary>
/// Dapper实例（采用单例模式）
/// </summary>
public class DapperFactory
{/// <summary>/// 读取配置文件用/// </summary>private IConfiguration Configuration { get; set; }// 静态变量保存类的实例    private static DapperFactory uniqueInstance;// 定义一个标识确保线程同步     private static readonly object locker = new object();/// <summary>/// 私有构造方法，使外界不能创建该类的实例，以便实现单例模式/// </summary>private DapperFactory(){Configuration = new ConfigurationBuilder().Add(new JsonConfigurationSource{Path = "appsettings.json",ReloadOnChange = true}).Build();}/// <summary>/// 获取实例，这里为单例模式，保证只存在一个实例/// </summary>/// <returns></returns>public static DapperFactory GetInstance(){// 双重锁定实现单例模式，在外层加个判空条件主要是为了减少加锁、释放锁的不必要的损耗if (uniqueInstance == null){lock (locker){if (uniqueInstance == null){uniqueInstance = new DapperFactory(); //懒汉模式}}}return uniqueInstance;}/// <summary>/// 创建数据库连接对象（采用了设计模式 之 简单工厂模式）/// </summary>/// <returns></returns>public IDbConnection CreateDbConnection(){IDbConnection dbConnection = null;//读取配置文件中的数据库服务器类型 mysql或sqlserverstring dbType = Configuration["DbServerType"];//读取配置文件中的连接字符串string _connectionString = Configuration.GetConnectionString("Default");switch (dbType){case "MySql":dbConnection = new MySqlConnection(_connectionString);break;case "SqlServer":dbConnection = new SqlConnection(_connectionString);break;}//判断连接状态（Dapper内部会自动打开数据库连接，所以无需以下下代码）//if (dbConnection.State == ConnectionState.Closed)//{//    dbConnection.Open();//}return dbConnection;}
}

  3. 编写泛型仓储接口

    using Dommel; //该库为Dapper扩展了CRUD方法/// <summary>
/// 仓储抽象基类
/// </summary>
/// <typeparam name="T"></typeparam>
public abstract class BaseRepository<T>: IBaseRepository<T> where T:class, new()
{//获取数据库连接对象  DapperSingleton这个类是第2步写的protected IDbConnection _db = DapperFactory.GetInstance().CreateDbConnection();/// <summary>/// 添加一条实体数据/// </summary>/// <param name="entity"></param>/// <returns></returns>public int Insert(T entity) {return (int)_db.Insert(entity); }/// <summary>///  更新实体数据/// </summary>/// <param name="entity"></param>/// <returns></returns>public bool Update(T entity){return _db.Update(entity);}/// <summary>/// 删除数据/// </summary>/// <param name="entity">实体类</param>/// <returns></returns>public bool Delete(T entity){return _db.Delete(entity);}/// <summary>///  删除指定ID的数据/// </summary>/// <param name="objId"></param>/// <returns></returns>public bool DeleteById(object objId){return Delete(_db.Get<T>(objId));}/// <summary>/// 根据主值查询单条数据/// </summary>/// <param name="objId">主键值</param>/// <returns>泛型实体</returns>public T GetById(object objId){return _db.Get<T>(objId);}/// <summary>/// 获取全部数据/// </summary>/// <returns></returns>public List<T> GetList(){return _db.GetAll<T>().ToList();}}

  4. 在appsettings.json中配置你要用的数据库和连接字符串

      "ConnectionStrings": {"Default": "server=127.0.0.1;database=superhousedb;user=root;password=root"},"DbServerType": "MySql" //MySql数据库 或  SqlServer

以上，借助Dapper扩展Domel是不是就能实现不用写SQL语句就能实现增删改查了？？
好，今天就分享到这里，更多高级用法以后有机会再分享。如果本文对你有帮助的话，请点赞+评论+关注，或者转发给需要的朋友。

参考链接：

Dapper官网

这篇关于用轻量级ORM--Dapper实现泛型仓储的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！


http://www.chinasem.cn/article/550660。

相关文章

Java+AI驱动实现PDF文件数据提取与解析

Java+AI驱动实现PDF文件数据提取与解析

《Java+AI驱动实现PDF文件数据提取与解析》本文将和大家分享一套基于AI的体检报告智能评估方案,详细介绍从PDF上传、内容提取到AI分析、数据存储的全流程自动化实现方法,感兴趣的可以了解下... 目录一、核心流程：从上传到评估的完整链路二、第一步：解析 PDF，提取体检报告内容1. 引入依赖2. 封装
阅读更多...
Java实现复杂查询优化的7个技巧小结

Java实现复杂查询优化的7个技巧小结

《Java实现复杂查询优化的7个技巧小结》在Java项目中,复杂查询是开发者面临的“硬骨头”,本文将通过7个实战技巧,结合代码示例和性能对比,手把手教你如何让复杂查询变得优雅,大家可以根据需求进行选择... 目录一、复杂查询的痛点：为何你的代码“又臭又长”1.1冗余变量与中间状态1.2重复查询与性能陷阱1.
阅读更多...
python 线程池顺序执行的方法实现

python 线程池顺序执行的方法实现

《python线程池顺序执行的方法实现》在Python中,线程池默认是并发执行任务的,但若需要实现任务的顺序执行,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋... 目录方案一：强制单线程（伪顺序执行）方案二：按提交顺序获取结果方案三：任务间依赖控制方案四：队列顺序消
阅读更多...
Redis实现分布式锁全过程

Redis实现分布式锁全过程

《Redis实现分布式锁全过程》文章介绍Redis实现分布式锁的方法,包括使用SETNX和EXPIRE命令确保互斥性与防死锁,Redisson客户端提供的便捷接口,以及Redlock算法通过多节点共识... 目录Redis实现分布式锁1. 分布式锁的基本原理2. 使用 Redis 实现分布式锁2.1 获取锁
阅读更多...
Linux实现查看某一端口是否开放

Linux实现查看某一端口是否开放

《Linux实现查看某一端口是否开放》文章介绍了三种检查端口6379是否开放的方法：通过lsof查看进程占用,用netstat区分TCP/UDP监听状态,以及用telnet测试远程连接可达性... 目录1、使用lsof 命令来查看端口是否开放2、使用netstat 命令来查看端口是否开放3、使用telnet
阅读更多...
使用SpringBoot+InfluxDB实现高效数据存储与查询

使用SpringBoot+InfluxDB实现高效数据存储与查询

《使用SpringBoot+InfluxDB实现高效数据存储与查询》InfluxDB是一个开源的时间序列数据库,特别适合处理带有时间戳的监控数据、指标数据等,下面详细介绍如何在SpringBoot项目... 目录1、项目介绍2、 InfluxDB 介绍3、Spring Boot 配置 InfluxDB4、I
阅读更多...
基于Java和FFmpeg实现视频压缩和剪辑功能

基于Java和FFmpeg实现视频压缩和剪辑功能

《基于Java和FFmpeg实现视频压缩和剪辑功能》在视频处理开发中,压缩和剪辑是常见的需求,本文将介绍如何使用Java结合FFmpeg实现视频压缩和剪辑功能,同时去除数据库操作,仅专注于视频处理,需... 目录引言1. 环境准备1.1 项目依赖1.2 安装 FFmpeg2. 视频压缩功能实现2.1 主要功
阅读更多...
使用Python实现无损放大图片功能

使用Python实现无损放大图片功能

《使用Python实现无损放大图片功能》本文介绍了如何使用Python的Pillow库进行无损图片放大,区分了JPEG和PNG格式在放大过程中的特点,并给出了示例代码,JPEG格式可能受压缩影响,需先... 目录一、什么是无损放大？二、实现方法步骤1：读取图片步骤2：无损放大图片步骤3：保存图片三、示php
阅读更多...
使用Python实现一个简易计算器的新手指南

使用Python实现一个简易计算器的新手指南

《使用Python实现一个简易计算器的新手指南》计算器是编程入门的经典项目,它涵盖了变量、输入输出、条件判断等核心编程概念,通过这个小项目,可以快速掌握Python的基础语法,并为后续更复杂的项目打下... 目录准备工作基础概念解析分步实现计算器第一步：获取用户输入第二步：实现基本运算第三步：显示计算结果进
阅读更多...
Python多线程实现大文件快速下载的代码实现

Python多线程实现大文件快速下载的代码实现

《Python多线程实现大文件快速下载的代码实现》在互联网时代,文件下载是日常操作之一,尤其是大文件,然而,网络条件不稳定或带宽有限时,下载速度会变得很慢,本文将介绍如何使用Python实现多线程下载... 目录引言一、多线程下载原理二、python实现多线程下载代码说明：三、实战案例四、注意事项五、总结引
阅读更多...

Copyright China编程 23002807@qq.com

沪ICP备2023033072号-2