| | |
| | | |
| | | import java.math.BigInteger; |
| | | import java.util.ArrayList; |
| | | import java.util.Arrays; |
| | | import java.util.List; |
| | | |
| | | import javax.annotation.Resource; |
| | |
| | | //清除数据库中的死数据 |
| | | @Service |
| | | public class ClearService { |
| | | |
| | | |
| | | private final String[] videoTables = new String[]{"wk_category_video", "wk_resource_video", "wk_video_attention", |
| | | "wk_video_banquan_video", "wk_video_banquan_webvideo", "wk_video_collection", "wk_video_comment", |
| | | "wk_video_comment2", "wk_video_getscore_collect", "wk_video_homead", "wk_video_homevideo", |
| | | "wk_video_hotstar_video", "wk_video_iqiyi", "wk_video_letv", "wk_video_play_statistics", |
| | | "wk_video_pptv", "wk_video_sohu", "wk_video_special_video", "wk_video_youku", "wk_video_youku_dj"}; |
| | | |
| | | @Resource |
| | | private VideoInfoDao videoInfoDao; |
| | | |
| | |
| | | // 清楚依赖VideoInfo的数据 |
| | | @SuppressWarnings("rawtypes") |
| | | public void clearDependVideo() { |
| | | String[] tables = new String[]{"wk_category_video", "wk_resource_video", "wk_video_attention", |
| | | "wk_video_banquan_video", "wk_video_banquan_webvideo", "wk_video_collection", "wk_video_comment", |
| | | "wk_video_comment2", "wk_video_getscore_collect", "wk_video_homead", "wk_video_homevideo", |
| | | "wk_video_hotstar_video", "wk_video_iqiyi", "wk_video_letv", "wk_video_play_statistics", |
| | | "wk_video_pptv", "wk_video_sohu", "wk_video_special_video", "wk_video_youku", "wk_video_youku_dj"}; |
| | | |
| | | for (String table : tables) { |
| | | |
| | | for (String table : videoTables) { |
| | | final String sql = String.format( |
| | | "SELECT vv.id FROM `%s` vv LEFT JOIN wk_video_video v ON v.`id`=vv.`videoid` WHERE v.`id` IS NULL", |
| | | table); |
| | |
| | | } |
| | | |
| | | /** |
| | | * 清理SQL数据库依赖视频 |
| | | * |
| | | * @param videoId |
| | | */ |
| | | public void clearDependVideo(final String videoId) { |
| | | clearDependVideo(Arrays.asList(new String[]{videoId})); |
| | | } |
| | | |
| | | |
| | | public void clearDependVideo(final List<String> videoIds) { |
| | | videoInfoDao.excute(new HibernateCallback() { |
| | | public Object doInHibernate(Session session) throws HibernateException { |
| | | session.getTransaction().begin(); |
| | | List<String> ors = new ArrayList<>(); |
| | | for (String videoId : videoIds) { |
| | | ors.add("videoid=" + videoId); |
| | | } |
| | | |
| | | for (String table : videoTables) |
| | | session.createSQLQuery( |
| | | String.format("delete from %s where %s", table, org.yeshi.utils.StringUtil.concat(ors, " or "))) |
| | | .executeUpdate(); |
| | | session.flush(); |
| | | session.getTransaction().commit(); |
| | | return null; |
| | | } |
| | | }); |
| | | } |
| | | |
| | | /** |
| | | * 清除无效的爱奇艺视频 |
| | | */ |
| | | @SuppressWarnings("unchecked") |