Linux基金会开源软件大学开源技术公开课即将上线，Kubernetes1.19实战讲解！>>> 
@红薯 你好，想跟你请教个问题：您好，麻烦请问下。我用ibatis2.3.0中分页 mappedStatement.setSql(proxy);这个类没有setSql这个方法。还有就是在调用方法findPageWithSqlHandler的时候怎么传递SqlHandler这个值？
public PageList findPageWithSqlHandler(String statementId, Object param, final PageList pageForm, final SqlHandler sqlHandler) {
大神有空帮忙指教下嘛？
原类：
/**
*
*/
package com.ibatis.sqlmap.engine.execution;
import java.lang.reflect.InvocationHandler;
import java.lang.reflect.Method;
import java.lang.reflect.Proxy;
import java.sql.SQLException;
import java.util.List;
import javax.annotation.Resource;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import org.springframework.jdbc.core.JdbcTemplate;
import com.ibatis.sqlmap.engine.impl.SqlMapClientImpl;
import com.ibatis.sqlmap.engine.mapping.sql.Sql;
import com.ibatis.sqlmap.engine.mapping.statement.MappedStatement;
import com.ibatis.sqlmap.engine.scope.RequestScope;
/**
* @author liguang
* 2015年6月16日
*/
public class BaseDao {
private static final Log log = LogFactory.getLog(BaseDao.class);
private SqlMapClientImpl sqlMapClient;
private JdbcTemplate jdbcTemplate;
@Resource(name = "sqlMapClient")
public final void setSqlMapClientImpl(SqlMapClientImpl sqlMapClient) {
this.sqlMapClient = sqlMapClient;
this.jdbcTemplate = new JdbcTemplate(sqlMapClient.getDataSource(), true);
}
/**
* 为SQL添加分页包装
*
* @param sql
* @param pageForm
* @return
*/
private String getSqlWithPagerLimit(final String sql, final PageList pageForm) {
/* final int start = pageForm.getPage() * pageForm.getPageSize();
final int end = (pageForm.getPage() + 1) * pageForm.getPageSize();
final String sidx = pageForm.getSidx();
final String sord = pageForm.getSord();*/
final StringBuilder _sql = new StringBuilder().append(sql);
//排序
/* if (StringUtils.isNotBlank(sidx) && StringUtils.isNotBlank(sord)) {
_sql.insert(0, "select * from (").append(") order by ").append(sidx).append(" ").append(sord);
}
//分页
_sql.insert(0, "select * from (select row_.*, rownum row_num_ from (");
_sql.append(") row_ where rownum<=").append(end).append(") where row_num_ > ").append(start);*/
log.debug("分页： " + _sql);
return _sql.toString();
}
/**
* 提供查询前对sql处理的功能
*
* @param statementId
* @param param
* @param sqlHandler sql处理器
* @return
*/
protected List queryWithSqlHandler(final String statementId, final Object param, final SqlHandler sqlHandler) {
if (sqlHandler != null) {
final MappedStatement mappedStatement = sqlMapClient.getMappedStatement(statementId);
final Sql dySql = mappedStatement.getSql();
if (Proxy.isProxyClass(dySql.getClass())) {
log.debug("该Sql对象已经是代理对象，设置新的sql处理器。");
((SqlProxyHandler) Proxy.getInvocationHandler(dySql)).setSqlHandler(sqlHandler);
} else {
log.debug("创建Sql的代理对象！");
final SqlProxyHandler sqlProxyHandler = new SqlProxyHandler(dySql, sqlHandler);
final Class sqlClass = dySql.getClass();
final Sql proxy = (Sql) Proxy.newProxyInstance(sqlClass.getClassLoader(), sqlClass.getInterfaces(), sqlProxyHandler);
mappedStatement.setSql(proxy);
}
}
try {
return sqlMapClient.queryForList(statementId, param);
} catch (SQLException ex) {
throw new RuntimeException("查询失败", ex);
}
}
public PageList findPageWithSqlHandler(String statementId, Object param, final PageList pageForm, final SqlHandler sqlHandler) {
final int[] total = new int[1];
List list = queryWithSqlHandler(statementId, param, new SqlHandler() {
public String handle(String sql, Object[] params) throws Throwable {
String nsql = sqlHandler.handle(sql, params);
System.out.println("--开始--");
//查询总记录数
total[0] = jdbcTemplate.queryForInt("select count(1) as RECORDS from (" + nsql + ") limitTable", params);
System.out.println(total[0]);
pageForm.setCount(total[0]);
System.out.println("--结束--");
// return getSqlWithPagerLimit(nsql, pageForm);
return "1234";
}
});
pageForm.setList(list);
return pageForm;
}
private static final class SqlProxyHandler implements InvocationHandler {
private final Sql sql;
private final ThreadLocal<SqlHandler> sqlHandler = new ThreadLocal();
public SqlProxyHandler(Sql sql, SqlHandler handler) {
this.sql = sql;
setSqlHandler(handler);
}
public Sql getSql() {
return sql;
}
public void setSqlHandler(SqlHandler handler) {
this.sqlHandler.set(handler);
}
public SqlHandler getSqlHandler() {
return sqlHandler.get();
}
public Object invoke(Object proxy, Method method, Object[] args) throws Throwable {
Object result = method.invoke(getSql(), args);
if ("getSql".equals(method.getName()) && getSqlHandler() != null) {
log.debug("原SQL： " + result);
final RequestScope statementScope = (RequestScope) args[0];
final Object[] params = statementScope.getParameterMap().getParameterObjectValues(statementScope, args[1]);
result = getSqlHandler().handle((String) result, params);
log.debug("处理后： " + result);
setSqlHandler(null);//执行完成后清除线程局部变量，下次调用需要设置新值，否则不拦截getSql方法
}
return result;
}
}
protected static interface SqlHandler {
/**
* 处理sql语句
*
* @param sql ibatis生成的sql语句，其中参数用?号占位
* @param params sql对应的参数
* @return
* @throws Throwable
*/
String handle(String sql, Object[] params) throws Throwable;
}
}
