Database.GetContainerQueryStreamIterator Méthode

Référence

Définition

Espace de noms:: Microsoft.Azure.Cosmos

Assembly:: Microsoft.Azure.Cosmos.Client.dll

Paquet:: Microsoft.Azure.Cosmos v3.39.0

Important

Certaines informations portent sur la préversion du produit qui est susceptible d’être en grande partie modifiée avant sa publication. Microsoft exclut toute garantie, expresse ou implicite, concernant les informations fournies ici.

Surcharges

GetContainerQueryStreamIterator(QueryDefinition, String, QueryRequestOptions)	Cette méthode crée une requête pour les conteneurs sous une base de données à l’aide d’une instruction SQL avec des valeurs paramétrables. Elle retourne un FeedIterator. Pour plus d’informations sur la préparation des instructions SQL avec des valeurs paramétrables, consultez QueryDefinition surcharge.
GetContainerQueryStreamIterator(String, String, QueryRequestOptions)	Cette méthode crée une requête pour les conteneurs sous une base de données à l’aide d’une instruction SQL. Elle retourne un FeedIterator.

GetContainerQueryStreamIterator(QueryDefinition, String, QueryRequestOptions)

Source:: Database.cs

Cette méthode crée une requête pour les conteneurs sous une base de données à l’aide d’une instruction SQL avec des valeurs paramétrables. Elle retourne un FeedIterator. Pour plus d’informations sur la préparation des instructions SQL avec des valeurs paramétrables, consultez QueryDefinition surcharge.

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

Paramètres

queryDefinition: QueryDefinition

Définition de requête Cosmos SQL.

continuationToken: String

Jeton de continuation dans le service Azure Cosmos DB.

requestOptions: QueryRequestOptions

(Facultatif) Options pour la demande de conteneur.

Retours

FeedIterator

Itérateur pour parcourir les conteneurs

Exemples

Cela crée l’itérateur de flux de flux pour les conteneurs avec queryDefinition comme entrée.

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

Cela crée un itérateur de flux pour obtenir la liste de tous les ID de conteneur

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

Remarques

Reportez-vous à pour obtenir des https://docs.microsoft.com/azure/cosmos-db/sql-query-getting-started exemples et la syntaxe.

ReadContainerStreamAsync(ContainerRequestOptions, CancellationToken) est recommandé pour la recherche d’un seul conteneur.

S’applique à

GetContainerQueryStreamIterator(String, String, QueryRequestOptions)

Source:: Database.cs

Cette méthode crée une requête pour les conteneurs sous une base de données à l’aide d’une instruction SQL. Elle retourne 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

Paramètres

queryText: String

Texte de la requête Cosmos SQL.

continuationToken: String

Jeton de continuation dans le service Azure Cosmos DB.

requestOptions: QueryRequestOptions

(Facultatif) Options pour la demande de conteneur.

Retours

FeedIterator

Itérateur pour parcourir les conteneurs

Exemples

Cela crée l’itérateur de flux de flux pour les conteneurs avec queryDefinition comme entrée.

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

Cela crée un itérateur de flux pour obtenir la liste de tous les ID de conteneur

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

Remarques

Reportez-vous à pour obtenir des https://docs.microsoft.com/azure/cosmos-db/sql-query-getting-started exemples et la syntaxe.

ReadContainerStreamAsync(ContainerRequestOptions, CancellationToken) est recommandé pour la recherche d’un seul conteneur.

S’applique à

Partager via

Database.GetContainerQueryStreamIterator Méthode

Définition

Surcharges

GetContainerQueryStreamIterator(QueryDefinition, String, QueryRequestOptions)

Paramètres

Retours

Exemples

Remarques

S’applique à

GetContainerQueryStreamIterator(String, String, QueryRequestOptions)

Paramètres

Retours

Exemples

Remarques

S’applique à

Ressources supplémentaires