summaryrefslogtreecommitdiff
path: root/jstests/core/apply_ops2.js
diff options
context:
space:
mode:
Diffstat (limited to 'jstests/core/apply_ops2.js')
-rw-r--r--jstests/core/apply_ops2.js71
1 files changed, 71 insertions, 0 deletions
diff --git a/jstests/core/apply_ops2.js b/jstests/core/apply_ops2.js
new file mode 100644
index 00000000000..1a5923c3465
--- /dev/null
+++ b/jstests/core/apply_ops2.js
@@ -0,0 +1,71 @@
+//Test applyops upsert flag SERVER-7452
+
+var t = db.apply_ops2;
+t.drop();
+
+assert.eq(0, t.find().count(), "test collection not empty");
+
+t.insert({_id:1, x:"init"});
+
+//alwaysUpsert = true
+print("Testing applyOps with alwaysUpsert = true");
+
+var res = db.runCommand({ applyOps: [
+ {
+ op: "u",
+ ns: t.getFullName(),
+ o2 : { _id: 1 },
+ o: { $set: { x: "upsert=true existing" }}
+ },
+ {
+ op: "u",
+ ns: t.getFullName(),
+ o2: { _id: 2 },
+ o: { $set : { x: "upsert=true non-existing" }}
+ }], alwaysUpsert: true });
+
+assert.eq(true, res.results[0], "upsert = true, existing doc update failed");
+assert.eq(true, res.results[1], "upsert = true, nonexisting doc not upserted");
+assert.eq(2, t.find().count(), "2 docs expected after upsert");
+
+//alwaysUpsert = false
+print("Testing applyOps with alwaysUpsert = false");
+
+res = db.runCommand({ applyOps: [
+ {
+ op: "u",
+ ns: t.getFullName(),
+ o2: { _id: 1 },
+ o: { $set : { x: "upsert=false existing" }}
+ },
+ {
+ op: "u",
+ ns: t.getFullName(),
+ o2: { _id: 3 },
+ o: { $set: { x: "upsert=false non-existing" }}
+ }], alwaysUpsert: false });
+
+assert.eq(true, res.results[0], "upsert = false, existing doc update failed");
+assert.eq(false, res.results[1], "upsert = false, nonexisting doc upserted");
+assert.eq(2, t.find().count(), "2 docs expected after upsert failure");
+
+//alwaysUpsert not specified, should default to true
+print("Testing applyOps with default alwaysUpsert");
+
+res = db.runCommand({ applyOps: [
+ {
+ op: "u",
+ ns: t.getFullName(),
+ o2: { _id: 1 },
+ o: { $set: { x: "upsert=default existing" }}
+ },
+ {
+ op: "u",
+ ns: t.getFullName(),
+ o2: { _id: 4 },
+ o: { $set: { x: "upsert=defaults non-existing" }}
+ }]});
+
+assert.eq(true, res.results[0], "default upsert, existing doc update failed");
+assert.eq(true, res.results[1], "default upsert, nonexisting doc not upserted");
+assert.eq(3, t.find().count(), "2 docs expected after upsert failure");