C#中如何使用Dapper的异步方法？示例代码是什么？

新闻中心 NEWS CENTER

您当前位置：首页 > 新闻中心 > 网络学院

C#中如何使用Dapper的异步方法？示例代码是什么？

2025-11-01

浏览次数：次

返回列表

Dapper通过QueryAsync、ExecuteAsync等异步方法提升数据库操作性能，需配合async/await使用，支持查询、插入、更新、删除操作，并在ASP.NET Core中实现异步调用，注意连接字符串配置与资源释放。

c#中如何使用dapper的异步方法？示例代码是什么？

在C#中使用Dapper的异步方法可以提升数据库操作的性能，特别是在高并发或I/O密集型场景下。Dapper提供了多个以 Async 结尾的方法，如 QueryAsync、ExecuteAsync、QueryFirstOrDefaultAsync 等，它们都返回 Task 或泛型 Task，需要配合 async/await 使用。

1. 安装 Dapper

通过 NuGet 安装 Dapper：

Install-Package Dapper

2. 基本异步查询示例（QueryAsync）

从数据库中异步查询多条记录：

// 假设有一个实体类 public class User { public int Id { get; set; } public string Name { get; set; } public string Email { get; set; } }

// 异步查询所有用户 public async Task> GetUsersAsync() { using var connection = new SqlConnection("YourConnectionString"); var sql = "SELECT Id, Name, Email FROM Users"; var users = await connection.QueryAsync(sql); return users; }

3. 查询单条记录（QueryFirstOrDefaultAsync）

根据ID异步查询一个用户：

public async Task GetUserByIdAsync(int id) { using var connection = new SqlConnection("YourConnectionString"); var sql = "SELECT Id, Name, Email FROM Users WHERE Id = @Id"; var user = await connection.QueryFirstOrDefaultAsync(sql, new { Id = id }); return user; }

4. 执行异步插入/更新/删除（ExecuteAsync）

执行非查询语句，如插入数据：

public async Task AddUserAsync(User user) { using var connection = new SqlConnection("YourConnectionString"); var sql = "INSERT INTO Users (Name, Email) VALUES (@Name, @Email)"; var affectedRows = await connection.ExecuteAsync(sql, user); return affectedRows; // 返回影响的行数 }

更新用户信息：

NameGPT

免费的名称生成器，AI驱动在线生成企业名称及Logo

119 查看详情 NameGPT

public async Task UpdateUserAsync(User user) { using var connection = new SqlConnection("YourConnectionString"); var sql = "UPDATE Users SET Name = @Name, Email = @Email WHERE Id = @Id"; var affectedRows = await connection.ExecuteAsync(sql, user); return affectedRows; }

删除用户：

public async Task DeleteUserAsync(int id) { using var connection = new SqlConnection("YourConnectionString"); var sql = "DELETE FROM Users WHERE Id = @Id"; var affectedRows = await connection.ExecuteAsync(sql, new { Id = id }); return affectedRows; }

5. 在 ASP.NET Core 中调用示例

控制器中调用异步方法：

[ApiController] [Route("[controller]")] public class UsersController : ControllerBase { private readonly IUserRepository _userRepository;

public UsersController(IUserRepository userRepository)
{
    _userRepository = userRepository;
}

[HttpGet]
public async Task<IActionResult> Get()
{
    var users = await _userRepository.GetUsersAsync();
    return Ok(users);
}

[HttpGet("{id}")]
public async Task<IActionResult> Get(int id)
{
    var user = await _userRepository.GetUserByIdAsync(id);
    if (user == null) return NotFound();
    return Ok(user);
}