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();
}