如何使用 Azure DocumentDB 执行 UPSERT?
How can I perform an UPSERT using Azure DocumentDB?
Azure DocumentDB 不支持 UPSERT。是否有合理的解决方法来实现相同的功能?
使用存储过程来检查文档是否存在以确定是否应该执行插入或更新是一种有效的策略吗?
如果我需要批量执行数千个这样的操作怎么办?
在此处为功能投票:
http://feedback.azure.com/forums/263030-documentdb/suggestions/7075256-provide-for-upsert
更新 - 这是我对批量更新插入存储过程的尝试。
function bulkImport(docs) {
var collection = getContext().getCollection();
var collectionLink = collection.getSelfLink();
var count = 0;
if (!docs) throw new Error('Docs parameter is null');
var docsLength = docs.length;
if (docsLength == 0) {
getContext().getResponse().setBody(0);
}
tryUpsert(docs[count], callback);
function tryUpsert(doc, callback) {
var query = { query: ""select * from root r where r.id = @id"", parameters: [ {name: ""@id"", value: doc.id}]};
var isAccepted = collection.queryDocuments(collectionLink, query, function(err, resources, options) {
if (err) throw err;
if(resources.length > 0) {
// Perform a replace
var isAccepted = collection.replaceDocument(resources[0]._self, doc, callback);
if (!isAccepted) getContext().getResponse().setBody(count);
}
else {
// Perform a create
var isAccepted = collection.createDocument(collectionLink, doc, callback);
if (!isAccepted) getContext().getResponse().setBody(count);
}
});
if (!isAccepted) getContext().getResponse().setBody(count);
}
function callback(err, doc, options) {
if (err) throw err;
// One more document has been inserted, increment the count.
count++;
if (count >= docsLength) {
// If we have created all documents, we are done. Just set the response.
getContext().getResponse().setBody(count);
} else {
// Create next document.
tryUpsert(docs[count], callback);
}
}
}
更新(2015-10-06): Atomic upsert Azure DocumentDB 现已支持。
是的,存储过程非常适合更新插入。
DocumentDB 上什至有可用的代码示例 Github:
Azure DocumentDB 不支持 UPSERT。是否有合理的解决方法来实现相同的功能?
使用存储过程来检查文档是否存在以确定是否应该执行插入或更新是一种有效的策略吗?
如果我需要批量执行数千个这样的操作怎么办?
在此处为功能投票:
http://feedback.azure.com/forums/263030-documentdb/suggestions/7075256-provide-for-upsert
更新 - 这是我对批量更新插入存储过程的尝试。
function bulkImport(docs) {
var collection = getContext().getCollection();
var collectionLink = collection.getSelfLink();
var count = 0;
if (!docs) throw new Error('Docs parameter is null');
var docsLength = docs.length;
if (docsLength == 0) {
getContext().getResponse().setBody(0);
}
tryUpsert(docs[count], callback);
function tryUpsert(doc, callback) {
var query = { query: ""select * from root r where r.id = @id"", parameters: [ {name: ""@id"", value: doc.id}]};
var isAccepted = collection.queryDocuments(collectionLink, query, function(err, resources, options) {
if (err) throw err;
if(resources.length > 0) {
// Perform a replace
var isAccepted = collection.replaceDocument(resources[0]._self, doc, callback);
if (!isAccepted) getContext().getResponse().setBody(count);
}
else {
// Perform a create
var isAccepted = collection.createDocument(collectionLink, doc, callback);
if (!isAccepted) getContext().getResponse().setBody(count);
}
});
if (!isAccepted) getContext().getResponse().setBody(count);
}
function callback(err, doc, options) {
if (err) throw err;
// One more document has been inserted, increment the count.
count++;
if (count >= docsLength) {
// If we have created all documents, we are done. Just set the response.
getContext().getResponse().setBody(count);
} else {
// Create next document.
tryUpsert(docs[count], callback);
}
}
}
更新(2015-10-06): Atomic upsert Azure DocumentDB 现已支持。
是的,存储过程非常适合更新插入。
DocumentDB 上什至有可用的代码示例 Github: