迁移Azure Table Storage至Azure.Data.Tables SDK时的泛型类型错误问题

我正尝试将Azure Table Storage的代码示例迁移至新的Azure.Data.Tables SDK。

我的接口定义如下：

public interface IAzureTableStorage<T> where T : ITableEntity, new()
{
    Task Delete(string rowKey);
    Task<T> GetItem(string rowKey);
    Task<List<T>> GetList();
    Task UpSert(T item);
}

以下是我遇到问题的实现代码：

public class AzureTableStorage<T> : IAzureTableStorage<T> where T : ITableEntity, new()
{
    private readonly AzureTableSettings Settings;
    private readonly TableClient TableClient;
    public AzureTableStorage(AzureTableSettings settings)
    {
        Settings = settings;
        TableClient = GetTableClient();
    }
    public Task<List<T>> GetList()
    {
        AsyncPageable<T> queryResults = TableClient.QueryAsync<T>(filter: $"PartitionKey eq '{Settings.TableName}'");

        //CloudTable table = await GetTableAsync();
        //TableQuery<T> query = new TableQuery<T>();
        //List<T> results = new List<T>();

        //TableContinuationToken continuationToken = null;
        //do
        //{
        //  TableQuerySegment<T> queryResults = await table.ExecuteQuerySegmentedAsync(query, continuationToken);
        //  continuationToken = queryResults.ContinuationToken;
        //  results.AddRange(queryResults.Results);
        //} while (continuationToken != null);
        //return results;
    }
}

当前遇到编译器错误CS0452，提示类型T必须是引用类型才能用作参数“T”。我清楚无法直接将AsyncPageable<T>作为List<T>返回，但目前还未到这一步，希望获得泛型实现相关的帮助。

解决方法 #

错误的核心原因是Azure.Data.Tables SDK的TableClient.QueryAsync<T>方法要求泛型参数T必须是引用类型。你需要在泛型约束中添加class关键字，明确限定T为引用类型：

1. 修改接口的泛型约束

public interface IAzureTableStorage<T> where T : class, ITableEntity, new()
{
    Task Delete(string rowKey);
    Task<T> GetItem(string rowKey);
    Task<List<T>> GetList();
    Task UpSert(T item);
}

2. 修改实现类的泛型约束并完善GetList方法

public class AzureTableStorage<T> : IAzureTableStorage<T> where T : class, ITableEntity, new()
{
    private readonly AzureTableSettings Settings;
    private readonly TableClient TableClient;
    public AzureTableStorage(AzureTableSettings settings)
    {
        Settings = settings;
        TableClient = GetTableClient();
    }

    public async Task<List<T>> GetList()
    {
        AsyncPageable<T> queryResults = TableClient.QueryAsync<T>(filter: $"PartitionKey eq '{Settings.TableName}'");
        List<T> results = new List<T>();
        
        // 遍历AsyncPageable收集结果
        await foreach (T item in queryResults)
        {
            results.Add(item);
        }
        return results;
    }

    // 实现其他接口方法（Delete、GetItem、UpSert）
}

说明 #

• 添加class约束后，编译器会确认T是引用类型，满足QueryAsync<T>的参数要求，解决CS0452错误。
• GetList方法需要改为异步方法（添加async关键字），通过await foreach遍历AsyncPageable<T>来异步收集所有结果，符合新SDK的异步编程规范。

内容的提问来源于stack exchange，提问作者Terrence