Simple CRUD Operations In Azure Cosmos DB

Introduction

• This article will help the beginners to perform CRUD operations on Cosmos DB database using C#.
• If you are new to Cosmos DB, then please refer Getting Started with Cosmos DB article.

Let’s start.

• Create Solution and add NuGet Package

1. Create a new console app.
2. Right-click on Project -> Manage NuGet Package.
3. Search for ‘documentdb’ under the "Browse" tab.
4. Select Microsoft.Azure.DocumentDB package and click on Install.
    

• Add Config Settings
   
  Go to App Settings and add the following configuration.

  <appSettings>
    <!--Add Cosmos DB Endpoint URL-->
    <add key="DocDbEndpoint" value =""/>
     <!--Add Primary Key-->
    <add key="DocDbMasterKey" value =""/>
  </appSettings>

• How to get Endpoint URL and Master Key?
   
  1. Open the Azure portal.
  2. Go to the Cosmos DB account.
  3. Click on Keys.
  4. Copy the URI and Primary Key.
      
      
      
  5. URI = DocDbEndpoint
  6. Primary Key = DocDbMasterKey

• Initialize Document Client Instance
   
  1. Add a reference to Configuration;
  2. Add a reference to Microsoft.Azure.Documents.Client;
  3. Retrieve Endpoint URL and Primary Key

     using Microsoft.Azure.Documents;
     using Microsoft.Azure.Documents.Client;
     using System;
     using System.Configuration;
     using System.Linq;
     using System.Threading.Tasks;
     
     namespace CosmosDBCrudOperationd
     {
         class Program
         {
             static void Main(string[] args)
             {
                 Task.Run(async () =>
                 {
                       var endpoint = ConfigurationManager.AppSettings["DocDbEndpoint"];
                     var masterKey = ConfigurationManager.AppSettings["DocDbMasterKey"];
                     using (var client = new DocumentClient(new Uri(endpoint), masterKey))
                     {
     
                     }
     
                 }).Wait();
             }
         }
     }

• Create a New Cosmos DB Database

  Console.WriteLine("\r\n>>>>>>>>>>>>>>>> Creating Database <<<<<<<<<<<<<<<<<<<");
  // Create new database Object
  //Id defines name of the database
  var databaseDefinition = new Database { Id = "testDb" };
  var database = await client.CreateDatabaseIfNotExistsAsync(databaseDefinition);
  Console.WriteLine("Database testDb created successfully");

• Create a new database collection.
   
  A database is a container that holds the number of collections.
   
  To create a new collection, you need to give the path of the database under which you want to create the collection.
   
  Database path can be given in following format,
   
  dbo/{databaseName}

  //Create new database collection
  Console.WriteLine("\r\n>>>>>>>>>>>>>>>> Creating Collection <<<<<<<<<<<<<<<<<<<");
  var collectionDefinition = new DocumentCollection { Id = "testDocumentCollection" };
  var collection = await client.CreateDocumentCollectionIfNotExistsAsync("dbo/testDb",
      collectionDefinition);
  Console.WriteLine("Collection testDocumentCollection created successfully");

You can see that CreateDocumentCollectionIfNotExistsAsync accepts two parameters.

1. Database Link (path to database): dbo/testDb
2. Document Collection Object
    
   Alternatively, you can use UriFactory.CreateDatabaseUri(databaseName) method to create database URI for you.

   //Create new database collection
    Console.WriteLine("\r\n>>>>>>>>>>>>>>>> Creating Collection <<<<<<<<<<<<<<<<<<<");
    var collectionDefinition = new DocumentCollection { Id = "testDocumentCollection" };
    var collection = await client.CreateDocumentCollectionIfNotExistsAsync(UriFactory.CreateDatabaseUri("testDb"),
        collectionDefinition);
    Console.WriteLine("Collection testDocumentCollection created successfully");

• Insert New Document in Collection
   
  To insert a new document, you need two things.
   
  1. Path to collection: dbo/{databaseName}/colls/{collectionName}
  2. Document Object 

     //Insert new Document
      Console.WriteLine("\r\n>>>>>>>>>>>>>>>> Creating Document <<<<<<<<<<<<<<<<<<<");
      dynamic doc1Definition = new
      {
          title = "Star War IV ",
          rank = 600,
          category = "Sci-fi"
      };
      var document1 = await client.CreateDocumentAsync(
          UriFactory.CreateDocumentCollectionUri("testDb", "testDocumentCollection"),
          doc1Definition);

Here, doc1Definatin defines the document we want to insert in Cosmos DB.

 

UriFactory.CreateDocumentCollectionUri("testDb", "testDocumentCollection") method is used to create the collection URI “dbo/testDb/colls/testDocumentCollection”.

 

Query Inserted Document

Console.WriteLine("\r\n>>>>>>>>>>>> Querying Document <<<<<<<<<<<<<<<<<<<<");
 var response = client.CreateDocumentQuery
 (UriFactory.CreateDocumentCollectionUri("testDb", "testDocumentCollection"),
     "select * from c").ToList();
 var document = response.First();
 Console.WriteLine($"Id:{document.id}");
 Console.WriteLine($"Title:{document.title}");
 Console.WriteLine($"Rank:{document.rank}");
 Console.WriteLine($"category:{document.category}");

CreateDocumentQuery method requires two parametes,

1. Collection URI
2. Query string

Delete Collection

Console.WriteLine("\r\n>>>>>>>>>>>>>>>> Deleteing Collection <<<<<<<<<<<<<<<<<<<");
await client.DeleteDocumentCollectionAsync(
    UriFactory.CreateDocumentCollectionUri("testDb", "testDocumentCollection"));

Overall Code

using Microsoft.Azure.Documents;
using Microsoft.Azure.Documents.Client;
using System;
using System.Configuration;
using System.Linq;
using System.Threading.Tasks;

namespace CosmosDBCrudOperationd
{
    class Program
    {
        static void Main(string[] args)
        {
            Task.Run(async () =>
            {
                var endpoint = ConfigurationManager.AppSettings["DocDbEndpoint"];
                var masterKey = ConfigurationManager.AppSettings["DocDbMasterKey"];
                using (var client = new DocumentClient(new Uri(endpoint), masterKey))
                {
                    Console.WriteLine("\r\n>>>>>>>>>>>>>>>> Creating Database <<<<<<<<<<<<<<<<<<<");
                    // Create new database Object
                    //Id defines name of the database
                    var databaseDefinition = new Database { Id = "testDb" };
                    var database = await client.CreateDatabaseIfNotExistsAsync(databaseDefinition);
                    Console.WriteLine("Database testDb created successfully");

                    //Create new database collection
                    Console.WriteLine("\r\n>>>>>>>>>>>>>>>> Creating Collection <<<<<<<<<<<<<<<<<<<");
                    var collectionDefinition = new DocumentCollection { Id = "testDocumentCollection" };
                    var collection = await client.CreateDocumentCollectionIfNotExistsAsync(UriFactory.CreateDatabaseUri("testDb"),
                        collectionDefinition);
                    Console.WriteLine("Collection testDocumentCollection created successfully");

                    //Insert new Document
                    Console.WriteLine("\r\n>>>>>>>>>>>>>>>> Creating Document <<<<<<<<<<<<<<<<<<<");
                    dynamic doc1Definition = new
                    {
                        title = "Star War IV ",
                        rank = 600,
                        category = "Sci-fi"
                    };
                    var document1 = await client.CreateDocumentAsync(
                        UriFactory.CreateDocumentCollectionUri("testDb", "testDocumentCollection"),
                        doc1Definition);

                    Console.WriteLine("\r\n>>>>>>>>>>>> Querying Document <<<<<<<<<<<<<<<<<<<<");
                    var response = client.CreateDocumentQuery(UriFactory.CreateDocumentCollectionUri("testDb", "testDocumentCollection"),
                        "select * from c").ToList();
                    var document = response.First();
                    Console.WriteLine($"Id:{document.id}");
                    Console.WriteLine($"Title:{document.title}");
                    Console.WriteLine($"Rank:{document.rank}");
                    Console.WriteLine($"category:{document.category}");

                    Console.WriteLine("\r\n>>>>>>>>>>>>>>>> Deleteing Collection <<<<<<<<<<<<<<<<<<<");
                    await client.DeleteDocumentCollectionAsync(UriFactory.CreateDocumentCollectionUri("testDb", "testDocumentCollection"));

                    Console.ReadKey();
                }

            }).Wait();
        }
    }
}