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

安装Dapper NuGet包后，通过IDbConnection扩展方法执行SQL；2. 手动创建并打开数据库连接；3. 使用Query执行查询并映射到强类型对象，支持参数化防注入；4. Execute用于增删改操作，返回影响行数，插入时可结合SELECT SCOPE_IDENTITY()获取新ID；5. QueryMultiple处理多结果集，Read依次读取。Dapper以轻量高效著称，适合需原生SQL又避免手动处理DataReader的场景。

在.NET中使用Dapper执行原生SQL查询非常简单高效。Dapper是一个轻量级的ORM（微对象关系映射器），直接扩展了IDbConnection接口，让你能用极少代码执行SQL并映射结果到强类型对象。

1. 安装Dapper NuGet包

在项目中使用Dapper前，需通过NuGet安装：

Install-Package Dapper

安装完成后，就可以在代码中使用Dapper提供的扩展方法了。

2. 建立数据库连接

Dapper不负责管理连接，你需要手动创建并打开一个IDbConnection实例。常用的是SqlConnection（用于SQL Server）：

using (var connection = new SqlConnection("YourConnectionString"))
{
    connection.Open();
    // 执行查询
}

3. 执行查询并映射到对象

假设有一个用户表：

CREATE TABLE Users (
    Id INT IDENTITY(1,1) PRIMARY KEY,
    Name NVARCHAR(50),
    Email NVARCHAR(100)
);

定义对应的C#类：

public class User
{
    public int Id { get; set; }
    public string Name { get; set; }
    public string Email { get; set; }
}

使用Dapper执行SQL查询：

var users = connection.Query("SELECT * FROM Users WHERE Name LIKE @Name",
    new { Name = "%张%" });

说明：

• Query 方法自动将结果集映射到User对象列表
• 支持参数化查询，防止SQL注入，使用@ParameterName占位符
• 参数以匿名对象传入

4. 执行非查询语句

对于INSERT、UPDATE、DELETE等操作，使用Execute方法：

var affectedRows = connection.Execute(
    "UPDATE Users SET Name = @Name WHERE Id = @Id",
    new { Name = "新名字", Id = 1 }
);

返回值是受影响的行数。

插入数据并获取自增ID：

var id = connection.QuerySingle(
    "INSERT INTO Users (Name, Email) VALUES (@Name, @Email); SELECT CAST(SCOPE_IDENTITY() as int);",
    new { Name = "李四", Email = "lisi@example.com" }
);

5. 处理多结果集

如果SQL返回多个结果集，可以用QueryMultiple：

using var multi = connection.QueryMultiple("SELECT * FROM Users; SELECT * FROM Orders");
var users = multi.Read();
var orders = multi.Read();

基本上就这些。Dapper的优势在于简洁和性能，适合需要写原生SQL又想避免手动处理DataReader的场景。