TableQuery <T> od Azure TableStorage który filtruje na PartitionKey

Question

Próbuję streszczenie geting wszystkie podmioty z tabeli przez partitionKey, tak:

public List<T> GetEntities<T>(string partitionKey, T entity) where T : TableEntity 
    { 
     try 
     { 
      var tableClient = _account.CreateCloudTableClient(); 
      var table = tableClient.GetTableReference(entity.GetType().Name.ToLower()); 
      var exQuery = 
       new TableQuery<T>().Where(TableQuery.GenerateFilterCondition("PartitionKey", QueryComparisons.Equal, 
                      partitionKey)); 

      var results = table.ExecuteQuery(exQuery).Select(ent => (T) ent).ToList(); 
      return results; 
     } 
     catch (StorageException ex) 
     { 
      //TODO: Add more trace info 
      Trace.TraceInformation("Unable to retrieve entity based on query specs"); 
      return null; 
     } 
    } 

Jednakże, jest to w przypadku braku na

new TableQuery<T> 

ponieważ TElement nie ma konstruktora bez parametrów.

Answer 1

Jak już wspomniano w pytaniu, T musi mieć konstruktor bez parametrów. Stąd, należy zmienić definicję swojej metody w następujący sposób:

public List<T> GetEntities<T>(string partitionKey, T entity) where T : TableEntity, new() 

Answer 2

oprócz @ Serdar-Ozler-microsoft odpowiedzi, nawet nie trzeba konwertować i oddania jednostki do powrotu.

Sposób CloudTable.ExecuteQuery ma przeciążenia, które akceptują typ rodzajowy:

public IEnumerable<TElement> ExecuteQuery<TElement>(
TableQuery<TElement> query, 
TableRequestOptions requestOptions = null, 
OperationContext operationContext = null) 
where TElement : new(), ITableEntity 

Można również używać LINQ do filtrowania na zastawy stołowej.

Tak aby można było przepisać metoda tak:

public List<T> GetEntities<T>(string partitionKey, T entity) where T : ITableEntity, new() 
{ 
    try 
    { 
     var tableClient = _account.CreateCloudTableClient(); 
     var table = tableClient.GetTableReference(entity.GetType().Name.ToLower()); 
     return table.CreateQuery<T>().Where(e => e.PartitionKey == partitionKey).ToList(); 
    } 
    catch (StorageException ex) 
    { 
     //TODO: Add more trace info 
     Trace.TraceInformation("Unable to retrieve entity based on query specs"); 
     return null; 
    } 
} 

Answer 3

napisałem małą rodzajowe repozytorium do przechowywania tabeli:

public class CloudTableRepository<T> where T : ITableEntity,new() 
{ 
    private readonly string _tableName; 
    private CloudTable _table; 

    public CloudTableRepository(string tableName) 
    { 
     _tableName = tableName; 
     InitializeTable(); 
    } 

    #region Public Methods 

    public virtual async Task<List<T>> GetPartitionAsync(string partitionKey, int takeCount = 1000) 
    { 
     var result = new List<T>(); 
     var query = 
      new TableQuery<T>().Where(TableQuery.GenerateFilterCondition("PartitionKey", QueryComparisons.Equal, 
       partitionKey)); 
     query.TakeCount = takeCount; 
     TableContinuationToken tableContinuationToken = null; 
     do 
     { 
      var queryResponse = await _table.ExecuteQuerySegmentedAsync(query, tableContinuationToken); 
      tableContinuationToken = queryResponse.ContinuationToken; 
      result.AddRange(queryResponse.Results); 
     } while (tableContinuationToken != null); 
     return result; 
    } 

    public virtual async Task<TableResult> GetSingleAsync(string partitionKey, string rowKey) 
    { 
     return await GetSingle(partitionKey, rowKey); 
    } 

    public virtual async Task<T> UpdateAsync(T tableEntityData) 
    { 
     var updateCallistConfig = await GetSingleAsync(tableEntityData.PartitionKey, tableEntityData.RowKey); 
     if (updateCallistConfig != null) 
     { 
      var updateOperation = TableOperation.InsertOrMerge(tableEntityData); 
      var tableResult = await _table.ExecuteAsync(updateOperation); 
      return (T) tableResult.Result; 
     } 
     return default(T); 
    } 

    public virtual async Task<T> AddAsync(T tableEntityData) 
    { 
     var retrieveOperation = TableOperation.Insert(tableEntityData); 
     var tableResult = await _table.ExecuteAsync(retrieveOperation); 
     return (T) tableResult.Result; 
    } 


    #endregion 

    #region Private Methods 

    private async void InitializeTable() 
    { 
     var storageAccount = 
      CloudStorageAccount.Parse(CloudConfigurationManager.GetSetting("TableStorageConnectionString")); 
     var tableClient = storageAccount.CreateCloudTableClient(); 
     _table = tableClient.GetTableReference(_tableName); 
     await _table.CreateIfNotExistsAsync(); 
    } 

    private async Task<TableResult> GetSingle(string partitionKey, string rowKey) 
    { 
     var retrieveOperation = TableOperation.Retrieve<T>(partitionKey, rowKey); 
     var tableResult = await _table.ExecuteAsync(retrieveOperation); 
     return tableResult; //(T) tableResult.Result; 
    } 

    #endregion 
}