相信大家每天都在使用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());
}
}