'完善'

admin

2021-02-06 e2c6372f29ae0a93d9f672ffad4613581ba3e201

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
package com.hxh.spring.test;
 
import java.util.List;
 
import org.hibernate.HibernateException;
import org.hibernate.Session;
import org.junit.Test;
import org.springframework.orm.hibernate4.HibernateCallback;
 
import com.newvideo.dao.VideoInfoDao;
import com.newvideo.util.BeanUtil;
 
public class MySqlTest {
 
    @Test
    public void test() {
        VideoInfoDao viDao = BeanUtil.getBean(VideoInfoDao.class);
        viDao.excute(new HibernateCallback() {
 
            public Object doInHibernate(Session session) throws HibernateException {
                List list = session
                        .createSQLQuery(
                                "select v.id,v.area,t.typeid from wk_video_area_video_temp t left join wk_video_video v on v.id=t.id where t.areas is null")
                        .setFirstResult(0).setMaxResults(5000).list();
                for (int i = 0; i < list.size(); i++) {
                    Object[] objs = (Object[]) list.get(i);
                    List areas = session
                            .createSQLQuery(
                                    "SELECT GROUP_CONCAT(DISTINCT (ca.`name`))  FROM (SELECT  ca.`pid`  FROM  wk_category_area ca   WHERE ? LIKE CONCAT('%', ca.`name`, '%')   AND ca.`pid` > 4) ca1  LEFT JOIN wk_category_area ca  ON ca1.`pid` = ca.id  WHERE ca.`pid` = ? - 149")
                            .setParameter(0, objs[1] + "").setParameter(1, objs[2] + "").list();
 
                    if (areas.size() > 0) {
                        session.getTransaction().begin();
                        session.createSQLQuery("update wk_video_area_video_temp wt set wt.areas=? where wt.id=?")
                                .setParameter(0, areas.get(0) + "").setParameter(1, objs[0]).executeUpdate();
                        session.flush();
                        session.getTransaction().commit();
                    }
                }
 
                return null;
            }
        });
 
    }
 
}