学步园

         以前写的一个改进版泛型dao,在这里
。基本实现了0代码编写dao。现在又加入了spring jdbc的支持，使得dao即可以用实体对象进行数据存取，有可以用jdbc的底层化操作删除，更新。结构见图：

具体代码和上图对应:

DaoTest.java

package com.test;<br /> import javax.annotation.Resource;<br /> import org.junit.Test;<br /> import org.junit.runner.RunWith;<br /> import org.springframework.test.context.ContextConfiguration;<br /> import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;<br /> import com.hibernate.entityclass.Daotest;<br /> import com.tinylight.dao.base.IBaseDao;<br /> @RunWith(SpringJUnit4ClassRunner.class)<br /> @ContextConfiguration(locations = {"classpath:applicationContext.xml"})<br /> public class DaoTest {</p> <p> @Resource(name="demoDao")<br /> private IBaseDao<Daotest,Integer> demoDao;</p> <p> @Test<br /> public void test(){</p> <p> }<br /> }<br />

BaseDao.java

/**<br /> *<br /> */<br /> package com.tinylight.dao.base;<br /> import java.io.Serializable;<br /> import java.util.Iterator;<br /> import java.util.List;<br /> import org.hibernate.Query;<br /> import org.hibernate.SQLQuery;<br /> import org.hibernate.Session;<br /> import org.hibernate.StatelessSession;<br /> import org.springframework.orm.hibernate3.HibernateTemplate;<br /> import com.tinylight.dao.hibernate.GenericDao;<br /> import com.tinylight.dao.hibernate.GenericEntityDao;<br /> import com.tinylight.dao.jdbc.SimpleJdbcDao;<br /> import com.tinylight.dao.support.Page;<br /> /**<br /> * @author scott.Cgi<br /> * @since 2009-5-12<br /> * 提供dao的所有操作<br><br /> * 实现类由spring注入:<br><br /> * {@link com.tinylight.dao.hibernate.GenericEntityDao}<br /> * {@link com.tinylight.dao.hibernate.GenericDao}<br /> * {@link com.tinylight.dao.jdbc.SimpleJdbcDao}<br /> */<br /> public class BaseDao<T,PK extends Serializable> implements IBaseDao<T,PK>{<br /> protected Class<T> entityClass;// DAO所管理的Entity类型.<br /> private GenericEntityDao<T,PK> gedao;<br /> private GenericDao gdao;<br /> private SimpleJdbcDao sjdao;</p> <p> public Class<T> getEntityClass() {return entityClass;}<br /> public void setEntityClass(Class<T> entityClass) {this.entityClass = entityClass;}</p> <p> public GenericEntityDao<T, PK> getGedao() {return gedao;}<br /> public void setGedao(GenericEntityDao<T, PK> gedao) {this.gedao = gedao;}</p> <p> public GenericDao getGdao() {return gdao;}<br /> public void setGdao(GenericDao gdao) {this.gdao = gdao;}</p> <p> public SimpleJdbcDao getSjdao() {return sjdao;}<br /> public void setSjdao(SimpleJdbcDao sjdao) {this.sjdao = sjdao;}<br /> /**<br /> *让spring提供构造函数注入<br /> */<br /> public BaseDao(Class<T> type) {<br /> this.entityClass = type;<br /> }</p> <p> public BaseDao(){}</p> <p> public void clear() {<br /> gdao.clear();<br /> }</p> <p> public Query createQuery(String hql, Object... values) {<br /> return gdao.createQuery(hql, values);<br /> }</p> <p> public void delete(T entityObject) {<br /> gedao.delete(entityObject);<br /> }</p> <p> public void deleteById(PK id) {<br /> gedao.deleteById(id);<br /> }</p> <p> public void evict(T entityObject) {<br /> gedao.evict(entityObject);<br /> }</p> <p> public List<T> find(String hql, Object... values) {<br /> return gdao.find(hql, values);<br /> }</p> <p> public List<T> findByNamedParams(String hql, String[] paramNames,<br /> Object... values) {<br /> return gdao.findByNamedParams(hql, paramNames, values);<br /> }</p> <p> public void flush() {<br /> gdao.flush();<br /> }</p> <p> public List<T> getAll() {<br /> return gedao.getAll();<br /> }</p> <p> public T getById(PK id) {<br /> return gedao.getById(id);<br /> }</p> <p> public Session getNativeHibernateSession() {<br /> return gdao.getNativeHibernateSession();<br /> }</p> <p> public StatelessSession getNativeStatelessHibernateSession() {<br /> return gdao.getNativeStatelessHibernateSession();<br /> }</p> <p> public HibernateTemplate getSpringHibernateTemplate() {<br /> return gdao.getSpringHibernateTemplate();<br /> }</p> <p> public Iterator<T> iterator(String hql, Object... values) {<br /> return gdao.iterator(hql, values);<br /> }</p> <p> public SimpleJdbcDao jdbc() {<br /> return sjdao;<br /> }</p> <p> public T load(PK id) {<br /> return gedao.load(id);<br /> }</p> <p> public void load(T entityObject, PK id) {<br /> gedao.load(entityObject, id);<br /> }</p> <p> public T merge(T entityObject) {<br /> return gedao.merge(entityObject);<br /> }</p> <p> public SQLQuery nativeSqlQuery(String sql) {<br /> return gdao.nativeSqlQuery(sql);<br /> }</p> <p> public Page<T> pagedQuery(String countHql,String hql, int pageNo, int pageSize,<br /> Object... values) {<br /> return gdao.pagedQuery(countHql,hql, pageNo, pageSize, values);<br /> }</p> <p> public Page<T> pagedQueryByStartNo(String countHql,String hql, int startNo, int pageSize,<br /> Object... values) {<br /> return gdao.pagedQueryByStartNo(countHql,hql, startNo, pageSize, values);<br /> }</p> <p> public void refresh(T entityObject) {<br /> gedao.refresh(entityObject);<br /> }</p> <p> public void save(T entityObject) {<br /> gedao.save(entityObject);<br /> }</p> <p>}<br />

IBaseDao.java

/**<br /> *<br /> */<br /> package com.tinylight.dao.base;<br /> import java.io.Serializable;<br /> import java.util.Iterator;<br /> import java.util.List;<br /> import org.hibernate.Query;<br /> import org.hibernate.SQLQuery;<br /> import org.hibernate.Session;<br /> import org.hibernate.StatelessSession;<br /> import org.springframework.orm.hibernate3.HibernateTemplate;<br /> import com.tinylight.dao.jdbc.SimpleJdbcDao;<br /> import com.tinylight.dao.support.Page;<br /> /**<br /> * @author scott.Cgi<br /> * @since 2009-5-12<br /> *<br /> */<br /> public interface IBaseDao<T,PK extends Serializable> {<br /> /**<br /> * 根据主键类型的id获取实体对象,立即执行查询返回对象,数据库没有匹配则返回null<br /> */<br /> public T getById(PK id);</p> <p> /**<br /> * 获取实体类型的全部对象<br /> */<br /> public List<T> getAll();</p> <p> /**<br /> * 获取实体对象的代理,如果数据库没有匹配则异常,实体类有关联其它对象则延时加载<br /> * @param id<br /> * @return<br /> */<br /> public T load(PK id);</p> <p> /**<br /> * 把数据加载到指定的非持久化实例上<br /> * @param entityObject<br /> * @param id<br /> */<br /> public void load(T entityObject,PK id);</p> <p> /**<br /> * 删除对象.<br /> */<br /> public void delete(T entityObject);</p> <p> /**<br /> * 根据id删除对象<br /> * @param id<br /> */<br /> public void deleteById(PK id);</p> <p> /**<br /> * 强迫装载对象和它的集合,使用了触发器的数据字段比较适合使用<br /> * @param entityObject<br /> */<br /> public void refresh(T entityObject);</p> <p> /**<br /> * 消除与 Hibernate Session 的关联<br /> * @param entityObject<br /> */<br /> public void evict(T entityObject);</p> <p> /**<br /> * 保存对象.<br><br /> * 如果对象已在本session中持久化了,不做任何事。<br><br /> * 如果另一个seesion拥有相同的持久化标识,抛出异常。<br><br /> * 如果没有持久化标识属性,调用save()。<br><br /> * 如果持久化标识表明是一个新的实例化对象,调用save()。<br><br /> * 如果是附带版本信息的(version或timestamp)且版本属性表明为新的实例化对象就save()。<br><br /> * 否则调用update()重新关联托管对象<br /> * @param entityObject<br /> */<br /> public void save(T entityObject);</p> <p> /**<br /> * 如果对象已在本session中持久化了,覆盖原有的<br><br /> * 如果session中没有对应对象,从数据库加载<br><br /> * 如果是脱管对象,则什么都不做<br /> * @param entityObject<br /> * @return<br /> */<br /> public T merge(T entityObject);</p> <p> /**<br /> * 根据hql查询,直接使用HibernateTemplate的find函数.<br /> * @param <T><br /> * @param hql<br /> * @param values<br /> * @return<br /> */<br /> public List<T> find(String hql, Object... values);</p> <p> /**<br /> * 根据命名参数查询<br /> * @param <T><br /> * @param hql 带有命名参数的hql语句<br /> * @param paramNames 命名参数的名字<br /> * @param values 命名参数的值<br><br /> * <b>例如:</b><br><br /> * findByNamedParams("from Test where t1 = :t",new String[]{"t"},tValue);<br /> * @return<br /> */<br /> public List<T> findByNamedParams(String hql,String[] paramNames,Object...values);</p> <p> /**<br /> * 创建Query对象.<br><br /> * 对于需要first,max,fetchsize,cache,cacheRegion等诸多设置的函数,可以在返回Query后自行设置.<br /> * @param hql<br /> * @param values<br /> * @return<br /> */<br /> public Query createQuery(String hql,Object... values);</p> <p> /**<br /> * 执行一些必须的sql语句把内存中的对象同步到数据库中<br /> */<br /> public void flush();</p> <p> /**<br /> * 清除对象缓存<br /> */<br /> public void clear();</p> <p> /**<br /> * 返回iterator接口类型的结果<br /> * @param <T><br /> * @param hql<br /> * @param values<br /> * @return<br /> */<br /> public Iterator<T> iterator(String hql,Object...values);</p> <p> /**<br /> * @return 当前上下文的原生Hibernate session对象,依然受到spring事务管理不需要手动close<br /> */<br /> public Session getNativeHibernateSession();</p> <p> /**<br /> * @return 当前上下文的原生Hibernate StatelessSession对象<br><br /> * 此对象不级联关联实例,忽略集合不触发Hibernate事件模型和拦截器,没有一级缓存,没有持久化上下文,接近JDBC.<br /> */<br /> public StatelessSession getNativeStatelessHibernateSession();</p> <p> /**<br /> * 执行本地查询获得SQLQuery对象<br><br /> * 可以调用addEntity(*.class).list();获得对应实体list集合<br><br /> * addEntity.add(*.class).addJoin(*.class).list();获得一对多代理对象<br><br /> * 更多用法见google<br /> * @param sql<br /> * @return<br /> */<br /> public SQLQuery nativeSqlQuery(String sql);</p> <p> /**<br /> * @param <T><br /> * @param countHql 计算数据总条数的hql语句(就是带count(*)的hql)<br /> * @param hql<br /> * @param pageNo 页面号<br /> * @param pageSize 页面容量<br /> * @param values<br /> * @return<br /> */<br /> public Page<T> pagedQuery(String countHql,String hql, int pageNo, int pageSize, Object... values);</p> <p> /**<br /> * @param <T><br /> * @param countHql 计算数据总条数的hql语句(就是带count(*)的hql)<br /> * @param hql<br /> * @param startNo 分页从哪一条数据开始<br /> * @param pageSize 页面容量<br /> * @param values<br /> * @return<br /> */<br /> public Page<T> pagedQueryByStartNo(String countHql,String hql, int startNo, int pageSize, Object... values);</p> <p> /**<br /> * @return 获得spring的HibernateTemplate拥有更多的功能<br /> */<br /> public HibernateTemplate getSpringHibernateTemplate();</p> <p> /**<br /> * @return 获得jdbc操作的超绚酷dao<br /> */<br /> public SimpleJdbcDao jdbc();<br /> }<br />

GenericDao.java

/**<br /> *<br /> */<br /> package com.tinylight.dao.hibernate;<br /> import java.util.Iterator;<br /> import java.util.List;<br /> import org.hibernate.Query;<br /> import org.hibernate.SQLQuery;<br /> import org.hibernate.Session;<br /> import org.hibernate.StatelessSession;<br /> import org.springframework.orm.hibernate3.HibernateTemplate;<br /> import org.springframework.orm.hibernate3.support.HibernateDaoSupport;<br /> import com.tinylight.dao.support.Page;<br /> /**<br /> * 继承自spring的HibernateDaoSupport<br><br /> * 提供了和具体实体类无关的数据库操作<br /> * @author scott.Cgi<br /> * @since 2009-5-10<br /> *<br /> */<br /> public class GenericDao extends HibernateDaoSupport {</p> <p> /**<br /> * 根据hql查询,直接使用HibernateTemplate的find函数.<br /> * @param <T><br /> * @param hql<br /> * @param values<br /> * @return<br /> */<br /> @SuppressWarnings("unchecked")<br /> public <T> List<T> find(String hql, Object... values) {<br /> return this.getHibernateTemplate().find(hql, values);<br /> }</p> <p> /**<br /> * 根据命名参数查询<br /> * @param <T><br /> * @param hql 带有命名参数的hql语句<br /> * @param paramNames 命名参数的名字<br /> * @param values 命名参数的值<br><br /> * <b>例如:</b><br><br /> * findByNamedParams("from Test where t1 = :t",new String[]{"t"},tValue);<br /> * @return<br /> */<br /> @SuppressWarnings("unchecked")<br /> public <T> List<T> findByNamedParams(String hql,String[] paramNames,Object...values){<br /> return this.getHibernateTemplate().findByNamedParam(hql, paramNames, values);<br /> }</p> <p> /**<br /> * 创建Query对象.<br><br /> * 对于需要first,max,fetchsize,cache,cacheRegion等诸多设置的函数,可以在返回Query后自行设置.<br /> * @param hql<br /> * @param values<br /> * @return<br /> */<br /> public Query createQuery(String hql,Object... values) {<br /> //这里的false表示不创建session保证,当前操作在spring同一个事务的管理下<br /> Query query = this.getSession(false).createQuery(hql);<br /> if (values != null) {<br /> for (int i = 0; i < values.length; i++) {<br /> query.setParameter(i, values[i]);<br /> }<br /> }<br /> return query;<br /> }</p> <p> /**<br /> * 执行一些必须的sql语句把内存中的对象同步到数据库中<br /> */<br /> public void flush() {<br /> this.getHibernateTemplate().flush();<br /> }</p> <p> /**<br /> * 清除对象缓存<br /> */<br /> public void clear() {<br /> this.getHibernateTemplate().clear();<br /> }</p> <p> /**<br /> * 返回iterator接口类型的结果<br /> * @param <T><br /> * @param hql<br /> * @param values<br /> * @return<br /> */<br /> @SuppressWarnings("unchecked")<br /> public <T> Iterator<T> iterator(String hql,Object...values){<br /> return this.getHibernateTemplate().iterate(hql, values);<br /> }</p> <p> /**<br /> * @return 当前上下文的原生Hibernate session对象,依然受到spring事务管理不需要手动close<br /> */<br /> public Session getNativeHibernateSession(){<br /> return this.getSessionFactory().getCurrentSession();<br /> }</p> <p> /**<br /> * @return 当前上下文的原生Hibernate StatelessSession对象<br><br /> * 此对象不级联关联实例,忽略集合不触发Hibernate事件模型和拦截器,没有一级缓存,没有持久化上下文,接近JDBC.<br /> */<br /> public StatelessSession getNativeStatelessHibernateSession(){<br /> return this.getSessionFactory().openStatelessSession();<br /> }</p> <p> /**<br /> * 执行本地查询获得SQLQuery对象<br><br /> * 可以调用addEntity(*.class).list();获得对应实体list集合<br><br /> * addEntity.add(*.class).addJoin(*.class).list();获得一对多代理对象<br><br /> * 更多用法见google<br /> * @param sql<br /> * @return<br /> */<br /> public SQLQuery nativeSqlQuery(String sql){<br /> return this.getSession(false).createSQLQuery(sql);<br /> }</p> <p> /**<br /> * @param <T><br /> * @param countHql 计算数据总条数的hql语句(就是带count(*)的hql)<br /> * @param hql<br /> * @param pageNo 页面号<br /> * @param pageSize 页面容量<br /> * @param values<br /> * @return<br /> */<br /> @SuppressWarnings("unchecked")<br /> public <T> Page<T> pagedQuery(String countHql,String hql, int pageNo, int pageSize, Object... values) {<br /> // Count查询<br /> List<T> countlist = this.getHibernateTemplate().find(countHql, values);<br /> long totalCount = (Long) countlist.get(0);<br /> if (totalCount < 1)<br /> return new Page<T>();<br /> // 当前页的开始数据索引<br /> long startIndex = Page.getStartOfPage(pageNo, pageSize);<br /> Query query = this.createQuery(hql, values);<br /> List<T> list = query.setFirstResult((int) startIndex).setMaxResults(pageSize).list();<br /> return new Page<T>(startIndex, totalCount, pageSize, list);<br /> }</p> <p> /**<br /> * @param <T><br /> * @param countHql 计算数据总条数的hql语句(就是带count(*)的hql)<br /> * @param hql<br /> * @param startNo 分页从哪一条数据开始<br /> * @param pageSize 页面容量<br /> * @param values<br /> * @return<br /> */<br /> @SuppressWarnings("unchecked")<br /> public <T> Page<T> pagedQueryByStartNo(String countHql,String hql, int startNo, int pageSize, Object... values){<br /> // Count查询<br /> List<T> countlist = getHibernateTemplate().find(countHql, values);<br /> long totalCount = (Long) countlist.get(0);<br /> if (totalCount < 1)<br /> return new Page();</p> <p> int startIndex = startNo;<br /> Query query = createQuery(hql, values);<br /> List<T> list = query.setFirstResult(startIndex).setMaxResults(pageSize).list();<br /> return new Page<T>(startIndex, totalCount, pageSize, list);<br /> }</p> <p> /**<br /> * @return 获得spring的HibernateTemplate拥有更多的功能<br /> */<br /> public HibernateTemplate getSpringHibernateTemplate(){<br /> return this.getHibernateTemplate();<br /> }<br /> }<br />

GenericEntityDao.java

/**<br /> *<br /> */<br /> package com.tinylight.dao.hibernate;<br /> import java.io.Serializable;<br /> import java.util.List;<br /> import org.springframework.orm.hibernate3.support.HibernateDaoSupport;<br /> /**<br /> * 负责为单个Entity对象提供CRUD操作的Hibernate DAO基类.<br><br /> * 子类只要在类定义时指定所管理Entity的Class<br><br /> * 即拥有对单个Entity对象的CRUD操作.<br /> * @author scott.Cgi<br /> * @since 2009-5-11<br /> *<br /> */<br /> public class GenericEntityDao<T,PK extends Serializable> extends HibernateDaoSupport {</p> <p> protected Class<T> entityClass;// DAO所管理的Entity类型.<br /> public void setEntityClass(Class<T> type){//注入实体类型<br /> this.entityClass=type;<br /> }<br /> public Class<T> getEntityClass(){<br /> return this.entityClass;<br /> }</p> <p> public GenericEntityDao(){}<br /> public GenericEntityDao(Class<T> entityClass){this.entityClass = entityClass;}<br /> /**<br /> * 根据主键类型的id获取实体对象,立即执行查询返回对象,数据库没有匹配则返回null<br /> */<br /> @SuppressWarnings("unchecked")<br /> public T getById(PK id) {<br /> return (T)this.getHibernateTemplate().get(this.entityClass, id);<br /> }</p> <p> /**<br /> * 获取实体类型的全部对象<br /> */<br /> @SuppressWarnings("unchecked")<br /> public List<T> getAll() {<br /> return (List<T>)(this.getHibernateTemplate().loadAll(this.entityClass));<br /> }</p> <p> /**<br /> * 获取实体对象的代理,如果数据库没有匹配则异常,实体类有关联其它对象则延时加载<br /> * @param id<br /> * @return<br /> */<br /> @SuppressWarnings("unchecked")<br /> public T load(PK id){<br /> return (T)this.getHibernateTemplate().load(this.entityClass, id);<br /> }</p> <p> /**<br /> * 把数据加载到指定的非持久化实例上<br /> * @param entityObject<br /> * @param id<br /> */<br /> public void load(T entityObject,PK id){<br /> this.getHibernateTemplate().load(entityObject, id);<br /> }</p> <p> /**<br /> * 删除对象.<br /> */<br /> public void delete(T entityObject) {<br /> this.getHibernateTemplate().delete(entityObject);<br /> }</p> <p> /**<br /> * 根据id删除对象<br /> * @param id<br /> */<br /> public void deleteById(PK id){<br /> this.delete(this.getById(id));<br /> }</p> <p> /**<br /> * 强迫装载对象和它的集合,使用了触发器的数据字段比较适合使用<br /> * @param entityObject<br /> */<br /> public void refresh(T entityObject){<br /> this.getHibernateTemplate().refresh(entityObject);<br /> }</p> <p> /**<br /> * 消除与 Hibernate Session 的关联<br /> * @param entityObject<br /> */<br /> public void evict(T entityObject){<br /> this.getHibernateTemplate().evict(entityObject);<br /> }</p> <p> /**<br /> * 保存对象.<br><br /> * 如果对象已在本session中持久化了,不做任何事。<br><br /> * 如果另一个seesion拥有相同的持久化标识,抛出异常。<br><br /> * 如果没有持久化标识属性,调用save()。<br><br /> * 如果持久化标识表明是一个新的实例化对象,调用save()。<br><br /> * 如果是附带版本信息的(version或timestamp)且版本属性表明为新的实例化对象就save()。<br><br /> * 否则调用update()重新关联托管对象<br /> * @param entityObject<br /> */<br /> public void save(T entityObject){<br /> this.getHibernateTemplate().saveOrUpdate(entityObject);<br /> } </p> <p> /**<br /> * 如果对象已在本session中持久化了,覆盖原有的<br><br /> * 如果session中没有对应对象,从数据库加载<br><br /> * 如果是脱管对象,则什么都不做<br /> * @param entityObject<br /> * @return<br /> */<br /> @SuppressWarnings("unchecked")<br /> public T merge(T entityObject){<br /> return (T)this.getHibernateTemplate().merge(entityObject);<br /> }</p> <p>}<br />

SimpleJdbcDao.java

/**<br /> *<br /> */<br /> package com.tinylight.dao.jdbc;<br /> import java.sql.Connection;<br /> import java.sql.SQLException;<br /> import org.springframework.jdbc.core.JdbcTemplate;<br /> import org.springframework.jdbc.core.namedparam.SqlParameterSource;<br /> import org.springframework.jdbc.core.simple.SimpleJdbcDaoSupport;<br /> import org.springframework.jdbc.core.simple.SimpleJdbcTemplate;<br /> import org.springframework.jdbc.datasource.DataSourceUtils;<br /> import org.springframework.jdbc.support.GeneratedKeyHolder;<br /> import org.springframework.jdbc.support.KeyHolder;<br /> import org.springframework.jdbc.support.rowset.SqlRowSet;<br /> /**<br /> * 继承spring的SimpleJdbcDaoSupport<br /> * 提供对数据库jdbc级别的操作<br /> * 内部使用spring的SimpleJdbcTemplate与JdbcTemplate<br /> * @author scott.Cgi<br /> * @since 2009-5-7<br /> */<br /> public class SimpleJdbcDao extends SimpleJdbcDaoSupport {</p> <p> /**<br /> * 提供对表的更改和删除操作<br /> * @param sql 要执行的sql语句<br /> * @param args 变参<br /> * @return 影响的行数<br /> */<br /> public int update(String sql,Object...args){<br /> return this.getSimpleJdbcTemplate().update(sql, args);<br /> }</p> <p> /**<br /> * 批量更新多条记录<br /> * @param sql 多条sql组成的数组(不带参数的)<br /> * @see 带参数的见: <br><br /> * getJdbcTemplate().batchUpdate(String[] sql,BatchPreparedStatementSetter pss)<br /> * @return 影响行数数组<br /> */<br /> public int[] batchUpdate(String[] sql){<br /> return this.getJdbcTemplate().batchUpdate(sql);<br /> }</p> <p> /**<br /> * 获取行数<br /> * @param countSql 计算行数的sql语句<br /> * @return<br /> */<br /> public long countRows(String countSql){<br /> return this.getJdbcTemplate().queryForLong(countSql);<br /> }</p> <p> /**<br /> * 获取本地的Connection对象<br /> * @return<br /> */<br /> public Connection getNativeConn(){</p> <p> //从当前线程绑定的数据连接获取连接<br /> Connection conn = DataSourceUtils.getConnection(this.getJdbcTemplate().getDataSource());<br /> try {<br /> conn = this.getJdbcTemplate().getNativeJdbcExtractor().getNativeConnection(conn);<br /> } catch (SQLException e) {<br /> e.printStackTrace();<br /> return null;<br /> }</p> <p> return conn;<br /> }</p> <p> /**<br /> * 获得断开数据库连接的行集,大结果集会消耗内存,受到maxSize的限制<br /> * @param sql 要执行的sql语句带?占位符<br /> * @param params 填充占位符的数组<br /> * @param types 填充参数类型(java.sql.Types中的常量)<br /> * 例如:new int[]{Types.VARCHAR,Types.DATE}<br /> * @return 影响的行数<br><br /> * <b>注:</b> params和types同时为空,sql为不带?占位符;仅仅types为空时,由spring去猜测类型<br /> */<br /> public SqlRowSet queryForRowSet(String sql,Object[] params,int[] types){</p> <p> if(params != null && types != null){<br /> return this.getJdbcTemplate().queryForRowSet(sql, params, types);<br /> }else if(params != null && types == null){<br /> return this.getJdbcTemplate().queryForRowSet(sql, params);<br /> }else {<br /> return this.getJdbcTemplate().queryForRowSet(sql);<br /> }<br /> }</p> <p> /**<br /> * 提供对表的更改和删除操作<br /> * @param hql 使用了命名参数的sql语句<br /> * @param sps 例如:<br><br /> * new BeanPropertySqlParamterSource(javaBean其属性要和命名参数对应);<br><br /> * new MapSqlParameterSource().add("命名参数",参数对应的值).add()...可以链式调用<br /> * @return KeyHolder主键持有者对象;如果是新增数据,KeyHolder持有新增的主键值<br><br /> * 有3个方法可调用:<br>getKey()一个数字主键<br><br /> * getKeys()复合主键Map结构<br><br /> * getKeyList()多个主键由多个Map组成的List<br /> */<br /> public KeyHolder updateNamedParamer(String hql,SqlParameterSource sps){<br /> KeyHolder keyHolder = new GeneratedKeyHolder();<br /> this.getSimpleJdbcTemplate().getNamedParameterJdbcOperations().update(hql, sps, keyHolder);<br /> return keyHolder;<br /> }</p> <p> /**<br /> * 执行sql语句,如创建表等<br /> * @param sql<br /> */<br /> public void executeSql(String sql){<br /> this.getJdbcTemplate().execute(sql);<br /> }</p> <p> /**<br /> * @return 获得spring的JdbcTemplate使用更多功能<br /> */<br /> public JdbcTemplate getSpringJdbcTemplate(){<br /> return this.getJdbcTemplate();<br /> }</p> <p> /**<br /> * 引入jdk5.0语法的JdbcTemplate的简化版本<br /> * @return 获得spring的SimpleJdbcTemplate使用更多功能<br /> */<br /> public SimpleJdbcTemplate getSpringSimplaJdbcTemplate(){<br /> return this.getSimpleJdbcTemplate();<br /> }<br /> }<br />

Page.java

package com.tinylight.dao.support;<br /> import java.io.Serializable;<br /> import java.util.Collections;<br /> import java.util.List;<br /> /**<br /> * 分页对象.包含当前页数据及分页信息如总记录数.<br /> *<br /> * @author scott.Cgi<br /> * @since 2008-6-29<br /> */<br /> public class Page<T> implements Serializable {<br /> private static final long serialVersionUID = -5624189033006412710L;<br /> private static long DEFAULT_PAGE_SIZE = 20;<br /> private long pageSize = DEFAULT_PAGE_SIZE; // 每页的记录数<br /> private long start; // 当前页第一条数据在List中的位置,从0开始<br /> private List<T> data = Collections.emptyList(); // 当前页中存放的记录<br /> private long totalCount = 0; // 总记录数<br /> /**<br /> * 构造方法，只构造空页.<br /> */<br /> public Page() {<br /> this(0l, 0l, DEFAULT_PAGE_SIZE, Collections.<T>emptyList());<br /> }<br /> /**<br /> * 默认构造方法.<br /> *<br /> * @param start 本页数据在数据库中的起始位置<br /> * @param totalSize 数据库中总记录条数<br /> * @param pageSize 本页容量<br /> * @param data 本页包含的数据<br /> */<br /> public Page(long start, long totalSize, long pageSize, List<T> data) {<br /> this.pageSize = pageSize;<br /> this.start = start;<br /> this.totalCount = totalSize;<br /> this.data = data;<br /> }<br /> /**<br /> * 取总记录数.<br /> */<br /> public long getTotalCount() {<br /> return this.totalCount;<br /> }<br /> /**<br /> * 取总页数.<br /> */<br /> public long getTotalPageCount() {<br /> if (totalCount % pageSize == 0)<br /> return totalCount / pageSize;<br /> else<br /> return totalCount / pageSize + 1;<br /> }<br /> /**<br /> * 取每页数据容量.<br /> */<br /> public Long getPageSize() {<br /> return pageSize;<br /> }<br /> /**<br /> * 取当前页中的记录.<br /> */<br /> public List<T> getResult() {<br /> return data;<br /> }<br /> /**<br /> * 取该页当前页码,页码从1开始.<br /> */<br /> public long getCurrentPageNo() {<br /> return start / pageSize + 1;<br /> }<br /> /**<br /> * 该页是否有下一页.<br /> */<br /> public boolean hasNextPage() {<br /> return this.getCurrentPageNo() < this.getTotalPageCount();<br /> }<br /> /**<br /> * 该页是否有上一页.<br /> */<br /> public boolean hasPreviousPage() {<br /> return this.getCurrentPageNo() > 1;<br /> }<br /> /**<br /> * 获取任一页第一条数据在数据集的位置，每页条数使用默认值.<br /> *<br /> */<br /> protected static long getStartOfPage(long pageNo) {<br /> return getStartOfPage(pageNo, DEFAULT_PAGE_SIZE);<br /> }<br /> /**<br /> * 获取任一页第一条数据在数据集的位置.<br /> *<br /> * @param pageNo 从1开始的页号<br /> * @param pageSize 每页记录条数<br /> * @return 该页第一条数据<br /> */<br /> public static long getStartOfPage(long pageNo, long pageSize) {<br /> return (pageNo - 1) * pageSize;<br /> }<br /> }
 

applicationContext-annotation.xml

<?xml version="1.0" encoding="UTF-8" ?><br /> <beans xmlns="http://www.springframework.org/schema/beans"<br /> xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"<br /> xmlns:dwr="http://www.directwebremoting.org/schema/spring-dwr"<br /> xmlns:context="http://www.springframework.org/schema/context"<br /> xmlns:aop="http://www.springframework.org/schema/aop"<br /> xsi:schemaLocation="http://www.springframework.org/schema/beans </p> <p>http://www.springframework.org/schema/beans/spring-beans-2.5.xsd</p> <p>http://www.springframework.org/schema/context</p> <p>http://www.springframework.org/schema/context/spring-context-2.5.xsd</p> <p>http://www.directwebremoting.org/schema/spring-dwr</p> <p>http://www.directwebremoting.org/schema/spring-dwr-2.0.xsd</p> <p>http://www.springframework.org/schema/aop</p> <p> http://www.springframework.org/schema/aop/spring-aop-2.5.xsd"></p> <p> <context:annotation-config/><br /> </beans><br />

applicationContext-list.xml

<?xml version="1.0" encoding="UTF-8"?><br /> <beans xmlns="http://www.springframework.org/schema/beans" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"<br /> xmlns:jee="http://www.springframework.org/schema/jee" xmlns:tx="http://www.springframework.org/schema/tx"<br /> xmlns:context="http://www.springframework.org/schema/context"<br /> xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-2.5.xsd http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-2.5.xsd http://www.springframework.org/schema/jee http://www.springframework.org/schema/jee/spring-jee-2.5.xsd http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-2.5.xsd"><br /> <description>导入applicationContext文件列表,可随时通过注释disable不需要的模块</description><br /> <!-- 导入spring aop配置文件 --><br /> <import resource="applicationContext-tx.xml" /><br /> <!-- 导入spring dao配置文件 --><br /> <import resource="tinylight-dao.xml" /></p> <p></beans>

applicationContext-tx.xml

<?xml version="1.0" encoding="UTF-8"?><br /> <!-- 使用aop/tx命名空间 --><br /> <beans xmlns="http://www.springframework.org/schema/beans"<br /> xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"<br /> xmlns:aop="http://www.springframework.org/schema/aop"<br /> xmlns:tx="http://www.springframework.org/schema/tx"<br /> xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd<br /> http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop.xsd<br /> http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx.xsd"><br /> <!-- 配置事务管理器bean,使用HibernateTransactionManager事务管理器 --><br /> <bean id="txManager"<br /> class="org.springframework.orm.hibernate3.HibernateTransactionManager"><br /> <!-- 为事务管理器注入sessionFactory" --><br /> <property name="sessionFactory"><br /> <ref bean="sessionFactory" /><br /> </property><br /> </bean><br /> <!-- 通过aop定义事务增强切面 --><br /> <aop:config><br /> <!-- 使用强大的切点表达式语言轻松定义目标方法 --><br /> <aop:pointcut id="serviceMethod"<br /> expression="execution(* com.tinylight.dao.base.IBaseDao.*(..))" /><br /> <!-- 引用事务增强 --><br /> <aop:advisor pointcut-ref="serviceMethod" advice-ref="txAdvice" /><br /> </aop:config><br /> <!-- 事务增强 --><br /> <tx:advice id="txAdvice" transaction-manager="txManager"><br /> <!-- 属性事务定义 --><br /> <tx:attributes><br /> <!--OpenSessionInViewFilter在getSession的时候,会把获取回来的session的flush mode 设为FlushMode.NEVER。<br /> 然后把该sessionFactory绑定到TransactionSynchronizationManager，使request的整个过程都使用同一个session，<br /> 在请求过后再接除该sessionFactory的绑定，最后closeSessionIfNecessary根据该session是否已和transaction绑定来决定是否关闭session。<br /> 在这个过程中，若HibernateTemplate 发现自当前session有不是readOnly的transaction，就会获取到FlushMode.AUTO Session，使方法拥有写权限。<br /> 也即是，如果有不是readOnly的transaction就可以由Flush.NEVER转为Flush.AUTO,拥有insert,update,delete操作权限，如果没有transaction，<br /> 并且没有另外人为地设flush model的话，则doFilter的整个过程都是Flush.NEVER。所以受transaction保护的方法有写权限，没受保护的则没有 --><br /> <tx:method name="*" /><br /> </tx:attributes><br /> </tx:advice></p> <p></beans><br />

applicationContext.xml

<?xml version="1.0" encoding="UTF-8"?><br /> <beans xmlns="http://www.springframework.org/schema/beans"<br /> xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"<br /> xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-2.5.xsd"><br /> <!-- 使用外部文件配置数据源的属性 --><br /> <bean<br /> class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer"><br /> <property name="locations"><br /> <list><br /> <!-- 外部文件地址 --><br /> <value>classpath:database_conn.properties</value><br /> </list><br /> </property><br /> <property name="fileEncoding" value="utf-8" /><br /> </bean><br /> <!-- 配置数据源 --><br /> <bean id="dataSource"<br /> class="com.mchange.v2.c3p0.ComboPooledDataSource"<br /> destroy-method="close"><br /> <property name="driverClass" value="${driverClassName}" /><br /> <property name="jdbcUrl" value="${url}"/><br /> <property name="user" value="${username}"/><br /> <property name="password" value="${password}"/></p> <p> <!--连接池中保留的最小连接数。--><br /> <property name="minPoolSize" value="5" /></p> <p> <!--连接池中保留的最大连接数。Default: 15 --><br /> <property name="maxPoolSize" value="20" /></p> <p> <!--初始化时获取的连接数，取值应在minPoolSize与maxPoolSize之间。Default: 3 --><br /> <property name="initialPoolSize" value="10" /></p> <p> <!--最大空闲时间,60秒内未使用则连接被丢弃。若为0则永不丢弃。Default: 0 --><br /> <property name="maxIdleTime" value="60" /></p> <p> <!--当连接池中的连接耗尽的时候c3p0一次同时获取的连接数。Default: 3 --><br /> <property name="acquireIncrement" value="5" /></p> <p> <!--JDBC的标准参数，用以控制数据源内加载的PreparedStatements数量。但由于预缓存的statements<br /> 属于单个connection而不是整个连接池。所以设置这个参数需要考虑到多方面的因素。<br /> 如果maxStatements与maxStatementsPerConnection均为0，则缓存被关闭。Default: 0--><br /> <property name="maxStatements" value="0"/><br /> <!--每60秒检查所有连接池中的空闲连接。Default: 0 --><br /> <property name="idleConnectionTestPeriod" value="60"/></p> <p> <!--定义在从数据库获取新连接失败后重复尝试的次数。Default: 30 --><br /> <property name="acquireRetryAttempts" value="0" /><br /> <!--获取连接失败将会引起所有等待连接池来获取连接的线程抛出异常。但是数据源仍有效<br /> 保留，并在下次调用getConnection()的时候继续尝试获取连接。如果设为true，那么在尝试<br /> 获取连接失败后该数据源将申明已断开并永久关闭。Default: false--><br /> <property name="breakAfterAcquireFailure" value="true" /></p> <p> <!--因性能消耗大请只在需要的时候使用它。如果设为true那么在每个connection提交的<br /> 时候都将校验其有效性。建议使用idleConnectionTestPeriod或automaticTestTable<br /> 等方法来提升连接测试的性能。Default: false --><br /> <property name="testConnectionOnCheckout" value="false" /><br /> </bean><br /> <!-- hibernate3 sessionfactory配置<br /> 使用AnnotationSessionFactoryBean创建基于JPA注解的SessionFactory--><br /> <bean id="sessionFactory"<br /> class="org.springframework.orm.hibernate3.annotation.AnnotationSessionFactoryBean"><br /> <!-- 引用数据源 --><br /> <property name="dataSource"><br /> <ref bean="dataSource" /><br /> </property><br /> <property name="namingStrategy"><br /> <bean class="org.hibernate.cfg.ImprovedNamingStrategy" /><br /> </property><br /> <!-- hibernate的属性具体见hibernate文档 --><br /> <property name="hibernateProperties"><br /> <props><br /> <prop key="hibernate.dialect"><br /> org.hibernate.dialect.MySQLDialect<br /> </prop><br /> <prop key="hibernate.show_sql">${hibernate.show_sql}</prop><br /> <prop key="hibernate.format_sql">${hibernate.format_sql}</prop><br /> <!-- 非0值 指定jdbc抓取数量的大小调用Statement.setFetchSize() --><br /> <prop key="hibernate.jdbc.fetch_size">${hibernate.jdbc.fetch_size}</prop><br /> <!-- jdbc批量更新 建议5到30 --><br /> <prop key="hibernate.jdbc.batch_size">${hibernate.jdbc.batch_size}</prop><br /> <!--说明一下：如果不设置查询缓存，那么hibernate只会缓存使用load()方法获得的单个持久化对象<br /> 如果想缓存使用findall()、list()、Iterator()、createCriteria()、createQuery()<br /> 等方法获得的数据结果集的话就需要设置hibernate.cache.use_query_cache true 才行 --><br /> <prop key="hibernate.cache.use_query_cache">${hibernate.cache.use_query_cache}</prop><br /> <prop key="hibernate.cache.provider_class"><br /> org.hibernate.cache.EhCacheProvider<br /> </prop><br /> <prop key="hibernate.cache.provider_configuration_file_resource_path"><br /> ${hibernate.ehcache_config_file}<br /> </prop><br /> </props><br /> </property></p> <p> <property name="packagesToScan" value="com.hibernate.entityclass" /><br /> </bean></p> <p> <!-- 加载spring功能列表文件 --><br /> <import resource="applicationContext-list.xml"/><br /> </beans>

database_conn.properties

#jdbc settings<br /> driverClassName=org.gjt.mm.mysql.Driver<br /> url=jdbc/:mysql/://127.0.0.1/:3306/mytest<br /> username=root<br /> password=123456<br /> #hibernate settings<br /> hibernate.show_sql=true<br /> hibernate.format_sql=true<br /> hibernate.cache.use_query_cache=false<br /> hibernate.jdbc.fetch_size=10<br /> hibernate.jdbc.batch_size=5<br /> hibernate.ehcache_config_file=ehcache.xml

ehcache.xml

<ehcache><br /> <!-- Sets the path to the directory where cache .data files are created.</p> <p> If the path is a Java System Property it is replaced by<br /> its value in the running VM.</p> <p> The following properties are translated:<br /> user.home - User's home directory<br /> user.dir - User's current working directory<br /> java.io.tmpdir - Default temp file path --><br /> <diskStore path="java.io.tmpdir" /><br /> <!--Default Cache configuration. These will applied to caches programmatically created through<br /> the CacheManager.</p> <p> The following attributes are required:</p> <p> maxElementsInMemory - Sets the maximum number of objects that will be created in memory<br /> eternal - Sets whether elements are eternal. If eternal, timeouts are ignored and the<br /> element is never expired.<br /> overflowToDisk - Sets whether elements can overflow to disk when the in-memory cache<br /> has reached the maxInMemory limit.</p> <p> The following attributes are optional:<br /> timeToIdleSeconds - Sets the time to idle for an element before it expires.<br /> i.e. The maximum amount of time between accesses before an element expires<br /> Is only used if the element is not eternal.<br /> Optional attribute. A value of 0 means that an Element can idle for infinity.<br /> The default value is 0.<br /> timeToLiveSeconds - Sets the time to live for an element before it expires.<br /> i.e. The maximum time between creation time and when an element expires.<br /> Is only used if the element is not eternal.<br /> Optional attribute. A value of 0 means that and Element can live for infinity.<br /> The default value is 0.<br /> diskPersistent - Whether the disk store persists between restarts of the Virtual Machine.<br /> The default value is false.<br /> diskExpiryThreadIntervalSeconds- The number of seconds between runs of the disk expiry thread. The default value<br /> is 120 seconds.<br /> --><br /> <cache name="org.hibernate.cache.StandardQueryCache"<br /> maxElementsInMemory="50"<br /> eternal="false"<br /> timeToIdleSeconds="3600"<br /> timeToLiveSeconds="7200"<br /> overflowToDisk="true" /><br /> <cache name="org.hibernate.cache.UpdateTimestampsCache"<br /> maxElementsInMemory="5000"<br /> eternal="true"<br /> overflowToDisk="true" /><br /> <!--<br /> 默认的Cache配置。用来实现CacheManager.add(String cacheName)创建的缓存<br /> memoryStoreEvictionPolicy:内存存储与释放策略。有三个值：<br /> LRU －least recently used<br /> LFU －least frequently used<br /> FIFO－first in first out, the oldest element by creation time<br /> diskPersistent ：是否持久化磁盘缓存。<br /> 当这个属性的值为true时，系统在初始化的时候会在磁盘中查找文件名为cache名称<br /> 后缀名为index的的文件，如CACHE_FUNC.index<br /> --><br /> <defaultCache maxElementsInMemory="10000"<br /> eternal="false"<br /> timeToIdleSeconds="120"<br /> timeToLiveSeconds="120"<br /> overflowToDisk="true"<br /> diskPersistent="false"<br /> diskExpiryThreadIntervalSeconds="120"<br /> memoryStoreEvictionPolicy="LFU"<br /> /><br /> <!-- See http://ehcache.sourceforge.net/documentation/#mozTocId258426 for how to configure caching for your objects --><br /> </ehcache>

log4j.properties

log4j.rootLogger=INFO, stdout, logfile<br /> log4j.logger.org.springframework=WARN<br /> log4j.logger.org.hibernate=WARN<br /> log4j.appender.stdout=org.apache.log4j.ConsoleAppender<br /> log4j.appender.stdout.layout=org.apache.log4j.PatternLayout<br /> log4j.appender.stdout.layout.ConversionPattern=[%d] %-5p /: %m%n<br /> log4j.appender.logfile=org.apache.log4j.RollingFileAppender<br /> log4j.appender.logfile.File=${webAppRootKey}/superDao.log<br /> log4j.appender.logfile.MaxFileSize=512KB<br /> # Keep three backup files.<br /> log4j.appender.logfile.MaxBackupIndex=3<br /> # Pattern to output: date priority [category] - message<br /> log4j.appender.logfile.layout=org.apache.log4j.PatternLayout<br /> log4j.appender.logfile.layout.ConversionPattern=[%d] %p [%c] - %m%n<br />

tinyLight-dao.xml

<?xml version="1.0" encoding="UTF-8"?><br /> <beans xmlns="http://www.springframework.org/schema/beans"<br /> xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"<br /> xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd"><br /> <description>tinyLight Dao配置</description><br /> <!-- 定义JdbcTemplate Bean(线程安全,执行底层sql语句) --><br /> <bean id="jdbcTemplate" class="org.springframework.jdbc.core.JdbcTemplate"><br /> <!-- 设置数据源 --><br /> <property name="dataSource" ref="dataSource" /><br /> <!-- 设置jdbcTemplate创建的statement查询数据时最大的超时时间,默认0 --><br /> <property name="queryTimeout" value="0" /><br /> <!-- 设置底层ResultSet每次从数据库返回的行数,默认0,Oracle默认100 --><br /> <property name="fetchSize" value="0" /><br /> <!-- 设置底层ResultSet从数据库返回的最大行数,默认0 --><br /> <property name="maxRows" value="0" /><br /> <!-- 是否忽略sql警告信息,默认true,false JdbcTemplate将会抛出SQLWarningException --><br /> <property name="ignoreWarnings" value="true" /><br /> <property name="nativeJdbcExtractor" ref="nativeJdbcExtractor" /><br /> </bean><br /> <!-- 定义DBCP数据源的JDBC本地对象抽取器 --><br /> <bean id="nativeJdbcExtractor" lazy-init="true"<br /> class="org.springframework.jdbc.support.nativejdbc.CommonsDbcpNativeJdbcExtractor" /><br /> <!-- 定义封装了jdbc操作数据的dao --><br /> <bean id="simpleJdbcDao" class="com.tinylight.dao.jdbc.SimpleJdbcDao"><br /> <property name="jdbcTemplate" ref="jdbcTemplate" /><br /> </bean><br /> <!-- 定义了与实体相关的dao --><br /> <bean id="genericEntityDao" class="com.tinylight.dao.hibernate.GenericEntityDao"<br /> scope="prototype" lazy-init="true"><br /> <property name="sessionFactory"><br /> <ref bean="sessionFactory" /><br /> </property><br /> </bean><br /> <!-- 定义了与实体无关的dao --><br /> <bean id="genericDao" class="com.tinylight.dao.hibernate.GenericDao"><br /> <property name="sessionFactory"><br /> <ref bean="sessionFactory" /><br /> </property><br /> </bean><br /> <!--使用泛型DAO作为抽象基类--><br /> <bean id="baseDao" class="com.tinylight.dao.base.BaseDao"<br /> abstract="true" depends-on="genericEntityDao,genericDao"><br /> <property name="gedao"><br /> <ref bean="genericEntityDao" /><br /> </property><br /> <property name="gdao"><br /> <ref bean="genericDao" /><br /> </property><br /> <property name="sjdao"><br /> <ref bean="simpleJdbcDao"/><br /> </property><br /> </bean><br /> <!--<br /> 当然这里也可以不必为每一个实体类的配置像下面这样的代码，<br /> 那就要在spring注解注入dao到service类的时候，加上下面这个方法：<br /> /**<br /> * spring bean的后处理器,如果子类是spring初始化的bean,则在初始化后设置注解dao的实体类类型<br /> * @throws IllegalArgumentException<br /> * @throws IllegalAccessException<br /> */<br /> @PostConstruct<br /> @SuppressWarnings("unchecked")<br /> protected void preparedDao() throws IllegalArgumentException, IllegalAccessException{<br /> Class<? extends BaseService> cl = this.getClass();<br /> for(Field f : cl.getDeclaredFields()){<br /> log.info("Service类注解属性名称 = {},类型 = {}",f.getName(),f.getGenericType());<br /> if(f.isAnnotationPresent(Resource.class) && f.getAnnotation(Resource.class).name().equals("baseDao")){<br /> f.setAccessible(true);//修改private修饰权限<br /> Type[] params = ((ParameterizedType)f.getGenericType()).getActualTypeArguments();<br /> log.info("实体类的参数类型 = {}",params[0].toString());<br /> ((IBaseDao<?,?>)f.get(this)).changeEntityClass((Class)params[0]);//设置实体类类型<br /> f.setAccessible(false);//恢复private修饰权限<br /> }<br /> }<br /> }<br /> 这样就可以为每一个实体类加下面这段xml配置了，当然dao是不在学要写一条代码啦<br /> --></p> <p> <!-- 配置实体Demodata的DAO --><br /> <bean id="demoDao" parent="baseDao"><br /> <constructor-arg><br /> <value>com.hibernate.entityclass.Daotest</value><br /> </constructor-arg><br /> </bean></p> <p></beans><br />