Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
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
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");

CosmosFeedIterator<CosmosContainerSettings> resultSetIterator = database.Containers.GetContainerIterator();
CosmosResultSetIterator<CosmosContainerSettings> resultSetIterator = database.Containers.GetContainerIterator();
Comment thread
kirankumarkolli marked this conversation as resolved.
while (resultSetIterator.HasMoreResults)
{
foreach (CosmosContainerSettings container in await resultSetIterator.FetchNextSetAsync())
Expand Down
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");
CosmosFeedIterator<CosmosDatabaseSettings> iterator = client.Databases.GetDatabaseIterator();
CosmosResultSetIterator<CosmosDatabaseSettings> iterator = client.Databases.GetDatabaseIterator();
do
{
foreach (CosmosDatabaseSettings db in await iterator.FetchNextSetAsync())
Expand Down
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
CosmosFeedIterator<Item> query = container.Items.CreateItemQuery<Item>(new CosmosSqlQueryDefinition("SELECT * FROM c"), maxConcurrency: 1);
CosmosResultSetIterator<Item> query = container.Items.CreateItemQuery<Item>(new CosmosSqlQueryDefinition("SELECT * FROM c"), maxConcurrency: 1);
List<Item> results = new List<Item>();
while (query.HasMoreResults)
{
CosmosFeedResponse<Item> response = await query.FetchNextSetAsync();
CosmosQueryResponse<Item> response = await query.FetchNextSetAsync();

results.AddRange(response.ToList());
}
Expand Down
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");

CosmosFeedIterator<SalesOrder> resultSet = container.Items.CreateItemQuery<SalesOrder>(
CosmosResultSetIterator<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
CosmosFeedIterator streamResultSet = container.Items.CreateItemQueryAsStream(
CosmosResultSetIterator 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 (CosmosResponseMessage responseMessage = await streamResultSet.FetchNextSetAsync())
using (CosmosQueryResponse responseMessage = await streamResultSet.FetchNextSetAsync())
{
// Item stream operations do not throw exceptions for better performance
if (responseMessage.IsSuccessStatusCode)
if (responseMessage.IsSuccess)
{
dynamic streamResponse = FromStream<dynamic>(responseMessage.Content);
List<SalesOrder> salesOrders = streamResponse.ToObject<List<SalesOrder>>();
Expand Down
6 changes: 6 additions & 0 deletions Microsoft.Azure.Cosmos.Samples/CodeSamples/NuGet.config
Original file line number Diff line number Diff line change
@@ -0,0 +1,6 @@
<?xml version="1.0" encoding="utf-8"?>
<configuration>
<packageSources>
<add key="NuGet" value="https://api.nuget.org/v3/index.json" />
</packageSources>
</configuration>
14 changes: 7 additions & 7 deletions Microsoft.Azure.Cosmos.Samples/CodeSamples/Queries/Program.cs
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
CosmosFeedIterator<Family> setIterator = container.Items.GetItemIterator<Family>(maxItemCount: 1);
CosmosResultSetIterator<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
CosmosFeedIterator setIterator = container.Items.GetItemStreamIterator();
CosmosFeedResultSetIterator 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
CosmosFeedIterator setIterator = container.Items.CreateItemQueryAsStream(
CosmosResultSetIterator 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 (CosmosResponseMessage response = await setIterator.FetchNextSetAsync())
using (CosmosQueryResponse response = await setIterator.FetchNextSetAsync())
{
Assert("Response failed", response.IsSuccessStatusCode);
Assert("Response failed", response.IsSuccess);
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>();
CosmosFeedIterator<Family> resultSetIterator = container.Items.CreateItemQuery<Family>(query, partitionKey: "Anderson");
CosmosResultSetIterator<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 };

CosmosFeedIterator<Family> query = container.Items.CreateItemQuery<Family>(
CosmosResultSetIterator<Family> query = container.Items.CreateItemQuery<Family>(
queryText,
maxConcurrency: 0,
requestOptions: options);
Expand Down
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;

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

Expand Down