From 923b3371ceced4d9d508ce4d98674a8d12b5e5f5 Mon Sep 17 00:00:00 2001 From: jay li <221531386@qq.com> Date: Fri, 30 Aug 2024 09:24:47 +0800 Subject: [PATCH] =?UTF-8?q?=E5=85=BC=E5=AE=B9=E6=95=B0=E6=8D=AE?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../yomahub/liteflow/parser/sql/read/impl/ChainRead.java | 9 ++++++++- 1 file changed, 8 insertions(+), 1 deletion(-) diff --git a/liteflow-rule-plugin/liteflow-rule-sql/src/main/java/com/yomahub/liteflow/parser/sql/read/impl/ChainRead.java b/liteflow-rule-plugin/liteflow-rule-sql/src/main/java/com/yomahub/liteflow/parser/sql/read/impl/ChainRead.java index af5217bce..f4dd72558 100644 --- a/liteflow-rule-plugin/liteflow-rule-sql/src/main/java/com/yomahub/liteflow/parser/sql/read/impl/ChainRead.java +++ b/liteflow-rule-plugin/liteflow-rule-sql/src/main/java/com/yomahub/liteflow/parser/sql/read/impl/ChainRead.java @@ -59,8 +59,15 @@ public class ChainRead extends AbstractSqlRead { String customFilterType = super.config.getCustomFilterType(); if (StrUtil.isNotBlank(customFilterType)) { + String replace = customFilterType.replace("where", "").replace("WHERE", ""); + String trim = replace.trim(); + + if (trim.startsWith("AND") || trim.startsWith("and")) { + trim = trim.substring(3); + } + return StrUtil.format(SqlReadConstant.SQL_PATTERN_WITH_SUFFIX, chainTableName, - chainApplicationNameField, customFilterType); + chainApplicationNameField, trim); } else { return StrUtil.format(SqlReadConstant.SQL_PATTERN, chainTableName, chainApplicationNameField); }