From e88a7053f81fab0161545a52e26e91f4de16e889 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E9=9F=A9=E5=8D=8E=E9=94=8B?= <799954772@qq.com>
Date: Fri, 8 Sep 2023 15:03:52 +0800
Subject: [PATCH] =?UTF-8?q?=E3=80=90fix=E3=80=91=E4=BF=AE=E5=A4=8D?=
 =?UTF-8?q?=E7=A9=BA=E9=A1=B9=E7=9B=AE=E5=90=AF=E5=8A=A8=E7=9A=84=E6=97=B6?=
 =?UTF-8?q?=E5=80=99=EF=BC=8C=E4=BD=BF=E7=94=A8spring=E9=BB=98=E8=AE=A4?=
 =?UTF-8?q?=E6=95=B0=E6=8D=AE=E6=BA=90=E6=97=B6=20=E8=A1=A8=E5=AE=9E?=
 =?UTF-8?q?=E9=99=85=E5=AD=98=E5=9C=A8=EF=BC=8C=E4=BD=86=E6=98=AF=E5=90=AF?=
 =?UTF-8?q?=E5=8A=A8=E6=97=B6=E5=80=99=E6=8A=A5=E6=97=A0=E5=8F=AF=E7=94=A8?=
 =?UTF-8?q?=E6=95=B0=E6=8D=AE=E6=BA=90=E7=9A=84=E9=97=AE=E9=A2=98?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../liteflow/parser/sql/util/LiteFlowJdbcUtil.java  | 13 +++++--------
 1 file changed, 5 insertions(+), 8 deletions(-)

diff --git a/liteflow-rule-plugin/liteflow-rule-sql/src/main/java/com/yomahub/liteflow/parser/sql/util/LiteFlowJdbcUtil.java b/liteflow-rule-plugin/liteflow-rule-sql/src/main/java/com/yomahub/liteflow/parser/sql/util/LiteFlowJdbcUtil.java
index e899c044c..6f59fb183 100644
--- a/liteflow-rule-plugin/liteflow-rule-sql/src/main/java/com/yomahub/liteflow/parser/sql/util/LiteFlowJdbcUtil.java
+++ b/liteflow-rule-plugin/liteflow-rule-sql/src/main/java/com/yomahub/liteflow/parser/sql/util/LiteFlowJdbcUtil.java
@@ -13,7 +13,7 @@ import java.util.Map;
 
 public class LiteFlowJdbcUtil {
     private static final Logger LOG = LoggerFactory.getLogger(LiteFlowJdbcUtil.class);
-    private static final String CHECK_SQL_PATTERN = "SELECT {},{} FROM {} WHERE {}='{}'";
+    private static final String CHECK_SQL_PATTERN = "SELECT {},{} FROM {}";
 
     /**
      * 获取链接
@@ -74,7 +74,7 @@ public class LiteFlowJdbcUtil {
             stmt = conn.prepareStatement(sql, ResultSet.TYPE_FORWARD_ONLY, ResultSet.CONCUR_READ_ONLY);
             stmt.setFetchSize(1);
             rs = stmt.executeQuery();
-            return rs.next();
+            return true;
         } catch (Exception e) {
             return false;
         } finally {
@@ -87,7 +87,6 @@ public class LiteFlowJdbcUtil {
      * 关闭
      *
      * @param conn conn
-     * @param conn conn
      * @param rs   rs
      */
     public static void close(Connection conn, PreparedStatement stmt, ResultSet rs) {
@@ -120,15 +119,13 @@ public class LiteFlowJdbcUtil {
     /**
      * 构建检查 sql
      *
-     * @param sqlParserVO
-     * @return
+     * @param sqlParserVO sql解析器参数
+     * @return 返回组合完成的检查sql
      */
     private static String buildCheckSql(SQLParserVO sqlParserVO) {
         String chainTableName = sqlParserVO.getChainTableName();
         String elDataField = sqlParserVO.getElDataField();
         String chainNameField = sqlParserVO.getChainNameField();
-        String chainApplicationNameField = sqlParserVO.getChainApplicationNameField();
-        String applicationName = sqlParserVO.getApplicationName();
-        return StrUtil.format(CHECK_SQL_PATTERN, chainNameField, elDataField, chainTableName, chainApplicationNameField, applicationName);
+        return StrUtil.format(CHECK_SQL_PATTERN, chainNameField, elDataField, chainTableName);
     }
 }