Database.GetContainerQueryStreamIterator Método

Definição

Namespace:

Microsoft.Azure.Cosmos

Assembly:

Microsoft.Azure.Cosmos.Client.dll

Pacote:

Microsoft.Azure.Cosmos v3.39.0

Sobrecargas

GetContainerQueryStreamIterator(QueryDefinition, String, QueryRequestOptions)	Esse método cria uma consulta para contêineres em um banco de dados usando uma instrução SQL com valores parametrizados. Ele retorna um FeedIterator. Para obter mais informações sobre como preparar instruções SQL com valores parametrizados, consulte QueryDefinition sobrecarga.
GetContainerQueryStreamIterator(String, String, QueryRequestOptions)	Esse método cria uma consulta para contêineres em um banco de dados usando uma instrução SQL. Ele retorna um FeedIterator.

GetContainerQueryStreamIterator(QueryDefinition, String, QueryRequestOptions)

Origem:

Database.cs

Esse método cria uma consulta para contêineres em um banco de dados usando uma instrução SQL com valores parametrizados. Ele retorna um FeedIterator. Para obter mais informações sobre como preparar instruções SQL com valores parametrizados, consulte QueryDefinition sobrecarga.

public abstract Microsoft.Azure.Cosmos.FeedIterator GetContainerQueryStreamIterator (Microsoft.Azure.Cosmos.QueryDefinition queryDefinition, string continuationToken = default, Microsoft.Azure.Cosmos.QueryRequestOptions requestOptions = default);

abstract member GetContainerQueryStreamIterator : Microsoft.Azure.Cosmos.QueryDefinition * string * Microsoft.Azure.Cosmos.QueryRequestOptions -> Microsoft.Azure.Cosmos.FeedIterator

Public MustOverride Function GetContainerQueryStreamIterator (queryDefinition As QueryDefinition, Optional continuationToken As String = Nothing, Optional requestOptions As QueryRequestOptions = Nothing) As FeedIterator

Parâmetros

queryDefinition

QueryDefinition

A definição de consulta do Cosmos SQL.

continuationToken

String

O token de continuação no serviço do Azure Cosmos DB.

requestOptions

QueryRequestOptions

(Opcional) As opções para a solicitação de contêiner.

Retornos

FeedIterator

Um iterador para percorrer os contêineres

Exemplos

Isso cria o iterador de feed de fluxo para contêineres com queryDefinition como entrada.

string queryText = "SELECT c.id FROM c where c.status like 'start%'";
QueryDefinition queryDefinition = new QueryDefinition(queryText);
using (FeedIterator feedIterator = this.cosmosDatabase.GetContainerQueryStreamIterator(queryDefinition))
{
    while (feedIterator.HasMoreResults)
    {
        using (ResponseMessage response = await feedIterator.ReadNextAsync())
        {
            response.EnsureSuccessStatusCode();
            using (StreamReader sr = new StreamReader(response.Content))
            using (JsonTextReader jtr = new JsonTextReader(sr))
            {
                // The stream content contains the following JSON structure
                // {"_rid":"FwsdAA==","DocumentCollections":[{"id":"container1"},{"id":"container2"}],"_count":2}
                JObject result = JObject.Load(jtr);
            }
        }
    }
}

Isso cria o iterador de feed para obter uma lista de todas as IDs de contêiner

using (FeedIterator feedIterator = this.cosmosDatabase.GetContainerQueryStreamIterator(
      new QueryDefinition("select value c.id From c ")))
  {
      while (feedIterator.HasMoreResults)
      {
          using (ResponseMessage response = await feedIterator.ReadNextAsync())
          {
               response.EnsureSuccessStatusCode();
               using (StreamReader streamReader = new StreamReader(response.Content))
               using (JsonTextReader jsonTextReader = new JsonTextReader(streamReader))
               {
                    // The stream content contains the following JSON structure
                    // {"_rid":"7p8wAA==","DocumentCollections":["container1","container2"],"_count":2}
                    JObject jObject = await JObject.LoadAsync(jsonTextReader);
                }
        }
    }
}

Comentários

Consulte para https://docs.microsoft.com/azure/cosmos-db/sql-query-getting-started obter sintaxe e exemplos.

ReadContainerStreamAsync(ContainerRequestOptions, CancellationToken) é recomendado para pesquisa de contêiner único.

GetContainerQueryStreamIterator(String, String, QueryRequestOptions)

Origem:

Database.cs

Esse método cria uma consulta para contêineres em um banco de dados usando uma instrução SQL. Ele retorna um FeedIterator.

public abstract Microsoft.Azure.Cosmos.FeedIterator GetContainerQueryStreamIterator (string queryText = default, string continuationToken = default, Microsoft.Azure.Cosmos.QueryRequestOptions requestOptions = default);

abstract member GetContainerQueryStreamIterator : string * string * Microsoft.Azure.Cosmos.QueryRequestOptions -> Microsoft.Azure.Cosmos.FeedIterator

Public MustOverride Function GetContainerQueryStreamIterator (Optional queryText As String = Nothing, Optional continuationToken As String = Nothing, Optional requestOptions As QueryRequestOptions = Nothing) As FeedIterator

Parâmetros

queryText

String

O texto da consulta do Cosmos SQL.

continuationToken

String

O token de continuação no serviço do Azure Cosmos DB.

requestOptions

QueryRequestOptions

(Opcional) As opções para a solicitação de contêiner.

Retornos

FeedIterator

Um iterador para percorrer os contêineres

Exemplos

Isso cria o iterador de feed de fluxo para contêineres com queryDefinition como entrada.

using (FeedIterator feedIterator = this.cosmosDatabase.GetContainerQueryStreamIterator(
    "SELECT c.id FROM c where c.status like 'start%'"))
{
    while (feedIterator.HasMoreResults)
    {
        using (ResponseMessage response = await feedIterator.ReadNextAsync())
        {
            response.EnsureSuccessStatusCode();
            using (StreamReader sr = new StreamReader(response.Content))
            using (JsonTextReader jtr = new JsonTextReader(sr))
            {
                // The stream content contains the following JSON structure
                // {"_rid":"FwsdAA==","DocumentCollections":[{"id":"container1"},{"id":"container2"}],"_count":2}
                JObject result = JObject.Load(jtr);
            }
        }
    }
}

Isso cria o iterador de feed para obter uma lista de todas as IDs de contêiner

using (FeedIterator feedIterator = this.cosmosDatabase.GetContainerQueryStreamIterator(
      "select value c.id From c "))
  {
      while (feedIterator.HasMoreResults)
      {
          using (ResponseMessage response = await feedIterator.ReadNextAsync())
          {
               response.EnsureSuccessStatusCode();
               using (StreamReader streamReader = new StreamReader(response.Content))
               using (JsonTextReader jsonTextReader = new JsonTextReader(streamReader))
               {
                    // The stream content contains the following JSON structure
                    // {"_rid":"7p8wAA==","DocumentCollections":["container1","container2"],"_count":2}
                    JObject jObject = await JObject.LoadAsync(jsonTextReader);
                }
        }
    }
}

Comentários

Consulte para https://docs.microsoft.com/azure/cosmos-db/sql-query-getting-started obter sintaxe e exemplos.

ReadContainerStreamAsync(ContainerRequestOptions, CancellationToken) é recomendado para pesquisa de contêiner único.