From cda890337e8ee5b730337086510f1e367749f651 Mon Sep 17 00:00:00 2001 From: kirankumarkolli Date: Fri, 10 May 2019 22:22:54 +0530 Subject: [PATCH] Fixing samples build break (#236) --- .../CodeSamples/ContainerManagement/Program.cs | 2 +- .../CodeSamples/DatabaseManagement/Program.cs | 2 +- .../CodeSamples/Handlers/Program.cs | 4 ++-- .../CodeSamples/ItemManagement/Program.cs | 8 ++++---- .../CodeSamples/Queries/Program.cs | 14 +++++++------- .../CodeSamples/ServerSideScripts/Program.cs | 4 ++-- 6 files changed, 17 insertions(+), 17 deletions(-) diff --git a/Microsoft.Azure.Cosmos.Samples/CodeSamples/ContainerManagement/Program.cs b/Microsoft.Azure.Cosmos.Samples/CodeSamples/ContainerManagement/Program.cs index cdbdb57f1..cb2c4119f 100644 --- a/Microsoft.Azure.Cosmos.Samples/CodeSamples/ContainerManagement/Program.cs +++ b/Microsoft.Azure.Cosmos.Samples/CodeSamples/ContainerManagement/Program.cs @@ -179,7 +179,7 @@ { Console.WriteLine("\n5. Reading all CosmosContainer resources for a database"); - CosmosResultSetIterator resultSetIterator = database.Containers.GetContainerIterator(); + CosmosFeedIterator resultSetIterator = database.Containers.GetContainerIterator(); while (resultSetIterator.HasMoreResults) { foreach (CosmosContainerSettings container in await resultSetIterator.FetchNextSetAsync()) diff --git a/Microsoft.Azure.Cosmos.Samples/CodeSamples/DatabaseManagement/Program.cs b/Microsoft.Azure.Cosmos.Samples/CodeSamples/DatabaseManagement/Program.cs index 398f0a40f..c9f0a69eb 100644 --- a/Microsoft.Azure.Cosmos.Samples/CodeSamples/DatabaseManagement/Program.cs +++ b/Microsoft.Azure.Cosmos.Samples/CodeSamples/DatabaseManagement/Program.cs @@ -90,7 +90,7 @@ } Console.WriteLine("\n5. Reading all databases resources for an account"); - CosmosResultSetIterator iterator = client.Databases.GetDatabaseIterator(); + CosmosFeedIterator iterator = client.Databases.GetDatabaseIterator(); do { foreach (CosmosDatabaseSettings db in await iterator.FetchNextSetAsync()) diff --git a/Microsoft.Azure.Cosmos.Samples/CodeSamples/Handlers/Program.cs b/Microsoft.Azure.Cosmos.Samples/CodeSamples/Handlers/Program.cs index 4430ed1d0..df96e0c29 100644 --- a/Microsoft.Azure.Cosmos.Samples/CodeSamples/Handlers/Program.cs +++ b/Microsoft.Azure.Cosmos.Samples/CodeSamples/Handlers/Program.cs @@ -80,11 +80,11 @@ await container.Items.ReplaceItemAsync(item.Id, item.Id, item); // Querying - CosmosResultSetIterator query = container.Items.CreateItemQuery(new CosmosSqlQueryDefinition("SELECT * FROM c"), maxConcurrency: 1); + CosmosFeedIterator query = container.Items.CreateItemQuery(new CosmosSqlQueryDefinition("SELECT * FROM c"), maxConcurrency: 1); List results = new List(); while (query.HasMoreResults) { - CosmosQueryResponse response = await query.FetchNextSetAsync(); + CosmosFeedResponse response = await query.FetchNextSetAsync(); results.AddRange(response.ToList()); } diff --git a/Microsoft.Azure.Cosmos.Samples/CodeSamples/ItemManagement/Program.cs b/Microsoft.Azure.Cosmos.Samples/CodeSamples/ItemManagement/Program.cs index d7e76dadb..0f594133b 100644 --- a/Microsoft.Azure.Cosmos.Samples/CodeSamples/ItemManagement/Program.cs +++ b/Microsoft.Azure.Cosmos.Samples/CodeSamples/ItemManagement/Program.cs @@ -235,7 +235,7 @@ "select * from sales s where s.AccountNumber = @AccountInput ") .UseParameter("@AccountInput", "Account1"); - CosmosResultSetIterator resultSet = container.Items.CreateItemQuery( + CosmosFeedIterator resultSet = container.Items.CreateItemQuery( query, partitionKey: "Account1", maxItemCount: 1); @@ -251,7 +251,7 @@ Console.WriteLine($"\n1.4.2 Query found {allSalesForAccount1.Count} items."); // Use the same query as before but get the cosmos response message to access the stream directly - CosmosResultSetIterator streamResultSet = container.Items.CreateItemQueryAsStream( + CosmosFeedIterator streamResultSet = container.Items.CreateItemQueryAsStream( query, maxConcurrency: 1, partitionKey: "Account1", @@ -260,10 +260,10 @@ List allSalesForAccount1FromStream = new List(); while (streamResultSet.HasMoreResults) { - using (CosmosQueryResponse responseMessage = await streamResultSet.FetchNextSetAsync()) + using (CosmosResponseMessage responseMessage = await streamResultSet.FetchNextSetAsync()) { // Item stream operations do not throw exceptions for better performance - if (responseMessage.IsSuccess) + if (responseMessage.IsSuccessStatusCode) { dynamic streamResponse = FromStream(responseMessage.Content); List salesOrders = streamResponse.ToObject>(); diff --git a/Microsoft.Azure.Cosmos.Samples/CodeSamples/Queries/Program.cs b/Microsoft.Azure.Cosmos.Samples/CodeSamples/Queries/Program.cs index 6a3033796..708ce3b1d 100644 --- a/Microsoft.Azure.Cosmos.Samples/CodeSamples/Queries/Program.cs +++ b/Microsoft.Azure.Cosmos.Samples/CodeSamples/Queries/Program.cs @@ -96,7 +96,7 @@ List families = new List(); // SQL - CosmosResultSetIterator setIterator = container.Items.GetItemIterator(maxItemCount: 1); + CosmosFeedIterator setIterator = container.Items.GetItemIterator(maxItemCount: 1); while (setIterator.HasMoreResults) { int count = 0; @@ -115,7 +115,7 @@ int totalCount = 0; // SQL - CosmosFeedResultSetIterator setIterator = container.Items.GetItemStreamIterator(); + CosmosFeedIterator setIterator = container.Items.GetItemStreamIterator(); while (setIterator.HasMoreResults) { int count = 0; @@ -140,7 +140,7 @@ private static async Task QueryItemsInPartitionAsStreams(CosmosContainer container) { // SQL - CosmosResultSetIterator setIterator = container.Items.CreateItemQueryAsStream( + CosmosFeedIterator setIterator = container.Items.CreateItemQueryAsStream( "SELECT F.id, F.LastName, F.IsRegistered FROM Families F", partitionKey: "Anderson", maxConcurrency: 1, @@ -149,9 +149,9 @@ int count = 0; while (setIterator.HasMoreResults) { - using (CosmosQueryResponse response = await setIterator.FetchNextSetAsync()) + using (CosmosResponseMessage response = await setIterator.FetchNextSetAsync()) { - Assert("Response failed", response.IsSuccess); + Assert("Response failed", response.IsSuccessStatusCode); count++; using (StreamReader sr = new StreamReader(response.Content)) using (JsonTextReader jtr = new JsonTextReader(sr)) @@ -178,7 +178,7 @@ .UseParameter("@city", "Seattle"); List results = new List(); - CosmosResultSetIterator resultSetIterator = container.Items.CreateItemQuery(query, partitionKey: "Anderson"); + CosmosFeedIterator resultSetIterator = container.Items.CreateItemQuery(query, partitionKey: "Anderson"); while (resultSetIterator.HasMoreResults) { results.AddRange((await resultSetIterator.FetchNextSetAsync())); @@ -195,7 +195,7 @@ // 0 maximum parallel tasks, effectively serial execution CosmosQueryRequestOptions options = new CosmosQueryRequestOptions() { MaxBufferedItemCount = 100 }; - CosmosResultSetIterator query = container.Items.CreateItemQuery( + CosmosFeedIterator query = container.Items.CreateItemQuery( queryText, maxConcurrency: 0, requestOptions: options); diff --git a/Microsoft.Azure.Cosmos.Samples/CodeSamples/ServerSideScripts/Program.cs b/Microsoft.Azure.Cosmos.Samples/CodeSamples/ServerSideScripts/Program.cs index 811b19a9b..f22f2d1c6 100644 --- a/Microsoft.Azure.Cosmos.Samples/CodeSamples/ServerSideScripts/Program.cs +++ b/Microsoft.Azure.Cosmos.Samples/CodeSamples/ServerSideScripts/Program.cs @@ -182,10 +182,10 @@ // 8. Validate int numDocs = 0; - CosmosResultSetIterator setIterator = container.Items.GetItemIterator(); + CosmosFeedIterator setIterator = container.Items.GetItemIterator(); while (setIterator.HasMoreResults) { - CosmosQueryResponse response = await setIterator.FetchNextSetAsync(); + CosmosFeedResponse response = await setIterator.FetchNextSetAsync(); numDocs += response.Count(); }