JDBC使用线程池与连接池,释放连接后,连接池不为空,使得Connection无法创建

时间:2022-09-12 22:49:05

在springboot+JDBC解决高并发的实例中,有一个大大的BUG,不知道小伙伴们发现了没有。

看代码:

private static final ThreadLocal<Connection> CONNECTION_HOLDER;

private static final BasicDataSource DATA_SOURCE = new BasicDataSource();

private JdbcUtils() {
}

static {
CONNECTION_HOLDER = new ThreadLocal<Connection>();

Properties conf = loadProps("dbconfig.properties");
String driverClass = conf.getProperty("jdbc.driverClass");
String url = conf.getProperty("jdbc.url");
String username = conf.getProperty("jdbc.username");
String password = conf.getProperty("jdbc.password");

DATA_SOURCE.setDriverClassName(driverClass);
DATA_SOURCE.setUrl(url);
DATA_SOURCE.setUsername(username);
DATA_SOURCE.setPassword(password);

}

private static Connection getConnection() {
Connection conn = CONNECTION_HOLDER.get();
if (conn == null) {
try {
conn = DATA_SOURCE.getConnection();
} catch (Exception e) {
e.printStackTrace();
} finally {
CONNECTION_HOLDER.set(conn);
}
}
return conn;
}

// 资源的释放
private static void release(Connection conn, PreparedStatement st,
ResultSet rs) {
if (rs != null) {
try {
rs.close();
} catch (SQLException e) {
throw new RuntimeException(e);
} finally {
rs = null;
}
}
if (st != null) {
try {
st.close();
} catch (SQLException e) {
throw new RuntimeException(e);
} finally {
st = null;
}
}
if (conn != null) {
try {
conn.close();
} catch (SQLException e) {
throw new RuntimeException(e);
} finally {
conn = null;

}
}
}

以上是以前的处理并发的连接代码。

我这里有个需求,创建一条数据,但是这条数据中有一半的字段来源于别的表,意味着你要先从别的表查出来,然后组装去插入。好,看清楚代码流程,

JDBC使用线程池与连接池,释放连接后,连接池不为空,使得Connection无法创建

第一次访问的时候,线程池肯定是空的,那么就往下走,建立连接池,给Connection赋值:

JDBC使用线程池与连接池,释放连接后,连接池不为空,使得Connection无法创建


用完之后,理所当然要关闭连接了:


JDBC使用线程池与连接池,释放连接后,连接池不为空,使得Connection无法创建


没错的,断点也显示了,线程池的Connection为null了,那么是不是一会再用到连接就会重新创建连接池呢?

我们继续看程序:

JDBC使用线程池与连接池,释放连接后,连接池不为空,使得Connection无法创建


天啊!!!!!!刚才Connection不是为null了吗,现在怎么仍然有值啊????如果这样,意味着不会创建连接池了,而此时的连接可是空啊,没法执行剩下的程序了,

什么??你说你不信??那好,我们把程序走完:

JDBC使用线程池与连接池,释放连接后,连接池不为空,使得Connection无法创建


报错啦!!!显然,意思是Connection为空了,无法创建了。解决的办法,就是,想办法,让它释放资源后,线程池真正的为Null,而我们指定的方式

‘’conn=null‘’很显然没起作用啊!!!

后来看了下ThreadLocal里面的方法,发现有个remove(),到底是不是我需要的呢?????看代码:


JDBC使用线程池与连接池,释放连接后,连接池不为空,使得Connection无法创建


然后再测试下,你会发现,BUG解决了。至此,我们的工作告一段落了。