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