根据这个问题:
Missing syncronous methods for dotnet core?,NetCore / Netstandard支持尚未包括API的同步实现。
由于CreateQuery和ExecuteQuery都是同步方法,因此我们无法在.NET Core中使用它们,您只能使用ExecuteQuerySegmentedAsync、TableQuery、Fluent API并处理它返回的继续标记。更多细节,请参考以下代码:
更新:
public static void Main(string[] args)
{
var result = Get<BookTest3>("Aut_Fantasy", "Cert-0000000020", "DifferenetPartitionTest");
Console.Write(result.PartitionKey);
Console.Read();
}
public static T Get<T>(string partitionKey, string rowKey, string tableName) where T : ITableEntity, new()
{
CloudTable table = ConnectToTable(tableName);
TableQuery<T> employeeQuery = new TableQuery<T>().Where(
TableQuery.CombineFilters(
TableQuery.GenerateFilterCondition("PartitionKey", QueryComparisons.Equal, partitionKey),
TableOperators.And,
TableQuery.GenerateFilterCondition("RowKey", QueryComparisons.LessThan, rowKey))
).Take(1);
var re = new T();
TableContinuationToken continuationToken = null;
do
{
Task<TableQuerySegment<T>> employees = table.ExecuteQuerySegmentedAsync(employeeQuery, continuationToken);
TableQuerySegment<T> employeess = employees.Result;
re= employeess.FirstOrDefault();
continuationToken = employeess.ContinuationToken;
} while (continuationToken != null);
return re;
}
希望这些提示能够对您有所帮助。
更新代码:
public static void Main(string[] args)
{
var tas = Get<BookTest3>("Aut_Fantasy", "Cert-0000000020", "DifferenetPartitionTest");
var result = tas.Result;
Console.Write(result.PartitionKey);
Console.Read();
}
public async static Task<T> Get<T>(string partitionKey, string rowKey, string tableName) where T : ITableEntity, new()
{
CloudTable table = ConnectToTable(tableName);
TableQuery<T> employeeQuery = new TableQuery<T>().Where(
TableQuery.CombineFilters(
TableQuery.GenerateFilterCondition("PartitionKey", QueryComparisons.Equal, partitionKey),
TableOperators.And,
TableQuery.GenerateFilterCondition("RowKey", QueryComparisons.LessThan, rowKey))
).Take(1);
var re = new T();
TableContinuationToken continuationToken = null;
do
{
var employees = await table.ExecuteQuerySegmentedAsync(employeeQuery, continuationToken);
re = employees.FirstOrDefault();
continuationToken = employees.ContinuationToken;
} while (continuationToken != null);
return re;
}