Oracle to MongoDB ETL만들기 - 대용량업데이트

Database/mongoDB

데브포유 2018. 6. 5. 20:01

bulkWrite()를 이용해서 다수의 도큐먼트를 원하는 값으로 업데이트 할 수 있습니다.

아래 예제를 참고하여 코딩해 보세요..

List<WriteModel<Document>> updateDocuments = new ArrayList<WriteModel<Document>>();

for(업데이트할도큐먼트리스트) {

Document filterDocument = new Document();

filterDocument.append("_id", entityId); // 업데이트 대상을 찾을 조건

//Update doc

Document updateDocument = new Document(); // 업데이트할 필드와 값

Document setDocument = new Document();

setDocument.append("name", "xyz");

setDocument.append("role", "abc");

updateDocument.append("$set", setDocument);

//Update option

UpdateOptions updateOptions = new UpdateOptions();

updateOptions.upsert(false); //if true, will create a new doc in case of unmatched find

updateOptions.bypassDocumentValidation(false); //set true/false

//Prepare list of Updates

updateDocuments.add(

new UpdateOneModel<Document>(

filterDocument,

updateDocument,

updateOptions));

} // end-for

//Bulk write options

BulkWriteOptions bulkWriteOptions = new BulkWriteOptions();

bulkWriteOptions.ordered(false); //False to allow parallel execution

bulkWriteOptions.bypassDocumentValidation(true);

MongoCollection<Document> mongoCollection = mongoDB.getCollection("myCollection");

BulkWriteResult bulkWriteResult = null;

try {

//Perform bulk update

bulkWriteResult = mongoCollection.bulkWrite(updateDocuments,

bulkWriteOptions);

} catch (BulkWriteException e) {

//Handle bulkwrite exception

List<BulkWriteError> bulkWriteErrors = e.getWriteErrors();

for (BulkWriteError bulkWriteError : bulkWriteErrors) {

int failedIndex = bulkWriteError.getIndex();

Long failedEntityId = entityIDs.get(failedIndex);

System.out.println("Failed record: " + failedEntityId);

//handle rollback

}

int rowsUpdated = bulkWriteResult.getModifiedCount();