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

CosmosClient.GetDatabaseQueryStreamIterator 方法

定义

命名空间:

Microsoft.Azure.Cosmos

程序集:

Microsoft.Azure.Cosmos.Client.dll

包:

Microsoft.Azure.Cosmos v3.39.0

重载

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

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

返回

FeedIterator

用于遍历数据库的迭代器

示例

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

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

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

返回

FeedIterator

用于遍历数据库的迭代器

示例

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

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) 建议用于单一数据库查找。