1、进入flyway github仓库下载flyway7.1.1版本源码,搜索7.1.1,下载地址为:https://github.com/flyway/flyway/releases
2、解压源码, 新建目录kingbase,将postgres目录文件拷贝进kingbase,修改下文件名:
3、修改KingbaseDatabaseType文件,源码如下:
public class KingbaseDatabaseType extends DatabaseType {
@Override
public String getName() {
return "Kingbase8";
}
@Override
public int getNullType() {
return Types.NULL;
}
@Override
public boolean handlesJDBCUrl(String url) {
if (url.startsWith("jdbc-secretsmanager:postgresql:")) {
throw new org.flywaydb.core.internal.license.FlywayTeamsUpgradeRequiredException("jdbc-secretsmanager");
}
return url.startsWith("jdbc:kingbase8:");
}
@Override
public String getDriverClass(String url, ClassLoader classLoader) {
return "com.kingbase8.Driver";
}
@Override
public boolean handlesDatabaseProductNameAndVersion(String databaseProductName, String databaseProductVersion, Connection connection) {
return databaseProductName.startsWith("KingbaseES");
}
@Override
public Database createDatabase(Configuration configuration, JdbcConnectionFactory jdbcConnectionFactory, StatementInterceptor statementInterceptor) {
return new KingbaseDatabase(configuration, jdbcConnectionFactory, statementInterceptor);
}
@Override
public Parser createParser(Configuration configuration, ResourceProvider resourceProvider, ParsingContext parsingContext) {
return new KingbaseParser(configuration, parsingContext);
}
@Override
public void setDefaultConnectionProps(String url, Properties props, ClassLoader classLoader) {
props.put("applicationName", APPLICATION_NAME);
}
@Override
public boolean detectUserRequiredByUrl(String url) {
return !url.contains("user=");
}
@Override
public boolean detectPasswordRequiredByUrl(String url) {
// Postgres supports password in URL
return !url.contains("password=");
}
4、修改DatabaseTypeRegister文件,在registerDatabaseTypes增加kingbase类型
registeredDatabaseTypes.add(new KingbaseDatabaseType());
5、修改下flyway-parent版本为7.1.1.1,flyway-core parent版本修改为7.1.1.1
6、执行mvn install -Dmaven.test.skip=true 打包即可