DocumentDB - 刪除資料庫



您可以透過門戶以及使用 .Net SDK 的程式碼刪除一個或多個數據庫。在這裡,我們將逐步討論如何在 DocumentDB 中刪除資料庫。

步驟 1 - 前往 Azure 門戶上的 DocumentDB 帳戶。為了演示,我添加了另外兩個資料庫,如下面的螢幕截圖所示。

Drop Databases

步驟 2 - 要刪除任何資料庫,您需要單擊該資料庫。讓我們選擇 tempdb,您將看到以下頁面,選擇“刪除資料庫”選項。

Delete Database

步驟 3 - 它將顯示確認訊息,現在單擊“是”按鈕。

Confirmation Message

您將看到 tempdb 不再在您的儀表板上可用。

TempDB Deleted

您也可以使用 .Net SDK 從程式碼中刪除資料庫。步驟如下。

步驟 1 - 讓我們透過指定要刪除的資料庫的 ID 來刪除資料庫,但我們需要它的 SelfLink。

步驟 2 - 我們像以前一樣呼叫 CreateDatabaseQuery,但這次我們實際上提供了一個查詢,只返回 ID 為 tempdb1 的一個數據庫。

private async static Task DeleteDatabase(DocumentClient client) {
   Console.WriteLine("******** Delete Database ********");
   Database database = client
      .CreateDatabaseQuery("SELECT * FROM c WHERE c.id = 'tempdb1'")
      .AsEnumerable()
      .First();
   await client.DeleteDatabaseAsync(database.SelfLink);
}

步驟 3 - 這次,我們可以呼叫 AsEnumerable 而不是 ToList(),因為我們實際上不需要列表物件。預期只有一個結果,呼叫 AsEnumerable 就足夠了,這樣我們就可以使用 First() 獲取查詢返回的第一個資料庫物件。這是 tempdb1 的資料庫物件,它有一個 SelfLink,我們可以使用它來呼叫 DeleteDatabaseAsync 來刪除資料庫。

步驟 4 - 在例項化 DocumentClient 後,您還需要從 CreateDocumentClient 任務呼叫 DeleteDatabase 任務。

步驟 5 - 要在刪除指定資料庫後檢視資料庫列表,讓我們再次呼叫 GetDatabases 方法。

using (var client = new DocumentClient(new Uri(EndpointUrl), AuthorizationKey)) {
   //await CreateDatabase(client);
	
   GetDatabases(client);
   await DeleteDatabase(client);
   GetDatabases(client); 
} 

以下是到目前為止完整的 Program.cs 檔案。

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;

using Microsoft.Azure.Documents;
using Microsoft.Azure.Documents.Client;
using Microsoft.Azure.Documents.Linq;
using Newtonsoft.Json;

namespace DocumentDBDemo {

   class Program {
	
      private const string EndpointUrl = "https://azuredocdbdemo.documents.azure.com:443/";
		
      private const string AuthorizationKey = "BBhjI0gxdVPdDbS4diTjdloJq7Fp4L5RO/
         StTt6UtEufDM78qM2CtBZWbyVwFPSJIm8AcfDu2O+AfV T+TYUnBQ==";
			
      static void Main(string[] args) {
         try {
            CreateDocumentClient().Wait();
         } catch (Exception e) {
            Exception baseException = e.GetBaseException();
            Console.WriteLine("Error: {0}, Message: {1}", e.Message, baseException.Message);
         }
         Console.ReadKey();
      }
		
      private static async Task CreateDocumentClient() {
         // Create a new instance of the DocumentClient
         using (var client = new DocumentClient(new Uri(EndpointUrl), AuthorizationKey)) {
            //await CreateDatabase(client);
            GetDatabases(client);
            await DeleteDatabase(client);
            GetDatabases(client);
         }
      }
		
      private async static Task CreateDatabase(DocumentClient client) {
         Console.WriteLine();
         Console.WriteLine("******** Create Database *******");
			
         var databaseDefinition = new Database { Id = "mynewdb" };
         var result = await client.CreateDatabaseAsync(databaseDefinition);
         var database = result.Resource;
			
         Console.WriteLine(" Database Id: {0}; Rid: {1}",
            database.Id, database.ResourceId);
         Console.WriteLine("******** Database Created *******");
      }
		
      private static void GetDatabases(DocumentClient client) {
         Console.WriteLine();
         Console.WriteLine();
         Console.WriteLine("******** Get Databases List ********");
			
         var databases = client.CreateDatabaseQuery().ToList();
			
         foreach (var database in databases) {
            Console.WriteLine(" Database Id: {0}; Rid: {1}", database.Id,
               database.ResourceId);
         }
			
         Console.WriteLine();
         Console.WriteLine("Total databases: {0}", databases.Count);
      }
		
      private async static Task DeleteDatabase(DocumentClient client) {
         Console.WriteLine();
         Console.WriteLine("******** Delete Database ********");
			
         Database database = client
            .CreateDatabaseQuery("SELECT * FROM c WHERE c.id = 'tempdb1'")
            .AsEnumerable()
            .First();
         await client.DeleteDatabaseAsync(database.SelfLink);
      }
		
   }
}

編譯並執行上述程式碼後,您將收到以下輸出,其中包含三個資料庫的資料庫 ID 和資源 ID,以及資料庫的總數。

******** Get Databases List ******** 
 Database Id: myfirstdb; Rid: Ic8LAA== 
 Database Id: mynewdb; Rid: ltpJAA== 
 Database Id: tempdb1; Rid: 06JjAA==
 
Total databases: 3  

******** Delete Database ******** 
  
******** Get Databases List ******** 
 Database Id: myfirstdb; Rid: Ic8LAA== 
 Database Id: mynewdb; Rid: ltpJAA==
 
Total databases: 2 

刪除資料庫後,您還將在最後看到 DocumentDB 帳戶中只剩下兩個資料庫。

廣告