在未分享整個查詢分頁的執行代碼之前，先了解一下執行流程。
1.總體上是利用mybatis的插件攔截器，在sql執行之前攔截，為查詢語句加上limit XX
2.用一個Page對象，貫穿整個執行流程，這個Page對象需要用Java編寫前端分頁組件
3.用一套比較完整的三層entity，dao，service支持這個分頁架構
4.這個分頁用到的一些輔助類
注：分享的內容較多，這邊的話我就不把需要的jar一一列舉，大家使用這個分頁功能的時候缺少什麼就去晚上找什麼jar包即可，盡可能用maven包導入因為maven能減少版本衝突等比較好的優勢。
我只能說盡可能讓大家快速使用這個比較好用的分頁功能，如果講得不明白，歡迎加我QQ一起探討1063150576,。莫噴哈！還有就是文章篇幅可能會比較大，不過花點時間，把它看完並實踐一下一定會收穫良多。
第一步：既然主題是圍繞怎麼進行分頁的，我們就從mybatis入手，首先，我們把mybatis相關的兩個比較重要的配置文件拿出來做簡要的理解，一個是mybatis-config.xml，另外一個是實體所對應的mapper配置文件，我會在配置文件上寫好註釋，大家一看就會明白。
mybatis-config.xml
<!DOCTYPE configuration PUBLIC "-//mybatis.org//DTD Config 3.0//EN" "http://mybatis.org/dtd/mybatis-3-config.dtd"> <configuration> <!-- 全局參數--> <settings> <!-- 使全局的映射器啟用或禁用緩存。 --> <setting name="cacheEnabled" value="false"/> <!-- 全局啟用或禁用延遲加載。當禁用時，所有關聯對像都會即時加載。 --> <setting name="lazyLoadingEnabled" value="true"/> <!-- 當啟用時，有延遲加載屬性的對像在被調用時將會完全加載任意屬性。否則，每種屬性將會按需要加載。 --> <setting name="aggressiveLazyLoading" value="true"/> <!-- 是否允許單條sql 返回多個數據集(取決於驅動的兼容性) default:true --> <setting name="multipleResultSetsEnabled" value="true"/> <!-- 是否可以使用列的別名(取決於驅動的兼容性) default:true --> <setting name="useColumnLabel" value="true"/> <!-- 允許JDBC 生成主鍵。需要驅動器支持。如果設為了true，這個設置將強制使用被生成的主鍵，有一些驅動器不兼容不過仍然可以執行。 default:false --> <setting name="useGeneratedKeys" value="false"/> <!-- 指定MyBatis 如何自動映射數據基表的列NONE：不隱射PARTIAL:部分FULL:全部--> <setting name="autoMappingBehavior" value="PARTIAL"/> <!-- 這是默認的執行類型（SIMPLE: 簡單； REUSE: 執行器可能重複使用prepared statements語句；BATCH: 執行器可以重複執行語句和批量更新） --> <setting name="defaultExecutorType" value="SIMPLE"/> <!-- 使用駝峰命名法轉換字段。 --> <setting name="mapUnderscoreToCamelCase" value="true"/> <!-- 設置本地緩存範圍session:就會有數據的共享statement:語句範圍(這樣就不會有數據的共享) defalut:session --> <setting name="localCacheScope" value="SESSION"/> <!-- 設置但JDBC類型為空時,某些驅動程序要指定值,default:OTHER，插入空值時不需要指定類型--> <setting name="jdbcTypeForNull" value="NULL"/> <setting name="logPrefix" value="dao."/> </settings> <!--別名是一個較短的Java 類型的名稱--> <typeAliases> <typeAlias type="com.store.base.model.StoreUser" alias="User"></typeAlias> <typeAlias type="com.store.base.secondmodel.pratice.model.Product" alias="Product"></typeAlias> <typeAlias type="com.store.base.secondmodel.base.Page" alias="Page"></typeAlias> </typeAliases> <!-- 插件配置,這邊為mybatis配置分頁攔截器，這個分頁攔截器需要我們自己實現--> <plugins> <plugin interceptor="com.store.base.secondmodel.base.pageinterceptor.PaginationInterceptor" /> </plugins> </configuration>
一個ProductMapper.xml作為測試對象，這個mapper文件就簡單配置一個需要用到的查詢語句
<?xml version="1.0" encoding="UTF-8" ?> <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd" > <mapper namespace="com.store.base.secondmodel.pratice.dao.ProductDao" > <sql id="baseColumns" > id, product_name as productName, product_no as productNo, price as price </sql> <select id="findList" resultType="com.store.base.secondmodel.pratice.model.Product"> select <include refid="baseColumns"/> from t_store_product </select> </mapper>
第二步：接下去主要針對這個分頁攔截器進行深入分析學習，主要有以下幾個類和其對應接口
（1）BaseInterceptor 攔截器基礎類
（2）PaginationInterceptor 我們要使用的分頁插件類，繼承上面基礎類
（3）SQLHelper 主要是用來提前執行count語句，還有就是獲取整個完整的分頁語句
（4）Dialect，MysqlDialect,主要用來數據庫是否支持limit語句，然後封裝完整limit語句
以下是這幾個類的分享展示
BaseInterceptor.java
package com.store.base.secondmodel.base.pageinterceptor; import java.io.Serializable; import java.util.Properties; import org.apache.ibatis.logging.Log; import org.apache.ibatis.logging.LogFactory; import org.apache.ibatis.plugin.Interceptor; import com.store.base.secondmodel.base.Global; import com.store.base.secondmodel.base.Page; import com.store.base.secondmodel.base.dialect.Dialect; import com.store.base.secondmodel.base.dialect.MySQLDialect; import com.store.base.util.Reflections; /** * Mybatis分頁攔截器基類* @author yiyong_wu * */ public abstract class BaseInterceptor implements Interceptor, Serializable { private static final long serialVersionUID = 1L; protected static final String PAGE = "page"; protected static final String DELEGATE = "delegate"; protected static final String MAPPED_STATEMENT = "mappedStatement"; protected Log log = LogFactory.getLog(this.getClass()); protected Dialect DIALECT; /** * 對參數進行轉換和檢查* @param parameterObject 參數對象* @param page 分頁對象* @return 分頁對象* @throws NoSuchFieldException 無法找到參數*/ @SuppressWarnings("unchecked") protected static Page<Object> convertParameter(Object parameterObject, Page<Object> page) { try{ if (parameterObject instanceof Page) { return (Page<Object>) parameterObject; } else { return (Page<Object>)Reflections.getFieldValue(parameterObject, PAGE); } }catch (Exception e) { return null; } } /** * 設置屬性，支持自定義方言類和製定數據庫的方式* <code>dialectClass</code>,自定義方言類。可以不配置這項* <ode>dbms</ode> 數據庫類型，插件支持的數據庫* <code>sqlPattern</code> 需要攔截的SQL ID * @param p 屬性*/ protected void initProperties(Properties p) { Dialect dialect = null; String dbType = Global.getConfig("jdbc.type"); if("mysql".equals(dbType)){ dialect = new MySQLDialect(); } if (dialect == null) { throw new RuntimeException("mybatis dialect error."); } DIALECT = dialect; } }PaginationInterceptor.java
package com.store.base.secondmodel.base.pageinterceptor; import java.util.Properties; import org.apache.ibatis.executor.Executor; import org.apache.ibatis.mapping.BoundSql; import org.apache.ibatis.mapping.MappedStatement; import org.apache.ibatis.mapping.SqlSource; import org.apache.ibatis.plugin.Intercepts; import org.apache.ibatis.plugin.Invocation; import org.apache.ibatis.plugin.Plugin; import org.apache.ibatis.plugin.Signature; import org.apache.ibatis.reflection.MetaObject; import org.apache.ibatis.session.ResultHandler; import org.apache.ibatis.session.RowBounds; import com.store.base.secondmodel.base.Page; import com.store.base.secondmodel.base.util.StringUtils; import com.store.base.util.Reflections; /** * 數據庫分頁插件，只攔截查詢語句. * @author yiyong_wu * */ @Intercepts({ @Signature(type = Executor.class, method = "query", args = { MappedStatement.class, Object.class, RowBounds.class, ResultHandler.class }) }) public class PaginationInterceptor extends BaseInterceptor { private static final long serialVersionUID = 1L; @Override public Object intercept(Invocation invocation) throws Throwable { final MappedStatement mappedStatement = (MappedStatement) invocation.getArgs()[0]; Object parameter = invocation.getArgs()[1]; BoundSql boundSql = mappedStatement.getBoundSql(parameter); Object parameterObject = boundSql.getParameterObject(); // 獲取分頁參數對象Page<Object> page = null; if (parameterObject != null) { page = convertParameter(parameterObject, page); } // 如果設置了分頁對象，則進行分頁if (page != null && page.getPageSize() != -1) { if (StringUtils.isBlank(boundSql.getSql())) { return null; } String originalSql = boundSql.getSql().trim(); // 得到總記錄數page.setCount(SQLHelper.getCount(originalSql, null,mappedStatement, parameterObject, boundSql, log)); // 分頁查詢本地化對象修改數據庫注意修改實現String pageSql = SQLHelper.generatePageSql(originalSql, page,DIALECT); invocation.getArgs()[2] = new RowBounds(RowBounds.NO_ROW_OFFSET,RowBounds.NO_ROW_LIMIT); BoundSql newBoundSql = new BoundSql( mappedStatement.getConfiguration(), pageSql, boundSql.getParameterMappings(), boundSql.getParameterObject()); // 解決MyBatis 分頁foreach 參數失效start if (Reflections.getFieldValue(boundSql, "metaParameters") != null) { MetaObject mo = (MetaObject) Reflections.getFieldValue( boundSql, "metaParameters"); Reflections.setFieldValue(newBoundSql, "metaParameters", mo); } // 解決MyBatis 分頁foreach 參數失效end MappedStatement newMs = copyFromMappedStatement(mappedStatement,new BoundSqlSqlSource(newBoundSql)); invocation.getArgs()[0] = newMs; } return invocation.proceed(); } @Override public Object plugin(Object target) { return Plugin.wrap(target, this); } @Override public void setProperties(Properties properties) { super.initProperties(properties); } private MappedStatement copyFromMappedStatement(MappedStatement ms, SqlSource newSqlSource) { MappedStatement.Builder builder = new MappedStatement.Builder( ms.getConfiguration(), ms.getId(), newSqlSource, ms.getSqlCommandType()); builder.resource(ms.getResource()); builder.fetchSize(ms.getFetchSize()); builder.statementType(ms.getStatementType()); builder.keyGenerator(ms.getKeyGenerator()); if (ms.getKeyProperties() != null) { for (String keyProperty : ms.getKeyProperties()) { builder.keyProperty(keyProperty); } } builder.timeout(ms.getTimeout()); builder.parameterMap(ms.getParameterMap()); builder.resultMaps(ms.getResultMaps()); builder.cache(ms.getCache()); return builder.build(); } public static class BoundSqlSqlSource implements SqlSource { BoundSql boundSql; public BoundSqlSqlSource(BoundSql boundSql) { this.boundSql = boundSql; } @Override public BoundSql getBoundSql(Object parameterObject) { return boundSql; } } }SQLHelper.java
package com.store.base.secondmodel.base.pageinterceptor; import java.sql.Connection; import java.sql.PreparedStatement; import java.sql.ResultSet; import java.sql.SQLException; import java.util.List; import java.util.regex.Matcher; import java.util.regex.Pattern; import org.apache.ibatis.executor.ErrorContext; import org.apache.ibatis.executor.ExecutorException; import org.apache.ibatis.logging.Log; import org.apache.ibatis.mapping.BoundSql; import org.apache.ibatis.mapping.MappedStatement; import org.apache.ibatis.mapping.ParameterMapping; import org.apache.ibatis.mapping.ParameterMode; import org.apache.ibatis.reflection.MetaObject; import org.apache.ibatis.reflection.property.PropertyTokenizer; import org.apache.ibatis.scripting.xmltags.ForEachSqlNode; import org.apache.ibatis.session.Configuration; import org.apache.ibatis.type.TypeHandler; import org.apache.ibatis.type.TypeHandlerRegistry; import com.store.base.secondmodel.base.Global; import com.store.base.secondmodel.base.Page; import com.store.base.secondmodel.base.dialect.Dialect; import com.store.base.secondmodel.base.util.StringUtils; import com.store.base.util.Reflections; /** * SQL工具類* @author yiyong_wu * */ public class SQLHelper { /** * 默認私有構造函數*/ private SQLHelper() { } /** * 對SQL參數(?)設值,參考org.apache.ibatis.executor.parameter.DefaultParameterHandler * * @param ps 表示預編譯的SQL 語句的對象。 * @param mappedStatement MappedStatement * @param boundSql SQL * @param parameterObject 參數對象* @throws java.sql.SQLException 數據庫異常*/ @SuppressWarnings("unchecked") public static void setParameters(PreparedStatement ps, MappedStatement mappedStatement, BoundSql boundSql, Object parameterObject) throws SQLException { ErrorContext.instance().activity("setting parameters").object(mappedStatement.getParameterMap().getId()); List<ParameterMapping> parameterMappings = boundSql.getParameterMappings(); if (parameterMappings != null) { Configuration configuration = mappedStatement.getConfiguration(); TypeHandlerRegistry typeHandlerRegistry = configuration.getTypeHandlerRegistry(); MetaObject metaObject = parameterObject == null ? null : configuration.newMetaObject(parameterObject); for (int i = 0; i < parameterMappings.size(); i++) { ParameterMapping parameterMapping = parameterMappings.get(i); if (parameterMapping.getMode() != ParameterMode.OUT) { Object value; String propertyName = parameterMapping.getProperty(); PropertyTokenizer prop = new PropertyTokenizer(propertyName); if (parameterObject == null) { value = null; } else if (typeHandlerRegistry.hasTypeHandler(parameterObject.getClass())) { value = parameterObject; } else if (boundSql.hasAdditionalParameter(propertyName)) { value = boundSql.getAdditionalParameter(propertyName); } else if (propertyName.startsWith(ForEachSqlNode.ITEM_PREFIX) && boundSql.hasAdditionalParameter(prop.getName())) { value = boundSql.getAdditionalParameter(prop.getName()); if (value != null) { value = configuration.newMetaObject(value).getValue(propertyName.substring(prop.getName().length())); } } else { value = metaObject == null ? null : metaObject.getValue(propertyName); } @SuppressWarnings("rawtypes") TypeHandler typeHandler = parameterMapping.getTypeHandler(); if (typeHandler == null) { throw new ExecutorException("There was no TypeHandler found for parameter " + propertyName + " of statement " + mappedStatement.getId()); } typeHandler.setParameter(ps, i + 1, value, parameterMapping.getJdbcType()); } } } } /** * 查詢總紀錄數* @param sql SQL語句* @param connection 數據庫連接* @param mappedStatement mapped * @param parameterObject 參數* @param boundSql boundSql * @return 總記錄數* @throws SQLException sql查詢錯誤*/ public static int getCount(final String sql, final Connection connection, final MappedStatement mappedStatement, final Object parameterObject, final BoundSql boundSql, Log log) throws SQLException { String dbName = Global.getConfig("jdbc.type"); final String countSql; if("oracle".equals(dbName)){ countSql = "select count(1) from (" + sql + ") tmp_count"; }else{ countSql = "select count(1) from (" + removeOrders(sql) + ") tmp_count"; } Connection conn = connection; PreparedStatement ps = null; ResultSet rs = null; try { if (log.isDebugEnabled()) { log.debug("COUNT SQL: " + StringUtils.replaceEach(countSql, new String[]{"/n","/t"}, new String[]{" "," "})); } if (conn == null){ conn = mappedStatement.getConfiguration().getEnvironment().getDataSource().getConnection(); } ps = conn.prepareStatement(countSql); BoundSql countBS = new BoundSql(mappedStatement.getConfiguration(), countSql, boundSql.getParameterMappings(), parameterObject); //解決MyBatis 分頁foreach 參數失效start if (Reflections.getFieldValue(boundSql, "metaParameters") != null) { MetaObject mo = (MetaObject) Reflections.getFieldValue(boundSql, "metaParameters"); Reflections.setFieldValue(countBS, "metaParameters", mo); } //解決MyBatis 分頁foreach 參數失效end SQLHelper.setParameters(ps, mappedStatement, countBS, parameterObject); rs = ps.executeQuery(); int count = 0; if (rs.next()) { count = rs.getInt(1); } return count; } finally { if (rs != null) { rs.close(); } if (ps != null) { ps.close(); } if (conn != null) { conn.close(); } } } /** * 根據數據庫方言，生成特定的分頁sql * @param sql Mapper中的Sql語句* @param page 分頁對象* @param dialect 方言類型* @return 分頁SQL */ public static String generatePageSql(String sql, Page<Object> page, Dialect dialect) { if (dialect.supportsLimit()) { return dialect.getLimitString(sql, page.getFirstResult(), page.getMaxResults()); } else { return sql; } } /** * 去除qlString的select子句。 * @param hql * @return */ @SuppressWarnings("unused") private static String removeSelect(String qlString){ int beginPos = qlString.toLowerCase().indexOf("from"); return qlString.substring(beginPos); } /** * 去除hql的orderBy子句。 * @param hql * @return */ private static String removeOrders(String qlString) { Pattern p = Pattern.compile("order//s*by[//w|//W|//s|//S]*", Pattern.CASE_INSENSITIVE); Matcher m = p.matcher(qlString); StringBuffer sb = new StringBuffer(); while (m.find()) { m.appendReplacement(sb, ""); } m.appendTail(sb); return sb.toString(); } }Dialect.java 接口
package com.store.base.secondmodel.base.dialect; /** * 類似hibernate的Dialect,但只精簡出分頁部分* @author yiyong_wu * */ public interface Dialect { /** * 數據庫本身是否支持分頁當前的分頁查詢方式* 如果數據庫不支持的話，則不進行數據庫分頁* * @return true：支持當前的分頁查詢方式*/ public boolean supportsLimit(); /** * 將sql轉換為分頁SQL，分別調用分頁sql * * @param sql SQL語句* @param offset 開始條數* @param limit 每頁顯示多少紀錄條數* @return 分頁查詢的sql */ public String getLimitString(String sql, int offset, int limit); }MySQLDialect.java
package com.store.base.secondmodel.base.dialect; /** * Mysql方言的實現* @author yiyong_wu * */ public class MySQLDialect implements Dialect { @Override public boolean supportsLimit() { return true; } @Override public String getLimitString(String sql, int offset, int limit) { return getLimitString(sql, offset, Integer.toString(offset),Integer.toString(limit)); } /** * 將sql變成分頁sql語句,提供將offset及limit使用佔位符號(placeholder)替換. * <pre> * 如mysql * dialect.getLimitString("select * from user", 12, ":offset",0,":limit") 將返回* select * from user limit :offset,:limit * </pre> * * @param sql 實際SQL語句* @param offset 分頁開始紀錄條數* @param offsetPlaceholder 分頁開始紀錄條數－佔位符號* @param limitPlaceholder 分頁紀錄條數佔位符號* @return 包含佔位符的分頁sql */ public String getLimitString(String sql, int offset, String offsetPlaceholder, String limitPlaceholder) { StringBuilder stringBuilder = new StringBuilder(sql); stringBuilder.append(" limit "); if (offset > 0) { stringBuilder.append(offsetPlaceholder).append(",").append(limitPlaceholder); } else { stringBuilder.append(limitPlaceholder); } return stringBuilder.toString(); } }差不多到這邊已經把整塊分頁怎麼實現的給分享完了，但是我們還有更重要的任務，想要整個東西跑起來，肯定還要有基礎工作要做，接下去我們分析整套Page對像以及它所依據的三層架構，還是用product作為實體進行分析。一整套三層架構講下來，收穫肯定又滿滿的。我們依次從entity->dao->service的順序講下來。
首先，針對我們的實體得繼承兩個抽象實體類BaseEntity 與DataEntity
BaseEntity.java 主要放置Page成員變量，繼承它後就可以每個實體都擁有這個成員變量
package com.store.base.secondmodel.base; import java.io.Serializable; import java.util.Map; import javax.xml.bind.annotation.XmlTransient; import org.apache.commons.lang3.StringUtils; import org.apache.commons.lang3.builder.ReflectionToStringBuilder; import com.fasterxml.jackson.annotation.JsonIgnore; import com.google.common.collect.Maps; import com.store.base.model.StoreUser; /** * 最頂層的Entity * @author yiyong_wu * * @param <T> */ public abstract class BaseEntity<T> implements Serializable { private static final long serialVersionUID = 1L; /** * 刪除標記（0：正常；1：刪除；2：審核；） */ public static final String DEL_FLAG_NORMAL = "0"; public static final String DEL_FLAG_DELETE = "1"; public static final String DEL_FLAG_AUDIT = "2"; /** * 實體編號（唯一標識） */ protected String id; /** * 當前用戶*/ protected StoreUser currentUser; /** * 當前實體分頁對象*/ protected Page<T> page; /** * 自定義SQL（SQL標識，SQL內容） */ private Map<String, String> sqlMap; public BaseEntity() { } public BaseEntity(String id) { this(); this.id = id; } public String getId() { return id; } public void setId(String id) { this.id = id; } /** * 這個主要針對shiro執行插入更新的時候會調用，獲取當前的用戶* @return */ @JsonIgnore @XmlTransient public StoreUser getCurrentUser() { if(currentUser == null){ // currentUser = UserUtils.getUser(); } return currentUser; } public void setCurrentUser(StoreUser currentUser) { this.currentUser = currentUser; } @JsonIgnore @XmlTransient public Page<T> getPage() { if (page == null){ page = new Page<>(); } return page; } public Page<T> setPage(Page<T> page) { this.page = page; return page; } @JsonIgnore @XmlTransient public Map<String, String> getSqlMap() { if (sqlMap == null){ sqlMap = Maps.newHashMap(); } return sqlMap; } public void setSqlMap(Map<String, String> sqlMap) { this.sqlMap = sqlMap; } /** * 插入之前執行方法，子類實現*/ public abstract void preInsert(); /** * 更新之前執行方法，子類實現*/ public abstract void preUpdate(); /** * 是否是新記錄（默認：false），調用setIsNewRecord()設置新記錄，使用自定義ID。 * 設置為true後強制執行插入語句，ID不會自動生成，需從手動傳入。 * @return */ public boolean getIsNewRecord() { return StringUtils.isBlank(getId()); } /** * 全局變量對象*/ @JsonIgnore public Global getGlobal() { return Global.getInstance(); } /** * 獲取數據庫名稱*/ @JsonIgnore public String getDbName(){ return Global.getConfig("jdbc.type"); } @Override public String toString() { return ReflectionToStringBuilder.toString(this); } }DataEntity.java,主要存儲更新刪除時間，創建用戶，更新用戶，邏輯刪除標誌等
package com.store.base.secondmodel.base; import java.util.Date; import org.hibernate.validator.constraints.Length; import com.fasterxml.jackson.annotation.JsonFormat; import com.fasterxml.jackson.annotation.JsonIgnore; import com.store.base.model.StoreUser; /** * 數據Entity * @author yiyong_wu * * @param <T> */ public abstract class DataEntity<T> extends BaseEntity<T> { private static final long serialVersionUID = 1L; protected StoreUser createBy; // 創建者protected Date createDate; // 創建日期protected StoreUser updateBy; // 更新者protected Date updateDate; // 更新日期protected String delFlag; // 刪除標記（0：正常；1：刪除；2：審核） public DataEntity() { super(); this.delFlag = DEL_FLAG_NORMAL; } public DataEntity(String id) { super(id); } /** * 插入之前執行方法，需要手動調用*/ @Override public void preInsert() { // 不限制ID為UUID，調用setIsNewRecord()使用自定義ID // User user = UserUtils.getUser(); // if (StringUtils.isNotBlank(user.getId())) { // this.updateBy = user; // this.createBy = user; // } this.updateDate = new Date(); this.createDate = this.updateDate; } /** * 更新之前執行方法，需要手動調用*/ @Override public void preUpdate() { // User user = UserUtils.getUser(); // if (StringUtils.isNotBlank(user.getId())) { // this.updateBy = user; // } this.updateDate = new Date(); } // @JsonIgnore public StoreUser getCreateBy() { return createBy; } public void setCreateBy(StoreUser createBy) { this.createBy = createBy; } @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss") public Date getCreateDate() { return createDate; } public void setCreateDate(Date createDate) { this.createDate = createDate; } // @JsonIgnore public StoreUser getUpdateBy() { return updateBy; } public void setUpdateBy(StoreUser updateBy) { this.updateBy = updateBy; } @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss") public Date getUpdateDate() { return updateDate; } public void setUpdateDate(Date updateDate) { this.updateDate = updateDate; } @JsonIgnore @Length(min = 1, max = 1) public String getDelFlag() { return delFlag; } public void setDelFlag(String delFlag) { this.delFlag = delFlag; } }Product.java 產品類
package com.store.base.secondmodel.pratice.model; import com.store.base.secondmodel.base.DataEntity; /** *產品基礎類*2016年10月11日*yiyong_wu */ public class Product extends DataEntity<Product>{ private static final long serialVersionUID = 1L; private String productName; private float price; private String productNo; public String getProductName() { return productName; } public void setProductName(String productName) { this.productName = productName; } public float getPrice() { return price; } public void setPrice(float price) { this.price = price; } public String getProductNo() { return productNo; } public void setProductNo(String productNo) { this.productNo = productNo; } }怎麼樣，是不是看到很複雜的一個實體繼承連關係，不過這有什麼，越複雜就會越完整。接下來我就看看dao層，同樣是三層，準備好接受洗禮吧
BaseDao.java 預留接口
package com.store.base.secondmodel.base; /** * 最頂層的DAO接口* @author yiyong_wu * */ public interface BaseDao { } CrudDao.java 針對增刪改查的一個dao接口層[java] view plain copy print?在CODE上查看代碼片派生到我的代碼片package com.store.base.secondmodel.base; import java.util.List; /** * 定義增刪改查的DAO接口* @author yiyong_wu * * @param <T> */ public interface CrudDao<T> extends BaseDao { /** * 獲取單條數據* @param id * @return */ public T get(String id); /** * 獲取單條數據* @param entity * @return */ public T get(T entity); /** * 查詢數據列表，如果需要分頁，請設置分頁對象，如：entity.setPage(new Page<T>()); * @param entity * @return */ public List<T> findList(T entity); /** * 查詢所有數據列表* @param entity * @return */ public List<T> findAllList(T entity); /** * 查詢所有數據列表* @see public List<T> findAllList(T entity) * @return public List<T> findAllList(); */ /** * 插入數據* @param entity * @return */ public int insert(T entity); /** * 更新數據* @param entity * @return */ public int update(T entity); /** * 刪除數據（一般為邏輯刪除，更新del_flag字段為1） * @param id * @see public int delete(T entity) * @return */ public int delete(String id); /** * 刪除數據（一般為邏輯刪除，更新del_flag字段為1） * @param entity * @return */ public int delete(T entity); }ProductDao.java mybatis對應的接口mapper，同時也是dao實現，這邊需要自定一個註解@MyBatisRepository
package com.store.base.secondmodel.pratice.dao; import com.store.base.secondmodel.base.CrudDao; import com.store.base.secondmodel.base.MyBatisRepository; import com.store.base.secondmodel.pratice.model.Product; /** *TODO *2016年10月11日*yiyong_wu */ @MyBatisRepository public interface ProductDao extends CrudDao<Product>{ }自定義註解MyBatisRepository.java，跟自定義註解相關，這裡就不做過多的解讀，網上資料一堆
package com.store.base.secondmodel.base; import java.lang.annotation.Documented; import java.lang.annotation.Retention; import java.lang.annotation.Target; import java.lang.annotation.RetentionPolicy; import java.lang.annotation.ElementType; import org.springframework.stereotype.Component; /** * 標識MyBatis的DAO,方便{@link org.mybatis.spring.mapper.MapperScannerConfigurer}的掃描。 * * 請注意要在spring的配置文件中配置掃描該註解類的配置* *<bean id="mapperScannerConfigurer"> *<property name="sqlSessionFactoryBeanName" value="sqlSessionFactory" /> *<property name="basePackage" value="com.store.base.secondmodel" /> *<property name="annotationClass" value="com.store.base.secondmodel.base.MyBatisRepository" /> *</bean> * @author yiyong_wu * */ @Retention(RetentionPolicy.RUNTIME) @Target(ElementType.TYPE) @Documented @Component public @interface MyBatisRepository { String value() default ""; }注意：跟ProductDao.java聯繫比較大的是ProductMapper.xml文件，大家可以看到上面那個配置文件的namespace是指向這個dao的路徑的。
接下來我們就進入最後的service分析了，一樣還是三層繼承
BaseService.java
package com.store.base.secondmodel.base; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.transaction.annotation.Transactional; /** * Service的最頂層父類* @author yiyong_wu * */ @Transactional(readOnly = true) public abstract class BaseService { //日誌記錄用的protected Logger logger = LoggerFactory.getLogger(getClass()); }CrudService.java 增刪改查相關的業務接口實現
package com.store.base.secondmodel.base; import java.util.List; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.transaction.annotation.Transactional; /** * 增刪改查Service基類* @author yiyong_wu * * @param <D> * @param <T> */ public abstract class CrudService<D extends CrudDao<T>, T extends DataEntity<T>> extends BaseService { /** * 持久層對象*/ @Autowired protected D dao; /** * 獲取單條數據* @param id * @return */ public T get(String id) { return dao.get(id); } /** * 獲取單條數據* @param entity * @return */ public T get(T entity) { return dao.get(entity); } /** * 查詢列表數據* @param entity * @return */ public List<T> findList(T entity) { return dao.findList(entity); } /** * 查詢分頁數據* @param page 分頁對象* @param entity * @return */ public Page<T> findPage(Page<T> page, T entity) { entity.setPage(page); page.setList(dao.findList(entity)); return page; } /** * 保存數據（插入或更新） * @param entity */ @Transactional(readOnly = false) public void save(T entity) { if (entity.getIsNewRecord()){ entity.preInsert(); dao.insert(entity); }else{ entity.preUpdate(); dao.update(entity); } } /** * 刪除數據* @param entity */ @Transactional(readOnly = false) public void delete(T entity) { dao.delete(entity); } }ProductService.java,去繼承CrudService接口，注意起注入dao和實體類型的一種模式
package com.store.base.secondmodel.pratice.service; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional; import com.store.base.secondmodel.base.CrudService; import com.store.base.secondmodel.pratice.dao.ProductDao; import com.store.base.secondmodel.pratice.model.Product; /** *TODO *2016年10月11日*yiyong_wu */ @Service @Transactional(readOnly = true) public class ProductService extends CrudService<ProductDao,Product>{ }我想看到這裡的同誌已經很不耐煩了。但是如果你錯過接下去的一段，基本上剛才看的就快等於白看了，革命的勝利就在後半段，因為整個分頁功能圍繞的就是一個Page對象，重磅內容終於要出來了，當你把Page對象填充到剛才那個BaseEntity上的時候，你會發現一切就完整起來了，廢話不多說，Page對像如下
package com.store.base.secondmodel.base; import java.io.Serializable; import java.util.ArrayList; import java.util.List; import java.util.regex.Pattern; import javax.servlet.http.HttpServletRequest; import javax.servlet.http.HttpServletResponse; import com.fasterxml.jackson.annotation.JsonIgnore; import com.store.base.secondmodel.base.util.CookieUtils; import com.store.base.secondmodel.base.util.StringUtils; /** * 分頁類* @author yiyong_wu * * @param <T> */ public class Page<T> implements Serializable{ private static final long serialVersionUID = 1L; private int pageNo = 1; // 當前頁碼private int pageSize = Integer.parseInt(Global.getConfig("page.pageSize")); // 頁面大小，設置為“-1”表示不進行分頁（分頁無效） private long count;// 總記錄數，設置為“-1”表示不查詢總數private int first;// 首頁索引private int last;// 尾頁索引private int prev;// 上一頁索引private int next;// 下一頁索引private boolean firstPage;//是否是第一頁private boolean lastPage;//是否是最後一頁private int length = 6;// 顯示頁面長度private int slider = 1;// 前後顯示頁面長度private List<T> list = new ArrayList<>(); private String orderBy = ""; // 標準查詢有效， 實例： updatedate desc, name asc private String funcName = "page"; // 設置點擊頁碼調用的js函數名稱，默認為page，在一頁有多個分頁對象時使用。 private String funcParam = ""; // 函數的附加參數，第三個參數值。 private String message = ""; // 設置提示消息，顯示在“共n條”之後public Page() { this.pageSize = -1; } /** * 構造方法* @param request 傳遞repage 參數，來記住頁碼* @param response 用於設置Cookie，記住頁碼*/ public Page(HttpServletRequest request, HttpServletResponse response){ this(request, response, -2); } /** * 構造方法* @param request 傳遞repage 參數，來記住頁碼* @param response 用於設置Cookie，記住頁碼* @param defaultPageSize 默認分頁大小，如果傳遞-1 則為不分頁，返回所有數據*/ public Page(HttpServletRequest request, HttpServletResponse response, int defaultPageSize){ // 設置頁碼參數（傳遞repage參數，來記住頁碼） String no = request.getParameter("pageNo"); if (StringUtils.isNumeric(no)){ CookieUtils.setCookie(response, "pageNo", no); this.setPageNo(Integer.parseInt(no)); }else if (request.getParameter("repage")!=null){ no = CookieUtils.getCookie(request, "pageNo"); if (StringUtils.isNumeric(no)){ this.setPageNo(Integer.parseInt(no)); } } // 設置頁面大小參數（傳遞repage參數，來記住頁碼大小） String size = request.getParameter("pageSize"); if (StringUtils.isNumeric(size)){ CookieUtils.setCookie(response, "pageSize", size); this.setPageSize(Integer.parseInt(size)); }else if (request.getParameter("repage")!=null){ no = CookieUtils.getCookie(request, "pageSize"); if (StringUtils.isNumeric(size)){ this.setPageSize(Integer.parseInt(size)); } }else if (defaultPageSize != -2){ this.pageSize = defaultPageSize; } // 設置排序參數String orderBy = request.getParameter("orderBy"); if (StringUtils.isNotBlank(orderBy)){ this.setOrderBy(orderBy); } } /** * 構造方法* @param pageNo 當前頁碼* @param pageSize 分頁大小*/ public Page(int pageNo, int pageSize) { this(pageNo, pageSize, 0); } /** * 構造方法* @param pageNo 當前頁碼* @param pageSize 分頁大小* @param count 數據條數*/ public Page(int pageNo, int pageSize, long count) { this(pageNo, pageSize, count, new ArrayList<T>()); } /** * 構造方法* @param pageNo 當前頁碼* @param pageSize 分頁大小* @param count 數據條數* @param list 本頁數據對象列表*/ public Page(int pageNo, int pageSize, long count, List<T> list) { this.setCount(count); this.setPageNo(pageNo); this.pageSize = pageSize; this.list = list; } /** * 初始化參數*/ public void initialize(){ //1 this.first = 1; this.last = (int)(count / (this.pageSize < 1 ? 20 : this.pageSize) + first - 1); if (this.count % this.pageSize != 0 || this.last == 0) { this.last++; } if (this.last < this.first) { this.last = this.first; } if (this.pageNo <= 1) { this.pageNo = this.first; this.firstPage=true; } if (this.pageNo >= this.last) { this.pageNo = this.last; this.lastPage=true; } if (this.pageNo < this.last - 1) { this.next = this.pageNo + 1; } else { this.next = this.last; } if (this.pageNo > 1) { this.prev = this.pageNo - 1; } else { this.prev = this.first; } //2 if (this.pageNo < this.first) {// 如果當前頁小於首頁this.pageNo = this.first; } if (this.pageNo > this.last) {// 如果當前頁大於尾頁this.pageNo = this.last; } } /** * 默認輸出當前分頁標籤* <div>${page}</div> */ @Override public String toString() { StringBuilder sb = new StringBuilder(); if (pageNo == first) {// 如果是首頁sb.append("<li class=/"disabled/"><a href=/"javascript:/">« 上一頁</a></li>/n"); } else { sb.append("<li><a href=/"javascript:/" onclick=/""+funcName+"("+prev+","+pageSize+",'"+funcParam+"');/">« 上一頁</a></li>/n"); } int begin = pageNo - (length / 2); if (begin < first) { begin = first; } int end = begin + length - 1; if (end >= last) { end = last; begin = end - length + 1; if (begin < first) { begin = first; } } if (begin > first) { int i = 0; for (i = first; i < first + slider && i < begin; i++) { sb.append("<li><a href=/"javascript:/" onclick=/""+funcName+"("+i+","+pageSize+",'"+funcParam+"');/">" + (i + 1 - first) + "</a></li>/n"); } if (i < begin) { sb.append("<li class=/"disabled/"><a href=/"javascript:/">...</a></li>/n"); } } for (int i = begin; i <= end; i++) { if (i == pageNo) { sb.append("<li class=/"active/"><a href=/"javascript:/">" + (i + 1 - first) + "</a></li>/n"); } else { sb.append("<li><a href=/"javascript:/" onclick=/""+funcName+"("+i+","+pageSize+",'"+funcParam+"');/">" + (i + 1 - first) + "</a></li>/n"); } } if (last - end > slider) { sb.append("<li class=/"disabled/"><a href=/"javascript:/">...</a></li>/n"); end = last - slider; } for (int i = end + 1; i <= last; i++) { sb.append("<li><a href=/"javascript:/" onclick=/""+funcName+"("+i+","+pageSize+",'"+funcParam+"');/">" + (i + 1 - first) + "</a></li>/n"); } if (pageNo == last) { sb.append("<li class=/"disabled/"><a href=/"javascript:/">下一頁»</a></li>/n"); } else { sb.append("<li><a href=/"javascript:/" onclick=/""+funcName+"("+next+","+pageSize+",'"+funcParam+"');/">" + "下一頁»</a></li>/n"); } return sb.toString(); } /** * 獲取分頁HTML代碼* @return */ public String getHtml(){ return toString(); } /** * 獲取設置總數* @return */ public long getCount() { return count; } /** * 設置數據總數* @param count */ public void setCount(long count) { this.count = count; if (pageSize >= count){ pageNo = 1; } } /** * 獲取當前頁碼* @return */ public int getPageNo() { return pageNo; } /** * 設置當前頁碼* @param pageNo */ public void setPageNo(int pageNo) { this.pageNo = pageNo; } /** * 獲取頁面大小* @return */ public int getPageSize() { return pageSize; } /** * 設置頁面大小（最大500）// > 500 ? 500 : pageSize; * @param pageSize */ public void setPageSize(int pageSize) { this.pageSize = pageSize <= 0 ? 10 : pageSize; } /** * 首頁索引* @return */ @JsonIgnore public int getFirst() { return first; } /** * 尾頁索引* @return */ @JsonIgnore public int getLast() { return last; } /** * 獲取頁面總數* @return getLast(); */ @JsonIgnore public int getTotalPage() { return getLast(); } /** * 是否為第一頁* @return */ @JsonIgnore public boolean isFirstPage() { return firstPage; } /** * 是否為最後一頁* @return */ @JsonIgnore public boolean isLastPage() { return lastPage; } /** * 上一頁索引值* @return */ @JsonIgnore public int getPrev() { if (isFirstPage()) { return pageNo; } else { return pageNo - 1; } } /** * 下一頁索引值* @return */ @JsonIgnore public int getNext() { if (isLastPage()) { return pageNo; } else { return pageNo + 1; } } /** * 獲取本頁數據對象列表* @return List<T> */ public List<T> getList() { return list; } /** * 設置本頁數據對象列表* @param list */ public Page<T> setList(List<T> list) { this.list = list; initialize(); return this; } /** * 獲取查詢排序字符串* @return */ @JsonIgnore public String getOrderBy() { // SQL過濾，防止注入String reg = "(?:')|(?:--)|(///*(?:.|[//n//r])*?//*/)|" + "(//b(select|update|and|or|delete|insert|trancate|char|into|substr|ascii|declare|exec|count|master|into|drop|execute)//b)"; Pattern sqlPattern = Pattern.compile(reg, Pattern.CASE_INSENSITIVE); if (sqlPattern.matcher(orderBy).find()) { return ""; } return orderBy; } /** * 設置查詢排序，標準查詢有效， 實例： updatedate desc, name asc */ public void setOrderBy(String orderBy) { this.orderBy = orderBy; } /** * 獲取點擊頁碼調用的js函數名稱* function ${page.funcName}(pageNo){location="${ctx}/list-${category.id}${urlSuffix}?pageNo="+i;} * @return */ @JsonIgnore public String getFuncName() { return funcName; } /** * 設置點擊頁碼調用的js函數名稱，默認為page，在一頁有多個分頁對象時使用。 * @param funcName 默認為page */ public void setFuncName(String funcName) { this.funcName = funcName; } /** * 獲取分頁函數的附加參數* @return */ @JsonIgnore public String getFuncParam() { return funcParam; } /** * 設置分頁函數的附加參數* @return */ public void setFuncParam(String funcParam) { this.funcParam = funcParam; } /** * 設置提示消息，顯示在“共n條”之後* @param message */ public void setMessage(String message) { this.message = message; } /** * 分頁是否有效* @return this.pageSize==-1 */ @JsonIgnore public boolean isDisabled() { return this.pageSize==-1; } /** * 是否進行總數統計* @return this.count==-1 */ @JsonIgnore public boolean isNotCount() { return this.count==-1; } /** * 獲取Hibernate FirstResult */ public int getFirstResult(){ int firstResult = (getPageNo() - 1) * getPageSize(); if (firstResult >= getCount()) { firstResult = 0; } return firstResult; } /** * 獲取Hibernate MaxResults */ public int getMaxResults(){ return getPageSize(); } }看完這個Page對象應該稍微有點感覺了吧，然後我在胡亂貼一些相關用到的工具類吧，工具類的話我只稍微提一下，具體大家可以弄到自己的代碼上好好解讀。
PropertiesLoader.java 用來獲取resource文件夾下的常量配置文件
package com.store.base.secondmodel.base.util; import java.io.IOException; import java.io.InputStream; import java.util.NoSuchElementException; import java.util.Properties; import org.apache.commons.io.IOUtils; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.core.io.DefaultResourceLoader; import org.springframework.core.io.Resource; import org.springframework.core.io.ResourceLoader; /** * Properties文件載入工具類. 可載入多個properties文件, * 相同的屬性在最後載入的文件中的值將會覆蓋之前的值，但以System的Property優先. * @author yiyong_wu * */ public class PropertiesLoader { private static Logger logger = LoggerFactory.getLogger(PropertiesLoader.class); private static ResourceLoader resourceLoader = new DefaultResourceLoader(); private final Properties properties; public PropertiesLoader(String... resourcesPaths) { properties = loadProperties(resourcesPaths); } public Properties getProperties() { return properties; } /** * 取出Property，但以System的Property優先,取不到返回空字符串. */ private String getValue(String key) { String systemProperty = System.getProperty(key); if (systemProperty != null) { return systemProperty; } if (properties.containsKey(key)) { return properties.getProperty(key); } return ""; } /** * 取出String類型的Property，但以System的Property優先,如果都為Null則拋出異常. */ public String getProperty(String key) { String value = getValue(key); if (value == null) { throw new NoSuchElementException(); } return value; } /** * 取出String類型的Property，但以System的Property優先.如果都為Null則返回Default值. */ public String getProperty(String key, String defaultValue) { String value = getValue(key); return value != null ? value : defaultValue; } /** * 取出Integer類型的Property，但以System的Property優先.如果都為Null或內容錯誤則拋出異常. */ public Integer getInteger(String key) { String value = getValue(key); if (value == null) { throw new NoSuchElementException(); } return Integer.valueOf(value); } /** * 取出Integer類型的Property，但以System的Property優先.如果都為Null則返回Default值，如果內容錯誤則拋出異常*/ public Integer getInteger(String key, Integer defaultValue) { String value = getValue(key); return value != null ? Integer.valueOf(value) : defaultValue; } /** * 取出Double類型的Property，但以System的Property優先.如果都為Null或內容錯誤則拋出異常. */ public Double getDouble(String key) { String value = getValue(key); if (value == null) { throw new NoSuchElementException(); } return Double.valueOf(value); } /** * 取出Double類型的Property，但以System的Property優先.如果都為Null則返回Default值，如果內容錯誤則拋出異常*/ public Double getDouble(String key, Integer defaultValue) { String value = getValue(key); return value != null ? Double.valueOf(value) : defaultValue.doubleValue(); } /** * 取出Boolean類型的Property，但以System的Property優先.如果都為Null拋出異常,如果內容不是true/false則返回false. */ public Boolean getBoolean(String key) { String value = getValue(key); if (value == null) { throw new NoSuchElementException(); } return Boolean.valueOf(value); } /** * 取出Boolean類型的Property，但以System的Property優先.如果都為Null則返回Default值,如果內容不為true/false則返回false. */ public Boolean getBoolean(String key, boolean defaultValue) { String value = getValue(key); return value != null ? Boolean.valueOf(value) : defaultValue; } /** * 載入多個文件, 文件路徑使用Spring Resource格式. */ private Properties loadProperties(String... resourcesPaths) { Properties props = new Properties(); for (String location : resourcesPaths) { InputStream is = null; try { Resource resource = resourceLoader.getResource(location); is = resource.getInputStream(); props.load(is); } catch (IOException ex) { logger.error("Could not load properties from path:" + location , ex); } finally { IOUtils.closeQuietly(is); } } return props; } }Global.java 用來獲取全局的一些常量，可以是從配置文件中讀取的常量，也可以是定義成final static的常量，獲取配置文件的話是調用上面那個類進行獲取的。
package com.store.base.secondmodel.base; import java.io.File; import java.io.IOException; import java.util.Map; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.core.io.DefaultResourceLoader; import com.google.common.collect.Maps; import com.store.base.secondmodel.base.util.PropertiesLoader; import com.store.base.secondmodel.base.util.StringUtils; /** * 全局配置類* @author yiyong_wu * */ public class Global { private static final Logger logger = LoggerFactory.getLogger(Global.class); /** * 當前對象實例*/ private static Global global = new Global(); /** * 保存全局屬性值*/ private static Map<String, String> map = Maps.newHashMap(); /** * 屬性文件加載對象*/ private static PropertiesLoader loader = new PropertiesLoader("application.properties"); /** * 顯示/隱藏public static final String SHOW = "1"; public static final String HIDE = "0"; /** * 是/否*/ public static final String YES = "1"; public static final String NO = "0"; /** * 狀態上/下app專用*/ public static final String UPSHVELF = "1"; public static final String DOWNSHVELF = "2"; public static final String SEPARATOR = "/"; /** * 對/錯*/ public static final String TRUE = "true"; public static final String FALSE = "false"; /** * 上傳文件基礎虛擬路徑*/ public static final String USERFILES_BASE_URL = "/userfiles/"; /** * 針對富文本編輯器，結尾會產生的空div */ public static final String ENDS = "<p><br></p>"; /** * 默認空的私有構造函數*/ public Global() { //do nothing in this method,just empty } /** * 獲取當前對象實例*/ public static Global getInstance() { return global; } /** * 獲取配置*/ public static String getConfig(String key) { String value = map.get(key); if (value == null){ value = loader.getProperty(key); map.put(key, value != null ? value : StringUtils.EMPTY); } return value; } /** * 獲取URL後綴*/ public static String getUrlSuffix() { return getConfig("urlSuffix"); } /** * 頁面獲取常量* @see ${fns:getConst('YES')} */ public static Object getConst(String field) { try { return Global.class.getField(field).get(null); } catch (Exception e) { logger.error("獲取常量出錯", e); } return null; } /** * 獲取工程路徑* @return */ public static String getProjectPath(){ // 如果配置了工程路徑，則直接返回，否則自動獲取。 String projectPath = Global.getConfig("projectPath"); if (StringUtils.isNotBlank(projectPath)){ return projectPath; } try { File file = new DefaultResourceLoader().getResource("").getFile(); if (file != null){ while(true){ File f = new File(file.getPath() + File.separator + "src" + File.separator + "main"); if (f == null || f.exists()){ break; } if (file.getParentFile() != null){ file = file.getParentFile(); }else{ break; } } projectPath = file.toString(); } } catch (IOException e) { logger.error("加載配置文件失敗", e); } return projectPath; } }CookieUtil.java 從名稱就知道是針對獲取和存儲cookie的一個工具類
package com.store.base.secondmodel.base.util; import java.io.UnsupportedEncodingException; import java.net.URLDecoder; import java.net.URLEncoder; import javax.servlet.http.Cookie; import javax.servlet.http.HttpServletRequest; import javax.servlet.http.HttpServletResponse; import org.slf4j.Logger; import org.slf4j.LoggerFactory; /** * Cookie工具類* @author yiyong_wu * */ public class CookieUtils { private static final Logger logger = LoggerFactory.getLogger(CookieUtils.class); /** * 私有構造函數*/ private CookieUtils() { } /** * 設置Cookie（生成時間為1年） * @param name 名稱* @param value 值*/ public static void setCookie(HttpServletResponse response, String name, String value) { setCookie(response, name, value, 60*60*24*365); } /** * 設置Cookie * @param name 名稱* @param value 值* @param maxAge 生存時間（單位秒） * @param uri 路徑*/ public static void setCookie(HttpServletResponse response, String name, String value, String path) { setCookie(response, name, value, path, 60*60*24*365); } /** * 設置Cookie * @param name 名稱* @param value 值* @param maxAge 生存時間（單位秒） * @param uri 路徑*/ public static void setCookie(HttpServletResponse response, String name, String value, int maxAge) { setCookie(response, name, value, "/", maxAge); } /** * 設置Cookie * @param name 名稱* @param value 值* @param maxAge 生存時間（單位秒） * @param uri 路徑*/ public static void setCookie(HttpServletResponse response, String name, String value, String path, int maxAge) { Cookie cookie = new Cookie(name, null); cookie.setPath(path); cookie.setMaxAge(maxAge); try { cookie.setValue(URLEncoder.encode(value, "utf-8")); } catch (UnsupportedEncodingException e) { logger.error("不支持的編碼", e); } response.addCookie(cookie); } /** * 獲得指定Cookie的值* @param name 名稱* @return 值*/ public static String getCookie(HttpServletRequest request, String name) { return getCookie(request, null, name, false); } /** * 獲得指定Cookie的值，並刪除。 * @param name 名稱* @return 值*/ public static String getCookie(HttpServletRequest request, HttpServletResponse response, String name) { return getCookie(request, response, name, true); } /** * 獲得指定Cookie的值* @param request 請求對象* @param response 響應對象* @param name 名字* @param isRemove 是否移除* @return 值*/ public static String getCookie(HttpServletRequest request, HttpServletResponse response, String name, boolean isRemove) { String value = null; Cookie[] cookies = request.getCookies(); if(cookies == null) { return value; } for (Cookie cookie : cookies) { if (cookie.getName().equals(name)) { try { value = URLDecoder.decode(cookie.getValue(), "utf-8"); } catch (UnsupportedEncodingException e) { logger.error("不支持的編碼", e); } if (isRemove) { cookie.setMaxAge(0); response.addCookie(cookie); } } } return value; } }SpringContextHolder.java 主要是用來在java代碼中獲取當前的ApplicationContext，需要在spring配置文件中配置這個bean並且懶加載設置成false；
package com.store.base.secondmodel.base.util; import org.apache.commons.lang3.Validate; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.beans.factory.DisposableBean; import org.springframework.context.ApplicationContext; import org.springframework.context.ApplicationContextAware; import org.springframework.context.annotation.Lazy; import org.springframework.stereotype.Service; @Service @Lazy(false) public class SpringContextHolder implements ApplicationContextAware, DisposableBean { private static Logger logger = LoggerFactory.getLogger(SpringContextHolder.class); private static ApplicationContext applicationContext = null; /** * 取得存儲在靜態變量中的ApplicationContext. */ public static ApplicationContext getApplicationContext() { assertContextInjected(); return applicationContext; } /** * 從靜態變量applicationContext中取得Bean, 自動轉型為所賦值對象的類型. */ @SuppressWarnings("unchecked") public static <T> T getBean(String name) { assertContextInjected(); return (T) applicationContext.getBean(name); } /** * 從靜態變量applicationContext中取得Bean, 自動轉型為所賦值對象的類型. */ public static <T> T getBean(Class<T> requiredType) { assertContextInjected(); return applicationContext.getBean(requiredType); } @Override public void destroy() throws Exception { SpringContextHolder.clearHolder(); } /** * 實現ApplicationContextAware接口, 注入Context到靜態變量中. */ @Override public void setApplicationContext(ApplicationContext applicationContext) { logger.debug("注入ApplicationContext到SpringContextHolder:{}", applicationContext); SpringContextHolder.applicationContext = applicationContext; if (SpringContextHolder.applicationContext != null) { logger.info("SpringContextHolder中的ApplicationContext被覆蓋, 原有ApplicationContext為:" + SpringContextHolder.applicationContext); } } /** * 清除SpringContextHolder中的ApplicationContext為Null. */ public static void clearHolder() { if (logger.isDebugEnabled()){ logger.debug("清除SpringContextHolder中的ApplicationContext:" + applicationContext); } applicationContext = null; } /** * 檢查ApplicationContext不為空. */ private static void assertContextInjected() { Validate.validState(applicationContext != null, "applicaitonContext屬性未註入, 請在applicationContext.xml中定義SpringContextHolder."); } }StringUtils.java字符串相關的一個工具類
package com.store.base.secondmodel.base.util; import java.io.UnsupportedEncodingException; import java.util.Locale; import java.util.regex.Matcher; import java.util.regex.Pattern; import javax.servlet.http.HttpServletRequest; import org.apache.commons.lang3.StringEscapeUtils; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.web.context.request.RequestContextHolder; import org.springframework.web.context.request.ServletRequestAttributes; import org.springframework.web.servlet.LocaleResolver; import com.store.base.util.Encodes; /** * 字符串幫助類* @author yiyong_wu * */ public class StringUtils extends org.apache.commons.lang3.StringUtils { private static final char SEPARATOR = '_'; private static final String CHARSET_NAME = "UTF-8"; private static final Logger logger = LoggerFactory.getLogger(StringUtils.class); /** * 轉換為字節數組* @param str * @return */ public static byte[] getBytes(String str){ if (str != null){ try { return str.getBytes(CHARSET_NAME); } catch (UnsupportedEncodingException e) { logger.error("", e); return new byte[0]; } }else{ return new byte[0]; } } /** * 轉換為字節數組* @param str * @return */ public static String toString(byte[] bytes){ try { return new String(bytes, CHARSET_NAME); } catch (UnsupportedEncodingException e) { logger.error("", e); return EMPTY; } } /** * 是否包含字符串* @param str 驗證字符串* @param strs 字符串組* @return 包含返回true */ public static boolean inString(String str, String... strs){ if (str != null){ for (String s : strs){ if (str.equals(trim(s))){ return true; } } } return false; } /** * 替換掉HTML標籤方法*/ public static String replaceHtml(String html) { if (isBlank(html)){ return ""; } String regEx = "<.+?>"; Pattern p = Pattern.compile(regEx); Matcher m = p.matcher(html); return m.replaceAll(""); } /** * 替換為手機識別的HTML，去掉樣式及屬性，保留回車。 * @param html * @return */ public static String replaceMobileHtml(String html){ if (html == null){ return ""; } return html.replaceAll("<([az]+?)//s+?.*?>", "<$1>"); } /** * 替換為手機識別的HTML，去掉樣式及屬性，保留回車。 * @param txt * @return */ public static String toHtml(String txt){ if (txt == null){ return ""; } return replace(replace(Encodes.escapeHtml(txt), "/n", "<br/>"), "/t", " "); } /** * 縮略字符串（不區分中英文字符） * @param str 目標字符串* @param length 截取長度* @return */ public static String abbr(String str, int length) { if (str == null) { return ""; } try { StringBuilder sb = new StringBuilder(); int currentLength = 0; for (char c : replaceHtml(StringEscapeUtils.unescapeHtml4(str)).toCharArray()) { currentLength += String.valueOf(c).getBytes("GBK").length; if (currentLength <= length - 3) { sb.append(c); } else { sb.append("..."); break; } } return sb.toString(); } catch (UnsupportedEncodingException e) { logger.error("", e); } return ""; } /** * 轉換為Double類型*/ public static Double toDouble(Object val){ if (val == null){ return 0D; } try { return Double.valueOf(trim(val.toString())); } catch (Exception e) { logger.error("", e); return 0D; } } /** * 轉換為Float類型*/ public static Float toFloat(Object val){ return toDouble(val).floatValue(); } /** * 轉換為Long類型*/ public static Long toLong(Object val){ return toDouble(val).longValue(); } /** * 轉換為Integer類型*/ public static Integer toInteger(Object val){ return toLong(val).intValue(); } /** * 獲得i18n字符串*/ public static String getMessage(String code, Object[] args) { LocaleResolver localLocaleResolver = SpringContextHolder.getBean(LocaleResolver.class); HttpServletRequest request = ((ServletRequestAttributes)RequestContextHolder.getRequestAttributes()).getRequest(); Locale localLocale = localLocaleResolver.resolveLocale(request); return SpringContextHolder.getApplicationContext().getMessage(code, args, localLocale); } /** * 獲得用戶遠程地址*/ public static String getRemoteAddr(HttpServletRequest request){ String remoteAddr = request.getHeader("X-Real-IP"); if (isNotBlank(remoteAddr)) { remoteAddr = request.getHeader("X-Forwarded-For"); } if (isNotBlank(remoteAddr)) { remoteAddr = request.getHeader("Proxy-Client-IP"); } if (isNotBlank(remoteAddr)) { remoteAddr = request.getHeader("WL-Proxy-Client-IP"); } return remoteAddr != null ? remoteAddr : request.getRemoteAddr(); } /** * 駝峰命名法工具* @return * toCamelCase("hello_world") == "helloWorld" * toCapitalizeCamelCase("hello_world") == "HelloWorld" * toUnderScoreCase("helloWorld") = "hello_world" */ public static String toCamelCase(String s) { String s1 =s; if (s1 == null) { return null; } s1 = s.toLowerCase(); StringBuilder sb = new StringBuilder(s1.length()); boolean upperCase = false; for (int i = 0; i < s1.length(); i++) { char c = s1.charAt(i); if (c == SEPARATOR) { upperCase = true; } else if (upperCase) { sb.append(Character.toUpperCase(c)); upperCase = false; } else { sb.append(c); } } return sb.toString(); } /** * 駝峰命名法工具* @return * toCamelCase("hello_world") == "helloWorld" * toCapitalizeCamelCase("hello_world") == "HelloWorld" * toUnderScoreCase("helloWorld") = "hello_world" */ public static String toCapitalizeCamelCase(String s) { String s1 = s; if (s1 == null) { return null; } s1 = toCamelCase(s1); return s1.substring(0, 1).toUpperCase() + s1.substring(1); } /** * 駝峰命名法工具* @return * toCamelCase("hello_world") == "helloWorld" * toCapitalizeCamelCase("hello_world") == "HelloWorld" * toUnderScoreCase("helloWorld") = "hello_world" */ public static String toUnderScoreCase(String s) { if (s == null) { return null; } StringBuilder sb = new StringBuilder(); boolean upperCase = false; for (int i = 0; i < s.length(); i++) { char c = s.charAt(i); boolean nextUpperCase = true; if (i < (s.length() - 1)) { nextUpperCase = Character.isUpperCase(s.charAt(i + 1)); } if ((i > 0) && Character.isUpperCase(c)) { if (!upperCase || !nextUpperCase) { sb.append(SEPARATOR); } upperCase = true; } else { upperCase = false; } sb.append(Character.toLowerCase(c)); } return sb.toString(); } /** * 轉換為JS獲取對象值，生成三目運算返回結果* @param objectString 對象串* 例如：row.user.id * 返回：!row?'':!row.user?'':!row.user.id?'':row.user.id */ public static String jsGetVal(String objectString){ StringBuilder result = new StringBuilder(); StringBuilder val = new StringBuilder(); String[] vals = split(objectString, "."); for (int i=0; i<vals.length; i++){ val.append("." + vals[i]); result.append("!"+(val.substring(1))+"?'':"); } result.append(val.substring(1)); return result.toString(); } }有了上面這些基礎的東西，只需要在寫一個控制層接口，就可以看到每次返回一個page對象，然後裡面封裝好了查詢對象的列表，並且是按分頁得出列表。
package com.store.controller; import javax.servlet.http.HttpServletRequest; import javax.servlet.http.HttpServletResponse; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.web.bind.annotation.RequestMapping; import org.springframework.web.bind.annotation.ResponseBody; import org.springframework.web.bind.annotation.RestController; import com.store.base.secondmodel.base.Page; import com.store.base.secondmodel.pratice.model.Product; import com.store.base.secondmodel.pratice.service.ProductService; /** *TODO *2016年10月11日*yiyong_wu */ @RestController @RequestMapping("/product") public class ProductController { @Autowired private ProductService productService; @ResponseBody @RequestMapping(value="/getPageProduct") public Page<Product> getPageProduct(HttpServletRequest request,HttpServletResponse response){ Page<Product> page = productService.findPage(new Page<Product>(request,response), new Product()); return page; } }最後在看一下頁面怎麼使用這個page對象，這樣我們就完整地介紹了這個一個分頁功能，代碼很多，但很完整。
<%@ page contentType="text/html;charset=UTF-8"%> <%@ include file="/WEB-INF/views/include/taglib.jsp"%> <html> <head> <title></title> <meta name="decorator" content="default" /> function page(n, s) { if (n) $("#pageNo").val(n); if (s) $("#pageSize").val(s); $("#searchForm").attr("action", "${ctx}/app/bank/list"); $("#searchForm").submit(); return false; } </script> </head> <body> <form:form id="searchForm" modelAttribute="XXXX" action="${ctx}/XXX" method="post"> <input id="pageNo" name="pageNo" type="hidden" value="${page.pageNo}" /> <input id="pageSize" name="pageSize" type="hidden" value="${page.pageSize}" /> <ul> <li> <label>是否上架：</label> <form:select id="status" path="status"> <form:option value="" label=""/> <form:options items="${fns:getDictList('yes_no_app')}" itemLabel="label" itemValue="value" htmlEscape="false"/> </form:select> </li> <li><input id="btnSubmit" type="submit" value="查詢"/> <li></li> </ul> </form:form> <sys:message content="${message}" /> <sys:message content="${message}" /> <table id="contentTable"> <thead> <tr> <th>XXXX</th> <th>XXXX</th> <th>XXXX</th> <th>XXXX</th> <th>XXXX</th> <th>XXXX</th> <th>XXXX</th> <th>XXXX</th> </tr> </thead> <tbody> <c:forEach items="${page.list}" var="XXXX"> <tr> <td>${XXXX.name}</td> <td><a href="${ctx}/app/bank/form?id=${XXXX.id}">${XXXX.}</a></td> <td>${XXXX.}</td> <td>${XXXX.}</td> <td>${XXXX.}</td> <td>${fns:getDictLabel(XXXX.isHot, 'yes_no_app', '無')}</td> <td>${XXXX.}</td> <td><c:if test="${XXXX.status==1 }">上架</c:if> <c:if test="${XXXX.status==2 }">下架</c:if> </td> </tr> </c:forEach> </tbody> </table> <div>${page} <li style="padding-top: 6px;padding-left: 12px;float: left;">共${page.count}條</li></div> </body> </html>到這裡就基本上把整個分頁功能描述得比較清楚了，希望可以幫助到你們快速解決分頁這個問題，當然要在前端顯示分頁漂亮的話要針對li做一些css樣式啥的，最後祝福你可以快速掌握這個分頁功能！
以上所述是小編給大家介紹的Mybatis常用分頁插件實現快速分頁處理技巧，希望對大家有所幫助，如果大家有任何疑問請給我留言，小編會及時回復大家的。在此也非常感謝大家對武林網網站的支持！