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 4efc058d..b779e56f 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,14 +102,12 @@ public interface StreamPushMapper { @Delete("DELETE FROM wvp_stream_push") void clear(); - @Delete("delete" + - " from wvp_stream_push " + - " where id in " + - " (select temp.id from " + - " (select wgs.gb_stream_id as id " + + @Delete("delete wvp_stream_push" + + " from wvp_stream_push" + + " join (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)" + " where wgs.gb_id is null and wgs.media_server_id = #{mediaServerId}) temp on wvp_stream_push.id = temp.id" ) void deleteWithoutGBId(String mediaServerId);