MongoFile.java 文件源码

public static void storeBlock(MongoBlock mongoBlock) {
    // System.out.println("Store: " + mongoBlock.getBlockNumber());

    MongoCollection<Document> c = mongoBlock.mongoFile.mongoDirectory.getBlocksCollection();

    Document query = new Document();
    query.put(MongoDirectory.FILE_NUMBER, mongoBlock.mongoFile.fileNumber);
    query.put(MongoDirectory.BLOCK_NUMBER, mongoBlock.blockNumber);

    Document object = new Document();
    object.put(MongoDirectory.FILE_NUMBER, mongoBlock.mongoFile.fileNumber);
    object.put(MongoDirectory.BLOCK_NUMBER, mongoBlock.blockNumber);
    object.put(MongoDirectory.BYTES, new Binary(mongoBlock.bytes));

    c.replaceOne(query, object, new UpdateOptions().upsert(true));

}