"上文记录了最基础的 JDBC 连接数据库的方法，但能看出一个问题，就是要不断的重复去创建 connection 和关闭 connection，如果在对数据库的访问比较频繁的情况下，这种处理方式方式在性能方面是不合适的，下面使用 JDBC 配合数据库连接池来访问数据库。除了 mysql 的驱动，还需 ...."

someone1
AI专业者开发社区 1 号成员
AI开发者社区 • 0 回帖 • 0 浏览 • 4 个月前

java数据库访问（二）—JDBC方式（配合连接池）

上文记录了最基础的 JDBC 连接数据库的方法，但能看出一个问题，就是要不断的重复去创建 connection 和关闭 connection，如果在对数据库的访问比较频繁的情况下，这种处理方式方式在性能方面是不合适的，下面使用 JDBC 配合数据库连接池来访问数据库。

除了 mysql 的驱动，还需引入数据库连接池，本次选用的是 dbcp2（类似的还有 c3p0、阿里的 druid），其实数据库连接池的原理都类似，了解一个，上手其他的就非常容易。

引入依赖：

    <dependency>
            <groupId>org.apache.commons</groupId>
            <artifactId>commons-dbcp2</artifactId>
            <version>2.5.0</version>
        </dependency>

本次要查询的数据：

查询 service 代码：

package com.test.database;
import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.Statement;
import javax.annotation.PostConstruct;
import org.apache.commons.dbcp2.BasicDataSource;
import org.springframework.stereotype.Service;
@Service
public class JdbcPooledService {
Connection connection;
BasicDataSource basicDataSource </span>= <span style="color: rgba(0, 0, 255, 1)">new</span><span style="color: rgba(0, 0, 0, 1)"> BasicDataSource();

@PostConstruct  //用于进行初始化操作，此处初始化连接池
</span><span style="color: rgba(0, 0, 255, 1)">public</span> <span style="color: rgba(0, 0, 255, 1)">void</span><span style="color: rgba(0, 0, 0, 1)"> initPool() {
    System.out.println(</span>"PostConstruct init....."<span style="color: rgba(0, 0, 0, 1)">);
    basicDataSource.setDriverClassName(</span>"com.mysql.jdbc.Driver"<span style="color: rgba(0, 0, 0, 1)">);
    basicDataSource.setUsername(</span>"root"<span style="color: rgba(0, 0, 0, 1)">);
    basicDataSource.setPassword(</span>"root"<span style="color: rgba(0, 0, 0, 1)">);
    basicDataSource.setUrl(</span>"jdbc:mysql://localhost:3306/test"<span style="color: rgba(0, 0, 0, 1)">);

}

</span><span style="color: rgba(0, 0, 255, 1)">public</span> <span style="color: rgba(0, 0, 255, 1)">void</span> testJdbc() <span style="color: rgba(0, 0, 255, 1)">throws</span><span style="color: rgba(0, 0, 0, 1)"> Exception {
    System.out.println(basicDataSource.getNumActive());
    connection </span>=<span style="color: rgba(0, 0, 0, 1)"> basicDataSource.getConnection();
    Statement statement </span>=<span style="color: rgba(0, 0, 0, 1)"> connection.createStatement();
    String sql </span>= "select * from user"<span style="color: rgba(0, 0, 0, 1)">;
    ResultSet resultSet </span>=<span style="color: rgba(0, 0, 0, 1)"> statement.executeQuery(sql);
    </span><span style="color: rgba(0, 0, 255, 1)">while</span><span style="color: rgba(0, 0, 0, 1)"> (resultSet.next()) {
        System.out.println(resultSet.getString(</span>"name"<span style="color: rgba(0, 0, 0, 1)">));
    }
    resultSet.close();
    statement.close();
    connection.close(); //连接池的连接同样需要调用close方法，但此时的close不是关闭连接，而是将连接还回连接池
}

}

测试类：

package com.test;
import org.springframework.beans.BeansException;
import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;
import com.test.database.JdbcPooledService;
public class Main {
</span><span style="color: rgba(0, 0, 255, 1)">public</span> <span style="color: rgba(0, 0, 255, 1)">static</span> <span style="color: rgba(0, 0, 255, 1)">void</span> main(String[] args) <span style="color: rgba(0, 0, 255, 1)">throws</span><span style="color: rgba(0, 0, 0, 1)"> BeansException, Exception {
    ApplicationContext context </span>= <span style="color: rgba(0, 0, 255, 1)">new</span> ClassPathXmlApplicationContext("spring-context.xml"<span style="color: rgba(0, 0, 0, 1)">);
    context.getBean(TestService.</span><span style="color: rgba(0, 0, 255, 1)">class</span><span style="color: rgba(0, 0, 0, 1)">).test();
    </span><span style="color: rgba(0, 128, 0, 1)">//</span><span style="color: rgba(0, 128, 0, 1)"> context.getBean(JdbcService.class).testJdbc();</span>
    <span style="color: rgba(0, 0, 255, 1)">for</span> (<span style="color: rgba(0, 0, 255, 1)">int</span> i = 0; i &lt; 10; i++<span style="color: rgba(0, 0, 0, 1)">) {
        System.out.println(i);
        context.getBean(JdbcPooledService.</span><span style="color: rgba(0, 0, 255, 1)">class</span><span style="color: rgba(0, 0, 0, 1)">).testJdbc();
    }
}

}

打印输出为：

PostConstruct init.....
test service
0
0
tim
1
0
tim
2
0
tim
3
0
tim
4
0
tim
5
0
tim
6
0
tim
7
0
tim
8
0
tim
9
0
tim

若在调用结束时不关闭（将连接还回连接池）connection：

package com.test.database;
import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.Statement;
import javax.annotation.PostConstruct;
import org.apache.commons.dbcp2.BasicDataSource;
import org.springframework.stereotype.Service;
@Service
public class JdbcPooledService {
Connection connection;
BasicDataSource basicDataSource </span>= <span style="color: rgba(0, 0, 255, 1)">new</span><span style="color: rgba(0, 0, 0, 1)"> BasicDataSource();

@PostConstruct </span><span style="color: rgba(0, 128, 0, 1)">//</span><span style="color: rgba(0, 128, 0, 1)">用于进行初始化操作，此处初始化连接池</span>
<span style="color: rgba(0, 0, 255, 1)">public</span> <span style="color: rgba(0, 0, 255, 1)">void</span><span style="color: rgba(0, 0, 0, 1)"> initPool() {
    System.out.println(</span>"PostConstruct init....."<span style="color: rgba(0, 0, 0, 1)">);
    basicDataSource.setDriverClassName(</span>"com.mysql.jdbc.Driver"<span style="color: rgba(0, 0, 0, 1)">);
    basicDataSource.setUsername(</span>"root"<span style="color: rgba(0, 0, 0, 1)">);
    basicDataSource.setPassword(</span>"root"<span style="color: rgba(0, 0, 0, 1)">);
    basicDataSource.setUrl(</span>"jdbc:mysql://localhost:3306/test"<span style="color: rgba(0, 0, 0, 1)">);

}

</span><span style="color: rgba(0, 0, 255, 1)">public</span> <span style="color: rgba(0, 0, 255, 1)">void</span> testJdbc() <span style="color: rgba(0, 0, 255, 1)">throws</span><span style="color: rgba(0, 0, 0, 1)"> Exception {
    System.out.println(basicDataSource.getNumActive());
    connection </span>=<span style="color: rgba(0, 0, 0, 1)"> basicDataSource.getConnection();
    Statement statement </span>=<span style="color: rgba(0, 0, 0, 1)"> connection.createStatement();
    String sql </span>= "select * from user"<span style="color: rgba(0, 0, 0, 1)">;
    ResultSet resultSet </span>=<span style="color: rgba(0, 0, 0, 1)"> statement.executeQuery(sql);
    </span><span style="color: rgba(0, 0, 255, 1)">while</span><span style="color: rgba(0, 0, 0, 1)"> (resultSet.next()) {
        System.out.println(resultSet.getString(</span>"name"<span style="color: rgba(0, 0, 0, 1)">));
    }
    resultSet.close();
    statement.close();
    </span><span style="color: rgba(0, 128, 0, 1)">//</span><span style="color: rgba(0, 128, 0, 1)">connection.close();</span>

    }
}

继续调用测试类，结果为：

PostConstruct init.....
test service
0
0
tim
1
1
tim
2
2
tim
3
3
tim
4
4
tim
5
5
tim
6
6
tim
7
7
tim
8
8

现象是建立了 8 个连接就不再建立了，原因是没有调用 connection 的 close 方法，而 dbcp2 的默认最大连接数是 8，所以已经到了最大连接数，注意在使用连接池获取连接时，务必关闭连接。

默认最大连接数：

public static final int DEFAULT_MAX_TOTAL = 8;

连接池获取的连接调用 close 方法的源码最终调用为：

方法声明：
 public synchronized void close() throws SQLException
关键调用：  
pool.returnObject(this);

将此连接还回到连接池。

java数据库访问（二）—JDBC方式（配合连接池）

相关帖子

随便看看

java数据库访问（二）—JDBC方式（配合连接池）