4.2.4.RELEASE
3.2.8
1.2.2

    
    
    <bean id="dataSource" class="org.springframework.jdbc.datasource.DriverManagerDataSource">
        <property name="driverClassName" value="org.logicalcobwebs.proxool.ProxoolDriver"/>
        <property name="url" value="proxool.hjzzAuthPlatform"/>
    bean>
    
    <bean id="jdbcTemplate" class="org.springframework.jdbc.core.JdbcTemplate">
        <property name="dataSource" ref="dataSource"/>
    bean>
    
    
    
    <bean id="sqlSessionFactory" class="org.mybatis.spring.SqlSessionFactoryBean">
        
        <property name="dataSource" ref="dataSource" />
        
        <property name="configLocation" value="classpath:mybatis/SqlMapConfig.xml" />
    bean>
    
    <bean class="org.mybatis.spring.mapper.MapperScannerConfigurer">
        <property name="basePackage" value="com.autumn" />
    bean>

xml version="1.0" encoding="UTF-8" ?>
DOCTYPE configuration
        PUBLIC "-//mybatis.org//DTD Config 3.0//EN"
        "http://mybatis.org/dtd/mybatis-3-config.dtd">
<configuration>
<plugins>
    <plugin interceptor="com.gmtx.system.intercepts.MyPageInterceptor">
        <property name="limit" value="10"/>
        <property name="dbType" value="mysql"/>
    plugin>
plugins>
configuration>

package com.autumn.system.intercepts;

import java.sql.Connection;
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.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;

/**
 * @Intercepts 说明是一个拦截器
 * @Signature 拦截器的签名
 * type 拦截的类型 四大对象之一( Executor,ResultSetHandler,ParameterHandler,StatementHandler)
 * method 拦截的方法
 * args 参数
 */
@Intercepts({@Signature(type = StatementHandler.class, method = "prepare", args = {Connection.class})})
public class MyPageInterceptor implements Interceptor {

    //每页显示的条目数
    private int pageSize;
    //当前现实的页数
    private int currPage;
    //数据库类型
    private String dbType;


    @Override
    public Object intercept(Invocation invocation) throws Throwable {
        //获取StatementHandler，默认是RoutingStatementHandler
        StatementHandler statementHandler = (StatementHandler) invocation.getTarget();
        //获取statementHandler包装类
        MetaObject MetaObjectHandler = SystemMetaObject.forObject(statementHandler);

        //分离代理对象链
        while (MetaObjectHandler.hasGetter("h")) {
            Object obj = MetaObjectHandler.getValue("h");
            MetaObjectHandler = SystemMetaObject.forObject(obj);
        }

        while (MetaObjectHandler.hasGetter("target")) {
            Object obj = MetaObjectHandler.getValue("target");
            MetaObjectHandler = SystemMetaObject.forObject(obj);
        }

        //获取连接对象
        //Connection connection = (Connection) invocation.getArgs()[0];


        //object.getValue("delegate");  获取StatementHandler的实现类

        //获取查询接口映射的相关信息
        MappedStatement mappedStatement = (MappedStatement) MetaObjectHandler.getValue("delegate.mappedStatement");
        String mapId = mappedStatement.getId();

        //statementHandler.getBoundSql().getParameterObject();

        //拦截以.ByPage结尾的请求，分页功能的统一实现
        if (mapId.matches(".+ByPage$")) {
            //获取进行数据库操作时管理参数的handler
            ParameterHandler parameterHandler = (ParameterHandler) MetaObjectHandler.getValue("delegate.parameterHandler");
            //获取请求时的参数
            Map paraObject = (Map) parameterHandler.getParameterObject();
            //也可以这样获取
            //paraObject = (Map) statementHandler.getBoundSql().getParameterObject();

            //参数名称和在service中设置到map中的名称一致
            currPage = Integer.parseInt((String) (paraObject.get("currPage")==null?"1":paraObject.get("currPage"))) ;
            pageSize = Integer.parseInt((String) (paraObject.get("pageSize")==null?"20":paraObject.get("pageSize"))) ;

            String sql = (String) MetaObjectHandler.getValue("delegate.boundSql.sql");
            //也可以通过statementHandler直接获取
            //sql = statementHandler.getBoundSql().getSql();

            //构建分页功能的sql语句
            String limitSql;
            sql = sql.trim();
            limitSql = sql + " limit " + (currPage - 1) * pageSize + "," + pageSize;
            //将构建完成的分页sql语句赋值个体'delegate.boundSql.sql'，偷天换日
            MetaObjectHandler.setValue("delegate.boundSql.sql", limitSql);
        }
        //调用原对象的方法，进入责任链的下一级
        return invocation.proceed();
    }


    //获取代理对象
    @Override
    public Object plugin(Object o) {
        //生成object对象的动态代理对象
        return Plugin.wrap(o, this);
    }

    //设置代理对象的参数
    @Override
    public void setProperties(Properties properties) {
        //如果项目中分页的pageSize是统一的，也可以在这里统一配置和获取，这样就不用每次请求都传递pageSize参数了。参数是在配置拦截器时配置的。
        String limit1 = properties.getProperty("limit", "10");
        this.pageSize = Integer.valueOf(limit1);
        this.dbType = properties.getProperty("dbType", "mysql");
    }
}

@Controller
@RequestMapping("/common")
public class CommonController {

    //Spring JDBCTemplate
    @Resource(name="commonDao")
    private CommonDao dao = null;;
    
    //Mybatis
    @Autowired
    AccountMapper accountMapper = null;
    
    //JDBCTemplate测试
    @RequestMapping(value="/testJDBCTemplate",method={RequestMethod.GET,RequestMethod.POST})
    public ModelAndView testJDBCTemplate(){
        ModelAndView mv = new ModelAndView("/jsp/success");
        dao.execute("INSERT INTO `account` (`sysid`, `userid`, `aut_userId`, `username`, `userpwd`) VALUES ('aaa', 'aeolian', 32323, 'fff', 'ggg')", new Object[]{});
        mv.addObject("msg", "success");
        return mv;
    }
    
    //mybatis测试
    @RequestMapping(value="/testMybatis",method={RequestMethod.GET,RequestMethod.POST})
    @ResponseBody
    public Object testMybatis(){
        AccountKey pam = new AccountKey();
        pam.setSysid("1");
        pam.setUserid("pingtai");
        return accountMapper.selectByPrimaryKey(pam);
    }
    
    //mybatis分页测试
    @RequestMapping(value="/testMybatisByPage",method={RequestMethod.GET,RequestMethod.POST})
    @ResponseBody
    public Object testMybatisByPage(Integer currPage,Integer pageSize){
        return accountMapper.getAllByPage(currPage,pageSize);
    }
}

public interface FrontUserMapper {
    Frontuser getFrontUserByAccount(Frontuser frontuser);
}

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.gmtx.front.mapper.FrontUserMapper">
    
    <select id="getFrontUserByAccount" parameterType="com.gmtx.manage.model.Frontuser"  resultType="com.gmtx.manage.model.Frontuser">
      SELECT * FROM  frontuser where userName =#{username} and pwd =#{pwd}
    select>
mapper>