DocumentDB – 列出数据库
DocumentDB – 列出数据库
到目前为止,我们已经在 DocumentDB 帐户中创建了两个数据库,第一个是使用 Azure 门户创建的,而第二个数据库是使用 .Net SDK 创建的。现在要查看这些数据库,您可以使用 Azure 门户。
转到 Azure 门户上的 DocumentDB 帐户,您现在将看到两个数据库。
您还可以使用 .Net SDK 从代码中查看或列出数据库。以下是涉及的步骤。
步骤 1 – 发出不带参数的数据库查询,返回完整列表,但您也可以传入查询以查找特定数据库或特定数据库。
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); }
您将看到有许多用于定位集合、文档、用户和其他资源的 CreateQuery 方法。这些方法实际上并不执行查询,它们只是定义查询并返回一个可迭代的对象。
实际上是调用 ToList() 来执行查询,迭代结果,并在列表中返回它们。
步骤 2 – 在 DocumentClient 实例化后,从 CreateDocumentClient 任务调用 GetDatabases 方法。
第 3 步– 您还需要注释 CreateDatabase 任务或更改数据库 ID,否则您将收到数据库存在的错误消息。
using (var client = new DocumentClient(new Uri(EndpointUrl), AuthorizationKey)) { //await CreateDatabase(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); } } 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); } } }
编译并执行上述代码后,您将收到以下输出,其中包含两个数据库的数据库和资源 ID。最后,您还将看到数据库的总数。
******** Get Databases List ******** Database Id: myfirstdb; Rid: Ic8LAA== Database Id: mynewdb; Rid: ltpJAA== Total databases: 2