Azure Cosmos DB 中的 JavaScript 查詢 API

  • 發行項

適用於：NoSQL

除了在 Azure Cosmos DB 中使用 API for NoSQL 發出查詢以外，Azure Cosmos DB 伺服器端 SDK 還提供 JavaScript 介面，可在 Azure Cosmos DB 預存程序和觸發程序中執行最佳化的查詢。 不必一定要懂得 SQL 語言才能使用此 JavaScript 介面。 JavaScript 的查詢 API 可讓您將述詞函式依序傳遞至函式呼叫，藉此以程式設計方式建立查詢，其語法類似 ECMAScript5 陣列內建和受歡迎的 JavaScript 程式庫，例如 lodash。 JavaScript 執行階段會剖析查詢，並使用 Azure Cosmos DB 的索引，有效執行該查詢。

支援的 JavaScript 函式

Function 說明
chain() ... .value([callback] [, options]) 啟動鏈結的呼叫，此呼叫必須以 value() 終止。
filter(predicateFunction [, options] [, callback]) 使用述詞函式來篩選輸入，此函式會傳回 true/false 以在結果集內篩出/篩除輸入文件。 此函式的行為類似於 SQL 中的 WHERE 子句。
flatten([isShallow] [, options] [, callback]) 合併並且壓平每個輸入項目的陣列成為單一陣列。 此函式的行為類似於 LINQ 中的 SelectMany。
map(transformationFunction [, options] [, callback]) 套用投射，其中提供了一個會將每個輸入項目對應至 JavaScript 物件或值的轉換函式。 此函式的行為類似於 SQL 中的 SELECT 子句。
pluck([propertyName] [, options] [, callback]) 此函式是一個對應的捷徑，此對應會從每個輸入項目擷取單一屬性值。
sortBy([predicate] [, options] [, callback]) 使用指定述詞以遞增順序排序輸入文件串流中的文件，產生一組新的文件。 此函式的行為類似於 SQL 中的 ORDER BY 子句。
sortByDescending([predicate] [, options] [, callback]) 使用指定述詞以遞減順序排序輸入文件串流中的文件，產生一組新的文件。 此函式的行為類似於 SQL 中的 ORDER BY x DESC 子句。
unwind(collectionSelector, [resultSelector], [options], [callback]) 使用內部陣列執行自我聯結，並將來自兩方的結果，以元組的方式新增到結果投射中。 例如，將個人文件與 person.pets 聯結後，會產生 [person, pet] 元組。 這類似於 .NET LINQ 中的 SelectMany。

當裡面包含述詞和/或選取器函式時，下列 JavaScript 建構會自動取得最佳化，以便直接在 Azure Cosmos DB 索引上執行：

  • 簡單運算子：=+-*/%|^&==!====!==<><=>=||&&<<>>>>>~
  • 常值，包含物件常值：{}
  • var、return

下列 JavaScript 建構不會取得 Azure Cosmos DB 索引的最佳化：

  • 控制流程： ifforwhile
  • 函式呼叫

如需詳細資料，請參閱 Azure Cosmos DB 伺服器端 JavaScript 文件。

SQL 到 JavaScript 的速查表

下列表格包含各種不同的 SQL 查詢和相對應的 JavaScript 查詢。 如同 SQL 查詢，屬性 （例如， item.id） 會區分大小寫。

注意

使用 JavaScript 查詢 API 時，__ (雙底線) 是 getContext().getCollection() 的別名。

SQL JavaScript 查詢 API 說明
SELECT *
FROM docs		 __.map(function(doc) {
    return doc;
});		 所有文件中的結果 (使用連續權杖分頁)。
SELECT
   docs.id,
   docs.message AS msg,
   docs.actions
FROM docs		 __.map(function(doc) {
    return {
        id: doc.id,
        msg: doc.message,
        actions:doc.actions
    };
});		 投射識別碼、訊息 (別名為 msg)，和所有文件中的動作。
SELECT *
FROM docs
WHERE
   docs.id="X998_Y998"		 __.filter(function(doc) {
    return doc.id ==="X998_Y998";
});		 使用 predicate: id = "X998_Y998" 查詢文件。
SELECT *
FROM docs
WHERE
   ARRAY_CONTAINS(docs.Tags, 123)		 __.filter(function(x) {
    return x.Tags && x.Tags.indexOf(123) > -1;
});		 查詢具有 Tags 屬性的文件，且 Tags 是包含值 123 的陣列。
SELECT
   docs.id,
   docs.message AS msg
FROM docs
WHERE
   docs.id="X998_Y998"		 __.chain()
    .filter(function(doc) {
        return doc.id ==="X998_Y998";
    })
    .map(function(doc) {
       return {
            id: doc.id,
            msg: doc.message
       };
    })
.value();		 使用 predicate, id = "X998_Y998" 查詢文件，然後投射識別碼和訊息 (別名為 msg)。
SELECT VALUE tag
FROM docs
JOIN tag IN docs.Tags
ORDER BY docs._ts		 __.chain()
    .filter(function(doc) {
        return doc.Tags && Array.isArray(doc.Tags);
    })
    .sortBy(function(doc) {
        return doc._ts;
    })
    .pluck("Tags")
    .flatten()
    .value()		 篩選具有陣列屬性 Tags 的文件，並且依據 _ts 時間戳記系統屬性來排序結果文件，然後投射及壓平合併 Tags 陣列。

下一步

進一步了解更多相關概念，以及如何在 Azure Cosmos DB 中寫入和使用預存程序、觸發程序和使用者定義的函式：