public/liteFlow
1
0
Fork 0
mirror of https://gitee.com/dromara/liteFlow.git synced 2026-06-10 11:17:00 +08:00
Code Issues Packages Projects Releases Wiki Activity

修改为支持自定义过滤

Browse Source
This commit is contained in:
jay li
2024-08-29 08:42:16 +08:00
parent c636847ce6
commit dd3cb00da3
6 changed files with 7 additions and 41 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
liteflow-rule-plugin/liteflow-rule-sql/src/main/java/com/yomahub/liteflow/parser/constant/SqlReadConstant.java
View File

@@ -12,7 +12,7 @@ public class SqlReadConstant {
public static final String SQL_PATTERN = "SELECT * FROM {} WHERE {}=?";
public static final String SQL_PATTERN_WITH_SUFFIX = "SELECT * FROM {} WHERE {}=? AND {} {} ?";
public static final String SQL_PATTERN_WITH_SUFFIX = "SELECT * FROM {} WHERE {}=? AND {}";
public static final String SCRIPT_SQL_CHECK_PATTERN = "SELECT 1 FROM {} ";

4
liteflow-rule-plugin/liteflow-rule-sql/src/main/java/com/yomahub/liteflow/parser/sql/read/AbstractSqlRead.java
View File

@@ -51,10 +51,6 @@ public abstract class AbstractSqlRead<T> implements SqlRead<T> {
stmt.setFetchSize(SqlReadConstant.FETCH_SIZE_MAX);
stmt.setString(1, config.getApplicationName());
if (sqlCmd.contains(config.getCustomFilterTypeField()) && StrUtil.isNotBlank(config.getCustomFilterType())) {
stmt.setString(2, config.getCustomFilterType());
}
rs = stmt.executeQuery();
while (rs.next()) {

8
liteflow-rule-plugin/liteflow-rule-sql/src/main/java/com/yomahub/liteflow/parser/sql/read/impl/ChainRead.java
View File

@@ -56,11 +56,11 @@ public class ChainRead extends AbstractSqlRead<ChainVO> {
public String buildQuerySql() {
String chainTableName = super.config.getChainTableName();
String chainApplicationNameField = super.config.getChainApplicationNameField();
String chainSuffixTypeField = super.config.getCustomFilterTypeField();
String chainSuffixOperator = super.config.getCustomFilterOperator();
if (StrUtil.isNotBlank(chainSuffixTypeField) && StrUtil.isNotBlank(chainSuffixOperator)) {
String customFilterType = super.config.getCustomFilterType();
if (StrUtil.isNotBlank(customFilterType)) {
return StrUtil.format(SqlReadConstant.SQL_PATTERN_WITH_SUFFIX, chainTableName,
chainApplicationNameField, chainSuffixTypeField, chainSuffixOperator);
chainApplicationNameField, customFilterType);
} else {
return StrUtil.format(SqlReadConstant.SQL_PATTERN, chainTableName, chainApplicationNameField);
}

26
liteflow-rule-plugin/liteflow-rule-sql/src/main/java/com/yomahub/liteflow/parser/sql/vo/SQLParserVO.java
View File

@@ -76,16 +76,6 @@ public class SQLParserVO {
*/
private String customFilterType;
/**
* 自定义过滤操作符
*/
private String customFilterOperator;
/**
* 自定义过滤字段名
*/
private String customFilterTypeField = "custom_filter_type";
/**
* 脚本 node 表名
*/
@@ -359,20 +349,4 @@ public class SQLParserVO {
public void setCustomFilterType(String customFilterType) {
this.customFilterType = customFilterType;
}
public String getCustomFilterTypeField() {
return customFilterTypeField;
}
public void setCustomFilterTypeField(String customFilterTypeField) {
this.customFilterTypeField = customFilterTypeField;
}
public String getCustomFilterOperator() {
return customFilterOperator;
}
public void setCustomFilterOperator(String customFilterOperator) {
this.customFilterOperator = customFilterOperator;
}
}

4
liteflow-testcase-el/liteflow-testcase-el-sql-springboot/src/test/resources/application-data-source-with-suffix-xml.properties
View File

@@ -3,9 +3,7 @@ liteflow.rule-source-ext-data={\
"chainTableName":"EL_TABLE",\
"chainApplicationNameField":"application_name",\
"chainNameField":"chain_name",\
"customFilterTypeField":"custom_filter_type",\
"customFilterOperator":"LIKE",\
"customFilterType":"%biz1",\
"customFilterType":"custom_filter_type = 'biz1'",\
"elDataField":"EL_DATA",\
"scriptTableName":"script_node_table",\
"scriptApplicationNameField":"application_name",\

4
liteflow-testcase-el/liteflow-testcase-el-sql-springboot/src/test/resources/application-data-source-with-suffix2-xml.properties
View File

@@ -3,9 +3,7 @@ liteflow.rule-source-ext-data={\
"chainTableName":"EL_TABLE",\
"chainApplicationNameField":"application_name",\
"chainNameField":"chain_name",\
"customFilterTypeField":"custom_filter_type",\
"customFilterOperator":"LIKE",\
"customFilterType":"%biz2",\
"customFilterType":"custom_filter_type = 'biz2' ",\
"elDataField":"EL_DATA",\
"scriptTableName":"script_node_table",\
"scriptApplicationNameField":"application_name",\