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

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

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

c#中使用Dapper的异步方法可以提升数据库操作的性能,特别是在高并发或I/O密集型场景下。Dapper提供了多个以 Async 结尾的方法,如 QueryAsyncExecuteAsyncQueryFirstOrDefaultAsync 等,它们都返回 Task泛型 Task<T>,需要配合 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<IEnumerable<User>> GetUsersAsync() { using var connection = new sqlConnection(“YourConnectionString”); var sql = “select Id, Name, Email FROM Users”; var users = await connection.QueryAsync<User>(sql); return users; }

3. 查询单条记录(QueryFirstOrDefaultAsync)

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

public async Task<User> 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<User>(sql, new { Id = id }); return user; }

4. 执行异步插入/更新/删除(ExecuteAsync)

执行非查询语句,如插入数据:

public async Task<int> 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; // 返回影响的行数 }

更新用户信息:

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

代码小浣熊

代码小浣熊是基于商汤大语言模型的软件智能研发助手,覆盖软件需求分析、架构设计、代码编写、软件测试等环节

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

查看详情 C#中如何使用Dapper的异步方法?示例代码是什么?

public async Task<int> 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<int> 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); }

}

注意点:

  • 所有异步方法必须在 async 方法中使用,并用 await 调用。
  • 数据库连接字符串应从配置中读取,不要硬编码
  • 使用 using 确保连接正确释放。
  • Dapper 不负责连接管理,需手动打开/关闭(通常 using 会自动处理)。

基本上就这些。Dapper 的异步用法简单直观,和同步几乎一致,只需加上 async/await 和 Async 后缀即可。

暂无评论

发送评论 编辑评论


				
上一篇
下一篇
text=ZqhQzanResources