Dapper通过QueryAsync、ExecuteAsync等异步方法提升数据库操作性能,需配合async/await使用,支持查询、插入、更新、删除操作,并在ASP.NET Core中实现异步调用,注意连接字符串配置与资源释放。
在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; // 返回影响的行数
}更新用户信息:
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 Get()
{
var us
ers = await _userRepository.GetUsersAsync();
return Ok(users);
}
[HttpGet("{id}")]
public async Task Get(int id)
{
var user = await _userRepository.GetUserByIdAsync(id);
if (user == null) return NotFound();
return Ok(user);
}}
注意点:
- 所有异步方法必须在 async 方法中使用,并用 await 调用。
- 数据库连接字符串应从配置中读取,不要硬编码。
- 使用 using 确保连接正确释放。
- Dapper 不负责连接管理,需手动打开/关闭(通常 using 会自动处理)。
基本上就这些。Dapper 的异步用法简单直观,和同步几乎一致,只需加上 async/await 和 Async 后缀即可。