`

mybatis泛型Dao参考四

阅读更多

import org.apache.commons.logging.Log;

import org.apache.commons.logging.LogFactory;

 

public abstract class BaseDAOImpl {

protected final Log logger = LogFactory.getLog(getClass());

 

private QueryDelegate queryDelegate = new QueryDelegate();

private EntityDelegate entityDelegate = new EntityDelegate();

 

private DBRoute route = DBRoute.getDefaultRoute();

 

public QueryDelegate getQueryDelegate() {

return queryDelegate;

}

 

public void setQueryDelegate(QueryDelegate queryDelegate) {

this.queryDelegate = queryDelegate;

}

 

public EntityDelegate getEntityDelegate() {

return entityDelegate;

}

 

public void setEntityDelegate(EntityDelegate entityDelegate) {

this.entityDelegate = entityDelegate;

}

 

public DBRoute getRoute() {

return route;

}

 

public void setRoute(DBRoute route) {

this.route = route;

}

 

}

 

import java.io.Serializable;

import java.util.HashMap;

import java.util.List;

import java.util.Map;

 

import org.springframework.orm.ibatis.support.SqlMapClientDaoSupport;

import org.springframework.util.Assert;

 

public class IbatisGenericDao extends BaseDAOImpl {

 

public static final String POSTFIX_INSERT = ".insert";

 

public static final String POSTFIX_UPDATE = ".update";

 

public static final String POSTFIX_DELETE = ".delete";

 

public static final String POSTFIX_DELETE_PRIAMARYKEY = ".deleteByPrimaryKey";

 

public static final String POSTFIX_SELECT = ".select";

 

public static final String POSTFIX_GETALL = ".getAll";

 

public static final String POSTFIX_SELECTMAP = ".selectByMap";

 

public static final String POSTFIX_SELECTSQL = ".selectBySql";

 

public static final String POSTFIX_COUNT = ".count";

 

public static final String POSTFIX_QUERY = ".query";

 

/**

* 根据ID获取对象

*/

public <T> T get(Class<T> entityClass, Serializable id) {

T o = (T)getQueryDelegate().queryForObject(

getStatementId(entityClass, IbatisGenericDao.POSTFIX_SELECT),

id,getRoute());

return o;

}

 

/**

* 新增对象

*/

public Integer _insert(Object o) {

Integer result = -1;

result = (Integer)getEntityDelegate().insert(

getStatementId(o.getClass(), IbatisGenericDao.POSTFIX_INSERT),

o,getRoute());

return result;

}

 

/**

* 保存对象

*/

public Integer _update(Object o) {

Integer result = -1;

result = (Integer)getEntityDelegate().update(

getStatementId(o.getClass(), IbatisGenericDao.POSTFIX_UPDATE),

o,getRoute());

return result;

}

 

/**

* 获取总数

* @param entityClass

* @param map

* @return

*/

public Integer _getCount(Class entityClass,HashMap map){

Integer totalCount = (Integer) getQueryDelegate()

.queryForObject(

getStatementId(entityClass,

IbatisGenericDao.POSTFIX_COUNT),

map,getRoute());

return totalCount;

}

 

/**

* 根据ID删除对象

*/

public <T> Integer removeById(Class<T> entityClass, Serializable id) {

Integer result = getEntityDelegate().delete(

getStatementId(entityClass,

IbatisGenericDao.POSTFIX_DELETE_PRIAMARYKEY), id,getRoute());

return result;

}

 

/**

* 分页查询函数,使用PaginatedList.

* @param start

* @param limit

* @return 含17117717记录数和当前页数据的Page对象.

*/

public Page pagedQuery(Class entityClass, Map parameterObject, int start,

int limit) {

 

Assert.isTrue(start >= 0, "pageNo should start from 0");

 

// 计算总数

Integer totalCount = (Integer) getQueryDelegate()

.queryForObject(

getStatementId(entityClass,

IbatisGenericDao.POSTFIX_COUNT),

parameterObject,getRoute());

 

// 如果没有数据则返回Empty Page

Assert.notNull(totalCount, "totalCount Error");

 

if (totalCount.intValue() == 0) {

return new Page();

}

 

List list;

int totalPageCount = 0;

int startIndex = 0;

 

// 如果pageSize小于0,则返回所有数捄1177,等同于getAll

if (limit > 0) {

 

// 计算页数

totalPageCount = (totalCount / limit);

totalPageCount += ((totalCount % limit) > 0) ? 1 : 0;

 

// 计算skip数量

if (totalCount > start) {

startIndex = start;

} else {

startIndex = (totalPageCount - 1) * limit;

}

 

if (parameterObject == null)

parameterObject = new HashMap();

 

parameterObject.put("startIndex", startIndex);

parameterObject.put("endIndex", limit);

 

list = getQueryDelegate()

.queryForList(

getStatementId(entityClass,

IbatisGenericDao.POSTFIX_QUERY),

parameterObject,getRoute());

 

} else {

list = getQueryDelegate()

.queryForList(

getStatementId(entityClass,

IbatisGenericDao.POSTFIX_QUERY),

parameterObject,getRoute());

}

return new Page(startIndex, totalCount, limit, list);

}

 

/**

* 分页查询函数,使用PaginatedList.

* @param start

* @param limit

* @return 含17117717记录数和当前页数据的Page对象.

*/

public Page pagedQuery(Class entityClass, Map parameterObject, int start,

int limit, String countSqlId, String pageQuerySqlId) {

 

Assert.isTrue(start >= 0, "pageNo should start from 0");

 

// 计算总数

Integer totalCount = (Integer) getQueryDelegate()

.queryForObject(getStatementId(entityClass, countSqlId),

parameterObject,getRoute());

 

// 如果没有数据则返回Empty Page

Assert.notNull(totalCount, "totalCount Error");

 

if (totalCount.intValue() == 0) {

return new Page();

}

 

List list;

int totalPageCount = 0;

int startIndex = 0;

 

// 如果pageSize小于0,则返回所有数捄1177,等同于getAll

if (limit > 0) {

 

// 计算页数

totalPageCount = (totalCount / limit);

totalPageCount += ((totalCount % limit) > 0) ? 1 : 0;

 

// 计算skip数量

if (totalCount >= start) {

startIndex = start;

} else {

startIndex = (totalPageCount - 1) * limit;

}

 

if (parameterObject == null)

parameterObject = new HashMap();

 

parameterObject.put("startIndex", startIndex);

parameterObject.put("endIndex", limit);

 

list = getQueryDelegate().queryForList(

getStatementId(entityClass, pageQuerySqlId),

parameterObject,getRoute());

 

} else {

list = getQueryDelegate().queryForList(

getStatementId(entityClass, pageQuerySqlId),

parameterObject,getRoute());

}

return new Page(startIndex, totalCount, limit, list);

}

 

/**

* get statement id in SQL Map file

* @param entityClass

*            entity class

* @param suffix

*            suffix

* @return statement id

*/

private String getStatementId(Class entityClass, String suffix) {

String className = entityClass.getName();

String shortName = className.replace(entityClass.getPackage().getName()

+ ".", "");

return shortName.toLowerCase() + suffix;

}

 

public <T> List<T> queryForList(Class<T> entityClass, String statementId,

Object parameters) {

return getQueryDelegate().queryForList(

getStatementId(entityClass, statementId), parameters,getRoute());

}

 

public <T> T queryForObject(Class<T> entityClass, String statementId,

Object parameters) {

return (T) getQueryDelegate().queryForObject(

getStatementId(entityClass, statementId), parameters,getRoute());

}

 

public Integer update(Class entityClass, String statementId, Object parameters) {

Integer result = -1;

result = (Integer)getEntityDelegate().update(

getStatementId(entityClass, statementId), parameters,getRoute());

return result;

}

}

 

分享到:
评论

相关推荐

    基于spring MVC 和 MyBatis 泛型的代码生成模板,可以根据自己的需求修改

    它利用Java的泛型特性实现了通用的DAO层,结合Spring MVC和MyBatis的灵活性,帮助开发者快速构建Web应用的后台逻辑。对于初学者而言,理解这两个框架的原理以及如何结合使用,是提升开发技能的关键步骤;对于有经验...

    泛型dao

    【泛型DAO】是一种在Java开发中常见的设计模式,它利用了Java泛型特性来提高代码的可重用性和类型安全性。在Java中,DAO(Data Access Object)模式是用来封装对数据库的操作,将业务逻辑与数据访问逻辑分离,使得...

    泛型DAO,注释详细

    接下来,我们可以使用Hibernate或MyBatis等持久层框架实现这个泛型DAO。以Hibernate为例,一个简单的实现可能如下: ```java public class HibernateGenericDAO, ID extends Serializable&gt; implements GenericDAO, ...

    Java Web程序运用中泛型DAO的作用.pdf

    Java Web程序中泛型DAO(Data Access Object)模式的应用与作用主要体现在提高程序的运算性能、安全性以及系统架构的复用性、拓展性和可维护性上。泛型DAO模式是基于Java泛型技术的一种设计模式,它在数据访问层提供...

    Mybatis通用DAO设计封装(mybatis)

    Mybatis通用DAO设计封装主要涉及的是在Java开发中如何高效地使用Mybatis框架进行数据库操作。Mybatis是一款轻量级的持久层框架,它避免了几乎所有的JDBC代码和手动设置参数以及获取结果集。通过提供自定义SQL、存储...

    ssh整合下的通用泛型DAO+分页

    在这个特定的讨论中,我们聚焦于SSH1中的一个关键概念:通用泛型DAO(Data Access Object)以及分页功能的实现。DAO层是模型层和数据访问层之间的桥梁,它的主要职责是处理数据库操作,为业务层提供无状态的数据访问...

    mybatis 通用DAO 简单实现

    - **泛型**:使用泛型可以确保DAO方法返回的对象与实体类类型一致,提高了代码的类型安全。 - **事务管理**:通用DAO通常不包含事务控制,需要在服务层(Service Layer)进行事务的开启、提交和回滚。 - **性能优化*...

    基于MAVEN的SpringMVC+Mybatis整合及dao、service强封装

    二、在封装上针对Mybatis进行Dao、service层封装,里面提供两种实现机制:一种采用注解泛型动态实现cud操作,目前查询还是有缺陷;另一种机制采用xml文件形式实现dao、service、controller层封装,具体业务类只需...

    泛型通用DAO,可以很简化DAO层的代码

    例如,我们可以有如下的泛型DAO接口: ```java public interface GenericDao&lt;T&gt; { void save(T entity); T get(Class&lt;T&gt; clazz, int id); void update(T entity); void delete(int id); } ``` 然后,对于特定...

    ssh通用基于泛型的dao

    1. `GenericDAO.java`:泛型DAO接口,定义了基本的CRUD方法。 2. `HibernateGenericDAO.java`:实现了`GenericDAO`接口的具体类,使用Hibernate作为底层的数据访问技术。 3. `BaseDAO.java`:可能是一个抽象类,包含...

    dao.rar_dao

    4. 示例代码:如何在业务逻辑中使用泛型DAO来操作数据库。 使用这样的设计,开发者可以快速地为新的实体类型创建DAO,减少了重复的代码编写,并且由于DAO层的解耦,可以更方便地更换底层的持久化技术,比如从...

    ssh2 + dao泛型

    在SSH2框架中,我们可以利用Spring的JdbcTemplate或MyBatis等工具来实现DAO层的泛型化。这些工具提供了强大的SQL执行能力,与泛型结合可以大大减少代码量,避免了重复的模板代码。例如,我们可以定义一个泛型方法`...

    SSH泛型代码实例

    - `DAO(1).rar`可能包含使用泛型的DAO设计模式示例,展示了如何创建泛型DAO以处理不同类型的数据对象。 综上所述,SSH框架结合泛型能够提升Java应用的开发效率和代码质量。通过学习和理解这些示例,开发者可以更好...

    通用DAO

    1. **创建泛型DAO接口**:定义一个泛型接口,如`GenericDAO&lt;T&gt;`,其中T代表数据库实体类型。 2. **实现DAO接口**:在实现类中,使用反射获取实体类的字段信息,构造SQL语句。 3. **执行SQL操作**:使用JDBC或其他ORM...

    iBatis和MyBatis对比

    MyBatis不仅继承了iBatis的优点,还引入了更多的增强功能,如泛型和注解的支持,使得框架更加现代化和易于使用。MyBatis的出现意味着iBatis的升级,它不再仅仅是SQL映射框架,而是发展成一个更全面的ORM解决方案。 ...

    MyBatis中英文文档.tar.gz

    前者是MyBatis的官方中文用户指南,详细介绍了MyBatis的安装、配置、映射文件的编写、事务管理等内容,是学习和使用MyBatis的重要参考资料。后者则是iBatis的英文教程,对于理解iBatis的工作原理和对比MyBatis的新...

    Java反射泛型,实现数据库的动态增删改查等功能

    在动态数据库操作中,泛型可以用来创建通用的DAO(数据访问对象)接口和实现,以处理不同类型的实体对象。例如,我们可以定义一个`GenericDAO&lt;T&gt;`接口,其中`T`代表任何数据模型类。这个接口可以包含`insert(T ...

    mybatis 通用mapper

    这个接口需要继承自通用Mapper提供的`Mapper&lt;T&gt;`接口,其中`T`表示泛型,代表具体的实体类型。此外,还可以选择性地继承`MySqlMapper&lt;T&gt;`接口,以获得更多的方法支持。 3. **配置拦截器** 在MyBatis配置文件中...

    万能javaDAO

    - **泛型使用**:为了增强类型安全和减少代码冗余,万能DAO可能使用Java泛型,允许开发者指定操作的数据实体类型。 - **动态SQL**:使用如MyBatis或JPA等框架,允许动态生成针对不同数据库的SQL语句,以实现数据库...

Global site tag (gtag.js) - Google Analytics