cosmos db 的 javascript 存储过程不支持原生 `cosmospatchoperation`，其内置 `upsertdocument` 方法仅接受完整文档对象；若需在单事务中混合执行插入和字段级更新，必须在存储过程中手动解析 patch 指令并合并到目标文档。
在 Cosmos DB 中，存储过程（Stored Procedure）运行于服务端、具备 ACID 事务语义，是实现多文档原子性操作的理想选择。但需注意：JavaScript 版本的服务器端 SDK（即 getContext().getCollection() 返回的 Collection 对象）并不提供 patchDocument 或类似 Patch 操作的 API。官方文档明确列出的方法仅包括 createDocument、readDocument、replaceDocument、upsertDocument 等——全部基于完整文档模型。
这意味着，当你从 Java 客户端传入一个 CosmosPatchOperation 对象（如 set("/status", "processed")），它在存储过程中只是一个普通 JSON 对象，不会被自动识别或执行。原始 SP 代码直接将该对象作为文档调用 upsertDocument，导致非法文档结构（例如含 op: "set" 字段）被拒绝，或意外创建无效文档，从而“看似无更新”。
✅ 正确做法：在存储过程中区分数据类型，对 Patch 类型指令做手动合并
假设你约定客户端传入的每项为如下两种之一：
- 完整文档（含 id 和所有字段）→ 直接 upsert；
- Patch 指令对象（含 id + patch 数组，如 [{"op":"set","path":"/count","value":100}]）→ 先读取原文档，再按 RFC 6902 规则应用补丁，最后 upsert 合并后结果。
以下是增强版存储过程示例（支持混合插入与 Patch）：
function createEvent(items) {
const collection = getContext().getCollection();
const response = getContext().getResponse();
let count = 0;
const total = items ? items.length : 0;
if (!items || total === 0) {
response.setBody(0);
return;
}
// 辅助函数：深合并 patch 到 target（简化版，仅支持 set/remove）
function applyPatch(target, patchOps) {
const doc = Object.assign({}, target);
(patchOps || []).forEach(op => {
if (op.op === "set" && typeof op.path === "string" && op.value !== undefined) {
const pathParts = op.path.split('/').filter(p => p);
let ref = doc;
for (let i = 0; i < pathParts.length - 1; i++) {
const key = pathParts[i];
if (ref[key] === undefined || ref[key] === null) ref[key] = {};
ref = ref[key];
}
ref[pathParts[pathParts.length - 1]] = op.value;
} else if (op.op === "remove" && typeof op.path === "string") {
const pathParts = op.path.split('/').filter(p => p);
let ref = doc;
for (let i = 0; i < pathParts.length - 1; i++) {
ref = ref[pathParts[i]];
if (!ref) return;
}
delete ref[pathParts[pathParts.length - 1]];
}
});
return doc;
}
function tryProcess(item, callback) {
// 判断是否为 Patch 指令（约定含 patch 字段）
if (item && item.id && Array.isArray(item.patch)) {
// Step 1: 读取现有文档
const query = `SELECT * FROM root r WHERE r.id = "${item.id}"`;
const isAccepted = collection.queryDocuments(
collection.getSelfLink(),
query,
{ enableCrossPartitionQuery: true },
(err, docs) => {
if (err) throw err;
const existing = docs.length > 0 ? docs[0] : null;
// Step 2: 应用 patch 并 upsert
const mergedDoc = existing
? applyPatch(existing, item.patch)
: { id: item.id, ...item.patch.reduce((acc, op) => {
if (op.op === "set") {
const key = op.path.split('/').pop();
acc[key] = op.value;
}
return acc;
}, {}) };
const options = { disableAutomaticIdGeneration: false };
collection.upsertDocument(collection.getSelfLink(), mergedDoc, options, callback);
}
);
if (!isAccepted) throw new Error("Query not accepted for patch");
} else {
// 常规 upsert：视为完整文档
const options = { disableAutomaticIdGeneration: false };
collection.upsertDocument(collection.getSelfLink(), item, options, callback);
}
}
function callback(err, doc, options) {
if (err) throw err;
count++;
if (count >= total) {
response.setBody(count);
} else {
tryProcess(items[count], callback);
}
}
tryProcess(items[0], callback);
}? 关键注意事项：
- ✅ 事务保障：整个 SP 在单个分区键范围内执行时天然具备事务性（跨分区需启用 enableCrossPartitionQuery，但此时不保证跨分区事务）；
- ⚠️ 性能权衡：Patch 操作需额外一次 queryDocuments，增加 RU 消耗，建议仅对高频更新小字段场景使用；
- ? 安全约束：避免直接拼接 item.id 到 SQL 字符串（示例中为简洁演示）；生产环境应使用参数化查询（当前 JS SDK 不支持，可改用 readDocument + 自行构造链接）；
- ? Patch 能力限制：上述示例仅实现 set/remove，如需 add/replace/copy 等，需扩展 applyPatch 函数逻辑，严格遵循 RFC 6902；
- ? Java 端适配：向 SP 传参时，将 Patch 操作序列化为标准 JSON 对象，例如：
Map
总结：Cosmos DB 存储过程虽不原生支持 Patch，但通过组合 queryDocuments + 手动合并 + upsertDocument，完全可在单事务内安全、可靠地实现“插入或局部更新”的混合语义——这正是替代客户端批量 Patch 的推荐架构模式。
