spring+springmvc+mybatis整合

package com.test.intercepter; import java.sql.Connection; import java.sql.PreparedStatement; import java.sql.ResultSet; import java.util.Map; import java.util.Properties; import org.apache.ibatis.executor.parameter.ParameterHandler; 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.test.entity.Page; @Intercepts({@Signature(type=StatementHandler.class,method="prepare",args={Connection.class})}) public class PageInterceptor implements Interceptor{ public Object intercept(Invocation invocation) throws Throwable { // TODO Auto-generated method stub StatementHandler handler = (StatementHandler) invocation.getTarget(); MetaObject metaObject = MetaObject.forObject(handler, SystemMetaObject.DEFAULT_OBJECT_FACTORY, SystemMetaObject.DEFAULT_OBJECT_WRAPPER_FACTORY); MappedStatement mappedStatement = (MappedStatement) metaObject.getValue("delegate.mappedStatement"); //配置文件中SQL语句的ID String id = mappedStatement.getId(); if(id.matches(".+ByPage$")){ BoundSql boundSql = handler.getBoundSql(); //原始的SQL语句 String sql = boundSql.getSql(); //查询总条数的SQL语句 String countSql = "select count(*) from ("+sql+")a"; Connection connection = (Connection) invocation.getArgs()[0]; PreparedStatement countStatement = connection.prepareStatement(countSql); ParameterHandler parameterHandler = (ParameterHandler) metaObject.getValue("delegate.parameterHandler"); parameterHandler.setParameters(countStatement); ResultSet rs = countStatement.executeQuery(); Map<?,?> parameter = (Map<?,?>)boundSql.getParameterObject(); Page page = (Page) parameter.get("page"); if(rs.next()) { page.setTotalNumber(rs.getInt(1)); } // 改造后带分页查询的SQL语句 int dbIndex = page.getDbIndex(); int dbNumber = page.getDbNumber(); // if(page.getCurrentPage()>page.getTotalPage()){ // return null; // } String pageSql = sql +" limit "+dbIndex+","+dbNumber; metaObject.setValue("delegate.boundSql.sql", pageSql); } return invocation.proceed(); } public Object plugin(Object arg0) { // TODO Auto-generated method stub return Plugin.wrap(arg0, this); } public void setProperties(Properties arg0) { // TODO Auto-generated method stub } }