跟我学Spring3（11.2）：SSH集成开发积分商城之实现通用层

package cn.javass.commons; public class Constants {     public static final int DEFAULT_PAGE_SIZE = 5;  //默认分页大小     public static final String DEFAULT_PAGE_NAME = "page";     public static final String CONTEXT_PATH = "ctx"; }

package cn.javass.commons.pagination; import java.util.Collections; import java.util.List; public class Page<E> {/** 表示分页中的一页。*/     private boolean hasPre; //是否有上一页     private boolean hasNext; //是否有下一页     private List<E> items; //当前页包含的记录列表     private int index; //当前页页码(起始为1)     //省略setter     public int getIndex() {         return this.index;     }     public boolean isHasPre() {         return this.hasPre;     }     public boolean isHasNext() {         return this.hasNext;     }     public List<E> getItems() {         return this.items == null ? Collections.<E>emptyList() : this.items;     } }

package cn.javass.commons.dao; import java.io.Serializable; import java.util.List; public interface IBaseDao<M extends Serializable, PK extends Serializable> {     public void save(M model);// 保存模型对象     public void saveOrUpdate(M model);// 保存或更新模型对象     public void update(M model);// 更新模型对象     public void merge(M model);// 合并模型对象状态到底层会话     public void delete(PK id);// 根据主键删除模型对象     public M get(PK id);// 根据主键获取模型对象     public int countAll();//统计模型对象对应数据库表中的记录数     public List<M> listAll();//查询所有模型对象     public List<M> listAll(int pn, int pageSize);// 分页获取所有模型对象 }

package cn.javass.commons.dao.hibernate; //为节省篇幅省略import public abstract class BaseHibernateDao<M extends Serializable, PK extends Serializable> extends HibernateDaoSupport implements IBaseDao<M, PK> {     private Class<M> entityClass;     private String HQL_LIST_ALL;     private String HQL_COUNT_ALL;     @SuppressWarnings("unchecked")     public void init() {//通过初始化方法在依赖注入完毕时生成HQL         //1、通过反射获取注解“M”（即模型对象）的类类型         this.entityClass = (Class<M>) ((ParameterizedType) getClass().getGenericSuperclass()).getActualTypeArguments()[0];         //2、得到模型对象的实体名         String entityName = getSessionFactory().getClassMetadata(this.entityClass).getEntityName();         //3、根据实体名生成HQL         HQL_LIST_ALL = "from " + entityName;         HQL_COUNT_ALL = " select count(*) from " + entityName;     }     protected String getListAllHql() {//获取查询所有记录的HQL         return HQL_LIST_ALL;     }     protected String getCountAllHql() {//获取统计所有记录的HQL         return HQL_COUNT_ALL;    }    public void save(M model) {         getHibernateTemplate().save(model);    }    public void saveOrUpdate(M model) {         getHibernateTemplate().saveOrUpdate(model);    }    public void update(M model) {         getHibernateTemplate().update(model);    }     public void merge(M model) {         getHibernateTemplate().merge(model);    }    public void delete(PK id) {         getHibernateTemplate().delete(this.get(id));    }    public M get(PK id) {         return getHibernateTemplate().get(this.entityClass, id);    }    public int countAll() {         Number total = unique(getCountAllHql());         return total.intValue();   }    public List<M> listAll() {         return list(getListAllHql());    }    public List<M> listAll(int pn, int pageSize) {         return list(getListAllHql(), pn, pageSize);    }    protected <T> List<T> list(final String hql, final Object... paramlist) {        return list(hql, -1, -1, paramlist);//查询所有记录    }     /** 通用列表查询,当pn<=-1 且 pageSize<=-1表示查询所有记录      * @param <T> 模型类型      * @param hql Hibernate查询语句      * @param pn  页码 从1开始，      * @param pageSize 每页记录数      * @param paramlist 可变参数列表      * @return 模型对象列表      */     @SuppressWarnings("unchecked")    protected <T> List<T> list(final String hql, final int pn, final int pageSize, final Object... paramlist) {            return getHibernateTemplate().         executeFind(new HibernateCallback<List<T>>() {             public List<T> doInHibernate(Session session)  throws HibernateException, SQLException {                 Query query = session.createQuery(hql);                 if (paramlist != null) {                     for (int i = 0; i < paramlist.length; i++) {                         query.setParameter(i, paramlist[i]);//设置占位符参数                     }                 }                 if (pn > -1 && pageSize > -1) {//分页处理                     query.setMaxResults(pageSize);//设置将获取的最大记录数                     int start = PageUtil.getPageStart(pn, pageSize);                     if(start != 0) {                         query.setFirstResult(start);//设置记录开始位置                     }                 }                 return query.list();             }         });     }    /**  根据查询条件返回唯一一条记录      * @param <T> 返回类型      * @param hql Hibernate查询语句      * @param paramlist 参数列表      * @return 返回唯一记录 */     @SuppressWarnings("unchecked")     protected <T> T unique(final String hql, final Object... paramlist) {         return getHibernateTemplate().execute(new HibernateCallback<T>() {             public T doInHibernate(Session session) throws HibernateException, SQLException {                 Query query = session.createQuery(hql);                 if (paramlist != null) {                     for (int i = 0; i < paramlist.length; i++) {                         query.setParameter(i, paramlist[i]);                     }                 }                 return (T) query.setMaxResults(1).uniqueResult();             }         });    }    //省略部分可选的便利方法，想了解更多请参考源代码 }

package cn.javass.commons.service; //由于篇幅问题省略import public interface IBaseService<M extends Serializable, PK extends Serializable> {     public M save(M model); //保存模型对象     public void saveOrUpdate(M model);// 保存或更新模型对象     public void update(M model);// 更新模型对象     public void merge(M model);// 合并模型对象状态     public void delete(PK id);// 删除模型对象     public M get(PK id);// 根据主键获取模型对象     public int countAll();//统计模型对象对应数据库表中的记录数     public List<M> listAll();//获取所有模型对象     public Page<M> listAll(int pn);// 分页获取默认分页大小的所有模型对象     public Page<M> listAll(int pn, int pageSize);// 分页获取所有模型对象 }

package cn.javass.commons.service.impl; //由于篇幅问题省略import public abstract class BaseServiceImpl<M extends Serializable, PK extends Serializable> implements IBaseService<M, PK> {     protected IBaseDao<M, PK> dao;     public void setDao(IBaseDao<M, PK> dao) {//需要依赖注入         this.dao = dao;     }     public IBaseDao<M, PK> getDao() {         return this.dao;     }     public M save(M model) {         getDao().save(model);         return model;     }     public void merge(M model) {         getDao().merge(model);     }     public void saveOrUpdate(M model) {         getDao().saveOrUpdate(model);     }     public void update(M model) {         getDao().update(model);     }     public void delete(PK id) {         getDao().delete(id);     }     public void deleteObject(M model) {         getDao().deleteObject(model);     }     public M get(PK id) {         return getDao().get(id);     }     public int countAll() {         return getDao().countAll();     }     public List<M> listAll() {         return getDao().listAll();     }     public Page<M> listAll(int pn) {         return this.listAll(pn, Constants.DEFAULT_PAGE_SIZE);     }     public Page<M> listAll(int pn, int pageSize) {         Integer count = countAll();         List<M> items = getDao().listAll(pn, pageSize);         return PageUtil.getPage(count, pn, items, pageSize);     } }

package cn.javass.commons.web.action; import cn.javass.commons.Constants; //省略import public class BaseAction extends ActionSupport {     /** 通用Result */     public static final String LIST = "list";     public static final String REDIRECT = "redirect";     public static final String ADD = "add";     /** 模型对象属性名*/     public static final String MODEL = "model";     /** 列表模型对象属性名*/     public static final String PAGE = Constants.DEFAULT_PAGE_NAME;     public static final int DEFAULT_PAGE_SIZE = Constants.DEFAULT_PAGE_SIZE;     private int pn = 1;  /** 页码，默认为1 */     //省略pn的getter和setter，自己补上     public ActionContext getActionContext() {         return ActionContext.getContext();     }     public ValueStack getValueStack() {//获取值栈的便利方法         return getActionContext().getValueStack();     } }

<%@ page language="java" pageEncoding="UTF-8" contentType="text/html; charset=UTF-8"%> <!DOCTYPE html PUBLIC "-//W3C//DTD HTML 4.01 Transitional//EN" "http://www.w3.org/TR/html4/loose.dtd"> <html> <head>     <meta http-equiv="Content-Type" content="text/html; charset=UTF-8">     <title>${param.title}</title> </head> <body>

</body> </html>

<%@taglib prefix="c" uri="http://java.sun.com/jstl/core" %> <%@taglib prefix="s" uri="/struts-tags" %

<%@ page language="java" pageEncoding="UTF-8" contentType="text/html; charset=UTF-8"%> <jsp:include page="inc/header.jsp"/> 失败或遇到异常！ <jsp:include page="inc/footer.jsp"/>

<%@ page language="java" pageEncoding="UTF-8" contentType="text/html; charset=UTF-8"%> <jsp:include page="inc/header.jsp"/> 成功！ <jsp:include page="inc/footer.jsp"/>

package cn.javass.commons.web.filter; //省略import /** 用户设置当前web环境上下文，用于方便如JSP页面使用 */ public class ContextPathFilter implements Filter {     @Override     public void init(FilterConfig config) throws ServletException {     }     @Override public void doFilter( ServletRequest request, ServletResponse response, FilterChain chain) throws IOException, ServletException {         String contextPath = ((HttpServletRequest) request).getContextPath();         request.setAttribute(Constants.CONTEXT_PATH, contextPath);         chain.doFilter(request, response);     }     @Override     public void destroy() {     } }

<bean class= "org.springframework.beans.factory.config.PropertyPlaceholderConfigurer"> <property name="locations">             <list>                 <value>classpath:resources.properties</value>             </list>         </property>     </bean>     <bean id="dataSource" class="org.springframework.jdbc.datasource.LazyConnectionDataSourceProxy">         <property name="targetDataSource">             <bean class="org.logicalcobwebs.proxool.ProxoolDataSource">                 <property name="driver" value="${db.driver.class}" />                 <property name="driverUrl" value="${db.url}" />                 <property name="user" value="${db.username}" />                 <property name="password" value="${db.password}" />                 <property name="maximumConnectionCount" value="${proxool.maxConnCount}" />                 <property name="minimumConnectionCount" value="${proxool.minConnCount}" />                 <property name="statistics" value="${proxool.statistics}" />                 <property name="simultaneousBuildThrottle" value="${proxool.simultaneousBuildThrottle}" />                 <property name="trace" value="${proxool.trace}" />             </bean>         </property>     </bean> </beans>

#数据库连接池属性 proxool.maxConnCount=10 proxool.minConnCount=5 proxool.statistics=1m,15m,1h,1d proxool.simultaneousBuildThrottle=30 proxool.trace=false db.driver.class=com.mysql.jdbc.Driver db.url=jdbc:mysql://localhost:3306/point_shop?useUnicode=true&characterEncoding=utf8 db.username=root db.password=

<?xml version="1.0" encoding="UTF-8"?> <!DOCTYPE struts PUBLIC     "-//Apache Software Foundation//DTD Struts Configuration 2.0//EN"     "http://struts.apache.org/dtds/struts-2.0.dtd"> <struts>     <constant name="struts.objectFactory" value="org.apache.struts2.spring.StrutsSpringObjectFactory"/>     <!-- 允许action的名字中出现"/" -->     <constant name="struts.enable.SlashesInActionNames" value="true"/>     <package name="custom-default" extends="struts-default" abstract="true">         <global-results>             <result name="success">/WEB-INF/jsp/common/success.jsp</result>             <result name="error">/WEB-INF/jsp/common/error.jsp</result>             <result name="exception">/WEB-INF/jsp/common/error.jsp</result>         </global-results>         <global-exception-mappings>            <exception-mapping result="exception" exception="java.lang.Exception"/>         </global-exception-mappings>     </package> </struts>

<?xml version="1.0" encoding="UTF-8"?> <!DOCTYPE log4j:configuration SYSTEM "log4j.dtd"> <log4j:configuration xmlns:log4j="http://jakarta.apache.org/log4j/">        <!-- Appenders -->        <appender name="console" class="org.apache.log4j.ConsoleAppender">               <param name="Target" value="System.out" />               <layout class="org.apache.log4j.PatternLayout">                      <param name="ConversionPattern" value="%-5p: %c - %m%n" />               </layout>        </appender>        <!-- Root Logger -->        <root>               <priority value="DEBUG" />               <appender-ref ref="console" />        </root> </log4j:configuration>