MongoDocumentStorage.java 文件源码

@Override
public void storeSourceDocument(String uniqueId, long timeStamp, Document document, List<Metadata> metaDataList) throws Exception {
    MongoDatabase db = mongoClient.getDatabase(database);
    MongoCollection<Document> coll = db.getCollection(rawCollectionName);
    Document mongoDocument = new Document();
    mongoDocument.putAll(document);

    if (!metaDataList.isEmpty()) {
        Document metadataMongoDoc = new Document();
        for (Metadata meta : metaDataList) {
            metadataMongoDoc.put(meta.getKey(), meta.getValue());
        }
        mongoDocument.put(METADATA, metadataMongoDoc);
    }

    mongoDocument.put(TIMESTAMP, timeStamp);
    mongoDocument.put(MongoConstants.StandardFields._ID, uniqueId);

    Document query = new Document(MongoConstants.StandardFields._ID, uniqueId);

    coll.replaceOne(query, mongoDocument, new UpdateOptions().upsert(true));
}