springboot—Jpa原生sql使用

package com.savingyu.dao;

import java.util.List;

import javax.persistence.EntityManager;
import javax.persistence.EntityManagerFactory;
import javax.persistence.PersistenceUnit;
import javax.persistence.Query;
/**
 * JPA使用原生Sql元素
 * @author Administrator
 *
 */
public class BaseNativeSqlRepository {
    
    @PersistenceUnit
    private EntityManagerFactory emf;
    /**
     * 查询多个属性
     * 返回List<Object[]>数组形式的，数组中内容按照查询字段先后
     * @author savingyu
     * @author 2018年8月30日
     * @param sql
     * @return
     */
    public List<Object[]> sqlArrayList(String sql){
        EntityManager em =emf.createEntityManager();
        Query query =em.createNamedQuery(sql);
        List<Object[]> list = query.getResultList();
        em.close();
        return list;
    }
    /**
     * 查询多个属性
     * 返回List<Object>对象形式的List，Object为Class格式对象
     * @author savingyu
     * @author 2018年8月30日
     * @param sql
     * @param obj
     * @return
     */
    public List sqlObjectList(String sql ,Object obj){
        EntityManager em =emf.createEntityManager();
        Query query = em.createNamedQuery(sql,obj.getClass());
        List list = query.getResultList();
        em.close();
        return list;
    }
    
    /**
     * 查询单个属性
     * @author savingyu
     * @author 2018年8月30日
     * @param sql
     * @return
     */
    public List sqlSingleList(String sql){
        EntityManager em = emf.createEntityManager();
        Query query = em.createNamedQuery(sql);
        List list = query.getResultList();
        em.close();
        return list;
    }
}

package com.favorites.repository.impl;

import com.favorites.domain.view.CollectorView;
import com.favorites.repository.BaseNativeSqlRepository;
import com.favorites.repository.CollectorRepository;
import com.favorites.utils.DateUtils;
import org.springframework.stereotype.Service;

import java.util.List;

/**
 * @Description: 获取收藏家
 * @Auth: yuyang
 * @Date: 2017/1/18 19:35
 * @Version: 1.0
 **/
@Service
public class CollectorRepositoryImpl extends BaseNativeSqlRepository implements CollectorRepository {

    /**
     * 收藏文章最多的用户
     * @return
     */
    @Override
    public Long getMostCollectUser() {
        String querySql = "SELECT c.user_id ,COUNT(1) AS counts FROM collect c WHERE type='PUBLIC' AND is_delete='NO' GROUP BY c.user_id ORDER BY counts DESC LIMIT 1";
        List<Object[]> objecArraytList = sqlArrayList(querySql);
        Object[] obj =  objecArraytList.get(0);
        return Long.valueOf(obj[0].toString());
    }

    /**
     * 被关注最多的用户
     * @param notUserId
     * @return
     */
    @Override
    public Long getMostFollowedUser(Long notUserId) {
        String querySql = "SELECT id,follow_id as user_id,COUNT(1) AS counts FROM follow 
" +
                "WHERE status='FOLLOW' and follow_id != " + notUserId +
                " GROUP BY follow_id ORDER BY counts DESC LIMIT 1";
        CollectorView cv = new CollectorView();
        List<CollectorView> list = sqlObjectList(querySql,cv);
        Long userId = list.get(0).getUserId();
        return  userId;
    }

    /**
     * 文章被赞最多的用户
     * @param notUserIds
     * @return
     */
    @Override
    public Long getMostPraisedUser(String notUserIds) {
        String querySql = "SELECT c.user_id,SUM(p.counts) as counts FROM collect c LEFT JOIN 
" +
                "(SELECT collect_id,COUNT(1) as counts FROM praise GROUP BY collect_id)p 
" +
                "ON c.id=p.collect_id WHERE c.type='PUBLIC' AND c.is_delete='NO' AND c.user_id NOT IN (" + notUserIds +") 
" +
                "GROUP BY c.user_id ORDER BY counts DESC LIMIT 1";
        List<Object[]> objecArraytList = sqlArrayList(querySql);
        Object[] obj =  objecArraytList.get(0);
        return Long.valueOf(obj[0].toString());
    }

    /**
     * 文章被评论最多的用户
     * @param notUserIds
     * @return
     */
    @Override
    public Long getMostCommentedUser(String notUserIds) {
        String querySql="SELECT c.user_id,SUM(p.counts) as counts FROM collect c LEFT JOIN 
" +
                "(SELECT collect_id,COUNT(1) as counts FROM `comment` GROUP BY collect_id)p 
" +
                "ON c.id=p.collect_id WHERE c.type='PUBLIC' AND c.is_delete='NO' AND c.user_id NOT IN (" + notUserIds +") 
" +
                "GROUP BY c.user_id ORDER BY counts DESC LIMIT 1";
        List<Object[]> objecArraytList = sqlArrayList(querySql);
        Object[] obj =  objecArraytList.get(0);
        return Long.valueOf(obj[0].toString());
    }

    /**
     * 最受欢迎的用户
     * @param notUserIds
     * @return
     */
    @Override
    public Long getMostPopularUser(String notUserIds) {
        String querySql = "SELECT u.user_id,SUM(u.counts) as counts FROM
" +
                "(SELECT c.user_id,COUNT(1) as counts FROM collect c LEFT JOIN notice n ON c.id=n.collect_id WHERE c.type='PUBLIC' AND c.is_delete='NO' GROUP BY c.user_id
" +
                "UNION ALL
" +
                "SELECT follow_id,COUNT(1) AS counts FROM follow GROUP BY follow_id)u
" +
                "WHERE u.user_id NOT IN (" + notUserIds + ")
" +
                "GROUP BY u.user_id ORDER BY counts DESC LIMIT 1";
        List<Object[]> objecArraytList = sqlArrayList(querySql);
        Object[] obj =  objecArraytList.get(0);
        return Long.valueOf(obj[0].toString());
    }

    /**
     * 近一个月最活跃用户
     * @param notUserIds
     * @return
     */
    @Override
    public Long getMostActiveUser(String notUserIds) {
        long nowTime = DateUtils.getCurrentTime();
        long lastMonth = DateUtils.getLastMonthTime();
        String querySql = "SELECT u.user_id,SUM(u.counts) as counts FROM
" +
                "(SELECT user_id,COUNT(1) as counts FROM collect WHERE create_time>" + lastMonth + " AND create_time<" + nowTime + " AND type='PUBLIC' AND is_delete='NO' GROUP BY user_id
" +
                "UNION ALL
" +
                "SELECT user_id,COUNT(1) as counts FROM `comment` WHERE create_time>" + lastMonth + " AND create_time<" + nowTime + " GROUP BY user_id
" +
                "UNION ALL
" +
                "SELECT user_id,COUNT(1) as counts FROM praise WHERE create_time>" + lastMonth + " AND create_time<" + nowTime + " GROUP BY user_id
" +
                "UNION ALL
" +
                "SELECT user_id,COUNT(1) as counts FROM follow WHERE create_time>" + lastMonth + " AND create_time<" + nowTime + " GROUP BY user_id)u
" +
                "WHERE u.user_id NOT IN (" + notUserIds + ")
" +
                "GROUP BY u.user_id ORDER BY counts DESC LIMIT 1";
        List<Object[]> objecArraytList = sqlArrayList(querySql);
        Object[] obj =  objecArraytList.get(0);
        return Long.valueOf(obj[0].toString());
    }
}