TableQuery <T> da Azure TableStorage che filtra sul PartitionKey

Question

sto cercando di astrarre geting tutte le entità da una tabella da PartitionKey, in questo modo:

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; 
     } 
    } 

tuttavia, è in mancanza sul

new TableQuery<T> 

perché TElement non ha un costruttore senza parametri.

Answer 1

Come hai anche menzionato nella tua domanda, T deve avere un costruttore senza parametri. Quindi, si prega di cambiare la definizione del metodo come segue:

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

Answer 2

Oltre alla risposta @ Serdar-Ozler-microsoft, non avrete nemmeno bisogno di convertire e gettato le entità di tornare.

Il metodo CloudTable.ExecuteQuery ha un sovraccarico che accetta un tipo generico:

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

È inoltre possibile utilizzare Linq per filtrare il servizio al tavolo.

Così che si può riscrivere il metodo del genere:

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

ho scritto un piccolo repository generico per lo stoccaggio tavolo:

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 
}