DefaultSchemaVersionDAO.java 文件源码

@Override
public void save(Migration migration) {
    Document d = new Document("version", migration.getVersion())
            .append("description", migration.getDescription())
            .append("author", migration.getAuthor())
            .append("started", Optional.ofNullable(migration.getStarted()).map(DateTime::toDate).orElse(null))
            .append("finished", Optional.ofNullable(migration.getFinished()).map(DateTime::toDate).orElse(null))
            .append("status", migration.getStatus().name())
            .append("failureMessage", migration.getFailureMessage());

    collection.replaceOne(eq("version", migration.getVersion()), d, new UpdateOptions().upsert(true));
}