From 9df6645ba84351a859c08fc86c41413e6d5e88b3 Mon Sep 17 00:00:00 2001 From: liangdaliang Date: Fri, 7 Mar 2025 15:31:18 +0800 Subject: [PATCH] =?UTF-8?q?=E9=80=82=E9=85=8DTinyInt?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../com/test/common/utils/MySQLExecutor.java | 23 ++++++++++++++++++- 1 file changed, 22 insertions(+), 1 deletion(-) diff --git a/test-common/src/main/java/com/test/common/utils/MySQLExecutor.java b/test-common/src/main/java/com/test/common/utils/MySQLExecutor.java index c45f2fe..4eeee4c 100644 --- a/test-common/src/main/java/com/test/common/utils/MySQLExecutor.java +++ b/test-common/src/main/java/com/test/common/utils/MySQLExecutor.java @@ -1,6 +1,7 @@ package com.test.common.utils; import java.sql.*; +import java.time.format.DateTimeFormatter; import java.util.ArrayList; import java.util.HashMap; import java.util.List; @@ -40,7 +41,14 @@ public class MySQLExecutor { // 获取字段名和字段值 String columnName = metaData.getColumnLabel(i); Object columnValue = resultSet.getObject(i); - row.put(columnName, columnValue); + int columnType = metaData.getColumnType(i); + if (columnType == Types.TINYINT) { + row.put(columnName, resultSet.getInt(columnName)); + } else if (columnType == Types.TIMESTAMP) { + row.put(columnName, ((Timestamp) columnValue).toLocalDateTime().format(DateTimeFormatter.ISO_LOCAL_DATE_TIME)); + } else { + row.put(columnName, columnValue); + } if (i == 1) { columnNameList.add(columnName); } @@ -53,4 +61,17 @@ public class MySQLExecutor { } return result; } + +// public static void main(String[] args) { +// String url = "jdbc:mysql://47.103.142.5:3306/cmcf-test"; +// List columnNameList = new ArrayList<>(); +// List> resultMapList = MySQLExecutor.executeQuery("select * from test_task t", url, "test", "Test123@", columnNameList); +// ObjectMapper objectMapper = new ObjectMapper(); +// try { +// String result = objectMapper.writeValueAsString(resultMapList); +// System.out.println(result); +// } catch (JsonProcessingException e) { +// throw new RuntimeException(e); +// } +// } }