public static String execute()

in src/main/java/org/apache/fineract/cn/core/data/jpa/core/MigrationHelper.java [41:54]


  public static String execute(final DataSource dataSource, final String changeLogFile) throws Exception {
    final JdbcConnection jdbcConnection = new JdbcConnection(dataSource.getConnection());
    final Database database = DatabaseFactory.getInstance().findCorrectDatabaseImplementation(jdbcConnection);
    final Liquibase liquibase =
        new Liquibase(changeLogFile, new ClassLoaderResourceAccessor(), database);
    liquibase.update(new Contexts(), new LabelExpression());

    final Optional<ChangeSet> optionalMaxChangeSet =
        liquibase.getDatabaseChangeLog().getChangeSets()
            .stream()
            .max(VersionComparator::compare);

    return optionalMaxChangeSet.orElseThrow(() -> new IllegalStateException("No valid version found!")).getId();
  }