Como escrever procedimentos armazenados e acionadores no Azure Cosmos DB com a API de consulta JavaScript
APLICA-SE A: NoSQL
O Azure Cosmos DB permite-lhe executar consultas otimizadas através de uma interface JavaScript fluente sem qualquer conhecimento da linguagem SQL que possa ser utilizada para escrever procedimentos ou acionadores armazenados. Para saber mais sobre o suporte da API de Consulta JavaScript no Azure Cosmos DB, veja o artigo Working with JavaScript language integrated query API in Azure Cosmos DB (Trabalhar com a API de consulta integrada de linguagem JavaScript no Azure Cosmos DB ).
Procedimento armazenado com a API de consulta JavaScript
O seguinte exemplo de código é um exemplo de como a API de consulta JavaScript é utilizada no contexto de um procedimento armazenado. O procedimento armazenado insere um item do Azure Cosmos DB especificado por um parâmetro de entrada e atualiza um documento de metadados com o __.filter()
método minSize, maxSize e totalSize com base na propriedade tamanho do item de entrada.
Nota
__
(sublinhado duplo) é um alias para quando getContext().getCollection()
utilizar a API de consulta JavaScript.
/**
* Insert an item and update metadata doc: minSize, maxSize, totalSize based on item.size.
*/
function insertDocumentAndUpdateMetadata(item) {
// HTTP error codes sent to our callback function by CosmosDB server.
var ErrorCode = {
RETRY_WITH: 449,
}
var isAccepted = __.createDocument(__.getSelfLink(), item, {}, function(err, item, options) {
if (err) throw err;
// Check the item (ignore items with invalid/zero size and metadata itself) and call updateMetadata.
if (!item.isMetadata && item.size > 0) {
// Get the metadata. We keep it in the same container. it's the only item that has .isMetadata = true.
var result = __.filter(function(x) {
return x.isMetadata === true
}, function(err, feed, options) {
if (err) throw err;
// We assume that metadata item was pre-created and must exist when this script is called.
if (!feed || !feed.length) throw new Error("Failed to find the metadata item.");
// The metadata item.
var metaItem = feed[0];
// Update metaDoc.minSize:
// for 1st document use doc.Size, for all the rest see if it's less than last min.
if (metaItem.minSize == 0) metaItem.minSize = item.size;
else metaItem.minSize = Math.min(metaItem.minSize, item.size);
// Update metaItem.maxSize.
metaItem.maxSize = Math.max(metaItem.maxSize, item.size);
// Update metaItem.totalSize.
metaItem.totalSize += item.size;
// Update/replace the metadata item in the store.
var isAccepted = __.replaceDocument(metaItem._self, metaItem, function(err) {
if (err) throw err;
// Note: in case concurrent updates causes conflict with ErrorCode.RETRY_WITH, we can't read the meta again
// and update again because due to Snapshot isolation we will read same exact version (we are in same transaction).
// We have to take care of that on the client side.
});
if (!isAccepted) throw new Error("replaceDocument(metaItem) returned false.");
});
if (!result.isAccepted) throw new Error("filter for metaItem returned false.");
}
});
if (!isAccepted) throw new Error("createDocument(actual item) returned false.");
}
Passos seguintes
Veja os seguintes artigos para saber mais sobre procedimentos armazenados, acionadores e funções definidas pelo utilizador no Azure Cosmos DB:
Como registar e utilizar procedimentos armazenados no Azure Cosmos DB
Como registar e utilizar pré-acionadores e pós-acionadores no Azure Cosmos DB
Como registar e utilizar funções definidas pelo utilizador no Azure Cosmos DB