まずドキュメントDBは(カウントのためのサポートを提供していません)と、彼らは問題がある、私は取得異なる結果が
function usp_GetInfinityDataView(param) {
var context = getContext();
var response = context.getResponse();
var collection = context.getCollection();
var collectionLink = collection.getSelfLink();
var Rount = 0;
count("SELECT i.id FROM infinity i",null);
var query = {
query: 'SELECT * FROM infinity i'
};
getNodes(param["ContinuationToken"],param["PageSize"]);
function getNodes(continuationToken,intPageSize) {
// Tune the pageSize to fit your dataset.
var requestOptions = {
continuation: continuationToken,
pageSize: intPageSize
};
var accepted = collection.queryDocuments(collectionLink, query, requestOptions,
function(err, documentsRead, responseOptions) {
response.setBody({
"ResponseContinuation": responseOptions.continuation,
"Count": Rount,
"ViewData": documentsRead
});
});
}
function count(filterQuery, continuationToken) {
var collection = getContext().getCollection();
var maxResult = 99999999999; // MAX number of docs to process in one batch, when reached, return to client/request continuation.
// intentionally set low to demonstrate the concept. This can be much higher. Try experimenting.
// We've had it in to the high thousands before seeing the stored proceudre timing out.
// The number of documents counted.
var result = 0;
tryQuery(continuationToken);
// Helper method to check for max result and call query.
function tryQuery(nextContinuationToken) {
var responseOptions = { continuation: nextContinuationToken, pageSize : maxResult };
// In case the server is running this script for long time/near timeout, it would return false,
// in this case we set the response to current continuation token,
// and the client will run this script again starting from this continuation.
// When the client calls this script 1st time, is passes empty continuation token.
if (result >= maxResult || !query(responseOptions)) {
setBody(nextContinuationToken);
}
}
function query(responseOptions) {
// For empty query string, use readDocuments rather than queryDocuments -- it's faster as doesn't need to process the query.
return (filterQuery && filterQuery.length) ?
collection.queryDocuments(collection.getSelfLink(), filterQuery, responseOptions, onReadDocuments) :
collection.readDocuments(collection.getSelfLink(), responseOptions, onReadDocuments);
}
// This is callback is called from collection.queryDocuments/readDocuments.
function onReadDocuments(err, docFeed, responseOptions) {
if (err) {
throw 'Error while reading document: ' + err;
}
// Increament the number of documents counted so far.
result += docFeed.length;
// If there is continuation, call query again with it,
// otherwise we are done, in which case set continuation to null.
if (responseOptions.continuation) {
tryQuery(responseOptions.continuation);
} else {
setBody(null);
}
}
// Set response body: use an object the client is expecting (2 properties: result and continuationToken).
function setBody(continuationToken) {
Rount = result;
}
}
}
の下に私のストアドプロシージャで使用されている数を取得するためにstored procedureを提供してきました私はこの手順をC#web apiから呼び出すたびに、実際の数ではなく、実際の数を返します(結果セット数は17491ですが、17020または17202と時々合計を返します)。私は両方の手順を分離しようとしましたが、それでも同じです。