Skip to content

Commit d461b94

Browse files
committed
Added Error Handling Class
1 parent 20be6ae commit d461b94

1 file changed

Lines changed: 40 additions & 36 deletions

File tree

memex/src/main/java/com/johnlpage/memex/repository/optimized/OptimizedMongoLoadRepositoryImpl.java

Lines changed: 40 additions & 36 deletions
Original file line numberDiff line numberDiff line change
@@ -186,42 +186,7 @@ public BulkWriteResult writeMany(
186186
}
187187
return result;
188188
} else {
189-
return new BulkWriteResult() {
190-
@Override
191-
public boolean wasAcknowledged() {
192-
return false;
193-
}
194-
195-
@Override
196-
public int getInsertedCount() {
197-
return 0;
198-
}
199-
200-
@Override
201-
public int getMatchedCount() {
202-
return 0;
203-
}
204-
205-
@Override
206-
public int getDeletedCount() {
207-
return 0;
208-
}
209-
210-
@Override
211-
public int getModifiedCount() {
212-
return 0;
213-
}
214-
215-
@Override
216-
public List<BulkWriteInsert> getInserts() {
217-
return List.of();
218-
}
219-
220-
@Override
221-
public List<BulkWriteUpsert> getUpserts() {
222-
return List.of();
223-
}
224-
};
189+
return getEmptyBWResult();
225190
}
226191
} catch (Exception e) {
227192
// TODO - Add code to retry if a transient transaction error, that would happen if
@@ -237,6 +202,45 @@ public List<BulkWriteUpsert> getUpserts() {
237202
}
238203
}
239204

205+
private BulkWriteResult getEmptyBWResult() {
206+
return new BulkWriteResult() {
207+
@Override
208+
public boolean wasAcknowledged() {
209+
return false;
210+
}
211+
212+
@Override
213+
public int getInsertedCount() {
214+
return 0;
215+
}
216+
217+
@Override
218+
public int getMatchedCount() {
219+
return 0;
220+
}
221+
222+
@Override
223+
public int getDeletedCount() {
224+
return 0;
225+
}
226+
227+
@Override
228+
public int getModifiedCount() {
229+
return 0;
230+
}
231+
232+
@Override
233+
public List<BulkWriteInsert> getInserts() {
234+
return List.of();
235+
}
236+
237+
@Override
238+
public List<BulkWriteUpsert> getUpserts() {
239+
return List.of();
240+
}
241+
};
242+
}
243+
240244
/**
241245
* Change to using a Pipeline, multistep update If we are blindly saving incoming data we don't
242246
* know what has changed either at a field or document level. This type of update will let us

0 commit comments

Comments
 (0)