|
@@ -8,7 +8,7 @@
|
|
|
msg_id, data_group_name, data_group_key,
|
|
|
data_id, root_log_id, parent_log_id,
|
|
|
log_id, `status`, source_time,
|
|
|
- created_time)
|
|
|
+ created_time, request_time)
|
|
|
values
|
|
|
<foreach collection="list" item="item" index="index" separator=",">
|
|
|
(
|
|
@@ -19,7 +19,8 @@
|
|
|
#{item.dataGroupKey,jdbcType=VARCHAR},
|
|
|
#{item.dataId,jdbcType=VARCHAR}, #{item.rootLogId,jdbcType=VARCHAR}, #{item.parentLogId,jdbcType=VARCHAR},
|
|
|
#{item.logId,jdbcType=VARCHAR}, #{item.status,jdbcType=INTEGER}, #{item.sourceTime,jdbcType=TIMESTAMP},
|
|
|
- #{item.createdTime,jdbcType=TIMESTAMP}
|
|
|
+ #{item.createdTime,jdbcType=TIMESTAMP},
|
|
|
+ #{item.requestTime,jdbcType=INTEGER}
|
|
|
)
|
|
|
</foreach>
|
|
|
</insert>
|
|
@@ -27,7 +28,7 @@
|
|
|
<sql id="Base_Column_List">
|
|
|
id, application_name, application_ip, mq_type, invoke_type, topic, partition_name,
|
|
|
msg_id, data_group_name, data_group_key, data_id, root_log_id, parent_log_id, log_id,
|
|
|
- `status`, source_time, created_time
|
|
|
+ `status`, source_time, created_time,request_time
|
|
|
</sql>
|
|
|
|
|
|
<select id="selectPartitionById" resultType="com.jay.monitor.data.server.models.entity.JayMonitorMq">
|
|
@@ -96,6 +97,9 @@
|
|
|
<if test="record.createdTime != null and record.createdTime != ''">
|
|
|
AND created_time = #{record.createdTime,jdbcType=TIMESTAMP}
|
|
|
</if>
|
|
|
+ <if test="record.requestTime != null and record.requestTime != ''">
|
|
|
+ AND request_time >= #{record.requestTime,jdbcType=INTEGER}
|
|
|
+ </if>
|
|
|
</where>
|
|
|
order by id desc limit ${pageSize}
|
|
|
</sql>
|