-
Notifications
You must be signed in to change notification settings - Fork 4
Expand file tree
/
Copy pathBulkWriteExample.java
More file actions
37 lines (26 loc) · 928 Bytes
/
BulkWriteExample.java
File metadata and controls
37 lines (26 loc) · 928 Bytes
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
import com.mongodb.BasicDBObject;
import com.mongodb.BulkWriteOperation;
import com.mongodb.BulkWriteResult;
import com.mongodb.Cursor;
import com.mongodb.DB;
import com.mongodb.DBCollection;
import com.mongodb.DBCursor;
import com.mongodb.DBObject;
import com.mongodb.MongoClient;
import com.mongodb.ParallelScanOptions;
import com.mongodb.ServerAddress;
import java.util.List;
import java.util.Set;
import static java.util.concurrent.TimeUnit.SECONDS;
public class BulkWriteExample {
public static void main(String[] args) {
MongoClient mongoClient = new MongoClient();
DB db = mongoClient.getDB( "test" );
DBCollection coll = db.getCollection("bulktest");
BulkWriteOperation bulk = coll.initializeUnorderedBulkOperation();
for (int i=0;i<2000;i++) {
bulk.insert( new BasicDBObject("i",i) );
}
BulkWriteResult result = bulk.execute();
}
}