j2ee之hibernate工具类

Posted 2020-10-05

package com.newtouch.utils;

import org.hibernate.*;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.orm.hibernate4.support.HibernateDaoSupport;
import org.springframework.stereotype.Component;

import java.io.Serializable;
import java.util.List;

/**
 * 工具类实例化
 *
 * @author 邵欣
 * @version 1.0
 * @project_name Personnel_Management_System
 * @package_name com.newtouch.utils
 * @class_name MyJdbcUtils
 * @company 新致软件
 * @time 2017年9月2日 上午10:30:10
 */
@Component("myJdbcUtils")
public class MyJdbcUtils extends HibernateDaoSupport {
    /**
     * 属性
     *
     * @param sessionFactory void
     * @author 邵欣
     * @time 2017年9月2日上午10:30:25
     */
    @Autowired
    public void setSessionFactoryOverride(SessionFactory sessionFactory) {
        super.setSessionFactory(sessionFactory);
    }

    /**
     * 保存或者修改这个对象所包含的数据
     *
     * @param entity void
     * @author 邵欣
     * @time 2017年9月2日下午8:57:23
     */
    public void saveOrUpdate(Object entity) {
        Session session = null;
        Transaction ts = null;
        try {
            session = this.getHibernateTemplate().getSessionFactory().openSession();
            ts = session.beginTransaction();
            session.saveOrUpdate(entity);
            ts.commit();
        } catch (Exception e) {
            e.printStackTrace();
            ts.rollback();
        } finally {
            session.close();
        }
    }

    /**
     * 查询一组数据
     *
     * @param sql
     * @param obj
     * @return List<?>
     * @author 邵欣
     * @time 2017年9月2日下午9:02:08
     */
    @SuppressWarnings("unchecked")
    public <T> List<T> find(String sql, Object... values) {
        Session session = this.getHibernateTemplate().getSessionFactory().openSession();
        Query queryObject = session.createQuery(sql);
        if (values != null) {
            for (int i = 0; i < values.length; i++) {
                queryObject.setParameter(i, values[i]);
            }
        }
        return queryObject.list();
    }

    /**
     * 查找指定的一条数据
     *
     * @param sql
     * @param obj
     * @return T
     * @author 邵欣
     * @time 2017年9月2日下午9:14:59
     */
    @SuppressWarnings("unchecked")
    public <T> T findAEntity(String sql, Object... values) {
        Session session = this.getHibernateTemplate().getSessionFactory().openSession();
        Query queryObject = session.createQuery(sql);
        if (values != null) {
            for (int i = 0; i < values.length; i++) {
                queryObject.setParameter(i, values[i]);
            }
        }
        List<T> list = queryObject.list();
        if (list.size() > 0) {
            return (T) list.get(0);
        } else {
            System.out.println("数据库中没有这条数据");
            return null;
        }
    }

    /**
     * 根据id查找对象
     *
     * @param clazz
     * @param id
     * @return T
     * @author 邵欣
     * @time 2017年9月2日下午9:14:22
     */
    public <T> T get(Class<T> clazz, Serializable id) {
        return this.getHibernateTemplate().get(clazz, id);
    }

    /**
     * 分页查询的数据
     *
     * @param sql
     * @param startNumber
     * @param pageCount
     * @return List<T>
     * @author 邵欣
     * @time 2017年9月2日下午9:41:03
     */
    @SuppressWarnings("unchecked")
    public <T> List<T> pageSelect(String sql, int startNumber, int pageCount) {
        Session session = this.getHibernateTemplate().getSessionFactory().openSession();
        Query query = session.createQuery(sql);
        query.setFirstResult(startNumber);
        query.setMaxResults(pageCount);
        return query.list();
    }

    /**
     * 分页查询的总行数
     *
     * @param sql
     * @param startNumber
     * @param pageCount
     * @return int
     * @author 邵欣
     * @time 2017年9月2日下午9:40:49
     */
    public int totalPageCount(String sql, int startNumber, int pageCount) {
        Session session = this.getHibernateTemplate().getSessionFactory().openSession();
        Query query = session.createQuery(sql);
        ScrollableResults scroll = query.scroll();
        scroll.last();
        int totalCount = scroll.getRowNumber() + 1;
        return totalCount;
    }

    /**
     * 删除一条数据（不建议使用）
     *
     * @param object void
     * @author 邵欣
     * @time 2017年9月2日下午10:02:09
     */
    public void delete(Object object) {
        Session session = this.getHibernateTemplate().getSessionFactory().openSession();
        Transaction tx = session.beginTransaction();
        session.delete(object);
        tx.commit();
        session.close();
    }


}