Azure Storage 系列（五）通過Azure.Cosmos.Table 類庫在.Net 上使用 Table Storage

一，引言

　　上一篇文章我們在.NET 項目中添加了 “WindowsAzure.Storage” 的 NuGet 包進行操作Table 數據，但是使用的 “WindowsAzure.Storage”  NeGet 以及沒微遺棄了，所以我們今天繼續講 Azure Table Storage，使用新的 Nuget  包--- “Microsoft.Azure.Cosmos.Table” 來操作 Table 數據。

nuget 鏈接：https://www.nuget.org/packages/Microsoft.Azure.Cosmos.Table

我們可以看到 當前neget 包 允許使用 Microsoft Azure CosmosDB 表 API 以及 Azure 表存儲。

--------------------我是分割線--------------------

Azure Blob Storage 存儲系列：

1，Azure Storage 系列（一）入門簡介

2，Azure Storage 系列（二） .NET Core Web 項目中操作 Blob 存儲

3，Azure Storage 系列（三）Blob 參數設置說明

4，Azure Storage 系列（四）在.Net 上使用Table Storage

5，Azure Storage 系列（五）通過Azure.Cosmos.Table 類庫在.Net 上使用 Table Storage  

6，Azure Storage 系列（六）使用Azure Queue Storage

二，正文

1，安裝 “Microsoft.Azure.Cosmos.Table” 的 NuGet

 

 使用程序包管理控制台進行安裝

Install-Package Microsoft.Azure.Cosmos.Table -Version 1.0.8

2，創建ITableServiceV2 接口，和 TableServiceV2 實現類，控制器方法等

　　因為使用的 “Microsoft.Azure.Cosmos.Table” 的Nuget 和 “WindowsAzure.Storage” Nuget 中對 Table Storage 的操作中使用的方法，以及類都是一樣的，只是命名空間不一樣，所以代碼上差別不太大。所以大家可以看一下具體代碼和已遺棄的方法進行對比。

完整代碼：

public interface ITableServiceV2
    {
        /// <summary>
        /// AddEntity(abandoned)
        /// </summary>
        /// <param name="user">user</param>
        /// <returns></returns>
        Task AddEntity(UserInfoV2 user);

        /// <summary>
        /// BatchAddEntities(abandoned)
        /// </summary>
        /// <param name="users">users</param>
        /// <returns></returns>
        Task BatchAddEntities(List<UserInfoV2> users);

        /// <summary>
        /// QueryUsers(abandoned)
        /// </summary>
        /// <param name="filter">filter</param>
        /// <returns></returns>
        IEnumerable<UserInfoV2> QueryUsers(string filter);

        /// <summary>
        /// UpdateEntity(abandoned)
        /// </summary>
        /// <param name="user">user</param>
        /// <returns></returns>
        Task UpdateEntity(UserInfoV2 user);

        /// <summary>
        /// DeleteEntity(abandoned)
        /// </summary>
        /// <param name="user">user</param>
        /// <returns></returns>
        Task DeleteEntity(UserInfoV2 user);

        /// <summary>
        /// DeleteTable(abandoned)
        /// </summary>
        /// <param name="tableName">tableName</param>
        /// <returns></returns>
        Task DeleteTable(string tableName);
    }

public class TableServiceV2 : ITableServiceV2
    {
        private readonly CloudStorageAccount _cloudStorageClient;
        public TableServiceV2(CloudStorageAccount cloudStorageClient)
        {
            _cloudStorageClient = cloudStorageClient;
        }

        #region 01，添加表數據+async Task AddEntity(UserInfo user)
        /// <summary>
        /// 添加表數據
        /// </summary>
        /// <param name="user">用戶數據</param>
        /// <returns></returns>
        public async Task AddEntity(UserInfoV2 user)
        {
            var cloudTableClient = _cloudStorageClient.CreateCloudTableClient();
            var cloudTable = cloudTableClient.GetTableReference("USERINFOV2");
            await cloudTable.CreateIfNotExistsAsync();

            var tableOperation = TableOperation.Insert(user);
            await cloudTable.ExecuteAsync(tableOperation);
        } 
        #endregion

        public async Task BatchAddEntities(List<UserInfoV2> users)
        {
            var cloudTableClient = _cloudStorageClient.CreateCloudTableClient();
            var cloudTable = cloudTableClient.GetTableReference("USERINFOV2");
            await cloudTable.CreateIfNotExistsAsync();

            var tableBatchOperation = new TableBatchOperation();
            foreach (UserInfoV2 item in users)
            {
                tableBatchOperation.Insert(item);
            }

            await cloudTable.ExecuteBatchAsync(tableBatchOperation);
        }

        public async Task DeleteEntity(UserInfoV2 user)
        {
            var cloudTableClient = _cloudStorageClient.CreateCloudTableClient();
            var cloudTable = cloudTableClient.GetTableReference("USERINFOV2");

            var queryOperation = TableOperation.Retrieve<UserInfoV2>(user.PartitionKey, user.RowKey);

            var tableResult = await cloudTable.ExecuteAsync(queryOperation);
            if (tableResult.Result is UserInfoV2 userInfo)
            {
                var deleteOperation = TableOperation.Delete(userInfo);
                await cloudTable.ExecuteAsync(deleteOperation);
            }
        }

        public async Task DeleteTable(string tableName)
        {
            var cloudTableClient = _cloudStorageClient.CreateCloudTableClient();
            var cloudTable = cloudTableClient.GetTableReference(tableName);
            await cloudTable.DeleteIfExistsAsync();
        }

        public IEnumerable<UserInfoV2> QueryUsers(string filter)
        {
            var cloudTableClient = _cloudStorageClient.CreateCloudTableClient();
            var cloudTable = cloudTableClient.GetTableReference("USERINFOV2");

            TableQuery<UserInfoV2> query = new TableQuery<UserInfoV2>().Where(filter);

            var users = cloudTable.ExecuteQuery(query);
            foreach (var item in users)
            {
                yield return item;
            }
        }

        public async Task UpdateEntity(UserInfoV2 user)
        {
            var cloudTableClient = _cloudStorageClient.CreateCloudTableClient();
            var cloudTable = cloudTableClient.GetTableReference("USERINFOV2");

            var queryOperation = TableOperation.Retrieve<UserInfoV2>(user.PartitionKey, user.RowKey);

            var tableResult = await cloudTable.ExecuteAsync(queryOperation);
            if (tableResult.Result is UserInfoV2 userInfo)
            {
                user.ETag = userInfo.ETag;
                var deleteOperation = TableOperation.Replace(user);
                await cloudTable.ExecuteAsync(deleteOperation);
            }
        }
    }

[Route("TableV2")]
    public class TableExplorerV2Controller : Controller
    {
        private readonly ITableServiceV2 _tableService;

        public TableExplorerV2Controller(ITableServiceV2 tableService)
        {
            this._tableService = tableService;
        }

        [HttpPost("AddUser")]
        public async Task<ActionResult> AddEntity([FromBody] UserInfoV2 user)
        {
            await _tableService.AddEntity(new UserInfoV2("huge", "610124199012221000") { Email = "[e-mail]", TelNum = "13000000000" });
            return Ok();
        }

        [HttpPost("AddBatchUser")]
        public async Task<ActionResult> AddEntities([FromBody] List<UserInfoV2> users)
        {
            List<UserInfoV2> userList = new List<UserInfoV2>();
            userList.Add(new UserInfoV2("wangwei", "610124199012221001") { Email = "[e-mail]", TelNum = "13000000001" });
            userList.Add(new UserInfoV2("wangwei", "610124199012221002") { Email = "[e-mail]", TelNum = "13000000002" });
            userList.Add(new UserInfoV2("wangwei", "610124199012221003") { Email = "[e-mail]", TelNum = "13000000003" });
            await _tableService.BatchAddEntities(userList);
            return Ok();
        }

        [HttpGet("Users")]
        public ActionResult QueryUsers()
        {
            var filter = TableQuery.CombineFilters(TableQuery.GenerateFilterCondition("PartitionKey", QueryComparisons.Equal, "wangwei"), TableOperators.And, TableQuery.GenerateFilterCondition("RowKey", QueryComparisons.Equal, "610124199012221001"));

            return Ok(_tableService.QueryUsers(filter));
        }

        [HttpPut("UpdateUser")]
        public async Task<ActionResult> UpdateUser([FromBody] UserInfoV2 user)
        {
            await _tableService.UpdateEntity(new UserInfoV2("huge", "610124199012221000") { Email = "[e-mail]", TelNum = "15000000000" });
            return Ok();
        }

        [HttpDelete("DeleteEntity")]
        public async Task<ActionResult> DeleteEntity([FromBody] UserInfoV2 user)
        {
            await _tableService.DeleteEntity(new UserInfoV2("wangwei", "610124199012221003"));
            return Ok();
        }

        [HttpDelete("{tableName}")]
        public async Task<ActionResult> DeleteTable(string tableName)
        {
            await _tableService.DeleteTable(tableName);
            return Ok();
        }
    }

3，添加對 TableServiceV2 ,CloudStorageAccount 的注入

services.AddSingleton(x => new Microsoft.Azure.Cosmos.Table.CloudStorageAccount(new Microsoft.Azure.Cosmos.Table.StorageCredentials("cnbateblogaccount", "FU01h022mn1JjONp+ta0DAXOO7ThK3diYhd4xrm0Hpg891n9nycsTLGZXXXXnJpGvTIZvO5VCVFhGOfV0wndOOQ=="), true));
services.AddSingleton<ITableServiceV2, TableServiceV2>();

4，測試使用新的 Nuget 包中的方法是否能正常操作 Table 表數據

添加用戶數據，我們在 postman 中調用添加用戶表數據接口

 我們可以看到，在Azure Portal 上已經創建出一個叫 “USERINFOV2” 的表信息（注意，大家不要疑惑，可以看看上面添加用戶的Service方法，我這里有兩行代碼）

var cloudTable = cloudTableClient.GetTableReference("USERINFOV2");
await cloudTable.CreateIfNotExistsAsync();

接下來我們在Cloud Explorer 查看 “USERINFOV2” Table 的表信息

 查詢用戶數據，我這里還是使用兩個查詢條件聯合進行查詢，分別是 “PartitionKey” 和 “RowKey” 作為查詢的 Key，通過 “Partition” 等於 “wangwei” 和 “RowKey” 等於 “610124199012221001” 

 注意（我提前已經將調用了批量添加用戶的接口，將 PartitionKey 等於 "wangwu" 的三條數據添加到 Table 中了）

 

 

 OK，剩余的更新，刪除就不再演示了，大家可以自行進行校驗，今天的分享內容到此結束。

三，結尾

github：https://github.com/yunqian44/Azure.Storage.git

作者：Allen 

版權：轉載請在文章明顯位置注明作者及出處。如發現錯誤，歡迎批評指正。