| | |
| | | "(gbStreamId, platformId, catalogId) " + |
| | | "values " + |
| | | "<foreach collection='streamPushItems' index='index' item='item' separator=','> " + |
| | | "(${item.gbStreamId}, '${item.platformId}', '${item.catalogId}')" + |
| | | "(#{item.gbStreamId}, #{item.platformId}, #{item.catalogId})" + |
| | | "</foreach> " + |
| | | "</script>") |
| | | int batchAdd(List<StreamPushItem> streamPushItems); |
| | |
| | | "left join platform_gb_stream pgs on " + |
| | | "pp.serverGBId = pgs.platformId " + |
| | | "left join gb_stream gs " + |
| | | "gs.gbStreamId = pgs.gbStreamId " + |
| | | "on gs.gbStreamId = pgs.gbStreamId " + |
| | | "WHERE " + |
| | | "gs.app = #{app} " + |
| | | "AND gs.stream = #{stream}" + |
| | |
| | | "</foreach>" + |
| | | "</script>") |
| | | void delByAppAndStreamsByPlatformId(List<GbStream> gbStreams, String platformId); |
| | | |
| | | @Delete("DELETE FROM platform_gb_stream WHERE platformId=#{platformId} and catalogId=#{catalogId}") |
| | | int delByPlatformAndCatalogId(String platformId, String catalogId); |
| | | } |