From 9e790eb0ff438121c8ca06021dbbb403aba84a83 Mon Sep 17 00:00:00 2001 From: 648540858 <648540858@qq.com> Date: 星期二, 16 五月 2023 17:17:24 +0800 Subject: [PATCH] 本地集成人大金仓连接jar --- src/main/java/com/genersoft/iot/vmp/storager/dao/StreamPushMapper.java | 10 +++++++++- 1 files changed, 9 insertions(+), 1 deletions(-) diff --git a/src/main/java/com/genersoft/iot/vmp/storager/dao/StreamPushMapper.java b/src/main/java/com/genersoft/iot/vmp/storager/dao/StreamPushMapper.java index 63fea06..45ed4f8 100644 --- a/src/main/java/com/genersoft/iot/vmp/storager/dao/StreamPushMapper.java +++ b/src/main/java/com/genersoft/iot/vmp/storager/dao/StreamPushMapper.java @@ -102,7 +102,15 @@ @Delete("DELETE FROM wvp_stream_push") void clear(); - @Delete("DELETE sp FROM wvp_stream_push sp left join wvp_gb_stream gs on gs.app = sp.app and gs.stream= sp.stream WHERE sp.media_server_id=#{mediaServerId} and gs.gb_id is null ") + @Delete("delete" + + " from wvp_stream_push " + + " where id in " + + " (select temp.id from " + + " (select wgs.gb_stream_id as id " + + " from wvp_gb_stream wgs" + + " left join wvp_stream_push sp on sp.id = wgs.gb_stream_id" + + " where wgs.gb_id is null and wgs.media_server_id = #{mediaServerId}) temp)" + ) void deleteWithoutGBId(String mediaServerId); @Select("SELECT * FROM wvp_stream_push WHERE media_server_id=#{mediaServerId}") -- Gitblit v1.8.0