Estou tentando paginar uma consulta no Azure Cosmos DB
, lendo esse post: Paging through query results in Azure DocumentDB, cheguei ao código:
public async Task <ICollection <TEntity>> GetAllPaged(int page, string colletionId) {
FeedOptions queryOptions = new FeedOptions {
MaxItemCount = 10
};
var query = client.CreateDocumentQuery <TEntity> (
UriFactory.CreateDocumentCollectionUri(databaseId, colletionId), queryOptions)
.AsDocumentQuery();
FeedResponse <TEntity> result;
List <TEntity> tEntitys = new List <TEntity> ();
int interacoes = 0;
while (query.HasMoreResults) {
interacoes++;
if (interacoes == page) {
result = await query.ExecuteNextAsync <TEntity> ();
tEntitys = result.ToList();
break;
}
}
return tEntitys;
}
Explicando:
MaxItemCount = 10
, total de itens por página.while (query.HasMoreResults)
, execute umloop
até que haja resultados.if (interacoes == page)
, quando chegar na minha página não preciso mais verificar os próximos, onde entra obreak
.
Problema:
Imaginem que tenho cerca de 50002 documentos, e que minha página solicite ao método o resultado de número 5001, ou seja, os 2 últimos registros.
A cada interação do while
esse código:result = await query.ExecuteNextAsync<TEntity>()
é responsável por cada página de resultados.
Pensei em executar esse código somente na página especifica que necessito através desse código :if (interacoes == page)
, o problema disso é que somente o primeiro resultado é lido, ou seja, eu preciso ler página por página para conseguir o resultado desejado descrito no cenário acima, e isso tem me gerado 15 segundos de performasse.
Nota: Skip
não é suportado pois oferece uma péssima performasse. Mais nos Issues do GitHub!