相信大家每天都在使用spring和mybatis,但是你们知道两个框架是怎么整合的吗？

     回忆下我们在项目中使用的场景,我们首先会定义一个interface接口，接口上会一个@Mapper注解，代表的意思就是持久层。

@Mapper
public interface IptvInfoDAO {
    @Select("select * from ${tableName} where loginaccount = #{userid} limit 1")
    IptvInfo select(@Param("tableName") String tableName, @Param("userid") String userid);
}

     接下来我们就会在service层，利用@Autowired 注解将Mapper注入,我们就可以对数据库进行操作了。

@Service
public class IptvInfoService {
    @Autowired
    private IptvInfoDAO iptvInfoDAO;

    public IptvInfo getIptvInfo(String userid) {
        return iptvInfoDAO.select(TableUtil.getUserTable(userid), userid);
    }
}

     大家有没有想过Mapper实际是一个接口，接口不可能实例化成一个对象，将其对象放入IOC容器中，那为什么可以在Spring 容器中获取一个对象，然后将对象赋给属性呢？

     带着这样的疑问继续往下看，有的小伙伴说那肯定是Spring框架帮我们生成了一个代理对象，然后将代理对象放入到了IOC容器，自然我们就可以@Autowired依赖注入进来。没错，确实是这样,原理太抽象啦，我们先通过一个简单的例子带大家了解下两个框架是如何整合的。

实战演练

     用到的技术有java自定义注解、java反射机制、jdk 的动态代理,有不熟悉的小伙伴利用业余时间充下电吧

1）首先定义一个注解,给注解一个属性sqlArr

package hchang.demo.annotate;

import java.lang.annotation.*;

/**
 * @author lhc
 * 1、注解本质是一个接口
 * 2、注解的方法相当于属性
 */
@Target(ElementType.METHOD)
@Retention(RetentionPolicy.RUNTIME)
public @interface mySelect {
    String [] sqlArr() default "";
}

2）定义一个interface接口，接口里面声明一个方法，方法上使用我们自定义的注解@mySelect

package hchang.demo.annotate;

public interface QryUserInfo {

    @mySelect(sqlArr = "select password from I_IPTVINFO01 where loginAccount = 'kl333'; ")
    String  queryUserinfo();

}

3）利用JDK的动态代理Proxy.newProxyInstance方法生成一个代理对象QryUserInfo，当代理对象的方法被调用时，自动执行invoke()方法，将返回值返回到调用方法。

     代理对象的三个参数分别是类加载器、class接口数组、InvocationHandler

package hchang.demo.annotate;


import hchang.demo.util.JDBCCon;

import java.lang.reflect.InvocationHandler;
import java.lang.reflect.Method;
import java.lang.reflect.Proxy;
import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;

/**
 * 手动编写模拟实现Spring整合mybatis,与数据库交互
 * 1、自定义注解@mySelect
 * 2、结合java反射机制获取注解属性值(sql语句)
 * 3、结合java jdk动态代理获取接口的代理对象执行sql语句
 */

public class AnnotateDemo {
    public static void main(String[] args) {
        QryUserInfo qryUserInfo = (QryUserInfo) Proxy.newProxyInstance(QryUserInfo.class.getClassLoader(), new Class[]{QryUserInfo.class}, new InvocationHandler() {
            @Override
            public Object invoke(Object proxy, Method method, Object[] args) throws Throwable {
                Object ret = null;
                //获取注解
                mySelect ms = method.getAnnotation(mySelect.class);
                //获取注解的属性值，也就是SQL语句
                String[] strings = ms.sqlArr();
                //执行SQL
                JDBCCon jdbcCon = new JDBCCon();
                Connection conn =  jdbcCon.getConnection();
                Statement stmt= null;
                ResultSet rs = null;
                try {
                    stmt = conn.createStatement();
                    rs  =stmt.executeQuery(strings[0]);
                    while (rs.next()) {
                        ret = rs.getString("password");
                    }
                } catch (SQLException throwables) {
                    throwables.printStackTrace();
                }
                finally {
                    if(conn !=null){
                        try {
                            conn.close();
                        } catch (SQLException throwables) {
                            throwables.printStackTrace();
                        }
                    }
                }
                //返回值
                return ret;
            }
        });
        System.out.println(qryUserInfo.queryUserinfo());
    }
}