.NET如何使用Dapper执行原生SQL查询_Dapper执行SQL查询指南

Dapper是.NET中轻量高效ORM工具,通过扩展IDbConnection支持原生SQL查询。1. 安装:使用NuGet安装Dapper包并引用using Dapper;2. 查询数据:用Query/QueryAsync方法将结果映射为强类型对象,如var users = await connection.QueryAsync(sql, new { Age = 18 });3. 非查询操作:用Execute/ExecuteAsync执行INSERT、UPDATE、DELETE,返回受影响行数,支持批量插入;4. 单值或单记录获取:QueryFirstOrDefault获取首条或默认值,QuerySingle确保唯一结果,ExecuteScalar获取标量值如count;5. 始终使用参数化查询防止SQL注入,保障安全。

在.NET开发中,Dapper是一个轻量级、高性能的ORM(对象关系映射)工具,特别适合执行原生SQL查询。它直接扩展了IDbConnection接口,让你可以用简洁的代码与数据库交互,同时保留对SQL的完全控制权。下面是如何使用Dapper执行原生SQL查询的实用指南。

安装Dapper

Dapper不是内置库,需要通过NuGet包管理器安装:

  • 在Visual Studio中:打开“NuGet包管理器”,搜索 Dapper 并安装。
  • 或使用命令行:
Install-Package Dapper

安装完成后,你就可以在项目中引用 using Dapper; 来使用其扩展方法。

执行查询:Query和QueryAsync

Dapper最常用的查询方法是 Query 和异步版本 QueryAsync,用于从数据库读取数据并映射到强类型对象。

示例:查询用户列表

var sql = "SELECT Id, Name, Email FROM Users WHERE Age > @Age";
using (var connection = new SqlConnection(connectionString))
{
    var users = await connection.QueryAsync(sql, new { Age = 18 });
    // users 是 IEnumerable
}

说明:

  • User 是一个具有 IdNameEmail 属性的类,属性名需与字段名匹配(或使用别名)。
  • @Age 是参数化查询,防止SQL注入,传入匿名对象作为参数。

执行非查询语句:Execute和ExecuteAsync

对于INSERT、UPDATE、DELETE等不返回结果集的操作,使用 ExecuteExecuteAsync

示例:插入一条记录

var sql = "INSERT INTO Users (Name, Email, Age) VALUES (@Name, @Email, @Age)";
using (var connection = new SqlConnection(connectionString))
{
    var rowsAffected = await connection.ExecuteAsync(sql, new
    {
        Name = "张三",
        Email = "zhangsan@example.com",
        Age = 25
    });
    // rowsAffected 返回受影响的行数
}

该方法也支持批量操作:

var users = new[]
{
    new { Name = "A", Email = "a@ex.com", Age = 20 },
    new { Name = "B", Email = "b@ex.com", Age = 22 }
};
await connection.ExecuteAsync(sql, users);

获取单条记录或标量值

当只需要一条记录或一个值时,Dapper提供了更精确的方法:

  • QueryFirstOrDefault:返回第一条记录,无结果则返回默认值。
  • QuerySingle:期望恰好一条记录,否则抛出异常。
  • ExecuteScalar:获取单个值(如COUNT、ID)。

示例:获取用户数量

var countSql = "SELECT COUNT(*) FROM Users";
var count = await connection.ExecuteScalarAsync(countSql);

示例:根据ID查找用户

var userSql = "SELECT * FROM Users WHERE Id = @Id";
var user = await connection.QueryFirstOrDefaultAsync(userSql, new { Id = 1 });

基本上就这些。Dapper的优势在于简单、高效,尤其适合需要写复杂SQL或对性能敏感的场景。只要掌握这几个核心方法,就能快速完成大多数数据库操作。注意始终使用参数化查询,避免拼接SQL,确保应用安全。