JAVA加载数据库驱动(JDBC)
前言
之前，对Class.forName("com.mysql.jdbc.Driver");这条动态加载JDBC驱动感觉很疑惑，故有了这篇短文。
一、使用JDBC连接MySQL
首先，来看一下正常使用Java操纵MySql的简单代码逻辑。
public static boolean connectionMySqlDemo() {
Connection conn = null;
try {
// 1、动态加载mysql驱动
Class.forName("com.mysql.jdbc.Driver");
// 2、连接数据库
conn = DriverManager.getConnection("jdbc:mysql://localhost:3306/test?"
+ "user=root&password=1234&useUnicode=true&characterEncoding=UTF8");
// 3、声明一个Statement 用来执行sql语句
Statement stmt = conn.createStatement();
// 4、执行sql语句
stmt.executeUpdate("create table student(no_id char(20),name varchar(20),primary key(no_id))");
int result = stmt.executeUpdate("insert into student(no_id,name) values('1','fxleyu')");
if (result > 0) {
ResultSet rs = stmt.executeQuery("select * from student");
while (rs.next()) {
System.out.println(rs.getString(1));
}
}
} catch (ClassNotFoundException e) {
e.printStackTrace();
} catch (SQLException e) {
e.printStackTrace();
} finally {
// 5、关闭数据库
if (conn != null) {
try {
conn.close();
return true;
} catch (SQLException e) {
e.printStackTrace();
}
}
}
return false;
}
在上述代码中，动态加载数据库驱动那条语句感觉独立于其余代码逻辑。感觉缺少其并无关系(当然缺少了会在链接数据库时报java.sql.SQLException: No suitable driver found for)。
二、疑惑
上述代码很容易理解，除了如下Class.forName("com.mysql.jdbc.Driver");。正常理解，该语句只是加载把com.mysql.jdbc.Driver加载到JVM中，没不会产生特殊作用。
阅读com.mysql.jdbc.Driver代码，可以发现其中的隐含逻辑。
public class Driver extends NonRegisteringDriver implements java.sql.Driver {
//
// Register ourselves with the DriverManager
//
static {
try {
java.sql.DriverManager.registerDriver(new Driver());
} catch (SQLException E) {
throw new RuntimeException("Can't register driver!");
}
}
/**
* Construct a new driver and register it with DriverManager
*
* @throws SQLException
*             if a database error occurs.
*/
public Driver() throws SQLException {
// Required for Class.forName().newInstance()
}
}
原来该类中有静态代码库，其加载到JVM时，会执行该静态代码库。而该代码块会把该类的对象实例自注册到DriverManager中。如此第一部分中的第二步就很容易理解了。
// 2、连接数据库
conn = DriverManager.getConnection("jdbc:mysql://localhost:3306/test?"
+ "user=root&password=1234&useUnicode=true&characterEncoding=UTF8");
其就是可以根据String来获得上述加载的驱动，从而可以正常访问数据库。
三、余以为
代码的逻辑很重要，而Class.forName("com.mysql.jdbc.Driver");单独来看只是一条孤立的语句。没有和上下文代码产生显示的关联，这就导致了余在前言中的疑惑。故，使用Class.forName("com.mysql.jdbc.Driver");来动态注册驱动，会对当前代码逻辑产生不利影响。
正常的逻辑，Class.forName方法就是加载一个指定类，并对该类做一些初始化工作(使用静态代码库)，其不应该做一些其它逻辑，例如动态注册驱动。如果需要注册驱动时，应该让用户自己使用DriverManager.registerDriver(new com.mysql.jdbc.Driver());来显示注册。这样代码逻辑会很清晰。
但在这里使用显示注册并不合适。因为当new com.mysql.jdbc.Driver()的动作中，就有类的加载过程。在该过程中，已经把该驱动加载到了DriverManager的列表中。而有显示的注册了一次，故DriverManager的列表会有两个com.mysql.jdbc.Driver实例。也就是说，MySql的jdbc并不适合用来进行显示加载。
当然，也许使用Class.forName("com.mysql.jdbc.Driver");有MySql团队自己的考虑，而我当前视野并没有看到其好处。
四、结束
Talk is cheap, show me the code. 当对某些代码逻辑有疑问时，不妨查看一下相关源码，就会豁然开朗。自勉。P.S. 第三部分的余以为灵感借鉴于“余晟以为”微信公众号，很喜欢他那句“我是这么以为的,当然你也可以那么以为”。
参考

最近接到一个比较恶心的需求，里面有一个小功能，使用不同的数据库驱动动态连接数据库，搞了一个测试demo，废话少说直接上代码

package com.aotain.taskmgr;

import java.net.URL; 

import java.net.URLClassLoader; 

import java.sql.Connection; 

import java.sql.Driver; 

import java.sql.DriverManager; 

import java.sql.DriverPropertyInfo; 

import java.sql.ResultSet; 

import java.sql.SQLException; 

import java.sql.SQLFeatureNotSupportedException; 

import java.sql.Statement; 

import java.util.HashMap; 

import java.util.Map; 

import java.util.Properties; 

import java.util.logging.Logger;

public class MycatMulitJdbcVersionTest {

private static final String JDBC_URL = "jdbc:mysql://localhost:3306/testdb?serverTimezone=UTC&useSSL=false";
private static final String USER = "root";
private static final String PASSWORD = "mysql";
private static final Map<String, String> jdbcVersionMap = new HashMap<String, String>();
private static final Map<String, Driver> tmpDriverMap = new HashMap<String, Driver>();

// 动态加载jdbc驱动
private static void dynamicLoadJdbc(String mysqlJdbcFile) throws Exception {
    URL u = new URL("jar:file:lib/" + mysqlJdbcFile + "!/");
    String classname = jdbcVersionMap.get(mysqlJdbcFile);
    URLClassLoader ucl = new URLClassLoader(new URL[] { u });
    Driver d = (Driver)Class.forName(classname, true, ucl).newInstance();
    DriverShim driver = new DriverShim(d);
    DriverManager.registerDriver(driver);
    tmpDriverMap.put(mysqlJdbcFile, driver);
}

// 每一次测试完卸载对应版本的jdbc驱动
private static void dynamicUnLoadJdbc(String mysqlJdbcFile) throws SQLException {
    DriverManager.deregisterDriver(tmpDriverMap.get(mysqlJdbcFile));
}

// 进行一次测试
private static void testOneVersion(String mysqlJdbcFile) {

    System.out.println("start test mysql jdbc version : " + mysqlJdbcFile);

    try {
        dynamicLoadJdbc(mysqlJdbcFile);
    } catch (Exception e1) {
        e1.printStackTrace();
    }

    Connection conn = null;
    try {
        conn = DriverManager.getConnection(JDBC_URL, USER, PASSWORD);
        Statement stmt = conn.createStatement();
        ResultSet rs = stmt.executeQuery("select user()");
        System.out.println("select user() output : ");
        while(rs.next()) {
            System.out.println(rs.getObject(1));
        }
        rs = stmt.executeQuery("show tables");
        System.out.println("show tables output : ");
        while(rs.next()) {
            System.out.println(rs.getObject(1));
        }
    } catch (SQLException e) {
        e.printStackTrace();
    } finally {
        if(conn != null) {
            try {
                conn.close();
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
    }

    try {
        dynamicUnLoadJdbc(mysqlJdbcFile);
    } catch (SQLException e) {
        e.printStackTrace();
    }

    System.out.println("end !!!");
    System.out.println();
}

public static void main(String[] args) {

    jdbcVersionMap.put("mysql-connector-java-6.0.3.jar", "com.mysql.cj.jdbc.Driver");
    jdbcVersionMap.put("mysql-connector-java-5.1.6.jar", "com.mysql.jdbc.Driver");
    jdbcVersionMap.put("mysql-connector-java-5.1.31.jar", "com.mysql.jdbc.Driver");
    jdbcVersionMap.put("mysql-connector-java-5.1.35.jar", "com.mysql.jdbc.Driver");
    jdbcVersionMap.put("mysql-connector-java-5.1.39.jar", "com.mysql.jdbc.Driver");

    for(String mysqlJdbcFile : jdbcVersionMap.keySet()) {
        testOneVersion(mysqlJdbcFile);
    }

}


}

class DriverShim implements Driver { 

    private Driver driver; 

    DriverShim(Driver d) { this.driver = d; } 

    public boolean acceptsURL(String u) throws SQLException { 

        return this.driver.acceptsURL(u); 

    } 

    public Connection connect(String u, Properties p) throws SQLException { 

        return this.driver.connect(u, p); 

    } 

    @Override 

    public DriverPropertyInfo[] getPropertyInfo(String url, Properties info) throws SQLException { 

        return this.driver.getPropertyInfo(url, info); 

    } 

    @Override 

    public int getMajorVersion() { 

        return this.driver.getMajorVersion(); 

    } 

    @Override 

    public int getMinorVersion() { 

        return this.driver.getMinorVersion(); 

    } 

    @Override 

    public boolean jdbcCompliant() { 

        return this.driver.jdbcCompliant(); 

    } 

    @Override 

    public Logger getParentLogger() throws SQLFeatureNotSupportedException { 

        return this.driver.getParentLogger(); 

    } 

}


我还是我，不一样的烟火*

前言
之前，对Class.forName("com.mysql.jdbc.Driver");这条动态加载JDBC驱动感觉很疑惑，故有了这篇短文。
一、使用JDBC连接MySQL
首先，来看一下正常使用Java操纵MySql的简单代码逻辑。
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38public static boolean connectionMySqlDemo() {
Connection conn = null;
try {
// 1、动态加载mysql驱动
Class.forName("com.mysql.jdbc.Driver");
// 2、连接数据库
conn = DriverManager.getConnection("jdbc:mysql://localhost:3306/test?"
+ "user=root&password=1234&useUnicode=true&characterEncoding=UTF8");
// 3、声明一个Statement 用来执行sql语句
Statement stmt = conn.createStatement();
// 4、执行sql语句
stmt.executeUpdate("create table student(no_id char(20),name varchar(20),primary key(no_id))");
int result = stmt.executeUpdate("insert into student(no_id,name) values('1','fxleyu')");
if (result > 0) {
ResultSet rs = stmt.executeQuery("select * from student");
while (rs.next()) {
System.out.println(rs.getString(1));
}
}
} catch (ClassNotFoundException e) {
e.printStackTrace();
} catch (SQLException e) {
e.printStackTrace();
} finally {
// 5、关闭数据库
if (conn != null) {
try {
conn.close();
return true;
} catch (SQLException e) {
e.printStackTrace();
}
}
}
return false;
}
在上述代码中，动态加载数据库驱动那条语句感觉独立于其余代码逻辑。感觉缺少其并无关系(当然缺少了会在链接数据库时报java.sql.SQLException: No suitable driver found for)。
二、疑惑
上述代码很容易理解，除了如下Class.forName("com.mysql.jdbc.Driver");。
正常理解，该语句只是加载把com.mysql.jdbc.Driver加载到JVM中，没不会产生特殊作用。
阅读com.mysql.jdbc.Driver代码，可以发现其中的隐含逻辑。
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23public class Driver extends NonRegisteringDriver implements java.sql.Driver {
//
// Register ourselves with the DriverManager
//
static {
try {
java.sql.DriverManager.registerDriver(new Driver());
} catch (SQLException E) {
throw new RuntimeException("Can't register driver!");
}
}
/**
* Construct a new driver and register it with DriverManager
*
* @throws SQLException
*             if a database error occurs.
*/
public Driver() throws SQLException {
// Required for Class.forName().newInstance()
}
}
原来该类中有静态代码库，其加载到JVM时，会执行该静态代码库。
而该代码块会把该类的对象实例自注册到DriverManager中。
如此第一部分中的第二步就很容易理解了。
1
2
3// 2、连接数据库
conn = DriverManager.getConnection("jdbc:mysql://localhost:3306/test?"
+ "user=root&password=1234&useUnicode=true&characterEncoding=UTF8");
其就是可以根据String来获得上述加载的驱动，从而可以正常访问数据库。
三、余以为
代码的逻辑很重要，而Class.forName("com.mysql.jdbc.Driver");单独来看只是一条孤立的语句。
没有和上下文代码产生显示的关联，这就导致了余在前言中的疑惑。
故，使用Class.forName("com.mysql.jdbc.Driver");来动态注册驱动，会对当前代码逻辑产生不利影响。
正常的逻辑，Class.forName方法就是加载一个指定类，并对该类做一些初始化工作(使用静态代码库)，
其不应该做一些其它逻辑，例如动态注册驱动。
如果需要注册驱动时，应该让用户自己使用DriverManager.registerDriver(new com.mysql.jdbc.Driver());来显示注册。
这样代码逻辑会很清晰。
但在这里使用显示注册并不合适。因为当new com.mysql.jdbc.Driver()的动作中，就有类的加载过程。在该过程中，已经把该驱动加载到了DriverManager的列表中。而有显示的注册了一次，故DriverManager的列表会有两个com.mysql.jdbc.Driver实例。也就是说，MySql的jdbc并不适合用来进行显示加载。
当然，也许使用Class.forName("com.mysql.jdbc.Driver");有MySql团队自己的考虑，而我当前视野并没有看到其好处。
四、结束
Talk is cheap, show me the code. 当对某些代码逻辑有疑问时，不妨查看一下相关源码，就会豁然开朗。自勉。P.S. 第三部分的余以为灵感借鉴于“余晟以为”微信公众号，很喜欢他那句“我是这么以为的,当然你也可以那么以为”。
参考
1、使用源码下载路径 http://101.96.8.142/dev.mysql.com/get/Downloads/Connector-J/mysql-connector-java-5.1.40.tar.gz

展开全部
独立使用ActiveRecord
ActiveRecordPlugin可以独立于java web 环境运行在任何普通的java程序中，使62616964757a686964616fe78988e69d8331333365653837用方式极度简单，相对于web项目只需要手动调用一下其start() 方法即可立即使用。以下是代码示例：public class ActiveRecordTest {
public static void main(String[] args) {
DruidPlugin dp = new DruidPlugin("localhost", "userName", "password");
ActiveRecordPlugin arp = new ActiveRecordPlugin(dp);
arp.addMapping("blog", Blog.class);
// 与 jfinal web 环境唯一的不同是要手动调用一次相关插件的start()方法
dp.start();
arp.start();
// 通过上面简单的几行代码，即可立即开始使用
new Blog().set("title", "title").set("content", "cxt text").save();
Blog.dao.findById(123);
}
}
注意：ActiveRecordPlugin所依赖的其它插件也必须手动调用一下start()方法，如上例中的dp.start()。网页链接
把上面代码写在Controller中, 动态请求, 进行管理即可: 参考代码:网页链接