diff --git a/oap-server/server-storage-plugin/storage-jdbc-hikaricp-plugin/src/main/java/org/apache/skywalking/oap/server/storage/plugin/jdbc/h2/dao/H2AlarmQueryDAO.java b/oap-server/server-storage-plugin/storage-jdbc-hikaricp-plugin/src/main/java/org/apache/skywalking/oap/server/storage/plugin/jdbc/h2/dao/H2AlarmQueryDAO.java index 0f4ff85086be0d9781f66139445eeb5a19593059..ddba6f7bbd1fe5dfcfe8c1909a05688abd84f1d7 100644 --- a/oap-server/server-storage-plugin/storage-jdbc-hikaricp-plugin/src/main/java/org/apache/skywalking/oap/server/storage/plugin/jdbc/h2/dao/H2AlarmQueryDAO.java +++ b/oap-server/server-storage-plugin/storage-jdbc-hikaricp-plugin/src/main/java/org/apache/skywalking/oap/server/storage/plugin/jdbc/h2/dao/H2AlarmQueryDAO.java @@ -61,7 +61,8 @@ public class H2AlarmQueryDAO implements IAlarmQueryDAO { } if (!Strings.isNullOrEmpty(keyword)) { - sql.append(" and ").append(AlarmRecord.ALARM_MESSAGE).append(" like '%").append(keyword).append("%' "); + sql.append(" and ").append(AlarmRecord.ALARM_MESSAGE).append(" like concat('%',?,'%') "); + parameters.add(keyword); } sql.append(" order by ").append(AlarmRecord.START_TIME).append(" desc "); diff --git a/oap-server/server-storage-plugin/storage-jdbc-hikaricp-plugin/src/main/java/org/apache/skywalking/oap/server/storage/plugin/jdbc/h2/dao/H2MetadataQueryDAO.java b/oap-server/server-storage-plugin/storage-jdbc-hikaricp-plugin/src/main/java/org/apache/skywalking/oap/server/storage/plugin/jdbc/h2/dao/H2MetadataQueryDAO.java index 2566ab2b5e38796ce5e03e034073ee6cd58fa8a9..a22b14cd2e3ce41b5486f7170419727c2e807788 100644 --- a/oap-server/server-storage-plugin/storage-jdbc-hikaricp-plugin/src/main/java/org/apache/skywalking/oap/server/storage/plugin/jdbc/h2/dao/H2MetadataQueryDAO.java +++ b/oap-server/server-storage-plugin/storage-jdbc-hikaricp-plugin/src/main/java/org/apache/skywalking/oap/server/storage/plugin/jdbc/h2/dao/H2MetadataQueryDAO.java @@ -125,7 +125,8 @@ public class H2MetadataQueryDAO implements IMetadataQueryDAO { sql.append(ServiceTraffic.NODE_TYPE).append("=?"); condition.add(NodeType.Normal.value()); if (!Strings.isNullOrEmpty(keyword)) { - sql.append(" and ").append(ServiceTraffic.NAME).append(" like \"%").append(keyword).append("%\""); + sql.append(" and ").append(ServiceTraffic.NAME).append(" like concat('%',?,'%')"); + condition.add(keyword); } sql.append(" limit ").append(metadataQueryMaxSize); @@ -175,7 +176,8 @@ public class H2MetadataQueryDAO implements IMetadataQueryDAO { sql.append(EndpointTraffic.SERVICE_ID).append("=?"); condition.add(serviceId); if (!Strings.isNullOrEmpty(keyword)) { - sql.append(" and ").append(EndpointTraffic.NAME).append(" like '%").append(keyword).append("%' "); + sql.append(" and ").append(EndpointTraffic.NAME).append(" like concat('%',?,'%') "); + condition.add(keyword); } sql.append(" limit ").append(limit); diff --git a/oap-server/server-storage-plugin/storage-jdbc-hikaricp-plugin/src/main/java/org/apache/skywalking/oap/server/storage/plugin/jdbc/h2/dao/H2TraceQueryDAO.java b/oap-server/server-storage-plugin/storage-jdbc-hikaricp-plugin/src/main/java/org/apache/skywalking/oap/server/storage/plugin/jdbc/h2/dao/H2TraceQueryDAO.java index 1928ef398e9d66e84eb1eb63c5745e575506c679..d3ee419416881231c7b61d3d444f15be21017dab 100644 --- a/oap-server/server-storage-plugin/storage-jdbc-hikaricp-plugin/src/main/java/org/apache/skywalking/oap/server/storage/plugin/jdbc/h2/dao/H2TraceQueryDAO.java +++ b/oap-server/server-storage-plugin/storage-jdbc-hikaricp-plugin/src/main/java/org/apache/skywalking/oap/server/storage/plugin/jdbc/h2/dao/H2TraceQueryDAO.java @@ -82,7 +82,8 @@ public class H2TraceQueryDAO implements ITraceQueryDAO { } } if (!Strings.isNullOrEmpty(endpointName)) { - sql.append(" and ").append(SegmentRecord.ENDPOINT_NAME).append(" like '%" + endpointName + "%'"); + sql.append(" and ").append(SegmentRecord.ENDPOINT_NAME).append(" like concat('%',?,'%')"); + parameters.add(endpointName); } if (StringUtil.isNotEmpty(serviceId)) { sql.append(" and ").append(SegmentRecord.SERVICE_ID).append(" = ?"); diff --git a/oap-server/server-storage-plugin/storage-jdbc-hikaricp-plugin/src/main/java/org/apache/skywalking/oap/server/storage/plugin/jdbc/mysql/MySQLAlarmQueryDAO.java b/oap-server/server-storage-plugin/storage-jdbc-hikaricp-plugin/src/main/java/org/apache/skywalking/oap/server/storage/plugin/jdbc/mysql/MySQLAlarmQueryDAO.java index aea77c845d6b1f900a0c74586de1b302a64513e8..6de9425c99f45f1e8ce3940c79f5d663f08f5dff 100644 --- a/oap-server/server-storage-plugin/storage-jdbc-hikaricp-plugin/src/main/java/org/apache/skywalking/oap/server/storage/plugin/jdbc/mysql/MySQLAlarmQueryDAO.java +++ b/oap-server/server-storage-plugin/storage-jdbc-hikaricp-plugin/src/main/java/org/apache/skywalking/oap/server/storage/plugin/jdbc/mysql/MySQLAlarmQueryDAO.java @@ -61,7 +61,8 @@ public class MySQLAlarmQueryDAO implements IAlarmQueryDAO { } if (!Strings.isNullOrEmpty(keyword)) { - sql.append(" and ").append(AlarmRecord.ALARM_MESSAGE).append(" like '%").append(keyword).append("%' "); + sql.append(" and ").append(AlarmRecord.ALARM_MESSAGE).append(" like concat('%',?,'%') "); + parameters.add(keyword); } sql.append(" order by ").append(AlarmRecord.START_TIME).append(" desc ");