package com.hxh.spring.test;
|
|
import java.util.List;
|
|
import org.hibernate.HibernateException;
|
import org.hibernate.Session;
|
import org.springframework.orm.hibernate4.HibernateCallback;
|
|
import com.yeshi.buwan.dao.juhe.sohu.SoHuVideoDao;
|
import com.yeshi.buwan.videos.sohu.SoHuUtil;
|
import com.yeshi.buwan.util.BeanUtil;
|
|
public class SoHuTest {
|
|
public static void main(String[] args) {
|
startParseSoHu();
|
}
|
|
public static void startParseSoHu() {
|
SoHuUtil soHuUtil = BeanUtil.getBean(SoHuUtil.class);
|
soHuUtil.parseAll();
|
}
|
|
@org.junit.Test
|
public void test1() {
|
SoHuVideoDao soHuVideoDao = BeanUtil.getBean(SoHuVideoDao.class);
|
soHuVideoDao.excute(new HibernateCallback() {
|
public Object doInHibernate(Session session) throws HibernateException {
|
List list = session
|
.createSQLQuery("SELECT rv.`videoid` FROM wk_resource_video rv WHERE rv.`resourceid`=14")
|
.list();
|
for (int i = 0; i < list.size(); i++) {
|
// 查询是否包含多个来源
|
Object count = session
|
.createSQLQuery("select count(*) from wk_resource_video rv where rv.videoid=?")
|
.setParameter(0, list.get(i) + "").uniqueResult();
|
int c = Integer.parseInt(count + "");
|
session.getTransaction().begin();
|
if (c > 1) {
|
session.createSQLQuery("delete from wk_resource_video where videoid=? and resourceid=14")
|
.setParameter(0, list.get(i) + "").executeUpdate();
|
} else {
|
// c==0 删除
|
session.createSQLQuery("update wk_video_video v set v.show=0 where v.id=?")
|
.setParameter(0, list.get(i) + "").executeUpdate();
|
}
|
session.flush();
|
session.getTransaction().commit();
|
}
|
return null;
|
}
|
});
|
|
}
|
|
}
|
