From 74472c9d22dddcb41383794caf0011043b20f817 Mon Sep 17 00:00:00 2001
From: kimi <kimi42345@gmail.com>
Date: 星期二, 31 三月 2020 13:25:47 +0800
Subject: [PATCH] fix 数据权限
---
src/main/java/com/highdatas/mdm/service/impl/SysAssembleDbServiceImpl.java | 31 ++++++++++++++++++++++++++++++-
1 files changed, 30 insertions(+), 1 deletions(-)
diff --git a/src/main/java/com/highdatas/mdm/service/impl/SysAssembleDbServiceImpl.java b/src/main/java/com/highdatas/mdm/service/impl/SysAssembleDbServiceImpl.java
index 8384686..8e066e7 100644
--- a/src/main/java/com/highdatas/mdm/service/impl/SysAssembleDbServiceImpl.java
+++ b/src/main/java/com/highdatas/mdm/service/impl/SysAssembleDbServiceImpl.java
@@ -43,6 +43,11 @@
return null;
}
+ return getConnection(assemble);
+
+ }
+
+ private Connection getConnection(SysAssembleDb assemble) {
Connection connection = null;
try {
SysAssembleDbdriver sysAssembleDbdriver = dbdriverService.selectOne(new EntityWrapper<SysAssembleDbdriver>().eq(Constant.TYPE, assemble.getDatasourceType()));
@@ -65,7 +70,6 @@
e.printStackTrace();
return null;
}
-
}
@Override
@@ -112,6 +116,31 @@
}
@Override
+ public boolean testConnection(SysAssembleDb sysAssembleDb) {
+ Connection connection = null;
+ try{
+ connection = getConnection(sysAssembleDb);
+ if (connection != null) {
+ return true;
+ }
+ return false;
+ }
+ catch (Exception e) {
+ e.printStackTrace();
+ return false;
+ }
+ finally {
+ if (connection != null) {
+ try {
+ connection.close();
+ } catch (SQLException e) {
+ e.printStackTrace();
+ }
+ }
+ }
+ }
+
+ @Override
public boolean testConnection(String parentId) {
Connection connection = null;
try{
--
Gitblit v1.8.0