Skip to content

Commit

Permalink
Merge pull request #9 from AzureCosmosDB/auto-20241016210424
Browse files Browse the repository at this point in the history
[AUTO] 2024-10-16 | Merge latest from source repo
  • Loading branch information
2 parents 4700d3a + 7573aa1 commit 9baba72
Show file tree
Hide file tree
Showing 2 changed files with 5 additions and 14 deletions.
2 changes: 0 additions & 2 deletions web/Models/Product.cs
Original file line number Diff line number Diff line change
@@ -1,6 +1,5 @@
namespace Cosmos.Samples.NoSQL.Quickstart.Web.Models;

// <model>
public record Product(
string id,
string category,
Expand All @@ -9,4 +8,3 @@ public record Product(
decimal price,
bool clearance
);
// </model>
17 changes: 5 additions & 12 deletions web/Services/DemoService.cs
Original file line number Diff line number Diff line change
Expand Up @@ -14,20 +14,17 @@ internal sealed class DemoService(CosmosClient client) : IDemoService

public async Task RunAsync(Func<string, Task> writeOutputAync)
{
// <get_database>
Database database = client.GetDatabase("cosmicworks");
// </get_database>

database = await database.ReadAsync();
await writeOutputAync($"Get database:\t{database.Id}");

// <get_container>
Container container = database.GetContainer("products");
// </get_container>

container = await container.ReadContainerAsync();
await writeOutputAync($"Get container:\t{container.Id}");

{
// <create_item>
Product item = new(
id: "68719518391",
category: "gear-surf-surfboards",
Expand All @@ -41,7 +38,7 @@ public async Task RunAsync(Func<string, Task> writeOutputAync)
item: item,
partitionKey: new PartitionKey("gear-surf-surfboards")
);
// </create_item>

await writeOutputAync($"Upserted item:\t{response.Resource}");
await writeOutputAync($"Status code:\t{response.StatusCode}");
await writeOutputAync($"Request charge:\t{response.RequestCharge:0.00}");
Expand All @@ -67,20 +64,18 @@ public async Task RunAsync(Func<string, Task> writeOutputAync)
}

{
// <read_item>
ItemResponse<Product> response = await container.ReadItemAsync<Product>(
id: "68719518391",
partitionKey: new PartitionKey("gear-surf-surfboards")
);
// </read_item>

await writeOutputAync($"Read item id:\t{response.Resource.id}");
await writeOutputAync($"Read item:\t{response.Resource}");
await writeOutputAync($"Status code:\t{response.StatusCode}");
await writeOutputAync($"Request charge:\t{response.RequestCharge:0.00}");
}

{
// <query_items>
var query = new QueryDefinition(
query: "SELECT * FROM products p WHERE p.category = @category"
)
Expand All @@ -89,10 +84,9 @@ public async Task RunAsync(Func<string, Task> writeOutputAync)
using FeedIterator<Product> feed = container.GetItemQueryIterator<Product>(
queryDefinition: query
);
// </query_items>

await writeOutputAync($"Ran query:\t{query.QueryText}");

// <parse_results>
List<Product> items = new();
double requestCharge = 0d;
while (feed.HasMoreResults)
Expand All @@ -104,7 +98,6 @@ public async Task RunAsync(Func<string, Task> writeOutputAync)
}
requestCharge += response.RequestCharge;
}
// </parse_results>

foreach (var item in items)
{
Expand Down

0 comments on commit 9baba72

Please sign in to comment.