1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
|
// Licensed under the Apache License, Version 2.0 (the "License"); you may not
// use this file except in compliance with the License. You may obtain a copy of
// the License at
//
// http://www.apache.org/licenses/LICENSE-2.0
//
// Unless required by applicable law or agreed to in writing, software
// distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
// WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
// License for the specific language governing permissions and limitations under
// the License.
couchTests.bulk_docs = function(debug) {
var db_name = get_random_db_name();
var db = new CouchDB(db_name, {"X-Couch-Full-Commit":"false"});
db.createDb();
if (debug) debugger;
var docs = makeDocs(5);
// Create the docs
var results = db.bulkSave(docs);
T(results.length == 5);
for (var i = 0; i < 5; i++) {
T(results[i].id == docs[i]._id);
T(results[i].rev);
// Update the doc
docs[i].string = docs[i].string + ".00";
}
// Save the docs
results = db.bulkSave(docs);
T(results.length == 5);
for (i = 0; i < 5; i++) {
T(results[i].id == i.toString());
// set the delete flag to delete the docs in the next step
docs[i]._deleted = true;
}
// now test a bulk update with a conflict
// open and save
var doc = db.open("0");
db.save(doc);
// Now bulk delete the docs
results = db.bulkSave(docs);
// doc "0" should be a conflict
T(results.length == 5);
T(results[0].id == "0");
T(results[0].error == "conflict");
T(typeof results[0].rev === "undefined"); // no rev member when a conflict
// but the rest are not
for (i = 1; i < 5; i++) {
T(results[i].id == i.toString());
T(results[i].rev);
T(db.open(docs[i]._id) == null);
}
// now force a conflict to to save
// save doc 0, this will cause a conflict when we save docs[0]
var doc = db.open("0");
docs[0] = db.open("0");
db.save(doc);
docs[0].shooby = "dooby";
// Now save the bulk docs, When we use all_or_nothing, we don't get conflict
// checking, all docs are saved regardless of conflict status, or none are
// saved.
// TODO: all_or_nothing is not yet supported on clusters
// results = db.bulkSave(docs,{all_or_nothing:true});
// T(results.error === undefined);
//
// var doc = db.open("0", {conflicts:true});
// var docConflict = db.open("0", {rev:doc._conflicts[0]});
//
// T(doc.shooby == "dooby" || docConflict.shooby == "dooby");
// verify creating a document with no id returns a new id
var req = CouchDB.request("POST", "/" + db_name + "/_bulk_docs", {
body: JSON.stringify({"docs": [{"foo":"bar"}]})
});
results = JSON.parse(req.responseText);
T(results[0].id != "");
T(results[0].rev != "");
// Regression test for failure on update/delete
var newdoc = {"_id": "foobar", "body": "baz"};
T(db.save(newdoc).ok);
var update = {"_id": newdoc._id, "_rev": newdoc._rev, "body": "blam"};
var torem = {"_id": newdoc._id, "_rev": newdoc._rev, "_deleted": true};
results = db.bulkSave([update, torem]);
T(results[0].error == "conflict" || results[1].error == "conflict");
// verify that sending a request with no docs causes error thrown
var req = CouchDB.request("POST", "/" + db_name + "/_bulk_docs", {
body: JSON.stringify({"doc": [{"foo":"bar"}]})
});
T(req.status == 400 );
result = JSON.parse(req.responseText);
T(result.error == "bad_request");
T(result.reason == "POST body must include `docs` parameter.");
// verify that sending a request with invalid `docs` causes error
var req = CouchDB.request("POST", "/" + db_name + "/_bulk_docs", {
body: JSON.stringify({"docs": "foo"})
});
T(req.status == 400);
result = JSON.parse(req.responseText);
T(result.error == "bad_request");
T(result.reason == "`docs` parameter must be an array.");
// verify that sending a request with invalid `new_edits` causes error
var req = CouchDB.request("POST", "/" + db_name + "/_bulk_docs", {
body: JSON.stringify({"docs": [], "new_edits": 0})
});
T(req.status == 400);
result = JSON.parse(req.responseText);
T(result.error == "bad_request");
T(result.reason == "`new_edits` parameter must be a boolean.");
// jira-911
db.deleteDb();
// avoid Heisenbugs w/ files remaining - create a new name
db_name = get_random_db_name();
db = new CouchDB(db_name, {"X-Couch-Full-Commit":"false"});
db.createDb();
docs = [];
docs.push({"_id":"0", "a" : 0});
docs.push({"_id":"1", "a" : 1});
docs.push({"_id":"1", "a" : 2});
docs.push({"_id":"3", "a" : 3});
results = db.bulkSave(docs);
T(results[1].id == "1");
T(results[1].error == undefined);
T(results[2].error == "conflict");
// cleanup
db.deleteDb();
};
|
