你当前正在访问 Microsoft Azure Global Edition 技术文档网站。 如果需要访问由世纪互联运营的 Microsoft Azure 中国技术文档网站,请访问 https://docs.azure.cn

CosmosClient.GetDatabaseQueryStreamIterator 方法

定义

重载

GetDatabaseQueryStreamIterator(QueryDefinition, String, QueryRequestOptions)

此方法使用具有参数化值的 SQL 语句为 Cosmos DB 帐户下的数据库创建查询。 它返回 FeedIterator。 有关使用参数化值准备 SQL 语句的详细信息,请参阅 QueryDefinition

GetDatabaseQueryStreamIterator(String, String, QueryRequestOptions)

此方法使用 SQL 语句为 Cosmos DB 帐户下的数据库创建查询。 它返回 FeedIterator。

GetDatabaseQueryStreamIterator(QueryDefinition, String, QueryRequestOptions)

Source:
CosmosClient.cs

此方法使用具有参数化值的 SQL 语句为 Cosmos DB 帐户下的数据库创建查询。 它返回 FeedIterator。 有关使用参数化值准备 SQL 语句的详细信息,请参阅 QueryDefinition

public virtual Microsoft.Azure.Cosmos.FeedIterator GetDatabaseQueryStreamIterator (Microsoft.Azure.Cosmos.QueryDefinition queryDefinition, string continuationToken = default, Microsoft.Azure.Cosmos.QueryRequestOptions requestOptions = default);
abstract member GetDatabaseQueryStreamIterator : Microsoft.Azure.Cosmos.QueryDefinition * string * Microsoft.Azure.Cosmos.QueryRequestOptions -> Microsoft.Azure.Cosmos.FeedIterator
override this.GetDatabaseQueryStreamIterator : Microsoft.Azure.Cosmos.QueryDefinition * string * Microsoft.Azure.Cosmos.QueryRequestOptions -> Microsoft.Azure.Cosmos.FeedIterator
Public Overridable Function GetDatabaseQueryStreamIterator (queryDefinition As QueryDefinition, Optional continuationToken As String = Nothing, Optional requestOptions As QueryRequestOptions = Nothing) As FeedIterator

参数

queryDefinition
QueryDefinition

cosmos SQL 查询定义。

continuationToken
String

Azure Cosmos DB 服务中的延续令牌。

requestOptions
QueryRequestOptions

(可选) 查询请求的选项。

返回

用于遍历数据库的迭代器

示例

有关如何完全清空查询结果的示例。

QueryDefinition queryDefinition = new QueryDefinition("select * From c where c._rid = @rid")
              .WithParameter("@rid", "TheRidValue");
using (FeedIterator feedIterator = this.CosmosClient.GetDatabaseQueryStreamIterator(
    queryDefinition)
{
    while (feedIterator.HasMoreResults)
    {
        // Stream iterator returns a response with status for errors
        using(ResponseMessage response = await feedIterator.ReadNextAsync())
        {
            // Handle failure scenario. 
            if(!response.IsSuccessStatusCode)
            {
                // Log the response.Diagnostics and handle the error
            }
        }
    }
}

注解

有关语法和示例, https://docs.microsoft.com/azure/cosmos-db/sql-query-getting-started 请参阅 。

ReadStreamAsync(RequestOptions, CancellationToken) 建议用于单一数据库查找。

适用于

GetDatabaseQueryStreamIterator(String, String, QueryRequestOptions)

Source:
CosmosClient.cs

此方法使用 SQL 语句为 Cosmos DB 帐户下的数据库创建查询。 它返回 FeedIterator。

public virtual Microsoft.Azure.Cosmos.FeedIterator GetDatabaseQueryStreamIterator (string queryText = default, string continuationToken = default, Microsoft.Azure.Cosmos.QueryRequestOptions requestOptions = default);
abstract member GetDatabaseQueryStreamIterator : string * string * Microsoft.Azure.Cosmos.QueryRequestOptions -> Microsoft.Azure.Cosmos.FeedIterator
override this.GetDatabaseQueryStreamIterator : string * string * Microsoft.Azure.Cosmos.QueryRequestOptions -> Microsoft.Azure.Cosmos.FeedIterator
Public Overridable Function GetDatabaseQueryStreamIterator (Optional queryText As String = Nothing, Optional continuationToken As String = Nothing, Optional requestOptions As QueryRequestOptions = Nothing) As FeedIterator

参数

queryText
String

cosmos SQL 查询文本。

continuationToken
String

Azure Cosmos DB 服务中的延续令牌。

requestOptions
QueryRequestOptions

(可选) 查询请求的选项。

返回

用于遍历数据库的迭代器

示例

有关如何完全清空查询结果的示例。

using (FeedIterator feedIterator = this.CosmosClient.GetDatabaseQueryStreamIterator(
    ("select * From c where c._rid = 'TheRidValue'")
{
    while (feedIterator.HasMoreResults)
    {
        // Stream iterator returns a response with status for errors
        using(ResponseMessage response = await feedIterator.ReadNextAsync())
        {
            // Handle failure scenario. 
            if(!response.IsSuccessStatusCode)
            {
                // Log the response.Diagnostics and handle the error
            }
        }
    }
}

注解

有关语法和示例, https://docs.microsoft.com/azure/cosmos-db/sql-query-getting-started 请参阅 。

ReadStreamAsync(RequestOptions, CancellationToken) 建议用于单一数据库查找。

适用于