提交 54804d9e authored 作者: taojinlong's avatar taojinlong

fix: 校验 db2

上级 d0f99d20
...@@ -672,7 +672,7 @@ public class JdbcProvider extends DatasourceProvider { ...@@ -672,7 +672,7 @@ public class JdbcProvider extends DatasourceProvider {
if (StringUtils.isEmpty(db2Configuration.getSchema())) { if (StringUtils.isEmpty(db2Configuration.getSchema())) {
throw new Exception(Translator.get("i18n_schema_is_empty")); throw new Exception(Translator.get("i18n_schema_is_empty"));
} }
return "select TABNAME from syscat.tables WHERE TABSCHEMA ='DE_SCHEMA' AND \"TYPE\" = 'T';".replace("DE_SCHEMA", db2Configuration.getSchema()); return "select TABNAME from syscat.tables WHERE TABSCHEMA ='DE_SCHEMA' AND \"TYPE\" = 'T'".replace("DE_SCHEMA", db2Configuration.getSchema());
default: default:
return "show tables;"; return "show tables;";
} }
...@@ -722,7 +722,7 @@ public class JdbcProvider extends DatasourceProvider { ...@@ -722,7 +722,7 @@ public class JdbcProvider extends DatasourceProvider {
if (StringUtils.isEmpty(db2Configuration.getSchema())) { if (StringUtils.isEmpty(db2Configuration.getSchema())) {
throw new Exception(Translator.get("i18n_schema_is_empty")); throw new Exception(Translator.get("i18n_schema_is_empty"));
} }
return "select TABNAME from syscat.tables WHERE TABSCHEMA ='DE_SCHEMA' AND \"TYPE\" = 'V';".replace("DE_SCHEMA", db2Configuration.getSchema()); return "select TABNAME from syscat.tables WHERE TABSCHEMA ='DE_SCHEMA' AND \"TYPE\" = 'V'".replace("DE_SCHEMA", db2Configuration.getSchema());
default: default:
return null; return null;
...@@ -738,7 +738,7 @@ public class JdbcProvider extends DatasourceProvider { ...@@ -738,7 +738,7 @@ public class JdbcProvider extends DatasourceProvider {
case sqlServer: case sqlServer:
return "select name from sys.schemas;"; return "select name from sys.schemas;";
case db2: case db2:
return "select SCHEMANAME from syscat.SCHEMATA WHERE \"DEFINER\" ='USER';".replace("USER", db2Configuration.getUsername().toUpperCase()) ; return "select SCHEMANAME from syscat.SCHEMATA WHERE \"DEFINER\" ='USER'".replace("USER", db2Configuration.getUsername().toUpperCase()) ;
case pg: case pg:
return "SELECT nspname FROM pg_namespace;"; return "SELECT nspname FROM pg_namespace;";
case redshift: case redshift:
......
Markdown 格式
0%
您添加了 0 到此讨论。请谨慎行事。
请先完成此评论的编辑!
注册 或者 后发表评论