Skip to content

Fixing samples build break #236

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
kirankumarkolli merged 1 commit into from
May 10, 2019
Merged

Fixing samples build break #236

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
1 commit
Select commit
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
2 changes: 1 addition & 1 deletion Microsoft.Azure.Cosmos.Samples/CodeSamples/ContainerManagement/Program.cs
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -179,7 +179,7 @@ private static async Task ListContainersInDatabase()
{
Console.WriteLine("\n5. Reading all CosmosContainer resources for a database");

CosmosResultSetIterator<CosmosContainerSettings> resultSetIterator = database.Containers.GetContainerIterator();
CosmosFeedIterator<CosmosContainerSettings> resultSetIterator = database.Containers.GetContainerIterator();
while (resultSetIterator.HasMoreResults)
{
foreach (CosmosContainerSettings container in await resultSetIterator.FetchNextSetAsync())
Expand Down
2 changes: 1 addition & 1 deletion Microsoft.Azure.Cosmos.Samples/CodeSamples/DatabaseManagement/Program.cs
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -90,7 +90,7 @@ private static async Task RunDatabaseDemo(CosmosClient client)
}

Console.WriteLine("\n5. Reading all databases resources for an account");
CosmosResultSetIterator<CosmosDatabaseSettings> iterator = client.Databases.GetDatabaseIterator();
CosmosFeedIterator<CosmosDatabaseSettings> iterator = client.Databases.GetDatabaseIterator();
do
{
foreach (CosmosDatabaseSettings db in await iterator.FetchNextSetAsync())
Expand Down
4 changes: 2 additions & 2 deletions Microsoft.Azure.Cosmos.Samples/CodeSamples/Handlers/Program.cs
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -80,11 +80,11 @@ public static async Task Main(string[] args)
await container.Items.ReplaceItemAsync<Item>(item.Id, item.Id, item);

// Querying
CosmosResultSetIterator<Item> query = container.Items.CreateItemQuery<Item>(new CosmosSqlQueryDefinition("SELECT * FROM c"), maxConcurrency: 1);
CosmosFeedIterator<Item> query = container.Items.CreateItemQuery<Item>(new CosmosSqlQueryDefinition("SELECT * FROM c"), maxConcurrency: 1);
List<Item> results = new List<Item>();
while (query.HasMoreResults)
{
CosmosQueryResponse<Item> response = await query.FetchNextSetAsync();
CosmosFeedResponse<Item> response = await query.FetchNextSetAsync();

results.AddRange(response.ToList());
}
Expand Down
8 changes: 4 additions & 4 deletions Microsoft.Azure.Cosmos.Samples/CodeSamples/ItemManagement/Program.cs
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -235,7 +235,7 @@ private static async Task QueryItems()
"select * from sales s where s.AccountNumber = @AccountInput ")
.UseParameter("@AccountInput", "Account1");

CosmosResultSetIterator<SalesOrder> resultSet = container.Items.CreateItemQuery<SalesOrder>(
CosmosFeedIterator<SalesOrder> resultSet = container.Items.CreateItemQuery<SalesOrder>(
query,
partitionKey: "Account1",
maxItemCount: 1);
Expand All @@ -251,7 +251,7 @@ private static async Task QueryItems()
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",
Expand All @@ -260,10 +260,10 @@ private static async Task QueryItems()
List<SalesOrder> allSalesForAccount1FromStream = new List<SalesOrder>();
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<dynamic>(responseMessage.Content);
List<SalesOrder> salesOrders = streamResponse.ToObject<List<SalesOrder>>();
Expand Down
14 changes: 7 additions & 7 deletions Microsoft.Azure.Cosmos.Samples/CodeSamples/Queries/Program.cs
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -96,7 +96,7 @@ private static async Task ItemFeed(CosmosContainer container)
List<Family> families = new List<Family>();

// SQL
CosmosResultSetIterator<Family> setIterator = container.Items.GetItemIterator<Family>(maxItemCount: 1);
CosmosFeedIterator<Family> setIterator = container.Items.GetItemIterator<Family>(maxItemCount: 1);
while (setIterator.HasMoreResults)
{
int count = 0;
Expand All @@ -115,7 +115,7 @@ private static async Task ItemStreamFeed(CosmosContainer container)
int totalCount = 0;

// SQL
CosmosFeedResultSetIterator setIterator = container.Items.GetItemStreamIterator();
CosmosFeedIterator setIterator = container.Items.GetItemStreamIterator();
while (setIterator.HasMoreResults)
{
int count = 0;
Expand All @@ -140,7 +140,7 @@ private static async Task ItemStreamFeed(CosmosContainer container)
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,
Expand All @@ -149,9 +149,9 @@ private static async Task QueryItemsInPartitionAsStreams(CosmosContainer contain
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))
Expand All @@ -178,7 +178,7 @@ private static async Task QueryWithSqlParameters(CosmosContainer container)
.UseParameter("@city", "Seattle");

List<Family> results = new List<Family>();
CosmosResultSetIterator<Family> resultSetIterator = container.Items.CreateItemQuery<Family>(query, partitionKey: "Anderson");
CosmosFeedIterator<Family> resultSetIterator = container.Items.CreateItemQuery<Family>(query, partitionKey: "Anderson");
while (resultSetIterator.HasMoreResults)
{
results.AddRange((await resultSetIterator.FetchNextSetAsync()));
Expand All @@ -195,7 +195,7 @@ private static async Task QueryPartitionedContainerInParallelAsync(CosmosContain
// 0 maximum parallel tasks, effectively serial execution
CosmosQueryRequestOptions options = new CosmosQueryRequestOptions() { MaxBufferedItemCount = 100 };

CosmosResultSetIterator<Family> query = container.Items.CreateItemQuery<Family>(
CosmosFeedIterator<Family> query = container.Items.CreateItemQuery<Family>(
queryText,
maxConcurrency: 0,
requestOptions: options);
Expand Down
4 changes: 2 additions & 2 deletions Microsoft.Azure.Cosmos.Samples/CodeSamples/ServerSideScripts/Program.cs
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -182,10 +182,10 @@ private static async Task RunBulkImport(CosmosContainer container)
// 8. Validate
int numDocs = 0;

CosmosResultSetIterator<dynamic> setIterator = container.Items.GetItemIterator<dynamic>();
CosmosFeedIterator<dynamic> setIterator = container.Items.GetItemIterator<dynamic>();
while (setIterator.HasMoreResults)
{
CosmosQueryResponse<dynamic> response = await setIterator.FetchNextSetAsync();
CosmosFeedResponse<dynamic> response = await setIterator.FetchNextSetAsync();
numDocs += response.Count();
}

Expand Down