02. Azure CosmosDB - Insert

🔷 Insert Data

🔶 Document

https://docs.microsoft.com/en-us/dotnet/api/microsoft.azure.cosmos.table.tableoperation?view=azure-dotnet

TableOperation Class (Microsoft.Azure.Cosmos.Table) - Azure for .NET Developers

 

 

 

https://docs.microsoft.com/ko-kr/rest/api/storageservices/Understanding-the-Table-Service-Data-Model

Table service 데이터 모델 이해 (REST API)-Azure Storage

- PartitionKey, RowKey는 필수 키임

- 유니크해야함

 

 

 

🔶 Unity

- 테이블이 아무것도 없는 상태

 

 

 

using System.Collections.Generic;
using System.IO;
using System.Linq;
using System.Net;
using System.Threading.Tasks;
using Microsoft.WindowsAzure.Storage;
using Microsoft.WindowsAzure.Storage.Blob;
using Microsoft.WindowsAzure.Storage.Table;
using MRTK.Tutorials.AzureCloudServices.Scripts.Domain;
using UnityEngine;
using UnityEngine.Events;

namespace MRTK.Tutorials.AzureCloudServices.Scripts.Managers
{
    public class DataManager : MonoBehaviour
    {
        public bool IsReady { get; private set; }

        [Header("Base Settings")]
        [SerializeField]
        private string connectionString = default;
        [Header("Table Settings")]
        [SerializeField]
        private string projectsTableName = "projects";
        [SerializeField]
        private bool tryCreateTableOnStart = true;
        [Header("Events")]
        [SerializeField]
        private UnityEvent onDataManagerReady = default;
        [SerializeField]
        private UnityEvent onDataManagerInitFailed = default;

        private CloudStorageAccount storageAccount;
        private CloudTableClient cloudTableClient;
        private CloudTable projectsTable;

        private async void Awake()
        {
            storageAccount = CloudStorageAccount.Parse(connectionString);
            cloudTableClient = storageAccount.CreateCloudTableClient();
            projectsTable = cloudTableClient.GetTableReference(projectsTableName);
            if (tryCreateTableOnStart)
            {
                try
                {
                    if (await projectsTable.CreateIfNotExistsAsync())
                    {
                        Debug.Log($"Created table {projectsTableName}.");
                    }
                }
                catch (StorageException ex)
                {
                    Debug.LogError("Failed to connect with Azure Storage.\nIf you are running with the default storage emulator configuration, please make sure you have started the storage emulator.");
                    Debug.LogException(ex);
                    onDataManagerInitFailed?.Invoke();
                }
            }

            IsReady = true;
            onDataManagerReady?.Invoke();

        }
}

- DataManager.cs에서 필요한 것만 남기고, 나머지는 삭제함.

- connectionString : Azure 연결 문자열

- projectsTableName : 생성/불러올 테이블 이름

- tryCreateTableOnStart : True일때 -> projectsTableName라는 테이블이 없으면 해당 이름으로 테이블 생성

 

 

 

using System.Collections.Generic;
using System.IO;
using System.Linq;
using System.Net;
using System.Threading.Tasks;
using Microsoft.WindowsAzure.Storage;
using Microsoft.WindowsAzure.Storage.Blob;
using Microsoft.WindowsAzure.Storage.Table;
using MRTK.Tutorials.AzureCloudServices.Scripts.Domain;
using UnityEngine;
using UnityEngine.Events;

namespace MRTK.Tutorials.AzureCloudServices.Scripts.Managers
{
    public class DataManager : MonoBehaviour
    {
        public bool IsReady { get; private set; }

        [Header("Base Settings")]
        [SerializeField]
        private string connectionString = default;
        [Header("Table Settings")]
        [SerializeField]
        private string projectsTableName = "students";
        [SerializeField]
        private bool tryCreateTableOnStart = true;
        [Header("Events")]
        [SerializeField]
        private UnityEvent onDataManagerReady = default;
        [SerializeField]
        private UnityEvent onDataManagerInitFailed = default;

        private CloudStorageAccount storageAccount;
        private CloudTableClient cloudTableClient;
        private CloudTable projectsTable;

        private async void Awake()
        {
            storageAccount = CloudStorageAccount.Parse(connectionString);
            cloudTableClient = storageAccount.CreateCloudTableClient();
            projectsTable = cloudTableClient.GetTableReference(projectsTableName);
            if (tryCreateTableOnStart)
            {
                try
                {
                    if (await projectsTable.CreateIfNotExistsAsync())
                    {
                        Debug.Log($"Created table {projectsTableName}.");
                    }
                }
                catch (StorageException ex)
                {
                    Debug.LogError("Failed to connect with Azure Storage.\nIf you are running with the default storage emulator configuration, please make sure you have started the storage emulator.");
                    Debug.LogException(ex);
                    onDataManagerInitFailed?.Invoke();
                }
            }

            InsertData();

            IsReady = true;
            onDataManagerReady?.Invoke();

        }

        public void InsertData()
        {
            TableOperation operation;
            TableResult result;

            Student student;

            student = new Student
            {
                PartitionKey = "00",
                RowKey = "00",
                Name = "OJUI",
                Email = "ojui@example.com",
                Address = "Developer Village"
            };

            operation = TableOperation.InsertOrMerge(student);
            result = projectsTable.ExecuteAsync(operation).Result;
        }

    }

    public class Student : TableEntity
    {
        public Student(string PartitionKey, string RowKey, string Name, string Email = null, string Address = null)
        {
            this.PartitionKey = PartitionKey;
            this.RowKey = RowKey;
            this.Name = Name;
            this.Email = Email;
            this.Address = Address;
        }

        public Student() { }

        public string Name { get; set; }

        public string Email { get; set; }

        public string Address { get; set; }

    }

}

- project 이름 students로 변경함

- Student Class : 데이터 구조

 

 

 

- play하면 위와 같은 log가 찍힘

 

 

 

- students라는 이름의 테이블이 생성됨

- 데이터도 삽입된 것을 확인

 

 

 

using System.Collections.Generic;
using System.IO;
using System.Linq;
using System.Net;
using System.Threading.Tasks;
using Microsoft.WindowsAzure.Storage;
using Microsoft.WindowsAzure.Storage.Blob;
using Microsoft.WindowsAzure.Storage.Table;
using MRTK.Tutorials.AzureCloudServices.Scripts.Domain;
using UnityEngine;
using UnityEngine.Events;

namespace MRTK.Tutorials.AzureCloudServices.Scripts.Managers
{
    public class DataManager : MonoBehaviour
    {
        public bool IsReady { get; private set; }

        [Header("Base Settings")]
        [SerializeField]
        private string connectionString = default;
        [Header("Table Settings")]
        [SerializeField]
        private string projectsTableName = "students";
        [SerializeField]
        private bool tryCreateTableOnStart = true;
        [Header("Events")]
        [SerializeField]
        private UnityEvent onDataManagerReady = default;
        [SerializeField]
        private UnityEvent onDataManagerInitFailed = default;

        private CloudStorageAccount storageAccount;
        private CloudTableClient cloudTableClient;
        private CloudTable projectsTable;

        private async void Awake()
        {
            storageAccount = CloudStorageAccount.Parse(connectionString);
            cloudTableClient = storageAccount.CreateCloudTableClient();
            projectsTable = cloudTableClient.GetTableReference(projectsTableName);
            if (tryCreateTableOnStart)
            {
                try
                {
                    if (await projectsTable.CreateIfNotExistsAsync())
                    {
                        Debug.Log($"Created table {projectsTableName}.");
                    }
                }
                catch (StorageException ex)
                {
                    Debug.LogError("Failed to connect with Azure Storage.\nIf you are running with the default storage emulator configuration, please make sure you have started the storage emulator.");
                    Debug.LogException(ex);
                    onDataManagerInitFailed?.Invoke();
                }
            }

            InsertData();

            IsReady = true;
            onDataManagerReady?.Invoke();

        }

        public void InsertData()
        {
            TableOperation operation;
            TableResult result;

            Student student;

            student = new Student
            {
                PartitionKey = "01",
                RowKey = "01",
                Name = "Minu",
                Email = "Minu01@example.com",
                Address = "Military Village"
            };

            operation = TableOperation.InsertOrMerge(student);
            result = projectsTable.ExecuteAsync(operation).Result;
        }
    }

    public class Student : TableEntity
    {
        public Student(string PartitionKey, string RowKey, string Name, string Email = null, string Address = null)
        {
            this.PartitionKey = PartitionKey;
            this.RowKey = RowKey;
            this.Name = Name;
            this.Email = Email;
            this.Address = Address;
        }

        public Student() { }

        public string Name { get; set; }

        public string Email { get; set; }

        public string Address { get; set; }

    }

}

- 넣고자하는 데이터를 바꿈

 

 

 

- play 해보면 이번에도 데이터가 삽입된 것을 확인할 수 있음.

 

 

 

🔶 Potal

- 포털에서 직접 데이터를 넣을 수 있음

 

 

 

- Add Entity

 

 

 

- Value 기입

- Add Entity

 

 

 

- 데이터가 추가된 것 확인