Microsoft AzureのNoSQLデータベース「Cosmos DB」における実装方法を知る

Microsoft AzureのNoSQLデータベース「Cosmos DB」を使ってみよう 第3回

ドキュメントの作成

　続いてドキュメントを作成していきます。

　まず、DocumentRepositoryで操作できるドキュメントの型を限定しないように、DocumentRepositoryをジェネリックなクラスにします。クラスの定義部分をリスト10の通りに修正します。

リスト10　クラスの修正（DocumentRepository.cs）

public class DocumentRepository<T> where T : class
{
・・・

　次に、CreateDocumentAsyncメソッドを追加します。

リスト11　CreateDocumentAsyncメソッド（DocumentRepository.cs）

public static async Task<Document> CreateDocumentAsync(T document)
{
    return await client.CreateDocumentAsync(
        UriFactory.CreateDocumentCollectionUri(DatabaseId, CollectionId),
        document);
}

　このメソッドに渡すドキュメントのクラスを作成します。TodoDocument.csという名前でクラスを新規作成します。

リスト12　TodoDocumentクラス

public class TodoDocument
{
    // やること
    [JsonProperty(PropertyName = "todo")]
    public string Todo { get; set; }

    // 作成者
    [JsonProperty(PropertyName = "auther")]
    public string Auther { get; set; }
 
    // 作成日
    [JsonProperty(PropertyName = "createDate")]
    public DateTime? CreateDate { get; set; }
 
    // 完了日
    [JsonProperty(PropertyName = "completeDate")]
    public DateTime? CompleteDate { get; set; }
 
    // 完了フラグ
    [JsonProperty(PropertyName = "isCompleted")]
    public bool IsCompleted { get; set; }
}

　ここでは、DocumnetDBのSDKがオブジェクトをJSONにシリアライズできるように、各フィールドにJsonProperty属性を追加して、JSON項目名を指定しています。

　最後にProgram.csを修正します。ToDoリストに1件、ドキュメントを追加します。

リスト13　Mainメソッドの修正（Program.cs）

static void Main()
{
    DocumentRepository<TodoDocument>.Initialize();
    
    var document = new TodoDocument {
        Todo = "Cosmos DBを触ってみる",
        Auther = "akiba",
        CreateDate = DateTime.Now,
        CompleteDate = null,
        IsCompleted = false
    };

    DocumentRepository<TodoDocument>.CreateDocumentAsync(document).Wait();
}

　Program.csを実行後、Emulatorを更新してTodoCollectionの中にドキュメントが1件追加されていれば成功です。

図6　ドキュメント1件追加後のEmulator画面

おわりに

　今回は実装編として、DocumentDB APIを使ったCosmos DBへの基本的なアクセス方法について、データベース、コレクション、ドキュメントの作成まで説明しました。

　次回は今回の続きでドキュメントの検索、更新、削除の実装を行う予定です。

参考資料

• Cosmos DB - グローバル分散データベース サービス （旧 DocumentDB）
• Cosmos DB Emulator