注:大家觉得博客好的话,别忘了点赞收藏呀,本人每周都会更新关于人工智能和大数据相关的内容,内容多为原创,Python Java Scala SQL 代码,CV NLP 推荐系统等,Spark Flink Kafka Hbase Hive Flume等等~写的都是纯干货,各种顶会的论文解读,一起进步。
今天和大家分享一下Java通过DBCP连接池方法实现JDBC代码案例
#博学谷IT学习技术支持#
文章目录
- Java和大数据系列
- 前言
- 一、使用步骤
- 1.Maven导包
- 2.定义dbcpconfig.properties文件
- 3.定义DBCPUtils类
- 4.定义测试类
- 总结
前言
Java为数据库连接池提供了公共的接口:javax.sql.DataSource,各个厂商需要让自己的连接池实现这个接口。这样应用程序可以方便的切换不同厂商的连接池!
常见的连接池:DBCP、C3P0。
本文介绍DBCP的用法,下一次介绍C3P0的用法。
一、使用步骤 1.Maven导包
2.定义dbcpconfig.properties文件commons-dbcp commons-dbcp 1.4
在resources文件中定义一个dbcpconfig.properties文件,把数据库的参数给配进去
driverClassName=com.mysql.cj.jdbc.Driver url=jdbc:mysql://localhost:3306/aaa username=root password=123456783.定义DBCPUtils类
import org.apache.commons.dbcp.BasicDataSourceFactory; import javax.sql.DataSource; import java.io.InputStream; import java.sql.Connection; import java.sql.ResultSet; import java.sql.ResultSetMetaData; import java.sql.SQLException; import java.util.Properties; public class DBCPUtils { //定义一个连接池对象 private static DataSource ds; static { try { Properties properties = new Properties(); InputStream inputStream = DBCPUtils.class.getClassLoader().getResourceAsStream("dbcpconfig.properties"); properties.load(inputStream); //创建连接池 ds = BasicDataSourceFactory.createDataSource(properties); } catch (Exception e) { throw new RuntimeException(e); } } //封装一个方法:从连接池获取一个连接 public static Connection getConnection() throws SQLException { return ds.getConnection(); } //封装一个printResult方法来显示输出结果 public static void printResult(ResultSet resultSet){ try { ResultSetMetaData metaData = resultSet.getMetaData(); int columnCount = metaData.getColumnCount(); while (resultSet.next()){ for (int i = 1; i <= columnCount; i++) { Object object = resultSet.getObject(i); System.out.print(object + "t"); } System.out.println(); } } catch (SQLException e) { throw new RuntimeException(e); } } }4.定义测试类
import java.sql.Connection; import java.sql.PreparedStatement; import java.sql.ResultSet; import java.sql.SQLException; public class demo01 { public static void main(String[] args) throws SQLException { //1:从连接池获取连接 Connection connection = DBCPUtils.getConnection(); //2:执行sql PreparedStatement preparedStatement = connection.prepareStatement("select * from employee"); ResultSet resultSet = preparedStatement.executeQuery(); //3;遍历 DBCPUtils.printResult(resultSet); //4:将连接池放回 connection.close(); } }
总结
本文主要介绍Java通过DBCP连接池方法实现JDBC代码案例。通过连接池操作jdbc会更高效一点,避免了多次连接。下一次介绍C3P0的用法。