jdk动态代理 代理接口方法 自定义实现逻辑-自定义注解使用

SqlSession执行原理初步解析

Author: GitJavaProgramming

.idea/workspace.xml

@@ -1,8 +1,10 @@
 # mybatis-test
 
- mybatis源码研究-2019/12/04   
+**mybatis源码研究-2019/12/04**   
  教你一周精通mybatis（调试版本：3.5.3）
- 从整体到局部，最后再回到整体，从全局把控mybatis各个模块；     
+ 从整体到局部，最后再回到整体，从全局把控mybatis各个模块；  
+ 1.自底向上分析法，先对基础控件描述并阐述相关实现原理，带着问题一步一步完成封装，最终形成整体。     
+ 2.从应用入手，自顶向下，挖掘实现机制，将具体模块一步一步细节拆解，最终形成深入全面的认识。       
  深挖mybatis所有核心知识点，真正掌握mybatis核心设计思想；    
  赠送各种流程图，思维导图。  
 
@@ -13,7 +15,7 @@
 
    * [mybatis-test](#mybatis-test)
    * [导航目录](#导航目录)
-   * [一个例子](#一个例子)
+   * [开个头](#开个头)
    * [XML基础知识（名称空间/文档验证/文档处理）](#xml基础知识名称空间文档验证文档处理)
       * [XML](#xml)
       * [XML名称空间](#xml名称空间)
@@ -37,6 +39,7 @@
             * [JDK动态代理](#jdk动态代理)
    * [从头开始](#从头开始)
       * [mybatis初始化流程](#mybatis初始化流程)
+      * [SqlSession运行原理解析](#SqlSession运行原理解析)
    * [<em><strong>mybatis思维导图</strong></em>](#mybatis思维导图)
    * [<em><strong>主要参考资料：</strong></em>](#主要参考资料)
 
@@ -47,9 +50,9 @@ mybatis整体架构分为三层，分别是基础支持层、核心处理层和
 > ![mybatis整体架构图](./mybatis整体架构图02.png "mybatis整体架构图")    
 
 ****
-# 一个例子
+# 开个头
 参考项目代码~~~  
-[详细标签版-MyBatis技术内幕](https://pan.baidu.com/s/1-JGtoXADDjQRw5v51np4vA "提取码是fcak")  
+[详细书签版-MyBatis技术内幕](https://pan.baidu.com/s/1-JGtoXADDjQRw5v51np4vA "提取码是fcak")  
 
 # XML基础知识（名称空间/文档验证/文档处理）
 
@@ -299,8 +302,29 @@ mybatis入口： SqlSessionFactoryBuilder读取xml文档，解析并构造Config
 sqlSessionFactory可以很轻易的拿到sqlSession，sqlSession提供系列操作方法,    
 sqlSession Javadoc：Through this interface you can execute commands, get mappers and manage transactions.。  
 ## mybatis初始化流程   
-mybatis初始化之后Configuration、sqlSessionFactory均已构造完成。  
-> ![mybatis初始化流程](./mybatis初始化流程.png "mybatis初始化流程图")   
+mybatis初始化之后Configuration、sqlSessionFactory均已构造完成。   
+
+MapperRegistry中维护了实际类型（*Mapper接口,由mapper元素的namespace属性指定）和代理类的map映射    
+提供两个泛型方法：      
+public <T> void addMapper(Class<T> type)中传入的Class将会被MapperProxyFactory代理，代理处理器是MapperProxy    
+public <T> T getMapper(Class<T> type, SqlSession sqlSession) 返回代理类实例（与被代理类是同一类型）  
+  
+![mybatis初始化流程](./mybatis初始化流程.png "mybatis初始化流程图")    
+
+## SqlSession运行原理解析
+
+所有配置解析完成之后，mapper映射文件中，一个SQL元素节点被封装成一个MappedStatement对象，在SqlSession中注入全局配置单例    
+Configuration通过元素id、MappedStatement映射可以找到对应MappedStatement对象，它包含了具体执行的sql字符串。      
+MapperProxyFactory仅仅只是代理方法，由于接口不提供实现，所以需要自己实现方法处理逻辑，并提供返回值。   
+`final MapperMethod mapperMethod = cachedMapperMethod(method);    
+    return mapperMethod.execute(sqlSession, args); `    
+
+具体实现在SqlSession中，SqlSession用到了缓存的MappedStatement执行真实的sql字符串；这是接口和实现分离思想的体现。   
+同时这里用到了命令模式。    
+
+    
+
+
 
 # ***mybatis思维导图***  
 > ![mybatis思维导图](./mybatis整体架构图01.png "mybatis思维导图")  

README.md

@@ -1,8 +1,6 @@
 package org.pp.mybatis.foundationsupportlayer.reflector.proxy;
 
-import org.pp.mybatis.foundationsupportlayer.reflector.proxy.jdk.JdkProxy;
-import org.pp.mybatis.foundationsupportlayer.reflector.proxy.jdk.JdkSubject;
-import org.pp.mybatis.foundationsupportlayer.reflector.proxy.jdk.Subject;
+import org.pp.mybatis.foundationsupportlayer.reflector.proxy.jdk.*;
 
 public class Client {
     public static void main(String[] args) {
@@ -14,5 +12,9 @@ public static void main(String[] args) {
         proxy.getStr();
 
         System.out.println("======================================================");
+
+        Subject proxy2 = JdkInterfaceProxy.newInstance(Subject.class);
+        proxy2.doSomething();
+        proxy2.getStr();
     }
 }

src/main/java/org/pp/mybatis/foundationsupportlayer/reflector/proxy/Client.java

@@ -0,0 +1,47 @@
+package org.pp.mybatis.foundationsupportlayer.reflector.proxy.jdk;
+
+import java.lang.annotation.Annotation;
+import java.lang.reflect.InvocationHandler;
+import java.lang.reflect.Method;
+
+public class JdkInterfaceDynamicProxyHandler implements InvocationHandler {
+
+    static {
+        System.out.println("JdkInterfaceDynamicProxyHandler Class init.");
+    }
+
+    private JdkInterfaceDynamicProxyHandler() {
+    }
+
+    public Object invoke(Object proxy/* 对象的代理 */, Method method, Object[] args) throws Throwable {
+        System.out.println("method.getDeclaringClass(): " + method.getDeclaringClass());
+        if (Object.class.equals(method.getDeclaringClass())) {
+            return method.invoke(this, args);
+        }
+        // wrap,getAnnotation() ops
+        System.out.println(method.getName() + " invoke.");
+        Annotation[] annotations = method.getAnnotations();
+        for (Annotation annotation : annotations) {
+            System.out.println("annotation annotationType: " + annotation.annotationType());
+            if (annotation.annotationType() == NAnnotation.class) {
+                NAnnotation nAnnotation = method.getAnnotation(NAnnotation.class);
+                System.out.println("annotation value: " + nAnnotation.value());
+            }
+        }
+        // 接口不提供实现，需要自己实现方法处理逻辑
+        // MapperMethod--methodCache--sqlCommand,MethodSignature,Executor......
+        return null;
+    }
+
+    private static class Holder {
+        static {
+            System.out.println("Holder Class init.");
+        }
+
+        private static /*final*/ /* final 指定为常量立即初始化？ */ JdkInterfaceDynamicProxyHandler handler = new JdkInterfaceDynamicProxyHandler();
+    }
+
+    public static JdkInterfaceDynamicProxyHandler getInstance() {
+        return Holder.handler;
+    }
+}

src/main/java/org/pp/mybatis/foundationsupportlayer/reflector/proxy/jdk/JdkInterfaceDynamicProxyHandler.java

@@ -0,0 +1,20 @@
+package org.pp.mybatis.foundationsupportlayer.reflector.proxy.jdk;
+
+import java.lang.reflect.InvocationHandler;
+import java.lang.reflect.Proxy;
+
+public class JdkInterfaceProxy {
+
+    private JdkInterfaceProxy() {
+    }
+
+    public static <T> T newInstance(Class<T> proxied/* 被代理接口 */, InvocationHandler handler) {
+        //取得代理对象
+        return (T) Proxy.newProxyInstance(proxied.getClassLoader(), new Class<?>[]{proxied}, handler);
+    }
+
+    public static <T> T newInstance(Class<T> proxied) {
+        InvocationHandler handler = JdkInterfaceDynamicProxyHandler.getInstance();
+        return (T) Proxy.newProxyInstance(proxied.getClassLoader(), new Class<?>[]{proxied}, handler);
+    }
+}

src/main/java/org/pp/mybatis/foundationsupportlayer/reflector/proxy/jdk/JdkInterfaceProxy.java

@@ -0,0 +1,12 @@
+package org.pp.mybatis.foundationsupportlayer.reflector.proxy.jdk;
+
+import java.lang.annotation.ElementType;
+import java.lang.annotation.Retention;
+import java.lang.annotation.RetentionPolicy;
+import java.lang.annotation.Target;
+
+@Target({ElementType.FIELD, ElementType.METHOD})
+@Retention(RetentionPolicy.RUNTIME)
+public @interface NAnnotation {
+    String value();
+}

src/main/java/org/pp/mybatis/foundationsupportlayer/reflector/proxy/jdk/NAnnotation.java

@@ -2,6 +2,7 @@
 
 public interface Subject {
 
+    @NAnnotation("你好")
     void doSomething();
 
     void getStr();