C#中如何使用异步方法执行数据库查询？示例代码是什么？-C#.Net教程-PHP中文网

C#中如何使用异步方法执行数据库查询？示例代码是什么？

星降

发布： 2025-09-27 09:24:02

原创

695人浏览过

使用异步方法执行数据库查询可提升响应性和性能，结合Entity Framework的ToListAsync、FirstOrDefaultAsync或ADO.NET的ExecuteReaderAsync实现异步操作，避免阻塞主线程。

c#中如何使用异步方法执行数据库查询？示例代码是什么？

在C#中使用异步方法执行数据库查询可以提升应用程序的响应性和性能，特别是在处理大量数据或高并发场景时。通常结合 ADO.NET 或 ORM 框架（如 Entity Framework）来实现异步操作。

使用 Entity Framework 的异步查询示例

Entity Framework 提供了基于 async/await 的异步方法，例如 ToListAsync()、FirstOrDefaultAsync() 等。

// 示例：使用 EF Core 异步查询用户数据

using Microsoft.EntityFrameworkCore;<br>using System.Collections.Generic;<br>using System.Threading.Tasks;<br><br>public class User<br>{<br>    public int Id { get; set; }<br>    public string Name { get; set; }<br>    public string Email { get; set; }<br>}<br><br>public class AppDbContext : DbContext<br>{<br>    public DbSet<User> Users { get; set; }<br><br>    protected override void OnConfiguring(DbContextOptionsBuilder optionsBuilder)<br>    {<br>        optionsBuilder.UseSqlServer("your_connection_string");<br>    }<br>}<br><br>public class UserService<br>{<br>    private readonly AppDbContext _context;<br><br>    public UserService(AppDbContext context)<br>    {<br>        _context = context;<br>    }<br><br>    // 异步获取所有用户<br>    public async Task<List<User>> GetUsersAsync()<br>    {<br>        return await _context.Users.ToListAsync();<br>    }<br><br>    // 异步根据ID查找用户<br>    public async Task<User> GetUserByIdAsync(int id)<br>    {<br>        return await _context.Users.FirstOrDefaultAsync(u => u.Id == id);<br>    }<br>}

登录后复制

使用 ADO.NET 执行异步数据库查询

如果你直接使用 ADO.NET（比如 SqlConnection），也可以通过 ExecuteReaderAsync 实现异步读取。

Fireflies.ai

自动化会议记录和笔记工具，可以帮助你的团队记录、转录、搜索和分析语音对话。

145

查看详情

// 示例：使用 SqlConnection 异步查询

using System;<br>using System.Collections.Generic;<br>using System.Data.SqlClient;<br>using System.Threading.Tasks;<br><br>public class AdoNetUserService<br>{<br>    private string _connectionString = "your_connection_string";<br><br>    public async Task<List<User>> GetUsersAsync()<br>    {<br>        var users = new List<User>();<br><br>        using (var connection = new SqlConnection(_connectionString))<br>        {<br>            await connection.OpenAsync();<br><br>            var query = "SELECT Id, Name, Email FROM Users";<br>            using (var command = new SqlCommand(query, connection))<br>            {<br>                using (var reader = await command.ExecuteReaderAsync())<br>                {<br>                    while (await reader.ReadAsync())<br>                    {<br>                        users.Add(new User<br>                        {<br>                            Id = reader.GetInt32("Id"),<br>                            Name = reader.GetString("Name"),<br>                            Email = reader.GetString("Email")<br>                        });<br>                    }<br>                }<br>            }<br>        }<br><br>        return users;<br>    }<br>}

登录后复制