Azure Cosmos DB (五) .Net Core 控制台应用

一，引言

　　之前在讲Azure CosmosDB Core(SQL)核心的时候，使用了EF Core 的方式，引用了 “Microsoft.EntityFrameworkCore.Cosmos” 的NuGet包，而今天来个简单的，使用 "Microsoft.Azure.Cosmos" 来操作CosmosDB，通过控制台来写一个简单的Demo。

--------------------我是分割线--------------------

1，Azure Cosmos DB (一) 入门介绍

2，Azure Cosmos DB (二) SQL API 操作

3，Azure Cosmos DB (三) EF Core 操作CURD Demo

4，Azure Cosmos DB (四) 使用EF的SQL API 异地冗余

5，Azure Cosmos DB (五) .Net Core Console

二，正文

1，安装依赖项

安装对Cosmos DB 的依赖 "Microsoft.Azure.Cosmos"

Azure Cosmos DB (五) .Net Core 控制台应用

使用程序包管理控制台进行安装：

Install-Package Microsoft.Azure.Cosmos -Version 3.15.0

其他程序包：

Install-Package Microsoft.Extensions.Configuration -Version 3.1.0
Install-Package Microsoft.Extensions.Configuration.FileExtensions -Version 3.1.0
Install-Package Microsoft.Extensions.Configuration.Json -Version 3.1.0

2，获取CosmosClient，Database，Container 对象

 #region Create CosmosClient
 this.cosmosClient = new CosmosClient(Appsettings.app("CosmosDB", "Endpoint"), Appsettings.app("CosmosDB", "Key")); 
 #endregion

 #region Create CosmosDB
 this.database = await this.cosmosClient.CreateDatabaseIfNotExistsAsync(Appsettings.app("CosmosDB", "DataBase"));
 Console.WriteLine("Created Database:{0} Success\n", Appsettings.app("CosmosDB", "DataBase"));
 #endregion

 #region Create Container 
 this.container = await this.database.CreateContainerIfNotExistsAsync(Appsettings.app("CosmosDB", "Container"), "/id"); 
 #endregion

3，针对于 Cosmos 的 CRUD 方法

3.1，数据初始化

 1 public async Task InitItem()
 2         {
 3             //Create a UserModel object for the Andersen family
 4             var user1 = new UserModel
 5             {
 6                 Id = "1",
 7                 Name = "张无忌",
 8                 Age = 12,
 9                 Address = "北京市西城区鲍家街43号",
10                 Remark = "中央音乐学院"
11             };
12 
13             var user2 = new UserModel
14             {
15                 Id = "2",
16                 Name = "令狐冲",
17                 Age = 20,
18                 Address = "佛山市南海区灯湖东路6号",
19                 Remark = "广发商学院"
20             };
21 
22             #region Query User1 of '张无忌'
23             var user1s = await QueryItems(user1.Name);
24             #endregion
25 
26 
27             #region Add User1 Item
28             if (user1s.Count <= 0)
29             {
30                 ItemResponse<UserModel> user1Response = await this.container.CreateItemAsync<UserModel>(user1, new PartitionKey(user1.Id));
31 
32                 Console.WriteLine("Created Item in database with id:{0} Operation consumed {1} RUs.\n", user1Response.Resource.Id, user1Response.StatusCode);
33             }
34             #endregion
35 
36 
37             #region Query User2 of '令狐冲'
38             var user2s = await QueryItems(user2.Name);
39             #endregion
40 
41             #region Add User2 Item
42             if (user2s.Count <= 0)
43             {
44                 ItemResponse<UserModel> user2Response = await this.container.CreateItemAsync<UserModel>(user2, new PartitionKey(user2.Id));
45 
46                 Console.WriteLine("Created Item in database with id:{0} Operation consumed {1} RUs.\n", user2Response.Resource.Id, user2Response.StatusCode);
47             }
48             #endregion
49         }

InitItem