From 65dd5eb9f8d50c5779e59360c9265029d18242dc Mon Sep 17 00:00:00 2001 From: taojinlong Date: Fri, 22 Mar 2024 15:51:04 +0800 Subject: [PATCH] =?UTF-8?q?fix:=20=E4=BF=AE=E5=A4=8DSQL=E6=B3=A8=E5=85=A5?= =?UTF-8?q?=E6=BC=8F=E6=B4=9E?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../io/dataease/datasource/provider/H2EngineProvider.java | 5 ++++- .../io/dataease/datasource/provider/MysqlEngineProvider.java | 5 ++++- 2 files changed, 8 insertions(+), 2 deletions(-) diff --git a/core/core-backend/src/main/java/io/dataease/datasource/provider/H2EngineProvider.java b/core/core-backend/src/main/java/io/dataease/datasource/provider/H2EngineProvider.java index 5b41826b34..dc374ec168 100644 --- a/core/core-backend/src/main/java/io/dataease/datasource/provider/H2EngineProvider.java +++ b/core/core-backend/src/main/java/io/dataease/datasource/provider/H2EngineProvider.java @@ -14,6 +14,7 @@ import org.apache.commons.lang3.StringUtils; import org.springframework.stereotype.Service; import java.sql.Connection; +import java.sql.PreparedStatement; import java.sql.Statement; import java.util.Arrays; import java.util.List; @@ -28,7 +29,9 @@ public class H2EngineProvider extends EngineProvider { CoreDatasource datasource = new CoreDatasource(); BeanUtils.copyBean(datasource, engineRequest.getEngine()); try (Connection connection = getConnection(datasource); Statement stat = getStatement(connection, queryTimeout)) { - Boolean result = stat.execute(engineRequest.getQuery()); + PreparedStatement preparedStatement = connection.prepareStatement(engineRequest.getQuery()); + preparedStatement.setQueryTimeout(queryTimeout); + Boolean result = preparedStatement.execute(); } catch (Exception e) { throw e; } diff --git a/core/core-backend/src/main/java/io/dataease/datasource/provider/MysqlEngineProvider.java b/core/core-backend/src/main/java/io/dataease/datasource/provider/MysqlEngineProvider.java index 4b16ed8e0b..e6b681aaa4 100644 --- a/core/core-backend/src/main/java/io/dataease/datasource/provider/MysqlEngineProvider.java +++ b/core/core-backend/src/main/java/io/dataease/datasource/provider/MysqlEngineProvider.java @@ -14,6 +14,7 @@ import org.apache.commons.lang3.StringUtils; import org.springframework.stereotype.Service; import java.sql.Connection; +import java.sql.PreparedStatement; import java.sql.Statement; import java.util.Arrays; import java.util.List; @@ -32,7 +33,9 @@ public class MysqlEngineProvider extends EngineProvider { CoreDatasource datasource = new CoreDatasource(); BeanUtils.copyBean(datasource, engineRequest.getEngine()); try (Connection connection = getConnection(datasource); Statement stat = getStatement(connection, queryTimeout)) { - Boolean result = stat.execute(engineRequest.getQuery()); + PreparedStatement preparedStatement = connection.prepareStatement(engineRequest.getQuery()); + preparedStatement.setQueryTimeout(queryTimeout); + Boolean result = preparedStatement.execute(); } catch (Exception e) { throw e; }