forked from github/dataease
fix(数据源): 修复校验数据源状态后,关闭连接
This commit is contained in:
parent
82654b999f
commit
ebfb1ff568
@ -615,9 +615,9 @@ public class JdbcProvider extends DefaultJdbcProvider {
|
|||||||
|
|
||||||
if (StringUtils.isNotEmpty(surpportVersions) && surpportVersions.split(",").length > 0) {
|
if (StringUtils.isNotEmpty(surpportVersions) && surpportVersions.split(",").length > 0) {
|
||||||
if (!Arrays.asList(surpportVersions.split(",")).contains(String.valueOf(conn.getMetaData().getDatabaseMajorVersion()))) {
|
if (!Arrays.asList(surpportVersions.split(",")).contains(String.valueOf(conn.getMetaData().getDatabaseMajorVersion()))) {
|
||||||
|
conn.close();
|
||||||
DataEaseException.throwException("当前驱动不支持此版本!");
|
DataEaseException.throwException("当前驱动不支持此版本!");
|
||||||
}
|
}
|
||||||
;
|
|
||||||
}
|
}
|
||||||
return conn;
|
return conn;
|
||||||
}
|
}
|
||||||
|
@ -114,6 +114,7 @@ public class DmDsProvider extends DefaultJdbcProvider {
|
|||||||
}
|
}
|
||||||
if (StringUtils.isNotEmpty(surpportVersions) && surpportVersions.split(",").length > 0) {
|
if (StringUtils.isNotEmpty(surpportVersions) && surpportVersions.split(",").length > 0) {
|
||||||
if (!Arrays.asList(surpportVersions.split(",")).contains(String.valueOf(conn.getMetaData().getDatabaseMajorVersion()))) {
|
if (!Arrays.asList(surpportVersions.split(",")).contains(String.valueOf(conn.getMetaData().getDatabaseMajorVersion()))) {
|
||||||
|
conn.close();
|
||||||
DataEaseException.throwException("当前驱动不支持此版本!");
|
DataEaseException.throwException("当前驱动不支持此版本!");
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
@ -96,6 +96,7 @@ public class KingbaseDsProvider extends DefaultJdbcProvider {
|
|||||||
}
|
}
|
||||||
if(StringUtils.isNotEmpty(surpportVersions) && surpportVersions.split(",").length > 0){
|
if(StringUtils.isNotEmpty(surpportVersions) && surpportVersions.split(",").length > 0){
|
||||||
if(! Arrays.asList(surpportVersions.split(",")).contains(String.valueOf(conn.getMetaData().getDatabaseMajorVersion()))){
|
if(! Arrays.asList(surpportVersions.split(",")).contains(String.valueOf(conn.getMetaData().getDatabaseMajorVersion()))){
|
||||||
|
conn.close();
|
||||||
DataEaseException.throwException("当前驱动不支持此版本!");
|
DataEaseException.throwException("当前驱动不支持此版本!");
|
||||||
};
|
};
|
||||||
}
|
}
|
||||||
|
@ -89,6 +89,7 @@ public class KylinDsProvider extends DefaultJdbcProvider {
|
|||||||
}
|
}
|
||||||
if(StringUtils.isNotEmpty(surpportVersions) && surpportVersions.split(",").length > 0){
|
if(StringUtils.isNotEmpty(surpportVersions) && surpportVersions.split(",").length > 0){
|
||||||
if(! Arrays.asList(surpportVersions.split(",")).contains(String.valueOf(conn.getMetaData().getDatabaseMajorVersion()))){
|
if(! Arrays.asList(surpportVersions.split(",")).contains(String.valueOf(conn.getMetaData().getDatabaseMajorVersion()))){
|
||||||
|
conn.close();
|
||||||
DataEaseException.throwException("当前驱动不支持此版本!");
|
DataEaseException.throwException("当前驱动不支持此版本!");
|
||||||
};
|
};
|
||||||
}
|
}
|
||||||
|
@ -94,6 +94,7 @@ public class MongobiDsProvider extends DefaultJdbcProvider {
|
|||||||
}
|
}
|
||||||
if(StringUtils.isNotEmpty(surpportVersions) && surpportVersions.split(",").length > 0){
|
if(StringUtils.isNotEmpty(surpportVersions) && surpportVersions.split(",").length > 0){
|
||||||
if(! Arrays.asList(surpportVersions.split(",")).contains(String.valueOf(conn.getMetaData().getDatabaseMajorVersion()))){
|
if(! Arrays.asList(surpportVersions.split(",")).contains(String.valueOf(conn.getMetaData().getDatabaseMajorVersion()))){
|
||||||
|
conn.close();
|
||||||
DataEaseException.throwException("当前驱动不支持此版本!");
|
DataEaseException.throwException("当前驱动不支持此版本!");
|
||||||
};
|
};
|
||||||
}
|
}
|
||||||
|
@ -116,6 +116,7 @@ public class PrestoDsProvider extends DefaultJdbcProvider {
|
|||||||
|
|
||||||
if(StringUtils.isNotEmpty(surpportVersions) && surpportVersions.split(",").length > 0){
|
if(StringUtils.isNotEmpty(surpportVersions) && surpportVersions.split(",").length > 0){
|
||||||
if(! Arrays.asList(surpportVersions.split(",")).contains(String.valueOf(conn.getMetaData().getDatabaseProductVersion().split("-")[0]))){
|
if(! Arrays.asList(surpportVersions.split(",")).contains(String.valueOf(conn.getMetaData().getDatabaseProductVersion().split("-")[0]))){
|
||||||
|
conn.close();
|
||||||
DataEaseException.throwException("当前驱动不支持此版本!");
|
DataEaseException.throwException("当前驱动不支持此版本!");
|
||||||
};
|
};
|
||||||
}
|
}
|
||||||
|
Loading…
Reference in New Issue
Block a user