c# Dapper -在QueryAsync上使用linq方法

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

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

public class CustomerRepository
{
    private readonly string connectionString;

    public CustomerRepository(string connectionString)
    {
        this.connectionString = connectionString;
    }

    public async Task<IEnumerable<Customer>> GetCustomersByEmailDomain(string domain)
    {
        using (var connection = new SqlConnection(connectionString))
        {
            await connection.OpenAsync();

            var query = "SELECT * FROM Customers";
            var customers = await connection.QueryAsync<Customer>(query);

            var filteredCustomers = customers.Where(c => c.Email.EndsWith(domain));

            return filteredCustomers;
        }
    }
}