解决SQL数据集直连DB2时,编写SQL必须要带schema的问题。

This commit is contained in:
qqfanga 2023-08-23 17:33:12 +08:00
parent 4071735d09
commit e1f44f9f5b

View File

@ -14,10 +14,11 @@ public class Db2Configuration extends JdbcConfiguration {
public String getJdbc() {
if(StringUtils.isEmpty(extraParams.trim())){
return "jdbc:db2://HOSTNAME:PORT/DATABASE"
return "jdbc:db2://HOSTNAME:PORT/DATABASE:currentSchema=SCHEMA;"
.replace("HOSTNAME", getHost().trim())
.replace("PORT", getPort().toString().trim())
.replace("DATABASE", getDataBase().trim());
.replace("DATABASE", getDataBase().trim()
.replace("SCHEMA",getSchema().trim()));
}else {
return "jdbc:hive2://HOSTNAME:PORT/DATABASE?EXTRA_PARAMS"
.replace("HOSTNAME", getHost().trim())