TableQuery PartitionKey

Question

üzerinde filtreler Azure TableStorage dan : Ancak

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

, O

new TableQuery<T> 

üzerinde başarısız oluyor çünkü TEHLİKE parametresiz bir kurucuya sahip değildir.

Answer 1

Sorunuzda da belirttiğiniz gibi, T parametresiz bir kurucuya sahip olmalıdır. aşağıdaki gibi Dolayısıyla, sizin yöntemin tanımını değiştirin: Ayrıca

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

Answer 2

@ serdar-ozler-microsoft cevap, hatta dönüştürmek ve geri dönmek için varlıkları döküm gerekmez. Ayrıca Tablo Hizmet üzerinde filtrelemek için Linq kullanabilirsiniz

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

:

CloudTable.ExecuteQuery yöntem genel bir türünü kabul aşırı yüklenmeye sahiptir.

Yani yöntem böyle yeniden yazabilir: Aferin

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 
} 

Answer 3

Ben masa depolama için küçük bir jenerik depo yazdı. Teşekkürler @Serdar. Mükemmel çalışıyor.