欢迎您访问程序员文章站本站旨在为大家提供分享程序员计算机编程知识!
您现在的位置是: 首页

mybatis泛型Dao参考一 博客分类: mybatis ibatis  泛型DAO接口的设计 博客分类:   结构设计 DAOiBATISMySQLOracleSpring 

程序员文章站 2024-03-14 12:12:04
...

1、泛型DAO接口定义

Java代码  mybatis泛型Dao参考一
            
    
    博客分类: mybatis ibatis 
  

泛型DAO接口的设计
博客分类:
 
结构设计

DAOiBATISMySQLOracleSpring 
  1. import java.io.Serializable;  
  2. import java.util.List;  
  3.   
  4. /** 
  5.  * GenericDao DAO层泛型接口,定义基本的DAO功能 
  6.  * @author wl 
  7.  * @since 0.1 
  8.  * @param <T>    实体类 
  9.  * @param <PK>    主键类,必须实现Serializable接口 
  10.  *  
  11.  * @see com.thinkon.commons.dao.GenericIbatisDao 
  12.  */  
  13. public abstract interface GenericDao<T, PK extends Serializable> {  
  14.     /** 
  15.      * 插入一个实体(在数据库INSERT一条记录) 
  16.      * @param entity 实体对象 
  17.      */  
  18.     public abstract void insert(T entity);  
  19.       
  20.     /** 
  21.      * 修改一个实体对象(UPDATE一条记录) 
  22.      * @param entity 实体对象 
  23.      * @return 修改的对象个数,正常情况=1 
  24.      */  
  25.     public abstract int update(T entity);  
  26.       
  27.     /** 
  28.      * 修改符合条件的记录 
  29.      * <p>此方法特别适合于一次性把多条记录的某些字段值设置为新值(定值)的情况,比如修改符合条件的记录的状态字段</p> 
  30.      * <p>此方法的另一个用途是把一条记录的个别字段的值修改为新值(定值),此时要把条件设置为该记录的主键</p> 
  31.      * @param param 用于产生SQL的参数值,包括WHERE条件、目标字段和新值等 
  32.      * @return 修改的记录个数,用于判断修改是否成功 
  33.      */  
  34.     public abstract int update(DynamicSqlParameter param);  
  35.       
  36.     /** 
  37.      * 按主键删除记录 
  38.      * @param primaryKey 主键对象 
  39.      * @return 删除的对象个数,正常情况=1 
  40.      */  
  41.     public abstract int delete(PK primaryKey);  
  42.   
  43.     /** 
  44.      * 删除符合条件的记录 
  45.      * <p><strong>此方法一定要慎用,如果条件设置不当,可能会删除有用的记录!</strong></p> 
  46.      * @param param 用于产生SQL的参数值,包括WHERE条件(其他参数内容不起作用) 
  47.      * @return 
  48.      */  
  49.     public abstract int delete(DynamicSqlParameter param);  
  50.       
  51.     /** 
  52.      * 清空表,比delete具有更高的效率,而且是从数据库中物理删除(delete是逻辑删除,被删除的记录依然占有空间) 
  53.      * <p><strong>此方法一定要慎用!</strong></p> 
  54.      * @return 
  55.      */  
  56.     public abstract int truncate();  
  57.       
  58.     /** 
  59.      * 查询整表总记录数 
  60.      * @return 整表总记录数 
  61.      */  
  62.     public abstract int count();  
  63.       
  64.     /** 
  65.      * 查询符合条件的记录数 
  66.      * @param param 查询条件参数,包括WHERE条件(其他参数内容不起作用)。此参数设置为null,则相当于count() 
  67.      * @return 
  68.      */  
  69.     public abstract int count(DynamicSqlParameter param);  
  70.   
  71.     /** 
  72.      * 按主键取记录 
  73.      * @param primaryKey 主键值 
  74.      * @return 记录实体对象,如果没有符合主键条件的记录,则返回null 
  75.      */  
  76.     public abstract T get(PK primaryKey);  
  77.   
  78.     /** 
  79.      * 按主键取记录 
  80.      * @param primaryKey 主键值 
  81.      * @return 记录实体对象,如果没有符合主键条件的记录,则 throw DataAccessException 
  82.      */  
  83.     public abstract T load(PK primaryKey) throws DataAccessException;  
  84.   
  85.     /** 
  86.      * 取全部记录 
  87.      * @return 全部记录实体对象的List 
  88.      */  
  89.     public abstract List<T> select();  
  90.       
  91.     /** 
  92.      * 按条件查询记录 
  93.      * @param param 查询条件参数,包括WHERE条件、分页条件、排序条件 
  94.      * @return 符合条件记录的实体对象的List 
  95.      */  
  96.     public abstract List<T> select(DynamicSqlParameter param);  
  97.       
  98.     /** 
  99.      * 按条件查询记录,并处理成分页结果 
  100.      * @param param 查询条件参数,包括WHERE条件、分页条件、排序条件 
  101.      * @return PaginationResult对象,包括(符合条件的)总记录数、页实体对象List等 
  102.      */  
  103.     public abstract PaginationResult<T> selectPagination(DynamicSqlParameter param);  
  104.       
  105.     /** 
  106.      * 按条件查询记录,并把有外键关联的字段的关联对象也处理出来 
  107.      * <p>此方法是为了避免1+N而设置的</p> 
  108.      * @param param 查询条件参数,包括WHERE条件、分页条件、排序条件<strong>(不包括外键关联表条件)</strong> 
  109.      * @return 符合条件记录的实体对象的List 
  110.      */  
  111.     public abstract List<T> selectFk(DynamicSqlParameter param);  
  112.       
  113.     /** 
  114.      * 按条件查询记录,并把有外键关联的字段的关联对象也处理出来,并处理成分页结果 
  115.      * <p>此方法是为了避免1+N而设置的</p> 
  116.      * @param param 查询条件参数,包括WHERE条件、分页条件、排序条件<strong>(不包括外键关联表条件)</strong> 
  117.      * @return PaginationResult对象,包括(符合条件的)总记录数、页实体对象List等 
  118.      */  
  119.     public abstract PaginationResult<T> selectFkPagination(DynamicSqlParameter param);  
  120.       
  121.     /** 
  122.      * 批量插入 
  123.      * @param list 
  124.      */  
  125.     public abstract void batchInsert(final List<T> list);  
  126.       
  127.     /** 
  128.      * 批量修改 
  129.      * @param list 
  130.      */  
  131.     public abstract void batchUpdate(final List<T> list);  
  132.       
  133.     /** 
  134.      * 批量删除 
  135.      * @param list 
  136.      */  
  137.     public abstract void batchDelete(final List<PK> list);  
  138. }  

 2、泛型接口的实现类(其他DAO的基类),以iBatis实现:

Java代码  mybatis泛型Dao参考一
            
    
    博客分类: mybatis ibatis 
  

泛型DAO接口的设计
博客分类:
 
结构设计

DAOiBATISMySQLOracleSpring 
  1. import java.io.Serializable;  
  2. import java.sql.SQLException;  
  3. import java.util.List;  
  4.   
  5. import org.springframework.orm.ibatis.SqlMapClientCallback;  
  6. import org.springframework.orm.ibatis.support.SqlMapClientDaoSupport;  
  7.   
  8. import com.ibatis.sqlmap.client.SqlMapExecutor;  
  9.   
  10. /** 
  11.  * iBatis DAO层泛型基类,实现了基本的DAO功能 利用了Spring的DaoSupport功能 
  12.  *  
  13.  * @author wl 
  14.  * @since 0.1 
  15.  * @param <T> 
  16.  *            实体类 
  17.  * @param <PK> 
  18.  *            主键类,必须实现Serializable接口 
  19.  *  
  20.  * @see com.thinkon.commons.dao.GenericDao 
  21.  * @see org.springframework.orm.ibatis.support.SqlMapClientDaoSupport 
  22.  */  
  23. public abstract class GenericIbatisDao<T, PK extends Serializable> extends  
  24.         SqlMapClientDaoSupport implements GenericDao<T, PK> {  
  25.   
  26.     // sqlmap.xml定义文件中对应的sqlid  
  27.     public static final String SQLID_INSERT = "insert";  
  28.     public static final String SQLID_UPDATE = "update";  
  29.     public static final String SQLID_UPDATE_PARAM = "updateParam";  
  30.     public static final String SQLID_DELETE = "delete";  
  31.     public static final String SQLID_DELETE_PARAM = "deleteParam";  
  32.     public static final String SQLID_TRUNCATE = "truncate";  
  33.     public static final String SQLID_SELECT = "select";  
  34.     public static final String SQLID_SELECT_PK = "selectPk";  
  35.     public static final String SQLID_SELECT_PARAM = "selectParam";  
  36.     public static final String SQLID_SELECT_FK = "selectFk";  
  37.     public static final String SQLID_COUNT = "count";  
  38.     public static final String SQLID_COUNT_PARAM = "countParam";  
  39.   
  40.     private String sqlmapNamespace = "";  
  41.   
  42.     /** 
  43.      * sqlmapNamespace,对应sqlmap.xml中的命名空间 
  44.      *  
  45.      * @return 
  46.      */  
  47.     public String getSqlmapNamespace() {  
  48.         return sqlmapNamespace;  
  49.     }  
  50.   
  51.     /** 
  52.      * sqlmapNamespace的设置方法,可以用于spring注入 
  53.      *  
  54.      * @param sqlmapNamespace 
  55.      */  
  56.     public void setSqlmapNamespace(String sqlmapNamespace) {  
  57.         this.sqlmapNamespace = sqlmapNamespace;  
  58.     }  
  59.   
  60.     /** 
  61.      * 数据库方言,缺省为MYSQL 
  62.      */  
  63.     private String dbDialect = "MYSQL";  
  64.   
  65.     /** 
  66.      * 数据库方言dbDialect的get方法 
  67.      *  
  68.      * @return 
  69.      */  
  70.     public String getDbDialect() {  
  71.         return dbDialect;  
  72.     }  
  73.   
  74.     /** 
  75.      * 数据库方言dbDialect的set方法 
  76.      *  
  77.      * @return 
  78.      */  
  79.     public void setDbDialect(String dbDialect) {  
  80.         if (dbDialect == null  
  81.                 || (!dbDialect.equals("MYSQL") && !dbDialect.equals("ORACLE")))  
  82.             throw new DaoException("错误的数据库方言设置:本系统只支持MYSQL和ORACLE");  
  83.         this.dbDialect = dbDialect;  
  84.     }  
  85.   
  86.     public int count() {  
  87.         Integer count = (Integer) getSqlMapClientTemplate().queryForObject(  
  88.                 sqlmapNamespace + "." + SQLID_COUNT);  
  89.         return count.intValue();  
  90.     }  
  91.   
  92.     public int count(DynamicSqlParameter param) {  
  93.         Integer count = (Integer) getSqlMapClientTemplate().queryForObject(  
  94.                 sqlmapNamespace + "." + SQLID_COUNT_PARAM, param);  
  95.         return count.intValue();  
  96.     }  
  97.   
  98.     public int delete(PK primaryKey) {  
  99.         int rows = getSqlMapClientTemplate().delete(  
  100.                 sqlmapNamespace + "." + SQLID_DELETE, primaryKey);  
  101.         try {  
  102.             getSqlMapClientTemplate().getSqlMapClient().startBatch();  
  103.         } catch (SQLException e) {  
  104.             // TODO Auto-generated catch block  
  105.             e.printStackTrace();  
  106.         }  
  107.         return rows;  
  108.     }  
  109.   
  110.     public int delete(DynamicSqlParameter param) {  
  111.         int rows = getSqlMapClientTemplate().delete(  
  112.                 sqlmapNamespace + "." + SQLID_DELETE_PARAM, param);  
  113.         return rows;  
  114.     }  
  115.   
  116.     public int truncate() {  
  117.         int rows = getSqlMapClientTemplate().delete(  
  118.                 sqlmapNamespace + "." + SQLID_TRUNCATE);  
  119.         return rows;  
  120.     }  
  121.   
  122.     public T get(PK primaryKey) {  
  123.         return (T) getSqlMapClientTemplate().queryForObject(  
  124.                 sqlmapNamespace + "." + SQLID_SELECT_PK, primaryKey);  
  125.     }  
  126.   
  127.     public void insert(T entity) {  
  128.         getSqlMapClientTemplate().insert(sqlmapNamespace + "." + SQLID_INSERT,  
  129.                 entity);  
  130.     }  
  131.   
  132.     public T load(PK primaryKey) throws DaoException {  
  133.         Object o = getSqlMapClientTemplate().queryForObject(  
  134.                 sqlmapNamespace + "." + SQLID_SELECT_PK, primaryKey);  
  135.         if (o == null)  
  136.             throw new DataAccessException("数据查询异常:无法查询出主键数据");  
  137.         return (T) o;  
  138.     }  
  139.   
  140.     public List<T> select() {  
  141.         return getSqlMapClientTemplate().queryForList(  
  142.                 sqlmapNamespace + "." + SQLID_SELECT);  
  143.     }  
  144.   
  145.     public List<T> select(DynamicSqlParameter param) {  
  146.         return getSqlMapClientTemplate().queryForList(  
  147.                 sqlmapNamespace + "." + SQLID_SELECT_PARAM, param);  
  148.     }  
  149.   
  150.     public PaginationResult<T> selectPagination(DynamicSqlParameter param) {  
  151.         if (param != null)  
  152.             param.setDbDialect(this.dbDialect);  
  153.   
  154.         PaginationResult<T> result = new PaginationResult<T>();  
  155.         int count = count(param);  
  156.         result.setTotalSize(count);  
  157.         if (count > 0) {  
  158.             List<T> data = getSqlMapClientTemplate().queryForList(  
  159.                     sqlmapNamespace + "." + SQLID_SELECT_PARAM, param);  
  160.             result.setData(data);  
  161.         }  
  162.   
  163.         return result;  
  164.     }  
  165.   
  166.     public List<T> selectFk(DynamicSqlParameter param) {  
  167.         return getSqlMapClientTemplate().queryForList(  
  168.                 sqlmapNamespace + "." + SQLID_SELECT_FK, param);  
  169.     }  
  170.   
  171.     public PaginationResult<T> selectFkPagination(DynamicSqlParameter param) {  
  172.         if (param != null)  
  173.             param.setDbDialect(this.dbDialect);  
  174.         PaginationResult<T> result = new PaginationResult<T>();  
  175.         int count = count(param);  
  176.         result.setTotalSize(count);  
  177.         if (count > 0) {  
  178.             List<T> data = getSqlMapClientTemplate().queryForList(  
  179.                     sqlmapNamespace + "." + SQLID_SELECT_FK, param);  
  180.             result.setData(data);  
  181.         }  
  182.   
  183.         return result;  
  184.     }  
  185.   
  186.     public int update(T entity) {  
  187.         return getSqlMapClientTemplate().update(  
  188.                 sqlmapNamespace + "." + SQLID_UPDATE, entity);  
  189.     }  
  190.   
  191.     public int update(DynamicSqlParameter param) {  
  192.         if (param == null || param.getUpdateValueList() == null)  
  193.             throw new ParameterException(  
  194.                     "参数设置错误:使用带参数的update必须设定update的column!");  
  195.   
  196.         return getSqlMapClientTemplate().update(  
  197.                 sqlmapNamespace + "." + SQLID_UPDATE_PARAM, param);  
  198.     }  
  199.   
  200.     public void batchInsert(final List<T> list){  
  201.         SqlMapClientCallback callback = new SqlMapClientCallback() {          
  202.             public Object doInSqlMapClient(SqlMapExecutor executor) throws SQLException {              
  203.                 executor.startBatch();              
  204.                 for (T member : list) {                  
  205.                     executor.insert(sqlmapNamespace + "." + SQLID_INSERT, member);              
  206.                 }              
  207.                 executor.executeBatch();              
  208.                 return null;          
  209.             }      
  210.         };      
  211.         this.getSqlMapClientTemplate().execute(callback);      
  212.     }  
  213.   
  214.     public void batchUpdate(final List<T> list){  
  215.         SqlMapClientCallback callback = new SqlMapClientCallback() {          
  216.             public Object doInSqlMapClient(SqlMapExecutor executor) throws SQLException {              
  217.                 executor.startBatch();              
  218.                 for (T member : list) {                  
  219.                     executor.update(sqlmapNamespace + "." + SQLID_UPDATE, member);              
  220.                 }              
  221.                 executor.executeBatch();              
  222.                 return null;          
  223.             }      
  224.         };      
  225.         this.getSqlMapClientTemplate().execute(callback);      
  226.     }  
  227.   
  228.     public void batchDelete(final List<PK> list){  
  229.         SqlMapClientCallback callback = new SqlMapClientCallback() {          
  230.             public Object doInSqlMapClient(SqlMapExecutor executor) throws SQLException {              
  231.                 executor.startBatch();              
  232.                 for (PK member : list) {                  
  233.                     executor.delete(sqlmapNamespace + "." + SQLID_DELETE, member);              
  234.                 }              
  235.                 executor.executeBatch();              
  236.                 return null;          
  237.             }      
  238.         };      
  239.         this.getSqlMapClientTemplate().execute(callback);      
  240.     }  
  241. }  

 3、某实体的DAO接口:

Java代码  mybatis泛型Dao参考一
            
    
    博客分类: mybatis ibatis 
  

泛型DAO接口的设计
博客分类:
 
结构设计

DAOiBATISMySQLOracleSpring 
  1. public interface UserDao extends GenericDao<User,Integer> {  
  2. //通用方法从GenericDao继承  
  3. //这里可以定义针对此类的特定方法  
  4. }  

 4、某实体的DAO实现:

Java代码  mybatis泛型Dao参考一
            
    
    博客分类: mybatis ibatis 
  

泛型DAO接口的设计
博客分类:
 
结构设计

DAOiBATISMySQLOracleSpring 
  1. public class UserDaoImpl extends GenericIbatisDao<User,Integer> implements UserDao {  
  2. }