javascript - Cosmos DB 中的 MaxItemCount 提要选项属性不起作用

Question

我正在尝试编写一个运行 SQL 查询的简单存储过程，我想通过使用 MaxItemCount 属性来限制结果。查询生成 3 个文档，但我只想返回 1 个文档。我正在使用 MaxItemCount 属性强制执行此限制，但这似乎不起作用。

function uspGetDetailsByEmailId(EmailId) {
  var collection = getContext().getCollection();
  var collectionLink = collection.getSelfLink();
  var response = getContext().getResponse();
  var recordcount = 0;
  if (!EmailId) throw new Error("Please provide the EmailId for which     Details need to be retrieved");     

  retrieveDetails();     

  function retrieveDetails() {
    var requestOptions = {MaxItemCount: "1"};
    var dbquery = {query: "SELECT * FROM c"};
    var isAccepted = collection.queryDocuments(collectionLink, dbquery, requestOptions,function (err, results) {
      console.log(results.length)  
      response.setBody(results)
      if (err) throw err;                   
    });

    if (!isAccepted) {
      response.setBody(null);
    }
  }
}

Answer 1

MaxItemCount 不是对整个查询将返回的文档数量的限制。

Cosmos DB 始终返回分页数据。这意味着，如果您取回 100 个文档，那么这些文档是从许多请求中返回的，每个请求具有相同或几乎相同数量的文档，这是一个很好的变化。然后将它们加在一起并返回。

MaxItemCount 是文档的最大帐户，单次访问 Cosmos DB 将包含，但是如果您使用 queryDocuments 方法查询数据，那么您将得到相同的结果数据量，但您将限制每次访问 Cosmos DB 的行程最多携带 1 个文档。

在这种情况下，您要做的是使用查询迭代器，并在获得第一个文档后退出迭代器的循环。

对此进行更多研究(主要是使用我能找到的唯一文档 https://azure.github.io/azure-cosmosdb-js-server)，存储过程使用的 js-server 看起来像是一个不同的 SDK。

进一步深入研究后，我发现 RequestOptions 对象中没有 MaxItemCount 属性(即使有也是一个整数)。然而，有一个名为 pageSize 的属性，您可以在 https://azure.github.io/azure-cosmosdb-js-server/DocDbWrapperScript.js.html 的第 554 行中看到。 .

经过测试，将 pageSize 设置为 1 似乎可以成功地将您的结果限制在所需的数量。

这是更新后的代码:

function uspGetDetailsByEmailId(EmailId) {
  var collection = getContext().getCollection();
  var collectionLink = collection.getSelfLink();
  var response = getContext().getResponse();
  var recordcount = 0;
  if (!EmailId) throw new Error("Please provide the EmailId for which     Details need to be retrieved");     

  retrieveDetails();     

  function retrieveDetails() {
    var requestOptions = { pageSize: 1};
    var dbquery = {query: "SELECT * FROM c"};
    var isAccepted = collection.queryDocuments(collectionLink, dbquery, requestOptions,function (err, results) {
      console.log(results.length)  
      response.setBody(results)
      if (err) throw err;                   
    });

    if (!isAccepted) {
      response.setBody(null);
    }
  }
}