加入JDBC规范

接口代理和jdbc操作的连接小例子

Author: GitJavaProgramming

.idea/workspace.xml

@@ -16,6 +16,8 @@
    * [mybatis-test](#mybatis-test)
    * [导航目录](#导航目录)
    * [开个头](#开个头)
+      * [基本结构：](#基本结构)
+      * [几个问题：](#几个问题)
    * [XML基础知识（名称空间/文档验证/文档处理）](#xml基础知识名称空间文档验证文档处理)
       * [XML](#xml)
       * [XML名称空间](#xml名称空间)
@@ -39,7 +41,14 @@
             * [JDK动态代理](#jdk动态代理)
    * [从头开始](#从头开始)
       * [mybatis初始化流程](#mybatis初始化流程)
-      * [SqlSession运行原理解析](#SqlSession运行原理解析)
+      * [SqlSession运行原理解析](#sqlsession运行原理解析)
+         * [Executor](#executor)
+            * [BaseExecutor](#baseexecutor)
+               * [一级缓存](#一级缓存)
+               * [事务管理](#事务管理)
+            * [sql操作具体实现](#sql操作具体实现)
+            * [CachingExecutor 二级缓存](#cachingexecutor-二级缓存)
+   * [JDBC](#jdbc)
    * [<em><strong>mybatis思维导图</strong></em>](#mybatis思维导图)
    * [<em><strong>主要参考资料：</strong></em>](#主要参考资料)
 
@@ -60,7 +69,7 @@ mybatis整体架构分为三层，分别是基础支持层、核心处理层和
     结果集/实体   UserEntiry  
 
 ## 几个问题：    
-  1. 读写配置文件，如何封装，提取配置的SQL语句  Configuration MapperProxy MappedStatement  
+  1. 读写配置文件，如何封装，提取配置的SQL语句并解析  Configuration MapperProxy MappedStatement  
   2. 接口在哪里实现，怎么实现，SQL如何执行 SqlSession Executor TypeHandler      
   3. 结果集映射返回期望的Java类型 ResultSetHandler  
   4. 对扩展开放   plugins  
@@ -401,6 +410,16 @@ Mybatis定义Transaction事务操作接口，它有两个实现JdbcTranscation
 二级缓存是事务级别缓存，是一个全局缓存，被所有SqlSession(ref -> sqlSession javadoc)共享。      
 CachingExecutor通过装饰模式组合Executor添加新功能，提供二级缓存功能。当然Cache的线程安全由自身保证。    
 
+# JDBC
+
+JDBC JSR221规范，当前4.3(oracle)草案，4.0(sun)为最终版。  
+
+[JCP](https://www.jcp.org/en/home/index "JCP")  
+[JSR221](https://www.jcp.org/en/jsr/detail?id=221 "jdbc规范")   
+[JDBC4.0](./jdbc4.0-fr-spec.pdf "4.0")   
+[JDBC4.0规范中文](https://www.jianshu.com/nb/15028668 "JDBC4.0规范")   
+
+DataSource数据源实现 参考规范4.0 ch09---connections   
 
 
 # ***mybatis思维导图***  
@@ -426,5 +445,5 @@ CachingExecutor通过装饰模式组合Executor添加新功能，提供二级缓
 > - [x] [深入理解Java虚拟机 JVM高级特性与最佳实践 第2版](https://pan.baidu.com/s/17mGl_Xu-dgWITfoD8V90HA "3tv9")  
 > - [x] [Java深度历险](https://pan.baidu.com/s/1FTxaBmZPaiHKA4MPEF9p5g "rx5d")  
 > - [x] [Java语言规范 基于Java SE 8](https://pan.baidu.com/s/1OSxrl5dZOvEHddAG4exNEA "wl1r")  
-> - [x] [Java虚拟机规范  Java SE 8版](https://pan.baidu.com/s/14PjId4EJOHhyPxqQITaUTA "fvgs")  
+> - [x] [Java虚拟机规范  Java SE 8版](https://pan.baidu.com/s/14PjId4EJOHhyPxqQITaUTA "fvgs")   
 

README.md

@@ -0,0 +1,20 @@
+package org.pp.mybatis.foundationsupportlayer;
+
+import org.pp.mybatis.foundationsupportlayer.reflector.proxy.jdk.*;
+
+public class Client {
+    public static void main(String[] args) {
+        // jdk proxy
+//        Subject subject = new JdkSubject();
+//
+//        Subject proxy = (Subject) JdkProxy.getProxy(subject);
+//        proxy.doSomething();
+//        proxy.getStr();
+//
+//        System.out.println("======================================================");
+
+        Subject proxy2 = JdkInterfaceProxy.newInstance(Subject.class);
+        proxy2.doSomething();
+        proxy2.getStr();
+    }
+}

jdbc4.0-fr-spec.pdf

@@ -0,0 +1,19 @@
+package org.pp.mybatis.foundationsupportlayer.jdbc;
+
+import org.pp.mybatis.foundationsupportlayer.jdbc.cases.prepare.BaseExecutor;
+import org.pp.mybatis.foundationsupportlayer.jdbc.cases.prepare.ExecutorFactory;
+
+import java.sql.Connection;
+import java.sql.DatabaseMetaData;
+import java.sql.SQLException;
+
+public class Client {
+    public static void main(String[] args) throws SQLException {
+        BaseExecutor executor = ExecutorFactory.newExecutor();
+        executor.doQuery("1");
+        Connection connection = executor.getTransaction().getConnection();
+        DatabaseMetaData metaData = connection.getMetaData();
+        System.out.println("driverName: " + metaData.getDriverName());
+        System.out.println("DriverVersion: " + metaData.getDriverVersion());
+    }
+}

jdbc4.3-fr-spec.pdf

@@ -0,0 +1,23 @@
+package org.pp.mybatis.foundationsupportlayer.jdbc;
+
+import java.util.ResourceBundle;
+
+public final class ConfigUtil {
+    private static final ResourceBundle config = ResourceBundle.getBundle("jdbc");
+
+    public static String getJdbcDriverClass() {
+        return config.getString("jdbc.driverClass");
+    }
+
+    public static String getJdbcUrl() {
+        return config.getString("jdbc.url");
+    }
+
+    public static String getJdbcUserName() {
+        return config.getString("jdbc.username");
+    }
+
+    public static String getJdbcPassWord() {
+        return config.getString("jdbc.password");
+    }
+}

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

@@ -0,0 +1,32 @@
+package org.pp.mybatis.foundationsupportlayer.jdbc.cases.prepare;
+
+import java.sql.Connection;
+import java.sql.SQLException;
+import java.util.List;
+
+/**
+ * 提供事务管理机制和基本数据库操作
+ */
+public abstract class BaseExecutor {
+
+    protected JdbcTransaction transaction;
+
+    private Environment environment;
+
+    protected BaseExecutor(Environment environment) {
+        this.environment = environment;
+        if (this.transaction == null) {
+            this.transaction = this.environment.getJdbcTransaction();
+        }
+    }
+
+    public abstract <E> List<E> doQuery(String parameter) throws SQLException;
+
+    public JdbcTransaction getTransaction() {
+        return transaction;
+    }
+
+    protected Connection getConnection() throws SQLException {
+        return transaction.getConnection();
+    }
+}

src/main/java/org/pp/mybatis/foundationsupportlayer/jdbc/Client.java

@@ -0,0 +1,42 @@
+package org.pp.mybatis.foundationsupportlayer.jdbc.cases.prepare;
+
+import javax.sql.DataSource;
+
+/**
+ * 提供数据源和事务管理
+ */
+public final class Environment {
+    private final String id;
+    private final JdbcTransaction jdbcTransaction;
+    private final DataSource dataSource;
+
+    public Environment(String id, DataSource dataSource) {
+        this.id = id;
+        this.dataSource = dataSource;
+        this.jdbcTransaction = newTransaction(dataSource, null, false);
+    }
+
+    public String getId() {
+        return this.id;
+    }
+
+    public JdbcTransaction getJdbcTransaction() {
+        return jdbcTransaction;
+    }
+
+    public DataSource getDataSource() {
+        return this.dataSource;
+    }
+
+    /**
+     *  数据源创建JdbcTransaction实例
+     * @param ds
+     * @param level
+     * @param autoCommit
+     * @return
+     */
+    public JdbcTransaction newTransaction(DataSource ds, TransactionIsolationLevel level, boolean autoCommit) {
+        return new JdbcTransaction(ds, level, autoCommit);
+    }
+
+}

src/main/java/org/pp/mybatis/foundationsupportlayer/jdbc/ConfigUtil.java

@@ -0,0 +1,35 @@
+package org.pp.mybatis.foundationsupportlayer.jdbc.cases.prepare;
+
+import org.apache.ibatis.datasource.unpooled.UnpooledDataSource;
+import org.pp.mybatis.foundationsupportlayer.jdbc.ConfigUtil;
+
+import javax.sql.DataSource;
+
+public class ExecutorFactory {
+
+    private static Environment environment;
+
+    private ExecutorFactory() {
+    }
+
+    public static BaseExecutor newExecutor() {
+        if (environment == null) {
+            // 读配置文件，获取数据源 这里直接用mybatis数据源测试
+            // UnpooledDataSource使用DriverManager.getDrivers();获取classpath下已加载的driver
+            // 如果pom中去掉唯一的mysql driver依赖 Client调用就会产生异常
+            // DataSource实现 请参考jdbc规范
+            DataSource dataSource = new UnpooledDataSource(ConfigUtil.getJdbcDriverClass(), ConfigUtil.getJdbcUrl(),
+                    ConfigUtil.getJdbcUserName(), ConfigUtil.getJdbcPassWord());
+            environment = new Environment("", dataSource);
+        }
+        return new SimpleExecutor(environment);
+    }
+
+//    private static final class Holder {
+//        private static final ExecutorFactory EXECUTOR_FACTORY = new ExecutorFactory();
+//    }
+//
+//    public static final ExecutorFactory getInstance() {
+//        return Holder.EXECUTOR_FACTORY;
+//    }
+}