Conflicts.GetConflictQueryStreamIterator Methode

Definition

Namespace:

Microsoft.Azure.Cosmos

Assembly:

Microsoft.Azure.Cosmos.Client.dll

Paket:

Microsoft.Azure.Cosmos v3.39.0

Überlädt

GetConflictQueryStreamIterator(QueryDefinition, String, QueryRequestOptions)	Ruft einen Iterator ab, um alle Konflikte für den Container als ursprüngliche ResponseMessage zu durchlaufen.
GetConflictQueryStreamIterator(String, String, QueryRequestOptions)	Ruft einen Iterator ab, um alle Konflikte für den Container als ursprüngliche ResponseMessage zu durchlaufen.

GetConflictQueryStreamIterator(QueryDefinition, String, QueryRequestOptions)

Quelle:

Conflicts.cs

Ruft einen Iterator ab, um alle Konflikte für den Container als ursprüngliche ResponseMessage zu durchlaufen.

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

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

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

Parameter

queryDefinition

QueryDefinition

Die Cosmos SQL-Abfragedefinition.

continuationToken

String

(Optional) Das Fortsetzungstoken im Azure Cosmos DB-Dienst.

requestOptions

QueryRequestOptions

(Optional) Die Optionen für die Elementabfrageanforderung.

Gibt zurück

FeedIterator

Ein Iterator, um die Konflikte zu durchlaufen.

Beispiele

Beispiel für die vollständige Entwässerung der Abfrageergebnisse.

QueryDefinition queryDefinition = new QueryDefinition("select * From c where c._rid = @rid")
              .WithParameter("@rid", "TheRidValue");
using (FeedIterator feedIterator = this.CosmosClient.GetConflictQueryStreamIterator(
    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
            }
        }
    }
}

GetConflictQueryStreamIterator(String, String, QueryRequestOptions)

Quelle:

Conflicts.cs

Ruft einen Iterator ab, um alle Konflikte für den Container als ursprüngliche ResponseMessage zu durchlaufen.

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

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

Public MustOverride Function GetConflictQueryStreamIterator (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

(Optional) Das Fortsetzungstoken im Azure Cosmos DB-Dienst.

requestOptions

QueryRequestOptions

(Optional) Die Optionen für die Elementabfrageanforderung.

Gibt zurück

FeedIterator

Ein Iterator, um die Konflikte zu durchlaufen.

Beispiele

Beispiel für die vollständige Entwässerung der Abfrageergebnisse.

using (FeedIterator feedIterator = this.CosmosClient.GetConflictQueryStreamIterator(
    "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
            }
        }
    }
}