About JDBC

什么是 JDBC

Java 数据库连接（Java Database Connectivity）是 Java 语言中用来规范客户端程序如何来访问数据库的应用程序接口，提供了诸如查询和更新数据库中数据的方法。是面向关系型数据库的。

JDBC 规范采用接口和实现分离的思想设计了 Java 数据库编程的框架，API 主要位于 JDK 中的 java.sql 包中（之后扩展的内容位于 javax.sql 包中），主要包括（其中接口需要驱动提供者实现）：

DriverManager：负责加载各种不同驱动程序（Driver），并根据不同的请求，向调用者返回相应的数据库连接（Connection）。（注：DataSource 接口是 JDBC 2.0 API 中的新增内容，它提供了连接到数据源的另一种方法以替代 DriverManager。使用 DataSource 对象是连接到数据源的首选方法。）
Driver（接口）：驱动程序
Connection（接口）：数据库连接，负责进行与数据库间的通讯
Statement（接口）：用以执行 SQL 查询和更新（针对静态 SQL 语句和单次执行）
PreparedStatement（接口）：用以执行包含动态参数的 SQL 查询和更新（在服务器端编译，允许重复执行以提高效率）
javax.sql.DataSource（接口）：该工厂用于提供到此 DataSource 对象所表示的物理数据源的连接（A factory for connections to the physical data source that this DataSource object represents.）。作为 DriverManager 工具的替代项，DataSource 对象是获取连接的首选方法。实现 DataSource 接口的对象通常在基于 JavaTM Naming and Directory Interface(JNDI) API 的命名服务中注册。

JDBC 连接数据库

JDBC 连接数据库主要分为 DriverManager 方式和实现了 DataSource 接口的连接池方式。

使用 java.sql.DriverManager 类

利用 Class.forName() 方法来加载 JDBC 驱动程序（Driver），加载成功后会自动将 Driver 类的实例注册到 DriverManager 类中。
从 DriverManager 中，通过 JDBC URL、用户名、密码来获取相应的数据库连接（Connection）。
在获取 Connection 之后，便可以创建 Statement（或 PreparedStatement）用以执行 SQL 语句。
查询（SELECT）的结果存放于结果集（ResultSet）中，可以按照顺序依次访问。

public static void main(String[] args) {
  Statement stmt = null;
  Connection conn = null;
  ResultSet rs = null;
  try {
    Class.forName("com.mysql.jdbc.Driver"); // 加载 JDBC 驱动，成功后会自动将 Driver 类的实例注册到 DriverManager 中
    conn = DriverManager.getConnection("jdbc:MySql://192.168.192.125:3358/spring_boot_test?useUnicode=true", // URL
            "root", // 用户名
            "123456" ); // 密码
    stmt = conn.createStatement();
//      stmt.executeUpdate("INSERT INTO user( name, age) VALUES ('iverson', 40) " );
    rs = stmt.executeQuery("SELECT * FROM user");
    while (rs.next() ) {int numColumns = rs.getMetaData().getColumnCount();
         for (int i = 1 ; i <= numColumns ; i++) {
            // 与大部分 Java API 中下标的使用方法不同，字段的下标从 1 开始
            System.out.println("COLUMN" + i + "=" + rs.getObject(i) ); // 也可以使用 ResultSet.getXXX()}
    }
  } catch (SQLException e) {
      System.out.println("SQLException: "+ e.getMessage());
      System.out.println("SQLState:" + e.getSQLState());
      System.out.println("VendorError:" + e.getErrorCode());
  } catch (ClassNotFoundException e) {
    e.printStackTrace();
  } finally {
    if (stmt != null) {try {stmt.close();  
            } catch (SQLException e) {e.printStackTrace();  
                throw new RuntimeException(e);  
            }  
    }
    if(conn!=null) {try {conn.close();  
            } catch (SQLException e) {e.printStackTrace();  
                throw new RuntimeException(e);  
            } 
    }
  }
}

使用事务

JDK 文档中对事务有比较详细的解释。when you do not want one statement to take effect unless another one completes, The way to be sure that either both actions occur or neither action occurs is to use a transaction. A transaction is a set of one or more statements that is executed as a unit, so either all of the statements are executed, or none of the statements is executed.

使用事务原理很简单，When a connection is created, it is in auto-commit mode.The way to allow two or more statements to be grouped into a transaction is to disable the auto-commit mode（conn.setAutoCommit(false)）。在所有操作执行完成以后统一进行提交 conn.commit();。

下面的代码有三个 update 操作，其中第二个试图去更新一个不存在的表 user1 会抛出异常。在不使用事务的时候，会发现第一条更新操作生效而后两条失败，如果使用了事务控制，则三条更新语句都不会生效。

在 spring 中使用事务只需要一个注解即可，原理都一样。具体可参考 Spring 的参考文档

Class.forName("com.mysql.jdbc.Driver"); // 加载 JDBC 驱动，成功后会自动将 Driver 类的实例注册到 DriverManager 中
conn = DriverManager.getConnection("jdbc:MySql://192.168.192.125:3358/spring_boot_test?useUnicode=true", // URL
        "root", // 用户名
        "123456" ); // 密码
conn.setAutoCommit(false); // 關閉自動提交，默認開啟

stmt = conn.createStatement();
stmt.executeUpdate("UPDATE user SET age = 222 WHERE Name ='james'");
stmt.executeUpdate("UPDATE user1 SET age = 2 WHERE Name ='kobe'");
stmt.executeUpdate("UPDATE user SET age = 123 WHERE Name ='iverson'");
conn.commit();
rs = stmt.executeQuery("SELECT * FROM user");
while (rs.next() ) {int numColumns = rs.getMetaData().getColumnCount();
     for (int i = 1 ; i <= numColumns ; i++) {
        // 与大部分 Java API 中下标的使用方法不同，字段的下标从 1 开始
        System.out.println("COLUMN" + i + "=" + rs.getObject(i) ); // 也可以使用 ResultSet.getXXX()}
}

Using Transactions：https://docs.oracle.com/javase/tutorial/jdbc/basics/transactions.html

使用实现了 javax.sql.DataSource 接口的子类（连接池实现）

作为 DriverManager 工具的替代项，DataSource 对象是获取连接的首选方法，并且如果使用连接池技术，都需要实现 javax.sql.DataSource 接口。DataSource 接口由驱动程序供应商实现。共有三种类型的实现：

基本实现，生成标准的 Connection 对象通过 DataSource 对象访问的驱动程序本身不会向 DriverManager 注册。通过查找操作获取 DataSource 对象，然后使用该对象创建 Connection 对象。使用基本的实现，通过 DataSource 对象获取的连接与通过 DriverManager 设施获取的连接相同。由于和 DriverManager 存在同样的性能问题这里不再讨论。
连接池实现，生成自动参与连接池的 Connection 对象。此实现与中间层连接池管理器一起使用。
分布式事务实现，生成一个 Connection 对象，该对象可用于分布式事务，大多数情况下总是参与连接池。此实现与中间层事务管理器一起使用，大多数情况下总是与连接池管理器一起使用。

DataSource 是一个接口，那么它的实现者有哪些呢？大多数 Web 服务器都实现了 DataSource 接口，如 WebLogic、Tomcat（7.0 版本以前默认使用 commons-dbcp，因为性能问题从 7.0 开始换成 jdbc-pool（Tomcat connection pool），spring boot 也是默认使用 jdbc-pool），另外，一些开源组织也提供了 DataSource 的实现，如 DBCP、C3P0 和 Druid（阿里巴巴）。由于 dbcp 和 c3p0 都是单线程的，在高并发的环境下性能会比较低下，jdbc-pool（Tomcat connection pool）则使用非常广泛，spring boot 默认使用的就是 jdbc-pool。

Tomcat connection pool 编码方式实现

public static void main(String[] args) {PoolProperties p = new PoolProperties();
    p.setUrl("jdbc:MySql://192.168.192.125:3358/spring_boot_test?useUnicode=true");
    p.setDriverClassName("com.mysql.jdbc.Driver");
    p.setUsername("root");
    p.setPassword("123456");
    p.setJmxEnabled(true);
    p.setTestWhileIdle(false);
    p.setTestOnBorrow(true);
    p.setValidationQuery("SELECT 1");
    p.setTestOnReturn(false);
    p.setValidationInterval(30000);
    p.setTimeBetweenEvictionRunsMillis(30000);
    p.setMaxActive(100);
    p.setInitialSize(10);
    p.setMaxWait(10000);
    p.setRemoveAbandonedTimeout(60);
    p.setMinEvictableIdleTimeMillis(30000);
    p.setMinIdle(10);
    p.setLogAbandoned(true);
    p.setRemoveAbandoned(true);
    p.setJdbcInterceptors("org.apache.tomcat.jdbc.pool.interceptor.ConnectionState;"+
      "org.apache.tomcat.jdbc.pool.interceptor.StatementFinalizer");
    DataSource datasource = new DataSource();
    datasource.setPoolProperties(p);

    Connection con = null;
    try {con = datasource.getConnection();
      Statement st = con.createStatement();
      ResultSet rs = st.executeQuery("select * from user");
      int cnt = 1;
      while (rs.next()) {System.out.println((cnt++)+". name:" +rs.getString("name")+
            "age:"+rs.getString("age"));
      }
      rs.close();
      st.close();} catch (SQLException e) {e.printStackTrace();
  } finally {if (con!=null) try {con.close();}catch (Exception ignore) {}}
}

关于 JDBC 的基础知识