Documentdb Sql 简明教程

DocumentDB SQL - JavaScript Integration

如今，JavaScript 无处不在，而不仅仅在浏览器中。DocumentDB 作为一种现代版 T-SQL 接受 JavaScript，支持原生地对 JavaScript 逻辑进行事务执行，就在数据库引擎内部。DocumentDB 提供了一种编程模型，用于根据存储过程和触发器直接对集合中的基于 JavaScript 的应用程序逻辑进行执行。

我们来看一个创建简单存储过程的示例。以下步骤 −

Step 1 − 创建一个新的控制台应用程序。

Step 2 − 从 NuGet 添加 .NET SDK。我们此处使用 .NET SDK，这意味着我们将编写一些 C# 代码来创建、执行，然后删除我们的存储过程，但存储过程本身是用 JavaScript 编写的。

Step 3 − 右键单击解决方案资源管理器中的项目。

Step 4 − 添加用于存储过程的新 JavaScript 文件并将其称为 HelloWorldStoreProce.js

每个存储过程都只是一个 JavaScript 函数，因此我们将创建一个新函数，并自然地也将此函数称为 HelloWorldStoreProce 。无论是否为函数命名都没有关系。DocumentDB 只会通过我们在创建时提供的 Id 来引用这个存储过程。

function HelloWorldStoreProce() {
   var context = getContext();
   var response = context.getResponse();
   response.setBody('Hello, and welcome to DocumentDB!');
}

存储过程的所有操作就是从上下文中获取 response 对象并调用其 setBody 方法，向调用方返回一个字符串。在 C# 代码中，我们将创建存储过程，执行它，然后删除它。

存储过程的范围是每个集合，因此我们将需要集合的 SelfLink 来创建存储过程。

Step 5 − 首先查询 myfirstdb 数据库，然后查询 MyCollection 集合。

创建存储过程就像创建 DocumentDB 中的任何其他资源一样。

private async static Task SimpleStoredProcDemo() {
   var endpoint = "https://azuredocdbdemo.documents.azure.com:443/";
   var masterKey =
      "BBhjI0gxdVPdDbS4diTjdloJq7Fp4L5RO/StTt6UtEufDM78qM2CtBZWbyVwFPSJIm8AcfDu2O+AfV T+TYUnBQ==";

   using (var client = new DocumentClient(new Uri(endpoint), masterKey)) {
      // Get database
      Database database = client
         .CreateDatabaseQuery("SELECT * FROM c WHERE c.id = 'myfirstdb'")
         .AsEnumerable()
         .First();

      // Get collection
      DocumentCollection collection = client
         .CreateDocumentCollectionQuery(database.CollectionsLink, "SELECT * FROM
         c WHERE c.id = 'MyCollection'")
         .AsEnumerable()
         .First();

      // Create stored procedure
      var sprocBody = File.ReadAllText(@"..\..\HelloWorldStoreProce.js");

      var sprocDefinition = new StoredProcedure {
         Id = "HelloWorldStoreProce",
         Body = sprocBody
      };

      StoredProcedure sproc = await client.
         CreateStoredProcedureAsync(collection.SelfLink, sprocDefinition);
      Console.WriteLine("Created stored procedure {0} ({1})",
         sproc.Id, sproc.ResourceId);

      // Execute stored procedure
      var result = await client.ExecuteStoredProcedureAsync(sproc.SelfLink);
      Console.WriteLine("Executed stored procedure; response = {0}", result.Response);

      // Delete stored procedure
      await client.DeleteStoredProcedureAsync(sproc.SelfLink);
      Console.WriteLine("Deleted stored procedure {0} ({1})",
         sproc.Id, sproc.ResourceId);
   }
}

Step 6 - 首先使用新资源的 Id 创建一个定义对象，然后在 DocumentClient 对象上调用 Create 方法之一。对于一个存储过程来说，定义包括用于传输到服务器的 Id 和实际 JavaScript 代码。

Step 7 - 调用 File.ReadAllText 以从 JS 文件中提取存储过程代码。

Step 8 - 将存储过程代码分配给定义对象的 body 属性。

对于 DocumentDB 来说，我们在定义中指定的 Id 是存储过程的名称，无关乎我们实际为 JavaScript 函数命名的名称。

然而，在创建存储过程和其他服务器端对象时，建议为 JavaScript 函数命名，而且这些函数名称要与我们在 DocumentDB 定义中设置的 Id 匹配。

Step 9 - 调用 CreateStoredProcedureAsync ，传递给 SelfLink 的 MyCollection 以及存储过程定义。这将创建 DocumentDB 为其分配的存储过程和 ResourceId 。

Step 10 - 调用存储过程。 ExecuteStoredProcedureAsync 采用类型参数，将其设置为存储过程返回的值的预期数据类型，如果你想要返回一个动态对象，则可以简单地将其指定为一个对象。那是一个在运行时将绑定其属性的对象。

在本例中，我们知道存储过程只返回一个字符串，因此我们调用 ExecuteStoredProcedureAsync<string> 。

以下是 Program.cs 文件的完整实现。

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

using System;
using System.Collections.Generic;
using System.Diagnostics;
using System.IO;

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

namespace DocumentDBStoreProce {
   class Program {
      private static void Main(string[] args) {
         Task.Run(async () => {
            await SimpleStoredProcDemo();
         }).Wait();
      }

      private async static Task SimpleStoredProcDemo() {
         var endpoint = "https://azuredocdbdemo.documents.azure.com:443/";
         var masterKey =
            "BBhjI0gxdVPdDbS4diTjdloJq7Fp4L5RO/StTt6UtEufDM78qM2CtBZWbyVwFPSJIm8AcfDu2O+AfV T+TYUnBQ==";

         using (var client = new DocumentClient(new Uri(endpoint), masterKey)) {
            // Get database
            Database database = client
               .CreateDatabaseQuery("SELECT * FROM c WHERE c.id = 'myfirstdb'")
               .AsEnumerable()
               .First();

            // Get collection
            DocumentCollection collection = client
               .CreateDocumentCollectionQuery(database.CollectionsLink,
               "SELECT * FROM c WHERE c.id = 'MyCollection'")
               .AsEnumerable()
               .First();

            // Create stored procedure
            var sprocBody = File.ReadAllText(@"..\..\HelloWorldStoreProce.js");

            var sprocDefinition = new StoredProcedure {
               Id = "HelloWorldStoreProce",
               Body = sprocBody
            };

            StoredProcedure sproc = await client
               .CreateStoredProcedureAsync(collection.SelfLink, sprocDefinition);

            Console.WriteLine("Created stored procedure {0} ({1})", sproc
               .Id, sproc.ResourceId);

            // Execute stored procedure
            var result = await client
               .ExecuteStoredProcedureAsync<string>(sproc.SelfLink);
            Console.WriteLine("Executed stored procedure; response = {0}",
               result.Response);

            // Delete stored procedure
            await client.DeleteStoredProcedureAsync(sproc.SelfLink);
            Console.WriteLine("Deleted stored procedure {0} ({1})",
               sproc.Id, sproc.ResourceId);
         }
      }
   }
}

执行以上代码时，会产生以下输出。

Created stored procedure HelloWorldStoreProce (Ic8LAMEUVgACAAAAAAAAgA==)

Executed stored procedure; response = Hello, and welcome to DocumentDB!

如上面的输出所示，response 属性包含存储过程返回的“Hello, and welcome to DocumentDB!”。