package com.dnkx.interceptor; 
import java.sql.*; 
import java.util.HashMap; 
import java.util.Properties; 
import org.apache.ibatis.executor.resultset.ResultSetHandler; 
import org.apache.ibatis.executor.statement.StatementHandler; 
import org.apache.ibatis.mapping.BoundSql; 
import org.apache.ibatis.mapping.MappedStatement; 
import org.apache.ibatis.plugin.Interceptor; 
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.reflection.SystemMetaObject; 
import com.dnkx.pojo.Page; 
/** 
* 
* 分頁(yè)攔截器，用于攔截需要進(jìn)行分頁(yè)查詢(xún)的操作，然后對(duì)其進(jìn)行分頁(yè)處理。 
* 利用攔截器實(shí)現(xiàn)Mybatis分頁(yè)的原理： 
* 要利用JDBC對(duì)數(shù)據(jù)庫(kù)進(jìn)行操作就必須要有一個(gè)對(duì)應(yīng)的Statement對(duì)象，Mybatis在執(zhí)行Sql語(yǔ)句前就會(huì)產(chǎn)生一個(gè)包含Sql語(yǔ)句的Statement對(duì)象，而且對(duì)應(yīng)的Sql語(yǔ)句 
* 是在Statement之前產(chǎn)生的，所以我們就可以在它生成Statement之前對(duì)用來(lái)生成Statement的Sql語(yǔ)句下手。在Mybatis中Statement語(yǔ)句是通過(guò)RoutingStatementHandler對(duì)象的 
* prepare方法生成的。所以利用攔截器實(shí)現(xiàn)Mybatis分頁(yè)的一個(gè)思路就是攔截StatementHandler接口的prepare方法，然后在攔截器方法中把Sql語(yǔ)句改成對(duì)應(yīng)的分頁(yè)查詢(xún)Sql語(yǔ)句，之后再調(diào)用 
* StatementHandler對(duì)象的prepare方法，即調(diào)用invocation.proceed()。 
* 對(duì)于分頁(yè)而言，在攔截器里面我們還需要做的一個(gè)操作就是統(tǒng)計(jì)滿(mǎn)足當(dāng)前條件的記錄一共有多少，這是通過(guò)獲取到了原始的Sql語(yǔ)句后，把它改為對(duì)應(yīng)的統(tǒng)計(jì)語(yǔ)句再利用Mybatis封裝好的參數(shù)和設(shè) 
* 置參數(shù)的功能把Sql語(yǔ)句中的參數(shù)進(jìn)行替換，之后再執(zhí)行查詢(xún)記錄數(shù)的Sql語(yǔ)句進(jìn)行總記錄數(shù)的統(tǒng)計(jì)。 
* 
* 解釋一下插件中可能要用到的幾個(gè)類(lèi)： 
* MetaObject：mybatis提供的一個(gè)基于返回獲取屬性值的對(duì)象的類(lèi) 
* BoundSql : 在這個(gè)里面可以獲取都要執(zhí)行的sql和執(zhí)行sql要用到的參數(shù) 
* MappedStatement ： 這個(gè)可以得到當(dāng)前執(zhí)行的sql語(yǔ)句在xml文件中配置的id的值 
* RowBounds : 是mybatis內(nèi)存分頁(yè)要用到的。 
* ParameterHandler ： 是mybatis中用來(lái)替換sql中?出現(xiàn)的值的. 
* 
* @author 李小拐 2016年11月9日 10:59:04 
*/ 
@Intercepts({ 
@Signature(type=StatementHandler.class,method="prepare",args={Connection.class}), 
@Signature(type = ResultSetHandler.class, method = "handleResultSets", args = {Statement.class}) 
}) 
public class PageInterceptor implements Interceptor{ 
//攔截分頁(yè)關(guān)鍵字 
private static final String SELECT_ID="page"; 
//插件運(yùn)行的代碼，它將代替原有的方法,要重寫(xiě)最重要的intercept了 
@Override 
public Object intercept(Invocation invocation) throws Throwable { 
if (invocation.getTarget() instanceof StatementHandler) { 
//這里我們有一個(gè)設(shè)定 如果查詢(xún)方法含有Page 就進(jìn)行分頁(yè) 其他方法無(wú)視 
//所以就要獲取方法名 
StatementHandler statementHandler=(StatementHandler)invocation.getTarget(); 
MetaObject metaObject=SystemMetaObject.forObject(statementHandler); 
MappedStatement mappedStatement=(MappedStatement)metaObject.getValue("delegate.mappedStatement"); 
String selectId=mappedStatement.getId(); 
String methorName=selectId.substring(selectId.lastIndexOf(".")+1).toLowerCase(); 
//然后判斷下 如果含有Page 就獲取sql 
if(methorName.contains(SELECT_ID)){ 
BoundSql boundSql=(BoundSql)metaObject.getValue("delegate.boundSql"); 
//分頁(yè)參數(shù)作為參數(shù)對(duì)象parameterObject的一個(gè)屬性 
String sql=boundSql.getSql(); 
System.out.println("獲取到的sql:"+sql); 
HashMap<String, Object> map=(HashMap<String, Object>)(boundSql.getParameterObject()); 
//Page page=(Page)(boundSql.getParameterObject()); 
Page page=(Page)map.get("page"); 
// 重寫(xiě)sql 
String countSql=concatCountSql(sql); 
String pageSql=concatPageSql(sql,page); 
// System.out.println("重寫(xiě)的 count sql :"+countSql); 
System.out.println("重寫(xiě)的 select sql :"+pageSql); 
Connection connection = (Connection) invocation.getArgs()[0]; 
PreparedStatement countStmt = null; 
ResultSet rs = null; 
int totalCount = 0; 
try { 
countStmt = connection.prepareStatement(countSql); 
rs = countStmt.executeQuery(); 
if (rs.next()) { 
totalCount = rs.getInt(1); 
} 
} catch (SQLException e) { 
System.out.println("Ignore this exception"+e); 
} finally { 
try { 
rs.close(); 
countStmt.close(); 
} catch (SQLException e) { 
System.out.println("Ignore this exception"+ e); 
} 
} 
metaObject.setValue("delegate.boundSql.sql", pageSql); 
//綁定count 
page.setNumCount(totalCount); 
} 
} 
return invocation.proceed(); 
} 
// 攔截類(lèi)型StatementHandler,重寫(xiě)plugin方法 
@Override 
public Object plugin(Object target) { 
if (target instanceof StatementHandler) { 
return Plugin.wrap(target, this); 
}else { 
return target; 
} 
} 
@Override 
public void setProperties(Properties properties) { 
} 
//改造sql 
public String concatCountSql(String sql){ 
//StringBuffer sb=new StringBuffer("select count(*) from "); 
/*sql=sql.toLowerCase(); 
if(sql.lastIndexOf("order")>sql.lastIndexOf(")")){ 
sb.append(sql.substring(sql.indexOf("from")+4, sql.lastIndexOf("order"))); 
}else{ 
sb.append(sql.substring(sql.indexOf("from")+4)); 
}*/ 
StringBuffer sb=new StringBuffer(); 
sql=sql.toLowerCase(); 
if(sql.lastIndexOf("order")>0){ 
sql=sql.substring(0,sql.indexOf("order")); 
} 
sb.append("select count(*) from ("+sql+") tmp"); 
return sb.toString(); 
} 
public String concatPageSql(String sql,Page page){ 
StringBuffer sb=new StringBuffer(); 
sb.append(sql); 
sb.append(" limit ").append(page.getPageBegin()).append(" , ").append(page.getPageSize()); 
return sb.toString(); 
} 
} 
分頁(yè)對(duì)象Page類(lèi)
[java] view plain copy
package com.dnkx.pojo; 
import java.util.HashMap; 
import java.util.Map; 
/** 
* 
* 分頁(yè)查詢(xún)輔助類(lèi) 
* @author 李小拐 2016年11月9日 13:55:37 
*/ 
public class Page { 
//----------分頁(yè)----------- 
private int pageSize;//每頁(yè)顯示條數(shù) 
private int pageCurrentPage;//第幾頁(yè) 
private int pageBegin;//開(kāi)始位置 
private int numCount;//總條數(shù) 
private int pageTotal;//總條數(shù) 
private String orderField = "";//控制排序頁(yè)面顯示的 
private String orderDirection = ""; 
public Page(){ 
} 
public Page(int pageSize, int pageCurrentPage) { 
super(); 
this.pageSize = pageSize; 
this.pageCurrentPage = pageCurrentPage; 
} 
public Page(Map<String, String> map){ 
if(map.get("pageNum")!=null){ 
this.setPageCurrentPage(this.pageCurrentPage = Integer.parseInt(map.get("pageNum")));//要查詢(xún)的頁(yè)數(shù) 
}else{ 
this.setPageCurrentPage(1);//設(shè)置初始值 
} 
if(map.get("numPerPage")!=null){ 
this.setPageSize(Integer.parseInt(map.get("numPerPage")));//每頁(yè)顯示條數(shù) 
}else{ 
this.setPageSize(5);//設(shè)置初始值 
} 
if(map.get("orderField")!=null){ 
this.setOrderField(map.get("orderField")); 
} 
if(map.get("orderDirection")!=null){ 
this.setOrderDirection(map.get("orderDirection")); 
} 
} 
public int getPageCurrentPage() { 
return pageCurrentPage; 
} 
public void setPageCurrentPage(int pageCurrentPage) { 
this.pageCurrentPage = pageCurrentPage; 
} 
public int getNumCount() { 
return numCount; 
} 
public void setNumCount(int numCount) { 
this.numCount = numCount; 
} 
public int getPageTotal() { 
return (numCount%pageSize>0)?(numCount/pageSize+1):(numCount/pageSize); 
} 
public void setPageTotal(int pageTotal) { 
this.pageTotal = pageTotal; 
} 
public int getPageSize() { 
return pageSize; 
} 
public void setPageSize(int pageSize) { 
this.pageSize = pageSize; 
} 
public int getPageBegin() { 
return pageSize*(pageCurrentPage-1); 
} 
public void setPageBegin(int pageBegin) { 
this.pageBegin = pageBegin; 
} 
public String getOrderField() { 
return orderField; 
} 
public void setOrderField(String orderField) { 
this.orderField = orderField; 
} 
public String getOrderDirection() { 
return orderDirection; 
} 
public void setOrderDirection(String orderDirection) { 
this.orderDirection = orderDirection; 
} 
public static Page getPage(int pageSize, int pageCurrentPage){ 
return new Page(pageSize,pageCurrentPage); 
} 
public static Page getPage(Map map){ 
return new Page(map); 
} 
}

public String list(HttpServletRequest request) { 
long a=System.currentTimeMillis(); 
HashMap<String,Object> map=GetRequestMap.getMap(request);//自己封裝的方法，取request的參數(shù) 
Page page= Page.getPage(map);//初始化page 
map.put("page", page);//把page對(duì)象放入?yún)?shù)集合(這個(gè)map是mybatis要用到的，包含查詢(xún)條件，排序，分頁(yè)等) 
//控制排序頁(yè)面顯示的 
map.put(map.get("orderField")+"", map.get("orderDirection")); 
List<Employee> list=employeeService.getListPage(map); 
request.setAttribute("emlist", list); 
request.setAttribute("page", page); 
request.setAttribute("map", map); 
//取page相關(guān)屬性 
page.getNumCount();//總條數(shù) 
page.getPageTotal();//總頁(yè)數(shù) 
long b=System.currentTimeMillis(); 
System.out.println("---------耗時(shí):"+(b-a)+"ms"); 
return "basic/employee_list"; 
}

<bean id="PageInterector" class="com.dnkx.interceptor.PageInterceptor"></bean> 
<!-- spring和MyBatis完美整合，不需要mybatis的配置映射文件 --> 
<bean id="sqlSessionFactory" class="org.mybatis.spring.SqlSessionFactoryBean"> 
<property name="dataSource" ref="dataSource" /> 
<!-- 自動(dòng)掃描mapping.xml文件 --> 
<property name="mapperLocations" value="classpath:com/dnkx/mapping/*.xml"></property> 
<property name="plugins"> 
<ref bean="PageInterector"/> 
</property> 
</bean>