前言
上篇文章分析了通过SPI技术如何来加载JDBC驱动连接。然后本篇继续写获得连接之后的一些事。
JDBC驱动加载
image.png
上篇文章写道，当JDBC驱动被加载的时候会执行这行代码，将当前的Driver注册到DriverManager中。而这段代码的执行主要是因为Driver的加载与初始化。Driver的加载与初始化 主要是因为SPI的加载。
image.png
当走到上述红框内的代码的时候会触发c.newInstance，而c就是加载的Driver，因此会触发其加载以及初始化。好了，接着回到第一张图。将Driver注册到DriverManager之后做了哪些事。点进去。
public static synchronized void registerDriver(java.sql.Driver driver,
DriverAction da)
throws SQLException {
/* Register the driver if it has not already been added to our list */
if(driver != null) {
// 可以看到其被封装成了一个DriverInfo加入到了registerDrivers中，registeredDrivers是一个线程安全的list.
registeredDrivers.addIfAbsent(new DriverInfo(driver, da));
} else {
// This is for compatibility with the original DriverManager
throw new NullPointerException();
}
println("registerDriver: " + driver);
}
然后回到下面这行代码
Connection connection = DriverManager.getConnection(url, "root", "chusen");
开始获得数据库连接，跟进去，最终会跟到DriverManager中比较长的getConnection方法中，下面截取核心代码
// 遍历刚才存进去的Driver
for(DriverInfo aDriver : registeredDrivers) {
// If the caller does not have permission to load the driver then
// skip it.
if(isDriverAllowed(aDriver.driver, callerCL)) {
try {
// 使用Driver内的connect方法来进行获得一个数据库连接
println(" trying " + aDriver.driver.getClass().getName());
// 继续跟到connect内部，看其做了哪些事
Connection con = aDriver.driver.connect(url, info);
if (con != null) {
// Success!
println("getConnection returning " + aDriver.driver.getClass().getName());
return (con);
}
} catch (SQLException ex) {
if (reason == null) {
reason = ex;
}
}
} else {
println(" skipping: " + aDriver.getClass().getName());
}
}
然后继续向下跟进，走到了Driver的父类NonRegisteringDriver中进行连接获得一条Connection。
// 核心代码 ---> 根据不同的类型获得不同的连接
switch (conStr.getType()) {
case SINGLE_CONNECTION:
// 跟进到这里面去
return com.mysql.cj.jdbc.ConnectionImpl.getInstance(conStr.getMainHost());
case LOADBALANCE_CONNECTION:
return LoadBalancedConnectionProxy.createProxyInstance((LoadbalanceConnectionUrl) conStr);
case FAILOVER_CONNECTION:
return FailoverConnectionProxy.createProxyInstance(conStr);
case REPLICATION_CONNECTION:
return ReplicationConnectionProxy.createProxyInstance((ReplicationConnectionUrl) conStr);
default:
return null;
}
public static JdbcConnection getInstance(HostInfo hostInfo) throws SQLException {
// 其直接new 了一个Connection的实现类，跟进去看做了哪些事
return new ConnectionImpl(hostInfo);
}
点进去可以看到大量的初始化操作，这里就不进行截图了，仍然截取关键代码。
// 其中最重要的就是这一行代码，来进行创建一条连接。 继续往下跟，看如何创建，创建之后做了哪些事
createNewIO(false);
unSafeQueryInterceptors();
AbandonedConnectionCleanupThread.trackConnection(this, this.getSession().getNetworkResources());
最终会跟到 connectOneTryOnly() 方法。下面为其源码。
JdbcConnection c = getProxy();
// 进行连接MySQL服务器，拿着服务器信息，用户名，密码，还有要连接的数据库进行连接。之后在服务器端 也可以看到连接建立了。
this.session.connect(this.origHostInfo, this.user, this.password, this.database, DriverManager.getLoginTimeout() * 1000, c);
// save state from old connection
// 拿到一些连接信息，这里的getAutoCommit实际上是一个默认值，为true，默认为自动提交。
// 在进行事务操作时，我们要将其设置为false，表示手动提交。
boolean oldAutoCommit = getAutoCommit();
// 隔离级别
int oldIsolationLevel = this.isolationLevel;
boolean oldReadOnly = isReadOnly(false);
String oldDb = getDatabase();
this.session.setQueryInterceptors(this.queryInterceptors);
// Server properties might be different from previous connection, so initialize again...
// 初始化连接信息，从服务器端进行加载的。
initializePropsFromServer();
if (isForReconnect) {
// Restore state from old connection
setAutoCommit(oldAutoCommit);
setTransactionIsolation(oldIsolationLevel);
setDatabase(oldDb);
setReadOnly(oldReadOnly);
}
初始化连接，其实到这里就已经结束了。到后面就是使用MySQL数据库连接了。下面总结下具体的流程，其实流程并不是很复杂。其实主要就是DriverManger.getConnectioin()这一行代码做了哪些事。
image.png
小结
1. 其实，连接被获取之后，可以进行缓存 做成数据库连接池。
2. SPI，未动态扩展，提供了强有力的支撑。
