manager/my-worker
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

修改

Browse Source
This commit is contained in:
gaoxq
2025-12-03 23:03:50 +08:00
parent 3b3c10d7b2
commit 3a0eefddef
1 changed files with 8 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

13
web-api/src/main/java/com/jeesite/modules/app/utils/MysqlUtils.java
View File

@@ -25,6 +25,7 @@ public class MysqlUtils {
private static final String filePath = "/ogsapp/resultList/"; private static final String filePath = "/ogsapp/resultList/";
private static String EXEC_CODE = "0"; private static String EXEC_CODE = "0";
private static String EXEC_FILE = "";
// 需要排除的系统数据库 // 需要排除的系统数据库
private static final List<String> SYSTEM_DATABASES = Arrays.asList( private static final List<String> SYSTEM_DATABASES = Arrays.asList(
@@ -213,12 +214,13 @@ public class MysqlUtils {
public static ExecResult getExecResult(BizDbConfig dbConfig, String sql) { public static ExecResult getExecResult(BizDbConfig dbConfig, String sql) {
String fileName = filePath + vId.getCid() + "_data.xlsx";
try { try {
Connection conn = getConnection(dbConfig.getDbIp(), dbConfig.getDbPort(), dbConfig.getDbUsername(), dbConfig.getDbPassword()); Connection conn = getConnection(dbConfig.getDbIp(), dbConfig.getDbPort(), dbConfig.getDbUsername(), dbConfig.getDbPassword());
Statement statement = conn.createStatement(); Statement statement = conn.createStatement();
boolean isQuery = sql.trim().toUpperCase().startsWith("SELECT"); boolean isQuery = sql.trim().toUpperCase().startsWith("SELECT");
if (isQuery) { if (isQuery) {
EXEC_FILE = filePath + vId.getCid() + "_data.xlsx";
ResultSet rs = statement.executeQuery(sql); ResultSet rs = statement.executeQuery(sql);
List<Map<String, Object>> resultList = new ArrayList<>(); List<Map<String, Object>> resultList = new ArrayList<>();
ResultSetMetaData metaData = rs.getMetaData(); ResultSetMetaData metaData = rs.getMetaData();
@@ -233,19 +235,20 @@ public class MysqlUtils {
resultList.add(rowMap); resultList.add(rowMap);
} }
List<Map<String, Object>> mapList = CollUtil.newArrayList(resultList); List<Map<String, Object>> mapList = CollUtil.newArrayList(resultList);
BigExcelWriter writer = ExcelUtil.getBigWriter(fileName); BigExcelWriter writer = ExcelUtil.getBigWriter(EXEC_FILE);
writer.write(mapList); writer.write(mapList);
writer.close(); writer.close();
logger.info(sql, "执行成功，影响行数:", resultList.size(), "执行结果:", fileName); EXEC_CODE = "1";
logger.info(sql, "执行成功，影响行数:", resultList.size(), "执行结果:", EXEC_FILE);
} else { } else {
int affectedRows = statement.executeUpdate(sql); int affectedRows = statement.executeUpdate(sql);
EXEC_CODE = "1";
logger.info(sql, "执行成功，影响行数:", affectedRows); logger.info(sql, "执行成功，影响行数:", affectedRows);
} }
EXEC_CODE = "1";
} catch (Exception e) { } catch (Exception e) {
EXEC_CODE = "0"; EXEC_CODE = "0";
logger.error(e.getMessage()); logger.error(e.getMessage());
} }
return new ExecResult(EXEC_CODE, fileName); return new ExecResult(EXEC_CODE, EXEC_FILE);
} }
} }