Database.GetContainerQueryStreamIterator Methode

Definition

Namespace:

Microsoft.Azure.Cosmos

Assembly:

Microsoft.Azure.Cosmos.Client.dll

Paket:

Microsoft.Azure.Cosmos v3.39.0

Überlädt

GetContainerQueryStreamIterator(QueryDefinition, String, QueryRequestOptions)	Diese Methode erstellt eine Abfrage für Container unter einer Datenbank mithilfe einer SQL-Anweisung mit parametrisierten Werten. Es gibt einen FeedIterator zurück. Weitere Informationen zum Vorbereiten von SQL-Anweisungen mit parametrisierten Werten finden Sie unter QueryDefinition Überladung.
GetContainerQueryStreamIterator(String, String, QueryRequestOptions)	Diese Methode erstellt mithilfe einer SQL-Anweisung eine Abfrage für Container unter einer Datenbank. Es gibt einen FeedIterator zurück.

GetContainerQueryStreamIterator(QueryDefinition, String, QueryRequestOptions)

Quelle:

Database.cs

Diese Methode erstellt eine Abfrage für Container unter einer Datenbank mithilfe einer SQL-Anweisung mit parametrisierten Werten. Es gibt einen FeedIterator zurück. Weitere Informationen zum Vorbereiten von SQL-Anweisungen mit parametrisierten Werten finden Sie unter QueryDefinition Überladung.

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

Parameter

queryDefinition

QueryDefinition

Die Cosmos SQL-Abfragedefinition.

continuationToken

String

Das Fortsetzungstoken im Azure Cosmos DB-Dienst.

requestOptions

QueryRequestOptions

(Optional) Die Optionen für die Containeranforderung.

Gibt zurück

FeedIterator

Ein Iterator zum Durchlaufen der Container

Beispiele

Dadurch wird der Streamfeed-Iterator für Container mit queryDefinition als Eingabe erstellt.

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

Dadurch wird ein Feed-Iterator erstellt, um eine Liste aller Container-IDs abzurufen.

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

Hinweise

Syntax und Beispiele finden Sie unter https://docs.microsoft.com/azure/cosmos-db/sql-query-getting-started .

ReadContainerStreamAsync(ContainerRequestOptions, CancellationToken) wird für die Einzelcontainersuche empfohlen.

GetContainerQueryStreamIterator(String, String, QueryRequestOptions)

Quelle:

Database.cs

Diese Methode erstellt mithilfe einer SQL-Anweisung eine Abfrage für Container unter einer Datenbank. Es gibt einen FeedIterator zurück.

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

Parameter

queryText

String

Der Cosmos SQL-Abfragetext.

continuationToken

String

Das Fortsetzungstoken im Azure Cosmos DB-Dienst.

requestOptions

QueryRequestOptions

(Optional) Die Optionen für die Containeranforderung.

Gibt zurück

FeedIterator

Ein Iterator zum Durchlaufen der Container

Beispiele

Dadurch wird der Streamfeed-Iterator für Container mit queryDefinition als Eingabe erstellt.

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

Dadurch wird ein Feed-Iterator erstellt, um eine Liste aller Container-IDs abzurufen.

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

Hinweise

Syntax und Beispiele finden Sie unter https://docs.microsoft.com/azure/cosmos-db/sql-query-getting-started .

ReadContainerStreamAsync(ContainerRequestOptions, CancellationToken) wird für die Einzelcontainersuche empfohlen.