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;
}
}
相关推荐
它利用Java的泛型特性实现了通用的DAO层,结合Spring MVC和MyBatis的灵活性,帮助开发者快速构建Web应用的后台逻辑。对于初学者而言,理解这两个框架的原理以及如何结合使用,是提升开发技能的关键步骤;对于有经验...
【泛型DAO】是一种在Java开发中常见的设计模式,它利用了Java泛型特性来提高代码的可重用性和类型安全性。在Java中,DAO(Data Access Object)模式是用来封装对数据库的操作,将业务逻辑与数据访问逻辑分离,使得...
接下来,我们可以使用Hibernate或MyBatis等持久层框架实现这个泛型DAO。以Hibernate为例,一个简单的实现可能如下: ```java public class HibernateGenericDAO, ID extends Serializable> implements GenericDAO, ...
Java Web程序中泛型DAO(Data Access Object)模式的应用与作用主要体现在提高程序的运算性能、安全性以及系统架构的复用性、拓展性和可维护性上。泛型DAO模式是基于Java泛型技术的一种设计模式,它在数据访问层提供...
Mybatis通用DAO设计封装主要涉及的是在Java开发中如何高效地使用Mybatis框架进行数据库操作。Mybatis是一款轻量级的持久层框架,它避免了几乎所有的JDBC代码和手动设置参数以及获取结果集。通过提供自定义SQL、存储...
在这个特定的讨论中,我们聚焦于SSH1中的一个关键概念:通用泛型DAO(Data Access Object)以及分页功能的实现。DAO层是模型层和数据访问层之间的桥梁,它的主要职责是处理数据库操作,为业务层提供无状态的数据访问...
- **泛型**:使用泛型可以确保DAO方法返回的对象与实体类类型一致,提高了代码的类型安全。 - **事务管理**:通用DAO通常不包含事务控制,需要在服务层(Service Layer)进行事务的开启、提交和回滚。 - **性能优化*...
二、在封装上针对Mybatis进行Dao、service层封装,里面提供两种实现机制:一种采用注解泛型动态实现cud操作,目前查询还是有缺陷;另一种机制采用xml文件形式实现dao、service、controller层封装,具体业务类只需...
例如,我们可以有如下的泛型DAO接口: ```java public interface GenericDao<T> { void save(T entity); T get(Class<T> clazz, int id); void update(T entity); void delete(int id); } ``` 然后,对于特定...
1. `GenericDAO.java`:泛型DAO接口,定义了基本的CRUD方法。 2. `HibernateGenericDAO.java`:实现了`GenericDAO`接口的具体类,使用Hibernate作为底层的数据访问技术。 3. `BaseDAO.java`:可能是一个抽象类,包含...
4. 示例代码:如何在业务逻辑中使用泛型DAO来操作数据库。 使用这样的设计,开发者可以快速地为新的实体类型创建DAO,减少了重复的代码编写,并且由于DAO层的解耦,可以更方便地更换底层的持久化技术,比如从...
在SSH2框架中,我们可以利用Spring的JdbcTemplate或MyBatis等工具来实现DAO层的泛型化。这些工具提供了强大的SQL执行能力,与泛型结合可以大大减少代码量,避免了重复的模板代码。例如,我们可以定义一个泛型方法`...
- `DAO(1).rar`可能包含使用泛型的DAO设计模式示例,展示了如何创建泛型DAO以处理不同类型的数据对象。 综上所述,SSH框架结合泛型能够提升Java应用的开发效率和代码质量。通过学习和理解这些示例,开发者可以更好...
1. **创建泛型DAO接口**:定义一个泛型接口,如`GenericDAO<T>`,其中T代表数据库实体类型。 2. **实现DAO接口**:在实现类中,使用反射获取实体类的字段信息,构造SQL语句。 3. **执行SQL操作**:使用JDBC或其他ORM...
MyBatis不仅继承了iBatis的优点,还引入了更多的增强功能,如泛型和注解的支持,使得框架更加现代化和易于使用。MyBatis的出现意味着iBatis的升级,它不再仅仅是SQL映射框架,而是发展成一个更全面的ORM解决方案。 ...
前者是MyBatis的官方中文用户指南,详细介绍了MyBatis的安装、配置、映射文件的编写、事务管理等内容,是学习和使用MyBatis的重要参考资料。后者则是iBatis的英文教程,对于理解iBatis的工作原理和对比MyBatis的新...
在动态数据库操作中,泛型可以用来创建通用的DAO(数据访问对象)接口和实现,以处理不同类型的实体对象。例如,我们可以定义一个`GenericDAO<T>`接口,其中`T`代表任何数据模型类。这个接口可以包含`insert(T ...
这个接口需要继承自通用Mapper提供的`Mapper<T>`接口,其中`T`表示泛型,代表具体的实体类型。此外,还可以选择性地继承`MySqlMapper<T>`接口,以获得更多的方法支持。 3. **配置拦截器** 在MyBatis配置文件中...
- **泛型使用**:为了增强类型安全和减少代码冗余,万能DAO可能使用Java泛型,允许开发者指定操作的数据实体类型。 - **动态SQL**:使用如MyBatis或JPA等框架,允许动态生成针对不同数据库的SQL语句,以实现数据库...