From 3a0eefddef6689d7174aae61911a74c0d4d9bf7c Mon Sep 17 00:00:00 2001 From: gaoxq <376340421@qq.com> Date: Wed, 3 Dec 2025 23:03:50 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E6=94=B9?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../com/jeesite/modules/app/utils/MysqlUtils.java | 13 ++++++++----- 1 file changed, 8 insertions(+), 5 deletions(-) diff --git a/web-api/src/main/java/com/jeesite/modules/app/utils/MysqlUtils.java b/web-api/src/main/java/com/jeesite/modules/app/utils/MysqlUtils.java index 26bf42f4..8cfc9055 100644 --- a/web-api/src/main/java/com/jeesite/modules/app/utils/MysqlUtils.java +++ b/web-api/src/main/java/com/jeesite/modules/app/utils/MysqlUtils.java @@ -25,6 +25,7 @@ public class MysqlUtils { private static final String filePath = "/ogsapp/resultList/"; private static String EXEC_CODE = "0"; + private static String EXEC_FILE = ""; // 需要排除的系统数据库 private static final List SYSTEM_DATABASES = Arrays.asList( @@ -213,12 +214,13 @@ public class MysqlUtils { public static ExecResult getExecResult(BizDbConfig dbConfig, String sql) { - String fileName = filePath + vId.getCid() + "_data.xlsx"; + try { Connection conn = getConnection(dbConfig.getDbIp(), dbConfig.getDbPort(), dbConfig.getDbUsername(), dbConfig.getDbPassword()); Statement statement = conn.createStatement(); boolean isQuery = sql.trim().toUpperCase().startsWith("SELECT"); if (isQuery) { + EXEC_FILE = filePath + vId.getCid() + "_data.xlsx"; ResultSet rs = statement.executeQuery(sql); List> resultList = new ArrayList<>(); ResultSetMetaData metaData = rs.getMetaData(); @@ -233,19 +235,20 @@ public class MysqlUtils { resultList.add(rowMap); } List> mapList = CollUtil.newArrayList(resultList); - BigExcelWriter writer = ExcelUtil.getBigWriter(fileName); + BigExcelWriter writer = ExcelUtil.getBigWriter(EXEC_FILE); writer.write(mapList); writer.close(); - logger.info(sql, "执行成功,影响行数:", resultList.size(), "执行结果:", fileName); + EXEC_CODE = "1"; + logger.info(sql, "执行成功,影响行数:", resultList.size(), "执行结果:", EXEC_FILE); } else { int affectedRows = statement.executeUpdate(sql); + EXEC_CODE = "1"; logger.info(sql, "执行成功,影响行数:", affectedRows); } - EXEC_CODE = "1"; } catch (Exception e) { EXEC_CODE = "0"; logger.error(e.getMessage()); } - return new ExecResult(EXEC_CODE, fileName); + return new ExecResult(EXEC_CODE, EXEC_FILE); } } \ No newline at end of file