From 04423260a16b03221e4db23f3d99e5d21212fa29 Mon Sep 17 00:00:00 2001 From: didiaode18 <563646039@qq.com> Date: Wed, 18 Aug 2021 00:53:12 +0800 Subject: [PATCH] [Improvement][dao]When I search for the keyword description, the web UI shows empty (#5952) * [Bug][WorkerServer] SqlTask NullPointerException #5549 * [Improvement][dao]When I search for the keyword Modify User, the web UI shows empty #5428 * [Improvement][dao]When I search for the keyword Modify User, the web UI shows empty #5428 * [Improvement][dao]When I search for the keyword Modify User, the web UI shows empty #5428 * [Improvement][dao]When I search for the keyword Modify User, the web UI shows empty #5428 * [Improvement][dao]When I search for the keyword Modify User, the web UI shows empty #5428 * [Improvement][dao]When I search for the keyword Modify User, the web UI shows empty #5428 * [Improvement][dao]When I search for the keyword description, the web UI shows empty #5428 --- .../dao/mapper/ProcessDefinitionMapper.xml | 4 +++- .../dolphinscheduler/dao/mapper/ProjectMapper.xml | 4 +++- .../server/worker/task/sql/SqlTask.java | 14 ++++++++++---- 3 files changed, 16 insertions(+), 6 deletions(-) diff --git a/dolphinscheduler-dao/src/main/resources/org/apache/dolphinscheduler/dao/mapper/ProcessDefinitionMapper.xml b/dolphinscheduler-dao/src/main/resources/org/apache/dolphinscheduler/dao/mapper/ProcessDefinitionMapper.xml index a16480fd6a..fec3342cf1 100644 --- a/dolphinscheduler-dao/src/main/resources/org/apache/dolphinscheduler/dao/mapper/ProcessDefinitionMapper.xml +++ b/dolphinscheduler-dao/src/main/resources/org/apache/dolphinscheduler/dao/mapper/ProcessDefinitionMapper.xml @@ -80,7 +80,9 @@ left join t_ds_user tu on td.user_id = tu.id where td.project_code = #{projectCode} - and td.name like concat('%', #{searchVal}, '%') + AND (td.name like concat('%', #{searchVal}, '%') + OR td.description like concat('%', #{searchVal}, '%') + ) and td.user_id = #{userId} diff --git a/dolphinscheduler-dao/src/main/resources/org/apache/dolphinscheduler/dao/mapper/ProjectMapper.xml b/dolphinscheduler-dao/src/main/resources/org/apache/dolphinscheduler/dao/mapper/ProjectMapper.xml index 59a24731fe..1b44c22158 100644 --- a/dolphinscheduler-dao/src/main/resources/org/apache/dolphinscheduler/dao/mapper/ProjectMapper.xml +++ b/dolphinscheduler-dao/src/main/resources/org/apache/dolphinscheduler/dao/mapper/ProjectMapper.xml @@ -88,7 +88,9 @@ ) - and p.name like concat('%', #{searchName}, '%') + AND (p.name LIKE concat('%', #{searchName}, '%') + OR p.description LIKE concat('%', #{searchName}, '%') + ) order by p.create_time desc diff --git a/dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/worker/task/sql/SqlTask.java b/dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/worker/task/sql/SqlTask.java index 9dd8b516ed..3c4b3ab273 100644 --- a/dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/worker/task/sql/SqlTask.java +++ b/dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/worker/task/sql/SqlTask.java @@ -42,6 +42,8 @@ import org.apache.dolphinscheduler.server.worker.task.AbstractTask; import org.apache.dolphinscheduler.service.alert.AlertClientService; import org.apache.dolphinscheduler.service.bean.SpringApplicationContext; +import org.apache.commons.collections.MapUtils; + import java.sql.Connection; import java.sql.PreparedStatement; import java.sql.ResultSet; @@ -271,11 +273,11 @@ public class SqlTask extends AbstractTask { public String setNonQuerySqlReturn(String updateResult, List properties) { String result = null; - for (Property info :properties) { + for (Property info : properties) { if (Direct.OUT == info.getDirect()) { - List> updateRL = new ArrayList<>(); - Map updateRM = new HashMap<>(); - updateRM.put(info.getProp(),updateResult); + List> updateRL = new ArrayList<>(); + Map updateRM = new HashMap<>(); + updateRM.put(info.getProp(), updateResult); updateRL.add(updateRM); result = JSONUtils.toJsonString(updateRL); break; @@ -490,6 +492,10 @@ public class SqlTask extends AbstractTask { public void printReplacedSql(String content, String formatSql, String rgex, Map sqlParamsMap) { //parameter print style logger.info("after replace sql , preparing : {}", formatSql); + if (MapUtils.isEmpty(sqlParamsMap)) { + logger.info("sqlParamsMap should not be Empty"); + return; + } StringBuilder logPrint = new StringBuilder("replaced sql , parameters:"); if (sqlParamsMap == null) { logger.info("printReplacedSql: sqlParamsMap is null.");