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

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

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

使用 Entity Framework 的异步查询示例

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

using Microsoft.EntityFrameworkCore;
using System.Collections.Generic;
using System.Threading.Tasks;

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

public class AppDbContext : DbContext
{
    public DbSet Users { get; set; }

    protected override void OnConfiguring(DbContextOptionsBuilder optionsBuilder)
    {
        optionsBuilder.UseSqlServer("your_connection_string");
    }
}

public class UserService
{
    private readonly AppDbContext _context;

    public UserService(AppDbContext context)
    {
        _context = context;
    }

    // 异步获取所有用户
    public async Task> GetUsersAsync()
    {
        return await _context.Users.ToListAsync();
    }

    // 异步根据ID查找用户
    public async Task GetUserByIdAsync(int id)
    {
        return await _context.Users.FirstOrDefaultAsync(u => u.Id == id);
    }
}

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

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

琅琅配音

全能AI配音神器

下载

using System;
using System.Collections.Generic;
using System.Data.SqlClient;
using System.Threading.Tasks;

public class AdoNetUserService
{
    private string _connectionString = "your_connection_string";

    public async Task> GetUsersAsync()
    {
        var users = new List();

        using (var connection = new SqlConnection(_connectionString))
        {
            await connection.OpenAsync();

            var query = "SELECT Id, Name, Email FROM Users";
            using (var command = new SqlCommand(query, connection))
            {
                using (var reader = await command.ExecuteReaderAsync())
                {
                    while (await reader.ReadAsync())
                    {
                        users.Add(new User
                        {
                            Id = reader.GetInt32("Id"),
                            Name = reader.GetString("Name"),
                            Email = reader.GetString("Email")
                        });
                    }
                }
            }
        }

        return users;
    }
}

调用异步方法的注意事项

在实际调用这些异步方法时，确保在支持异步的上下文中使用 await，避免死锁。

• 控制器中可以直接 await 异步方法（ASP.NET Core 支持）
• 不要在同步方法中使用 .Result 或 .Wait()，可能导致线程阻塞
• 确保数据库连接字符串配置正确，并启用异步支持（SQL Server 默认支持）