使用HibernateDaoSupport抽取BaseDao
Posted zeng1994
tags:
篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了使用HibernateDaoSupport抽取BaseDao相关的知识,希望对你有一定的参考价值。
在开发采用Struts2+Spring+hibernate这三大框架的项目时,我们需要一个抽取一个BaseDao。这个Dao里面CRUD都给封装好,后续的其他Dao直接用它的功能就可以。Spring里面有个HibernateDaoSupport的类,这个类需要给他一个SessionFactory。有了SessionFactory后,他就可以做各种操作;最强大的功能是它可以getHibernateTemplate来获取一个HibernateTemplate。有了HibernateTemplate,就有了各种CRUD方法。废话不多说,下面直接看代码
一、BaseDao接口及实现的代码
(1)BaseDao接口的代码
package com.tax.core.dao;
import java.io.Serializable;
import java.util.List;
/**
* BaseDao
* @author ZENG.XIAO.YAN
* @date 2017年6月29日 上午10:36:57
* @version v1.0
*/
public interface BaseDao<T> {
/**
* 新增
* @param entity
*/
public void save(T entity);
/**
* 更新
* @param entity
*/
public void update(T entity);
/**
* 根据id删除
* @param id
*/
public void deleteById(Serializable id);
/**
* 通过id查找
* @param id
* @return 实体
*/
public T findById(Serializable id);
/**
* 查找所有
* @return List集合
*/
public List<T> findAll();
}
45
1
package com.tax.core.dao;
2
import java.io.Serializable;
3
import java.util.List;
4
5
/**
6
* BaseDao
7
* @author ZENG.XIAO.YAN
8
* @date 2017年6月29日 上午10:36:57
9
* @version v1.0
10
*/
11
public interface BaseDao<T> {
12
13
/**
14
* 新增
15
* @param entity
16
*/
17
public void save(T entity);
18
19
/**
20
* 更新
21
* @param entity
22
*/
23
public void update(T entity);
24
25
/**
26
* 根据id删除
27
* @param id
28
*/
29
public void deleteById(Serializable id);
30
31
32
/**
33
* 通过id查找
34
* @param id
35
* @return 实体
36
*/
37
public T findById(Serializable id);
38
39
40
/**
41
* 查找所有
42
* @return List集合
43
*/
44
public List<T> findAll();
45
}
(2)BaseDaoImpl的代码
package com.tax.core.dao.impl;
import java.io.Serializable;
import java.lang.reflect.ParameterizedType;
import java.util.List;
import org.hibernate.HibernateException;
import org.hibernate.Query;
import org.hibernate.Session;
import org.hibernate.SessionFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.orm.hibernate5.support.HibernateDaoSupport;
import com.tax.core.dao.BaseDao;
/**
* BaseDaoImpl
* @author ZENG.XIAO.YAN
* @date 2017年6月29日 下午12:23:16
* @version v1.0
*/
public abstract class BaseDaoImpl<T> extends HibernateDaoSupport implements BaseDao<T> {
private Class<T> clazz;
// 按照类型自动注入SessionFactory; 在实例化的时候,Spring按照形参的类型自动注入
@Autowired
public void setMySessionFactory(SessionFactory sessionFactory){
setSessionFactory(sessionFactory);
}
public BaseDaoImpl() {
//this表示当前被实例化的对象;如UserDaoImpl
ParameterizedType pt = (ParameterizedType)this.getClass().getGenericSuperclass();//BaseDaoImpl<User>
clazz = (Class<T>)pt.getActualTypeArguments()[0];
}
/**
* 获取session
* @return session
*/
public Session getCurrentSession(){
Session session = null;
try {
session = getSessionFactory().getCurrentSession();
} catch (HibernateException e) {
throw new RuntimeException("getCurrentSession error", e);
//session = getSessionFactory().openSession();
}
return session;
}
@Override
public void save(T entity) {
getHibernateTemplate().save(entity);
}
@Override
public void update(T entity) {
getHibernateTemplate().update(entity);
}
@Override
public void deleteById(Serializable id) {
getHibernateTemplate().delete(findById(id));
}
@Override
public T findById(Serializable id) {
return getHibernateTemplate().get(clazz, id);
}
@Override
public List<T> findAll() {
Session session = getCurrentSession();
Query query = session.createQuery("FROM "+ clazz.getSimpleName());
return query.list();
}
}
x
1
package com.tax.core.dao.impl;
2
3
import java.io.Serializable;
4
import java.lang.reflect.ParameterizedType;
5
import java.util.List;
6
import org.hibernate.HibernateException;
7
import org.hibernate.Query;
8
import org.hibernate.Session;
9
import org.hibernate.SessionFactory;
10
import org.springframework.beans.factory.annotation.Autowired;
11
import org.springframework.orm.hibernate5.support.HibernateDaoSupport;
12
13
import com.tax.core.dao.BaseDao;
14
15
/**
16
* BaseDaoImpl
17
* @author ZENG.XIAO.YAN
18
* @date 2017年6月29日 下午12:23:16
19
* @version v1.0
20
*/
21
public abstract class BaseDaoImpl<T> extends HibernateDaoSupport implements BaseDao<T> {
22
23
private Class<T> clazz;
24
25
// 按照类型自动注入SessionFactory; 在实例化的时候,Spring按照形参的类型自动注入
26
27
public void setMySessionFactory(SessionFactory sessionFactory){
28
setSessionFactory(sessionFactory);
29
}
30
31
32
public BaseDaoImpl() {
33
//this表示当前被实例化的对象;如UserDaoImpl
34
ParameterizedType pt = (ParameterizedType)this.getClass().getGenericSuperclass();//BaseDaoImpl<User>
35
clazz = (Class<T>)pt.getActualTypeArguments()[0];
36
}
37
38
/**
39
* 获取session
40
* @return session
41
*/
42
public Session getCurrentSession(){
43
Session session = null;
44
try {
45
session = getSessionFactory().getCurrentSession();
46
} catch (HibernateException e) {
47
throw new RuntimeException("getCurrentSession error", e);
48
//session = getSessionFactory().openSession();
49
}
50
return session;
51
}
52
53
54
public void save(T entity) {
55
getHibernateTemplate().save(entity);
56
}
57
58
59
public void update(T entity) {
60
getHibernateTemplate().update(entity);
61
}
62
63
64
public void deleteById(Serializable id) {
65
getHibernateTemplate().delete(findById(id));
66
}
67
68
69
public T findById(Serializable id) {
70
return getHibernateTemplate().get(clazz, id);
71
}
72
73
public List<T> findAll() {
74
Session session = getCurrentSession();
75
Query query = session.createQuery("FROM "+ clazz.getSimpleName());
76
return query.list();
77
}
78
79
}