jdk1.5的推出为我们带来了枚举、泛型、foreach循环、同步工具包等等好东西。其中,泛型的使用为我们的代码开发提供了很大的简便,简化了我们的代码。
1、设计思路
1)GenericDao泛型类提供所有的增删改查功能;
2)所有的dao在继承GenericDao泛型类拥有自身的增删改查功能,不需再写其他代码。
2、实现GenericDao
- public abstract class GenericDao<T, PK extends Serializable> {
- protected final Logger logger = LoggerFactory.getLogger(getClass());
- public static final String POSTFIX_SELECTBYID = ".selectById";
- public static final String POSTFIX_SELECTBYIDS = ".selectByIds";
- public static final String POSTFIX_SELECTBYMAP = ".selectByMap";
- public static final String POSTFIX_SELECTIDSLIKEBYMAP = ".selectIdsLikeByMap";
- public static final String POSTFIX_PKSELECTMAP = ".pkSelectByMap";
- public static final String POSTFIX_COUNT = ".count";
- public static final String POSTFIX_COUNTLIKEBYMAP = ".countLikeByMap";
- public static final String POSTFIX_INSERT = ".insert";
- public static final String POSTFIX_DELETEBYID = ".deleteById";
- public static final String POSTFIX_DELETEBYIDS = ".deleteByIds";
- public static final String POSTFIX_DELETEBYIDSMAP = ".deleteByIdsMap";
- public static final String POSTFIX_DELETEBYMAP = ".deleteByMap";
- public static final String POSTFIX_UPDATE = ".update";
- public static final String POSTFIX_UPDATEBYMAP = ".updateByMap";
- public static final String POSTFIX_UPDATEBYIDSMAP = ".updateByIdsMap";
- protected Class<T> clazz;
- protected String clazzName;
- protected T t;
- // 定义主从数据库服务器,主数据库负责(Write op),从数据库负责(read op)
- @Autowired
- protected SqlMapClientTemplate masterSqlMapClientTemplate;
- @Autowired
- protected SqlMapClientTemplate slaveSqlMapClientTemplate;
- public GenericDao() {
- // 通过范型反射,取得在子类中定义的class.
- clazz = (Class<T>) ((ParameterizedType) getClass().getGenericSuperclass()).getActualTypeArguments()[0];
- clazzName = clazz.getSimpleName();
- }
- public Integer count(String propertyName, Object propertyValue) {
- return count(new String[]{propertyName},new Object[]{propertyValue});
- }
- public Integer count(String[] propertyNames, Object[] propertyValues) {
- Map<String, Object> map = new HashMap<String, Object>();
- for (int i = 0; i < propertyNames.length; i++) {
- map.put(propertyNames[i], propertyValues[i]);
- }
- return (Integer) slaveSqlMapClientTemplate.queryForObject(clazz.getName() + POSTFIX_COUNT, map);
- }
- @Override
- public Integer countLikeByMap(String[] propertyNames, Object[] propertyValues) {
- Map<String, Object> map = new HashMap<String, Object>();
- for (int i = 0; i < propertyNames.length; i++) {
- map.put(propertyNames[i], propertyValues[i]);
- }
- return (Integer) slaveSqlMapClientTemplate.queryForObject(clazz.getName() + POSTFIX_COUNTLIKEBYMAP, map);
- }
- /** 根据自定义SqlMap中的条件语句查询出记录数量 */
- public Integer countByStatementPostfix(String statementPostfix,String[] properties, Object[] propertyValues){
- Map<String, Object> map = new HashMap<String, Object>();
- for (int i = 0; i < properties.length; i++) {
- map.put(properties[i], propertyValues[i]);
- }
- return (Integer) slaveSqlMapClientTemplate.queryForObject(clazz.getName() + statementPostfix, map);
- }
- /**
- * 通过id得到实体对象
- */
- public T findById(PK id) {
- return (T) slaveSqlMapClientTemplate.queryForObject(clazz.getName() + POSTFIX_SELECTBYID, id);
- }
- /**
- * 根据ids获取实体列表
- *
- * @param ids
- * @return
- */
- public List<T> findByIds(List<PK> ids) {
- return (List<T>) slaveSqlMapClientTemplate.queryForList(clazz.getName() + POSTFIX_SELECTBYIDS, ids);
- }
- /**
- * 直接从数据库查询出ids列表(包括符合条件的所有id)
- *
- * @param properties
- * 查询条件字段名
- * @param propertyValues
- * 字段取值
- * @return
- */
- public List<PK> findIdsBy(String[] properties, Object[] propertyValues, String orderBy, String order) {
- Map<String, Object> map = new HashMap<String, Object>();
- for (int i = 0; i < properties.length; i++) {
- map.put(properties[i], propertyValues[i]);
- }
- if (orderBy != null) {
- map.put("orderBy", orderBy);
- map.put("order", order);
- }
- return (List<PK>) slaveSqlMapClientTemplate.queryForList(clazz.getName() + POSTFIX_PKSELECTMAP, map);
- }
- /**
- * 根据条件查询结果
- *
- * @param properties
- * 查询条件名
- * @param propertyValues
- * 查询条件值
- * @return
- */
- public List<T> findByMap(String[] properties, Object[] propertyValues, String orderBy, String order) {
- return (List<T>) slaveSqlMapClientTemplate.queryForList(clazz.getName() + POSTFIX_SELECTBYMAP, map);
- }
- /**
- * 根据条件查询结果的id列表
- *
- * @param properties
- * 查询条件名
- * @param propertyValues
- * 查询条件值
- * @return
- */
- public List<PK> findIdsByMap(String[] properties, Object[] propertyValues, String orderBy, String order) {
- Map<String, Object> map = new HashMap<String, Object>();
- for (int i = 0; i < properties.length; i++) {
- map.put(properties[i], propertyValues[i]);
- }
- if (orderBy != null) {
- map.put("orderBy", orderBy);
- map.put("order", order);
- }
- return (List<PK>) slaveSqlMapClientTemplate.queryForList(clazz.getName() + POSTFIX_PKSELECTMAP, map);
- }
- /**
- * 分页查询(未处理缓存)
- *
- * @param properties
- * 查询条件字段名
- * @param propertyValues
- * 字段取值
- * @return
- */
- public List<T> pageQueryBy(String[] properties, Object[] propertyValues, String orderBy, String order, int pageSize, int pageNo) {
- Map<String, Object> map = new HashMap<String, Object>();
- for (int i = 0; i < properties.length; i++) {
- map.put(properties[i], propertyValues[i]);
- }
- if (orderBy != null) {
- map.put("orderBy", orderBy);
- map.put("order", order);
- }
- map.put("limit", true);
- map.put("start", (pageNo - 1) * pageSize );// limit 操作
- map.put("end", pageSize);
- return (List<T>) slaveSqlMapClientTemplate.queryForList(clazz.getName() + POSTFIX_SELECTBYMAP, map);
- }
- /**
- * 从数据库分页查询出ids列表的前200个id
- *
- * @param properties
- * 查询条件字段名
- * @param propertyValues
- * 字段取值
- * @return
- */
- protected List<PK> pageQueryIdsBy(String[] properties, Object[] propertyValues, String orderBy, String order) {
- Map<String, Object> map = new HashMap<String, Object>();
- for (int i = 0; i < properties.length; i++) {
- map.put(properties[i], propertyValues[i]);
- }
- if (orderBy != null) {
- map.put("orderBy", orderBy);
- map.put("order", order);
- }
- map.put("limit", true);
- map.put("start", 0);// 操作
- map.put("end", Config.getInstance().getPageCacheSize());
- return (List<PK>) slaveSqlMapClientTemplate.queryForList(clazz.getName() + POSTFIX_PKSELECTMAP, map);
- }
- /**
- * 分页查询出id列表(处理缓存)
- *
- * @param properties
- * 查询条件字段名
- * @param propertyValues
- * 字段取值
- * @return
- */
- public List<PK> pageQueryIdsByMap(String[] properties, Object[] propertyValues, String orderBy, String order, int pageSize, int pageNo) {
- Map<String, Object> map = new HashMap<String, Object>();
- for (int i = 0; i < properties.length; i++) {
- map.put(properties[i], propertyValues[i]);
- }
- if (orderBy != null) {
- map.put("orderBy", orderBy);
- map.put("order", order);
- }
- map.put("limit", true);
- map.put("start", (pageNo - 1) * pageSize );// limit 操作
- map.put("end", pageSize);
- return (List<PK>) slaveSqlMapClientTemplate.queryForList(clazz.getName() + POSTFIX_PKSELECTMAP, map);
- }
- /** like分页查询(不走列表缓存) */
- public List<T> pageLikeBy(String[] properties, Object[] propertyValues, String orderBy, String order, int pageSize, int pageNo){
- Map<String, Object> map = new HashMap<String, Object>();
- for (int i = 0; i < properties.length; i++) {
- map.put(properties[i], propertyValues[i]);
- }
- if (orderBy != null) {
- map.put("orderBy", orderBy);
- map.put("order", order);
- }
- map.put("limit", true);
- map.put("start", (pageNo - 1) * pageSize );// limit 操作
- map.put("end", pageSize);
- List<PK> ids = (List<PK>) slaveSqlMapClientTemplate.queryForList(clazz.getName() + POSTFIX_SELECTIDSLIKEBYMAP, map);
- return findByIds(ids);
- }
- /**
- * 新增对象
- */
- public Serializable insert(T o) throws Exception {
- if (t instanceof QueryCachable) {
- // 清除受影响的缓存
- clearListCache(o);
- }
- return (Serializable) masterSqlMapClientTemplate.insert(clazz.getName() + POSTFIX_INSERT, o);
- }
- /**
- * 更新对象
- */
- public T update(T o) throws Exception {
- masterSqlMapClientTemplate.update(clazz.getName() + POSTFIX_UPDATE, o);
- return o;
- }
- /**
- * 更新对象的部分属性
- */
- public int update(PK id, String[] properties, Object[] propertyValues) throws Exception {
- // 更新数据库
- Map<String, Object> map = new HashMap<String, Object>();
- for (int i = 0; i < properties.length; i++) {
- map.put(properties[i], propertyValues[i]);
- }
- map.put("id", id);
- return masterSqlMapClientTemplate.update(clazz.getName() + POSTFIX_UPDATEBYMAP, map);
- }
- /**
- * 根据ID列表更新对象的部分属性
- */
- public int updateByIdsMap(List<PK> ids,String[] properties, Object[] propertyValues) throws Exception{
- // 更新数据库
- Map<String, Object> map = new HashMap<String, Object>();
- for (int i = 0; i < properties.length; i++) {
- map.put(properties[i], propertyValues[i]);
- }
- map.put("ids", ids);
- return masterSqlMapClientTemplate.update(clazz.getName() + POSTFIX_UPDATEBYIDSMAP, map);
- }
- /**
- * 根据ID删除对象
- */
- public void deleteById(PK id) throws Exception {
- masterSqlMapClientTemplate.delete(clazz.getName() + POSTFIX_DELETEBYID, id);
- }
- /**
- * 根据ID删除对象
- */
- public void deleteByIds(List<PK> ids) throws Exception {
- masterSqlMapClientTemplate.delete(clazz.getName() + POSTFIX_DELETEBYIDS, ids);
- }
- /** 根据ID及条件删除对象 */
- public void deleteByIdsMap(List<PK> ids, String[] properties, Object[] propertyValues) throws Exception {
- Map<String, Object> map = new HashMap<String, Object>();
- for (int i = 0; i < properties.length; i++) {
- map.put(properties[i], propertyValues[i]);
- }
- map.put("ids", ids);
- masterSqlMapClientTemplate.delete(clazz.getName() + POSTFIX_DELETEBYIDSMAP, map);
- }
- /**
- * 根据条件删除对象
- */
- public int deleteByMap(String[] properties, Object[] propertyValues) throws Exception {
- Map<String, Object> map = new HashMap<String, Object>();
- for (int i = 0; i < properties.length; i++) {
- map.put(properties[i], propertyValues[i]);
- }
- return masterSqlMapClientTemplate.delete(clazz.getName() + POSTFIX_DELETEBYMAP, map);
- }
- /**
- * 根据自定义SqlMap中的条件语句查询出列表(注意:不处理缓存)
- */
- public List<T> findByStatementPostfix(String statementPostfix, String[] properties, Object[] propertyValues, String orderBy, String order) {
- Map<String, Object> map = new HashMap<String, Object>();
- for (int i = 0; i < properties.length; i++) {
- map.put(properties[i], propertyValues[i]);
- }
- if (orderBy != null) {
- map.put("orderBy", orderBy);
- map.put("order", order);
- }
- return slaveSqlMapClientTemplate.queryForList(clazz.getName() + statementPostfix, map);
- }
- /**
- * 根据自定义SqlMap中的条件语句查询出列表(注意:不处理缓存)
- */
- public List<T> pageQueryByStatementPostfix(String statementPostfix, String[] properties, Object[] propertyValues, String orderBy, String order,int pageSize,int pageNo) {
- Map<String, Object> map = new HashMap<String, Object>();
- for (int i = 0; i < properties.length; i++) {
- map.put(properties[i], propertyValues[i]);
- }
- if (orderBy != null) {
- map.put("orderBy", orderBy);
- map.put("order", order);
- }
- map.put("limit", true);
- map.put("start", (pageNo - 1) * pageSize );// limit 操作
- map.put("end", pageSize);
- List<PK> ids = (List<PK>) slaveSqlMapClientTemplate.queryForList(clazz.getName() + statementPostfix, map);
- return findByIds(ids);
- }
- /**
- * 根据自定义SqlMap中的条件语句更新数据(注意:不处理缓存)
- */
- public void updateByStatementPostfix(String statementPostfix, String[] properties, Object[] propertyValues) {
- Map<String, Object> map = new HashMap<String, Object>();
- for (int i = 0; i < properties.length; i++) {
- map.put(properties[i], propertyValues[i]);
- }
- masterSqlMapClientTemplate.update(clazz.getName() + statementPostfix, map);
- }
- /**
- * 根据自定义SqlMap中的条件语句删除数据(注意:不处理缓存)
- */
- public void deleteByStatementPostfix(String statementPostfix, String[] properties, Object[] propertyValues) {
- Map<String, Object> map = new HashMap<String, Object>();
- for (int i = 0; i < properties.length; i++) {
- map.put(properties[i], propertyValues[i]);
- }
- masterSqlMapClientTemplate.delete(clazz.getName() + statementPostfix, map);
- }
- /**
- * 根据自定义SqlMap中的条件语句插入数据(注意:不处理缓存)
- */
- public void insertByStatementPostfix(String statementPostfix, String[] properties, Object[] propertyValues) {
- Map<String, Object> map = new HashMap<String, Object>();
- for (int i = 0; i < properties.length; i++) {
- map.put(properties[i], propertyValues[i]);
- }
- masterSqlMapClientTemplate.insert(clazz.getName() + statementPostfix, map);
- }
- }
3、所有其他Dao只需继承GenericDao,不需再写增删改查的方法
- package com.teacherclub.business.album.dao;
- import org.springframework.stereotype.Repository;
- import com.teacherclub.business.album.entity.Album;
- import com.teacherclub.core.mem.MemcacheUtil;
- import com.teacherclub.core.orm.EntityCachable;
- import com.teacherclub.core.orm.dao.impl.GenericDao;
- @Repository
- public class AlbumDao extends GenericDao<Album,Integer> {
- }
此泛型的实现,关键在于:clazz = (Class<T>) ((ParameterizedType) getClass().getGenericSuperclass()).getActualTypeArguments()[0];
相关推荐
它利用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, ...
3. **增强复用性**:泛型DAO模式使得数据访问层更加通用,可以方便地应用于不同的业务场景,减少了代码的重复编写。 4. **提升拓展性**:当添加新的数据实体类时,只需简单地声明新的实体类类型,而无需修改已有的...
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`:可能是一个抽象类,包含...
在实际应用中,我们可以为JXVA框架提供一个泛型DAO的实现,如`HibernateGenericDAO`或`MyBatisGenericDAO`,利用ORM(对象关系映射)工具如Hibernate或MyBatis进行数据库操作。这些实现类将处理与具体数据库系统的...
在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配置文件中...
在Java编程中,反射、注解(Annotation)和泛型是三个非常重要的特性,它们各自在不同的场景下发挥着关键作用。这篇博文“利用java反射、注解及泛型模拟ORM实现”旨在探讨如何结合这三种技术来实现对象关系映射(ORM...