From 5d15287b2a06f978485ac6af71e33e1a82b43a65 Mon Sep 17 00:00:00 2001
From: kimi <kimi42345@gmail.com>
Date: 星期三, 15 四月 2020 16:29:55 +0800
Subject: [PATCH] fix 上传后生成版本连接池用完不释放问题
---
src/main/java/com/highdatas/mdm/service/impl/SysAssembleServiceImpl.java | 9 ++++-----
1 files changed, 4 insertions(+), 5 deletions(-)
diff --git a/src/main/java/com/highdatas/mdm/service/impl/SysAssembleServiceImpl.java b/src/main/java/com/highdatas/mdm/service/impl/SysAssembleServiceImpl.java
index d9c2740..19170e4 100644
--- a/src/main/java/com/highdatas/mdm/service/impl/SysAssembleServiceImpl.java
+++ b/src/main/java/com/highdatas/mdm/service/impl/SysAssembleServiceImpl.java
@@ -73,8 +73,7 @@
BigDataDataSourceInfo bigDataDataSourceInfo;
@Autowired
MasterDataService masterDataService;
- @Autowired
- ITUserService userService;
+
@Autowired
RuleClient ruleClient;
@Autowired
@@ -235,7 +234,7 @@
if (audit) {
String chargeId = menuMapping.getChargeId();
- TUser user = userService.selectById(chargeId);
+ TUser user = DbUtils.getUserById(chargeId);
if (user == null) {
return Result.error(new CodeMsg(6009, "鎵句笉鍒板搴旂殑璐熻矗浜�:" + chargeId));
}
@@ -816,8 +815,8 @@
conn = dataSourceInfo.conn();
PreparedStatement statement = conn.prepareStatement(sql);
int result = 0;
- if (statement.isWrapperFor(com.mysql.jdbc.Statement.class)) {
- com.mysql.jdbc.PreparedStatement mysqlStatement = statement.unwrap(com.mysql.jdbc.PreparedStatement.class);
+ if (statement.isWrapperFor(java.sql.Statement.class)) {
+ com.mysql.cj.jdbc.PreparedStatement mysqlStatement = statement.unwrap( com.mysql.cj.jdbc.PreparedStatement.class);
mysqlStatement.setLocalInfileInputStream(dataStream);
result = mysqlStatement.executeUpdate();
}
--
Gitblit v1.8.0