CancellationToken 与异步 Dapper 方法

csharp
using System.Threading;
using Dapper;
public class UserRepository
{
    private readonly IDbConnection _dbConnection;
    public UserRepository(IDbConnection dbConnection)
    {
        _dbConnection = dbConnection;
    }
    public async Task> GetUsersAsync(CancellationToken cancellationToken)
    {
        var sql = "SELECT * FROM Users";
        return await _dbConnection.QueryAsync(sql, cancellationToken: cancellationToken);
    }
}
public class Program
{
    public static async Task Main()
    {
        var cancellationTokenSource = new CancellationTokenSource();
        var cancellationToken = cancellationTokenSource.Token;
        var userRepository = new UserRepository(new SqlConnection("connectionString"));
        var task = userRepository.GetUsersAsync(cancellationToken);
        // 模拟操作取消
        cancellationTokenSource.CancelAfter(TimeSpan.FromSeconds(5));
        try
        {
            var users = await task;
            foreach (var user in users)
            {
                Console.WriteLine(user.Name);
            }
        }
        catch (OperationCanceledException)
        {
            Console.WriteLine("操作已取消");
        }
    }
}