Lines Matching refs:bulk

40 	bulk := coll.Bulk()
41 	bulk.Insert(M{"n": 1})
42 	bulk.Insert(M{"n": 2}, M{"n": 3})
43 	r, err := bulk.Run()
60 	bulk := coll.Bulk()
61 	bulk.Insert(M{"_id": 1}, M{"_id": 2}, M{"_id": 2}, M{"_id": 3})
62 	_, err = bulk.Run()
81 	bulk := coll.Bulk()
82 	bulk.Unordered()
83 	bulk.Insert(M{"_id": 1}, M{"_id": 2}, M{"_id": 2}, M{"_id": 3})
84 	_, err = bulk.Run()
108 	bulk := coll.Bulk()
109 	bulk.Unordered()
120 	bulk.Insert(docs...)
121 	_, err = bulk.Run()
142 	bulk := coll.Bulk()
143 	bulk.Unordered()
144 	bulk.Insert(M{"_id": 1}, M{"_id": 2}, M{"_id": 2})
145 	_, err = bulk.Run()
151 	bulk = coll.Bulk()
152 	bulk.Unordered()
153 	bulk.Insert(M{"_id": "dupone"}, M{"_id": "dupone"}, M{"_id": "duptwo"}, M{"_id": "duptwo"})
154 	_, err = bulk.Run()
166 	bulk = coll.Bulk()
167 	bulk.Unordered()
168 	bulk.Insert(M{"_id": 1}, M{"_id": []int{2}})
169 	_, err = bulk.Run()
189 	bulk := coll.Bulk()
190 	bulk.Unordered()
197 			bulk.Insert(M{"_id": "dupone"})
199 			bulk.Update(M{"_id": i - 1}, M{"$set": M{"_id": 4}})
201 			bulk.Insert(M{"_id": "duptwo"})
203 			bulk.Insert(M{"_id": i})
207 	_, err = bulk.Run()
228 	bulk := coll.Bulk()
229 	bulk.Unordered()
236 			bulk.Insert(M{"_id": "dupone"})
238 			bulk.Update(M{"_id": i - 1}, M{"$set": M{"n": 4}})
240 			bulk.Update(M{"_id": i - 1}, M{"$bogus": M{"n": 4}})
242 			bulk.Insert(M{"_id": "duptwo"})
244 			bulk.Insert(M{"_id": i})
248 	_, err = bulk.Run()
264 	bulk := coll.Bulk()
271 			bulk.Insert(M{"_id": "dupone"})
273 			bulk.Insert(M{"_id": "duptwo"})
275 			bulk.Insert(M{"_id": i})
279 	_, err = bulk.Run()
301 	bulk := coll.Bulk()
302 	bulk.Update(M{"n": 1}, M{"$set": M{"n": 1}})
303 	bulk.Update(M{"n": 2}, M{"$set": M{"n": 20}})
304 	bulk.Update(M{"n": 5}, M{"$set": M{"n": 50}}) // Won't match.
305 	bulk.Update(M{"n": 1}, M{"$set": M{"n": 10}}, M{"n": 3}, M{"$set": M{"n": 30}})
306 	r, err := bulk.Run()
330 	bulk := coll.Bulk()
331 	bulk.Update(
336 	r, err := bulk.Run()
357 	bulk := coll.Bulk()
358 	bulk.Unordered()
359 	bulk.Update(
364 	r, err := bulk.Run()
385 	bulk := coll.Bulk()
386 	bulk.UpdateAll(M{"n": 1}, M{"$set": M{"n": 10}})
387 	bulk.UpdateAll(M{"n": 2}, M{"$set": M{"n": 2}})  // Won't change.
388 	bulk.UpdateAll(M{"n": 5}, M{"$set": M{"n": 50}}) // Won't match.
389 	bulk.UpdateAll(M{}, M{"$inc": M{"n": 1}}, M{"n": 11}, M{"$set": M{"n": 5}})
390 	r, err := bulk.Run()
412 	bulk := coll.Bulk()
413 	bulk.Unordered()
414 	bulk.Insert(M{"n": 1})
415 	bulk.Update(M{"n": 2}, M{"$inc": M{"n": 1}})
416 	bulk.Insert(M{"n": 2})
417 	bulk.Update(M{"n": 3}, M{"$inc": M{"n": 1}})
418 	bulk.Update(M{"n": 1}, M{"$inc": M{"n": 1}})
419 	bulk.Insert(M{"n": 3})
420 	r, err := bulk.Run()
444 	bulk := coll.Bulk()
445 	bulk.Upsert(M{"n": 2}, M{"$set": M{"n": 20}})
446 	bulk.Upsert(M{"n": 4}, M{"$set": M{"n": 40}}, M{"n": 3}, M{"$set": M{"n": 30}})
447 	r, err := bulk.Run()
468 	bulk := coll.Bulk()
469 	bulk.Remove(M{"n": 1})
470 	bulk.Remove(M{"n": 2}, M{"n": 4})
471 	r, err := bulk.Run()
492 	bulk := coll.Bulk()
493 	bulk.RemoveAll(M{"n": 1})
494 	bulk.RemoveAll(M{"n": 2}, M{"n": 4})
495 	r, err := bulk.Run()