解读MySQL驱动加载逻辑
我们很早之前就知道最基础的JDBC编写，先执行Class.forName方法，加载MySQL驱动。但是为什么加载过驱动后，后续的接口层的调用就会自动切换到MySQL的相关代码去执行呢？(作者：高元)
常见jdbc编写
Connection connection = null;
PreparedStatement ps = null;
ResultSet rs = null;
try {
Class.forName("com.mysql.jdbc.Driver");
connection = DriverManager.getConnection("jdbc:mysql://localhost:3306/gdjt_db","root","root");
ps = connection.prepareStatement("select * from sys_user where id = ? ");
ps.setString(1, "1");
rs = ps.executeQuery();
while (rs.next()){
System.out.println(rs.getString("name"));
}
}catch (Exception e){
e.printStackTrace();
}finally {
try {
if(rs != null)rs.close();
}catch (Exception e){}
try {
if(ps != null)ps.close();
}catch (Exception e){}
try {
if(connection != null)connection.close();
}catch (Exception e){}
}
当然，我们这里使用MySQL来演示，所以需要导入相关依赖
mysql
mysql-connector-java
5.1.44
以上是最简单的JDBC实现，下面我们主要查看Class.forName("com.mysql.jdbc.Driver");具体的执行逻辑。
查看第一步具体做了什么?
Class.forName("com.mysql.jdbc.Driver");
1、我们先看Class.forName
@CallerSensitive
public static Class> forName(String className) throws ClassNotFoundException {
/** 获取调用者Class */
Class> caller = Reflection.getCallerClass();
/**
* 1、获取调用者的类加载器
* 2、执行类加载
* 3、执行初始化方法(initialize = true)
*/
return forName0(className, true, ClassLoader.getClassLoader(caller), caller);
}
具体内容见代码中的注解，可以发现，Class.forName主要就是类加载，加载了类com.mysql.jdbc.Driver
2、接着看mysql的Driver源码实现
/**
* java.sql.Driver 是jdk封装的驱动接口
*/
public class Driver extends NonRegisteringDriver implements java.sql.Driver {
public Driver() throws SQLException {
}
/** 上一步骤类加载器加载类时，执行了初始化方法，就是执行这里的static中的代码 */
static {
try {
/** 将当前mysql的Driver注册到DriverManager中 */
DriverManager.registerDriver(new Driver());
} catch (SQLException var1) {
throw new RuntimeException("Can't register driver!");
}
}
}
具体注册代码如下：
public static synchronized void registerDriver(java.sql.Driver driver, DriverAction da) throws SQLException {
if(driver != null) {
// 将mysql的driver封装成DriverInfo对象，并传入registeredDrivers链表中。
registeredDrivers.addIfAbsent(new DriverInfo(driver, da));
} else {
throw new NullPointerException();
}
}
其中 registeredDrivers 是全局的静态变量
private final static CopyOnWriteArrayList registeredDrivers = new CopyOnWriteArrayList<>();
这样，无论在哪里，都可以通过registeredDrivers来获取当前的驱动。
3、继续看Connection如何获取到对应的连接的
Connection conn = DriverManager.getConnection(url,username,password);
我们进入getConnection查看，代码稍微长点，不过没关系，我们只要看如下一行代码即可
private static Connection getConnection(String url, java.util.Properties info, Class> caller) throws SQLException {
...
// 看到了熟悉的身影 registeredDrivers
for(DriverInfo aDriver : registeredDrivers) {
...
// 从registeredDrivers获取之前存入的mysql对应的Driver
Connection con = aDriver.driver.connect(url, info);
...
}
...
}
接着执行 driver.connect( ) 方法，之前我们看过 Driver 的源码
Driver extends NonRegisteringDriver implements java.sql.Driver
所以 driver.connect 的方法，不是在 Driver 中就是在 NonRegisteringDriver 中。 结果我们在 NonRegisteringDriver 中如愿以偿的找到了connect方法(118行左右)
public Connection connect(String url, Properties info) throws SQLException {
...
// 重要代码在这里，获取具体的连接实例
com.mysql.jdbc.Connection newConn = ConnectionImpl.getInstance(this.host(props), this.port(props), props, this.database(props), url);
return newConn;
...
}
接下来的步骤就不一一演示了。
总结
通过类加载器加载Driver并初始化，将Driver添加到DriverManager的registeredDrivers中；
通过registeredDrivers获取到Driver；
调用Driver的connect方法，获取Mysql中的MySQLConnection；
博客
开源中国博客地址
个人博客地址
欢迎关注我的个人微信订阅号：(据说这个头像程序猿专用)
