Database.GetContainerQueryStreamIterator Método

Definición

Espacio de nombres:

Microsoft.Azure.Cosmos

Ensamblado:

Microsoft.Azure.Cosmos.Client.dll

Paquete:

Microsoft.Azure.Cosmos v3.39.0

Sobrecargas

GetContainerQueryStreamIterator(QueryDefinition, String, QueryRequestOptions)	Este método crea una consulta para contenedores en una base de datos mediante una instrucción SQL con valores con parámetros. Devuelve un feedIterator. Para obtener más información sobre cómo preparar instrucciones SQL con valores con parámetros, consulte QueryDefinition sobrecarga.
GetContainerQueryStreamIterator(String, String, QueryRequestOptions)	Este método crea una consulta para contenedores en una base de datos mediante una instrucción SQL. Devuelve un feedIterator.

GetContainerQueryStreamIterator(QueryDefinition, String, QueryRequestOptions)

Source:

Database.cs

Este método crea una consulta para contenedores en una base de datos mediante una instrucción SQL con valores con parámetros. Devuelve un feedIterator. Para obtener más información sobre cómo preparar instrucciones SQL con valores con parámetros, 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

Definición de consulta de Cosmos SQL.

continuationToken

String

Token de continuación en el servicio Azure Cosmos DB.

requestOptions

QueryRequestOptions

(Opcional) Las opciones de la solicitud de contenedor.

Devoluciones

FeedIterator

Iterador para recorrer los contenedores

Ejemplos

Esto crea el iterador de fuente de secuencia para contenedores con 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);
            }
        }
    }
}

Esto crea un iterador de fuente para obtener una lista de todos los identificadores de contenedor.

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);
                }
        }
    }
}

Comentarios

https://docs.microsoft.com/azure/cosmos-db/sql-query-getting-started Consulte para obtener sintaxis y ejemplos.

ReadContainerStreamAsync(ContainerRequestOptions, CancellationToken) se recomienda para la búsqueda de un único contenedor.

GetContainerQueryStreamIterator(String, String, QueryRequestOptions)

Source:

Database.cs

Este método crea una consulta para contenedores en una base de datos mediante una instrucción SQL. Devuelve un 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

Texto de la consulta de Cosmos SQL.

continuationToken

String

Token de continuación en el servicio Azure Cosmos DB.

requestOptions

QueryRequestOptions

(Opcional) Las opciones de la solicitud de contenedor.

Devoluciones

FeedIterator

Iterador para recorrer los contenedores

Ejemplos

Esto crea el iterador de fuente de secuencia para contenedores con 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);
            }
        }
    }
}

Esto crea un iterador de fuente para obtener una lista de todos los identificadores de contenedor.

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);
                }
        }
    }
}

Comentarios

https://docs.microsoft.com/azure/cosmos-db/sql-query-getting-started Consulte para obtener sintaxis y ejemplos.

ReadContainerStreamAsync(ContainerRequestOptions, CancellationToken) se recomienda para la búsqueda de un único contenedor.