Skip to content

Commit 8403eda

Browse files
committed
fixing supporting code
1 parent 107ef4b commit 8403eda

File tree

1 file changed

+28
-37
lines changed

1 file changed

+28
-37
lines changed

source/includes/fundamentals/code-snippets/BulkWrite.java

Lines changed: 28 additions & 37 deletions
Original file line numberDiff line numberDiff line change
@@ -52,18 +52,22 @@ public static void main(String[] args) {
5252
bulkWrite.insertExceptionExample();
5353

5454
System.out.println("Insert");
55+
bulkWrite.setUpCollection();
5556
bulkWrite.insertDocumentsExample();
5657
bulkWrite.preview();
5758

5859
System.out.println("Replace");
60+
bulkWrite.setUpCollection();
5961
bulkWrite.replaceDocumentsExample();
6062
bulkWrite.preview();
6163

6264
System.out.println("Update");
65+
bulkWrite.setUpCollection();
6366
bulkWrite.updateDocumentsExample();
6467
bulkWrite.preview();
6568

6669
System.out.println("Delete");
70+
bulkWrite.setUpCollection();
6771
bulkWrite.deleteDocumentsExample();
6872
bulkWrite.preview();
6973
}
@@ -91,16 +95,18 @@ private void insertExceptionExample() {
9195
private void bulkWriteNotOrderedExample() {
9296
List<WriteModel<Document>> bulkOperations = new ArrayList<>();
9397

94-
InsertOneModel<Document> doc1 = new InsertOneModel<>(new Document("_id", 3));
95-
ReplaceOneModel<Document> doc2 = new ReplaceOneModel<>(Filters.eq("_id", 1),
96-
new Document("_id", 1).append("x", 2));
97-
UpdateOneModel<Document> doc3 = new UpdateOneModel<>(Filters.eq("_id", 3), Updates.set("x", 2));
98-
DeleteManyModel<Document> doc4 = new DeleteManyModel<>(Filters.eq("x", 2));
98+
99+
InsertOneModel<Document> insertDoc = new InsertOneModel<>(new Document("_id", 6).append("name", "Zaynab Omar").append("age", 37));
100+
ReplaceOneModel<Document> replaceDoc = new ReplaceOneModel<>(Filters.eq("_id", 1),
101+
new Document("name", "Sandy Kane").append("location", "Helena, MT"));
102+
UpdateOneModel<Document> updateDoc = new UpdateOneModel<>(Filters.eq("name", "Zaynab Omar"), Updates.set("name", "Zaynab Hassan"));
103+
DeleteManyModel<Document> deleteDoc = new DeleteManyModel<>(Filters.gt("age", 50));
99104

100-
bulkOperations.add(doc1);
101-
bulkOperations.add(doc2);
102-
bulkOperations.add(doc3);
103-
bulkOperations.add(doc4);
105+
bulkOperations.add(insertDoc);
106+
bulkOperations.add(replaceDoc);
107+
bulkOperations.add(updateDoc);
108+
bulkOperations.add(deleteDoc);
109+
104110

105111
// begin bulkWriteNotOrderedExample
106112
BulkWriteOptions options = new BulkWriteOptions().ordered(false);
@@ -114,7 +120,8 @@ private void bulkWriteExample() {
114120

115121
List<WriteModel<Document>> bulkOperations = new ArrayList<>();
116122

117-
InsertOneModel<Document> insertDoc = new InsertOneModel<>(new Document("name", "Zaynab Omar").append("age", 37));
123+
124+
InsertOneModel<Document> insertDoc = new InsertOneModel<>(new Document("_id", 6).append("name", "Zaynab Omar").append("age", 37));
118125
ReplaceOneModel<Document> replaceDoc = new ReplaceOneModel<>(Filters.eq("_id", 1),
119126
new Document("name", "Sandy Kane").append("location", "Helena, MT"));
120127
UpdateOneModel<Document> updateDoc = new UpdateOneModel<>(Filters.eq("name", "Zaynab Omar"), Updates.set("name", "Zaynab Hassan"));
@@ -130,7 +137,6 @@ private void bulkWriteExample() {
130137
}
131138

132139
private void insertDocumentsExample(){
133-
collection.drop();
134140
List<WriteModel<Document>> bulkOperations = new ArrayList<>();
135141

136142
// begin insertDocumentsExample
@@ -140,65 +146,47 @@ private void insertDocumentsExample(){
140146
.append("age", 22));
141147
//end insertDocumentsExample
142148

143-
bulkOperations.add(doc1);
144-
bulkOperations.add(doc2);
149+
bulkOperations.add(juneDoc);
150+
bulkOperations.add(kevinDoc);
145151

146152
collection.bulkWrite(bulkOperations);
147153
}
148154

149155
private void replaceDocumentsExample(){
150-
collection.drop();
151156
List<WriteModel<Document>> bulkOperations = new ArrayList<>();
152157

153-
InsertOneModel<Document> doc1 = new InsertOneModel<>(new Document("_id", 1));
154-
InsertOneModel<Document> doc2 = new InsertOneModel<>(new Document("_id", 2));
155-
156158
// begin replaceDocumentsExample
157159
ReplaceOneModel<Document> celineDoc = new ReplaceOneModel<>(
158160
Filters.eq("_id", 1),
159161
new Document("name", "Celine Stork").append("location", "San Diego, CA"));
160162
//end replaceDocumentsExample
161163

162-
bulkOperations.add(doc1);
163-
bulkOperations.add(doc2);
164-
bulkOperations.add(doc3);
164+
bulkOperations.add(celineDoc);
165165

166166
collection.bulkWrite(bulkOperations);
167167
}
168168

169169
private void updateDocumentsExample(){
170-
collection.drop();
171170
List<WriteModel<Document>> bulkOperations = new ArrayList<>();
172171

173-
InsertOneModel<Document> doc1 = new InsertOneModel<>(new Document("_id", 1));
174-
InsertOneModel<Document> doc2 = new InsertOneModel<>(new Document("_id", 2));
175-
176172
// begin updateDocumentsExample
177173
UpdateOneModel<Document> updateDoc = new UpdateOneModel<>(
178174
Filters.eq("_id", 2),
179175
Updates.set("age", 31));
180176
//end updateDocumentsExample
181177

182-
bulkOperations.add(doc1);
183-
bulkOperations.add(doc2);
184-
bulkOperations.add(doc3);
178+
bulkOperations.add(updateDoc);
185179

186180
collection.bulkWrite(bulkOperations);
187181
}
188182

189183
private void deleteDocumentsExample(){
190-
collection.drop();
191184
List<WriteModel<Document>> bulkOperations = new ArrayList<>();
192185

193-
InsertOneModel<Document> doc1 = new InsertOneModel<>(new Document("_id", 1));
194-
InsertOneModel<Document> doc2 = new InsertOneModel<>(new Document("_id", 2));
195-
196186
// begin deleteDocumentsExample
197187
DeleteOneModel<Document> deleteDoc = new DeleteOneModel<>(Filters.eq("_id", 1));
198188
//end deleteDocumentsExample
199189

200-
bulkOperations.add(doc1);
201-
bulkOperations.add(doc2);
202190
bulkOperations.add(deleteDoc);
203191

204192
collection.bulkWrite(bulkOperations);
@@ -215,11 +203,14 @@ private void setUpCollection(){
215203
List<WriteModel<Document>> bulkOperations = new ArrayList<>();
216204
//end bulkOpsList
217205

218-
InsertOneModel<Document> doc1 = new InsertOneModel<>(new Document("_id", 1));
219-
InsertOneModel<Document> doc2 = new InsertOneModel<>(new Document("_id", 2));
206+
InsertOneModel<Document> karen = new InsertOneModel<>(new Document("_id", 1).append("name", "Karen Sandoval").append("age", 31));
207+
InsertOneModel<Document> william = new InsertOneModel<>(new Document("_id", 2).append("name", "William Chin").append("age", 54));
208+
InsertOneModel<Document> shayla = new InsertOneModel<>(new Document("_id", 8).append("name", "Shayla Ray").append("age", 20));
220209

221-
bulkOperations.add(doc1);
222-
bulkOperations.add(doc2);
210+
bulkOperations.add(karen);
211+
bulkOperations.add(william);
212+
bulkOperations.add(shayla);
213+
223214

224215
collection.bulkWrite(bulkOperations);
225216
}

0 commit comments

Comments
 (0)