修复 deleteWithoutGBId sql 语句

This commit is contained in:
zxb 2023-09-27 09:43:08 +08:00
parent a0d04ca7ff
commit 1b3ba023ae

View File

@ -102,14 +102,12 @@ public interface StreamPushMapper {
@Delete("DELETE FROM wvp_stream_push") @Delete("DELETE FROM wvp_stream_push")
void clear(); void clear();
@Delete("delete" + @Delete("delete wvp_stream_push" +
" from wvp_stream_push " + " from wvp_stream_push" +
" where id in " + " join (select wgs.gb_stream_id as id" +
" (select temp.id from " +
" (select wgs.gb_stream_id as id " +
" from wvp_gb_stream wgs" + " from wvp_gb_stream wgs" +
" left join wvp_stream_push sp on sp.id = wgs.gb_stream_id" + " 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); void deleteWithoutGBId(String mediaServerId);