Comment interroger une table de stockage Azure avec Linq?

Je ne sais pas où exactement, mais j'ai eu la mauvaise idée quelque part avec cette.

J'essaie, en première instance, à la requête d'un stockage azure table à l'aide de linq. Mais je ne peux pas savoir comment c'est fait. En regardant une variété de sources, j'ai le texte suivant:

List<BlogViewModel> blogs = new List<BlogViewModel>();

CloudStorageAccount storageAccount = CloudStorageAccount.Parse(RoleEnvironment.GetConfigurationSettingValue("BlogConnectionString"));
CloudTableClient tableClient = storageAccount.CreateCloudTableClient();
CloudTable blogTable = tableClient.GetTableReference("BlogEntries");

try
{
   TableServiceContext tableServiceContext = tableClient.GetTableServiceContext();
   TableServiceQuery<BlogEntry> query = (from blog in blogTable.CreateQuery<BlogEntry>()
   select blog).AsTableServiceQuery<BlogEntry>(tableServiceContext);
   foreach (BlogEntry blog in query)
   {
      blogs.Add(new BlogViewModel { Body = blog.Body });
   }
}
catch { }

J'ai probablement eu ça de plus près avant que j'ai foiré autour avec il. Soit ça, ou je suis l'incompréhension de ce que le TableService est. Le code suivant ne fonctionne pour moi, mais je suis en train de passer à l'utilisation de Linq à la place.

List<BlogViewModel> blogs = new List<BlogViewModel>();

var storageAccount = CloudStorageAccount.Parse(RoleEnvironment.GetConfigurationSettingValue("BlogConnectionString"));
var tableClient = storageAccount.CreateCloudTableClient();
CloudTable blogTable = tableClient.GetTableReference("BlogEntries");

TableRequestOptions reqOptions = new TableRequestOptions()
{
   MaximumExecutionTime = TimeSpan.FromSeconds(1.5),
   RetryPolicy = new LinearRetry(TimeSpan.FromSeconds(3), 3)
};
List<BlogEntry> lists;

try
{
   var query = new TableQuery<BlogEntry>();
   lists = blogTable.ExecuteQuery(query, reqOptions).ToList();

   foreach (BlogEntry blog in lists)
   {
      blogs.Add(new BlogViewModel { Body = blog.Body });
   }
}
catch { }

J'ai été incapable de trouver un solide bon exemple de ce que je devrais faire. Mais de ce que j'ai lu, il ne suggère l'utilisation de Linq est possible. De l'aide ou des pointeurs apprécié. Merci.

Légère mise à jour. La syntaxe est la suivante erreur que j'ai actuellement sur AsTableServiceQuery:

'Système.Linq.IQueryable' ne contient pas une définition pour 'AsTableServiceQuery' et aucune méthode d'extension 'AsTableServiceQuery' acceptant un premier argument de type 'System.Linq.IQueryable' a pu être trouvé (vous manque une directive using ou une référence d'assembly?)

Cependant, je ne pense pas que cela reflète la vraie question, je pense que je viens juste de me mettre ensemble de mal, juste ne pouvez pas trouver un exemple solide de n'importe où qui fonctionne.

source d'informationauteur AndrewPolland

  1. 24

    TableServiceContext n'est plus nécessaire à la nouvelle Table de la Couche de Service de Stockage Azure de la Bibliothèque du Client. Pour plus d'informations sur ce changement, veuillez consulter notre article de blog Annonce de Stockage de la Bibliothèque du Client 2.1 RTM & CTP pour Windows Phone.

    Assurez-BlogEntry implémente ITableEntity et ensuite le code suivant devrait fonctionner parfaitement:

    List<BlogViewModel> blogs = new List<BlogViewModel>();

CloudTableClient tableClient = storageAccount.CreateCloudTableClient();
CloudTable blogTable = tableClient.GetTableReference("BlogEntries");

try
{
    IEnumerable<BlogEntry> query = (from blog in blogTable.CreateQuery<BlogEntry>()
                                    select blog);
    foreach (BlogEntry blog in query)
    {
        blogs.Add(new BlogViewModel { Body = blog.Body });
    }
}
catch { }
  2. 15

    Mon tableau actuel référentiel de stockage fait ceci:

    public IQueryable<TEntity> Find(Expression<Func<TEntity, bool>> expression) 
{
    if (IsTableEmpty())
    {
        return Enumerable.Empty<TEntity>().AsQueryable();
    }
    else
    {
        return _cloudTable.CreateQuery<TEntity>().AsQueryable().Where(expression);
    }
}

    Mon _cloudTable correspond à votre blogTable.

  3. 1

    Basée sur la réponse précédente, j'ai créé des extensions de méthodes pour soutenir les First, FirstOrDefault, Single and SingleOrDefault:

    ///<summary>
///Provides additional Linq support for the <see cref="TableQuery{TElement}"/> class. 
///</summary>
public static class LinqToTableQueryExtensions
{
///<summary>
///Returns the first element in a sequence.
///</summary>
///<typeparam name="TSource">The type of the elements of source.</typeparam>
///<param name="tableQuery">A TableQuery{TSource} to return the first element of</param>
public static TSource First<TSource>(this TableQuery<TSource> tableQuery) where TSource : ITableEntity
{
return ((IEnumerable<TSource>)tableQuery.Take(1)).First();
}
///<summary>
///Returns the first element in a sequence that satisfies a specified condition.
///</summary>
///<typeparam name="TSource">The type of the elements of source.</typeparam>
///<param name="tableQuery">A TableQuery{TSource} to return the first element of</param>
///<param name="predicate">A function to test an element for a condition.</param>
public static TSource First<TSource>(this TableQuery<TSource> tableQuery, Expression<Func<TSource, bool>> predicate) where TSource : ITableEntity
{
return tableQuery.Where(predicate).Take(1).First();
}
///<summary>
///Returns the first element of the sequence or a default value if no such element is found.
///</summary>
///<typeparam name="TSource">The type of the elements of source.</typeparam>
///<param name="tableQuery">A TableQuery{TSource} to return the first element of</param>
public static TSource FirstOrDefault<TSource>(this TableQuery<TSource> tableQuery) where TSource : ITableEntity
{
return ((IEnumerable<TSource>)tableQuery.Take(1)).FirstOrDefault();
}
///<summary>
///Returns the first element of the sequence that satisfies a condition or a default value if no such element is found.
///</summary>
///<typeparam name="TSource">The type of the elements of source.</typeparam>
///<param name="tableQuery">A TableQuery{TSource} to return the first element of</param>
///<param name="predicate">A function to test an element for a condition.</param>
public static TSource FirstOrDefault<TSource>(this TableQuery<TSource> tableQuery, Expression<Func<TSource, bool>> predicate) where TSource : ITableEntity
{
return tableQuery.Where(predicate).Take(1).FirstOrDefault();
}
///<summary>
///Return the only element of a sequence, and throws an exception if there is no exactly one element in the sequence.
///</summary>
///<typeparam name="TSource">The type of the elements of source.</typeparam>
///<param name="tableQuery">A TableQuery{TSource}> to return the single element of</param>
///<param name="predicate">A function to test an element for a condition.</param>
public static TSource Single<TSource>(this TableQuery<TSource> tableQuery, Expression<Func<TSource, bool>> predicate) where TSource : ITableEntity
{
//Get 2 and try to get single ^^
return tableQuery.Where(predicate).Take(2).Single();
}
///<summary>
///Returns the only element of a sequence, or a default value if the sequence is empty; this method throws an exception if there is more than one element in the sequence.
///</summary>
///<typeparam name="TSource">The type of the elements of source.</typeparam>
///<param name="tableQuery">A TableQuery{TSource}> to return the single element of</param>
///<param name="predicate">A function to test an element for a condition.</param>
public static TSource SingleOrDefault<TSource>(this TableQuery<TSource> tableQuery, Expression<Func<TSource, bool>> predicate) where TSource : ITableEntity
{
//Get 2 and try to get single ^^
return tableQuery.Where(predicate).Take(2).SingleOrDefault();
}
}

    De sorte que vous pouvez l'utiliser comme ça:

    public class CustomerEntity : TableEntity { public string Email { get; set; } } 
...
var storageAccount = CloudStorageAccount.Parse( "MyStorageAccountConnectionstring");
var tableClient = storageAccount.CreateCloudTableClient();
var table = tableClient.GetTableReference("myTable");
//Linq Query with Where And First
var person = table.CreateQuery<CustomerEntity>()
.Where(c => c.Email == "[email protected]").First();
//Linq query that used the First() Extension method
person = table.CreateQuery<CustomerEntity>()
.First(c => c.Email == "[email protected]");
  4. 0

    Voici quelques pratique de méthodes d'extension pour conclure..
    (et un bonus de cas pour ServiceBus Propriétés Personnalisées keystore)

    namespace Microsoft.WindowsAzure.Storage.Table
{
public static class CloudTableExtensions
{
public static TEntity GetTableEntity<TEntity>(this CloudTable cloudTable, BrokeredMessage brokeredMessage, string partitionKeyPropertyName, string rowKeyPropertyName, TableRequestOptions requestOptions = null, OperationContext operationContext = null)
where TEntity : ITableEntity, new()
{
var partitionKey = brokeredMessage.Properties[partitionKeyPropertyName] as string;
var rowKey = brokeredMessage.Properties[rowKeyPropertyName] as string;
return GetTableEntity<TEntity>(cloudTable, partitionKey, rowKey, requestOptions, operationContext);
}
public static TEntity GetTableEntity<TEntity>(this CloudTable cloudTable, string partitionKey, string rowKey, TableRequestOptions requestOptions = null, OperationContext operationContext = null)
where TEntity : ITableEntity, new()
{
var singleInstanceQuery = (Expression<Func<TEntity, bool>>)(x => x.PartitionKey == partitionKey && x.RowKey == rowKey);
IEnumerable<TEntity> queryResults = cloudTable.ExecuteQuery(singleInstanceQuery, requestOptions, operationContext);
return queryResults.SingleOrDefault();
}
public static IEnumerable<TEntity> ExecuteQuery<TEntity>(this CloudTable cloudTable, Expression<Func<TEntity, bool>> expression, TableRequestOptions requestOptions = null, OperationContext operationContext = null)
where TEntity : ITableEntity, new()
{
var query = cloudTable.CreateQuery<TEntity>().Where(expression) as TableQuery<TEntity>;
return cloudTable.ExecuteQuery(query, requestOptions, operationContext);
}
}
}