JDBC和数据库连接池

JDBC是一种用于执行SQL语句的Java API，可以为多种关系数据库提供统一访问，它由一组用Java语言编写的类和接口组成。

●  JDBC

●  C3P0

●  DRUID

JDBC

基本使用

使用 JDBC 操作MySQL数据库时，可以将步骤分为以下7步：

// 1.注册驱动(将mysql的驱动类加载到内存中)
DriverManager.registerDriver(new Driver());
// 2.获取连接
String url = "jdbc:mysql://localhost:3306/db";
String username = "root";
String password = "root";
Connection con = DriverManager.getConnection(url, username, password);
// 3.编写sql
String sql = " ... ";
// 4.获取语句的执行器
Statement statement = con.createStatement();
// 5.执行sql并返回结果集
ResultSet rs = statement.excuteQuery(sql);
// 6.处理结果集
while(rs.next()){ ... }
// 7.释放资源
rs.close();
statement.close();
con.close();

PreparedStatement:预编译对象 ： 未防止 SQL 注入，我们先将sql 传给数据库，将sql语句事先编译好，使用时直接赋真实值，执行sql即可。

// 使用 ？ 占位
String sql = "select * from stu where id= ? "
// 创建预编译对象
PreparedStatement pst = con.prepareStatement(sql);
// 设置具体的参数 （第几个 ？， 具体值）
pst.set(1, 2);
// 执行sql
ResultSet rs = pst.executeQuery();
int i = pst.executeUpdate();

封装优化

由于Driver类的源码当中有注册驱动的静态代码块，因此我们可以不用自己再去注册（类加载后就完成了注册），同时为了避免硬编码和代码冗余我们将其优化，封装成简单工具类。

1.编写配置文件 ：Jdbc.properties

# 数据库驱动配置
# Driver类的全限定类名（加载即完成注册）
jdbc.driver=com.mysql.jdbc.Driver
# 协议 协议 地址 端口 数据库
jdbc.url=jdbc:mysql://localhost:3306/db
# 用户名
jdbc.username=root
# 密码
jdbc.password=root

2.编写工具类 ：JdbcUtils

public class JdbcUtils {
//声明配置信息
private static String driver;
private static String url;
private static String username;
private static String password;
private static Connection con;
//静态代码块,类加载时解析配置信息
static {
try {
InputStreamReader is = new InputStreamReader
(JdbcUtils.class.getResourceAsStream("/jdbc.properties"));
Properties properties = new Properties();
properties.load(is);
driver = properties.getProperty("jdbc.driver").trim();
url = properties.getProperty("jdbc.url").trim();
username = properties.getProperty("jdbc.username").trim();
password = properties.getProperty("jdbc.password").trim();
//加载驱动获取连接
Class.forName(driver);
con = DriverManager.getConnection(url, username, password);
} catch (Exception e) {
e.printStackTrace();
}
}
// 获取数据库连接（如果连接关闭则重新创建）
public static Connection getConnection() {
try {
if (con.isClosed()) {
con = DriverManager.getConnection(
url,username,password);
return con;
}
} catch (SQLException e) {
e.printStackTrace();
return null;
}
return con;
}
// 关闭资源（有结果集）
public static void close(ResultSet rs, Statement s,
Connection con) {
if (rs != null) {
try {
rs.close();
} catch (SQLException e) {
e.printStackTrace();
}
}
if (s != null) {
try {
s.close();
} catch (SQLException e) {
e.printStackTrace();
}
}
if (con != null) {
try {
con.close();
} catch (SQLException e) {
e.printStackTrace();
}
}
}
// 关闭资源（无结果集）
public static void close(Statement s, Connection con) {
close(null, s, con);
}
}

3.注意事项

// 需要注意的是
// 1.将jdbc.properties放到src文件下

// 2.解析配置文件时除上述写法还可以使用如下方式(此法针对src下的properties文件)：
ResourceBundle bundle = ResourceBundle.getBundle("jdbc");
driver = bundle.getString("jdbc.driver").trim();
url = bundle.getString("jdbc.url").trim();
username = bundle.getString("jdbc.username").trim();
password = bundle.getString("jdbc.password").trim();

在使用上述方法连接并操作数据库时，若没有按照上面的代码对连接的状态进行检查那么肯定会遇到这样一个异常：No operations allowed after connection closed. 因为我们只创建了一个连接，当完成一个操作后将其关闭，那么下一次操作获得的连接就是已经关闭了的连接，因此会发生此异常！上述代码中对连接进行了状态的判断，比较麻烦。而数据库连接池正是维护着几个连接供我们使用，使用后将其归还至连接池（并不是真的关闭）。

C3P0连接池

C3P0是开源的连接池，Hibernate框架默认使用的就是C3P0连接池。使用配置文件创建连接池时注意文件名称“ c3p0-config.xml"不能更改（放在src下）。

1.创建配置文件：c3p0-config.xml

<c3p0-config>
<!-- 使用默认的配置读取连接池对象 -->
<default-config>
<!-- 连接参数 -->
<property name="driverClass">com.mysql.jdbc.Driver</property>
<property name="jdbcUrl">jdbc:mysql://localhost:3306/db</property>
<property name="user">root</property>
<property name="password">root</property>
<!-- 连接池参数 -->
<property name="initialPoolSize">5</property>
<property name="maxPoolSize">10</property>
<property name="checkoutTimeout">3000</property>
</default-config>
<!-- 指定名称的配置信息 -->
<named-config name="myc3p0">
<!-- 连接参数 -->
<property name="driverClass">com.mysql.jdbc.Driver</property>
<property name="jdbcUrl">jdbc:mysql://localhost:3306/day25</property>
<property name="user">root</property>
<property name="password">root</property>
<!-- 连接池参数 -->
<property name="initialPoolSize">5</property>
<property name="maxPoolSize">8</property>
<property name="checkoutTimeout">1000</property>
</named-config>
</c3p0-config>

2.获取连接池对象

// 关键代码
// 使用默认配置获取连接池对象
ComboPooledDataSource comboPooledDataSource =
new ComboPooledDataSource();
// 使用指定的配置 （配置名） 获取连接池对象
ComboPooledDataSource comboPooledDataSource =
new ComboPooledDataSource("myc3p0");

DRUID(德鲁伊)连接池

DRUID是阿里巴巴开发的目前最好的数据库连接池。 com.alibaba.druid.pool.DruidDataSourceFactory 类创建连接池的方法：

1.创建配置文件：mydruid.properties

driverClassName=com.mysql.jdbc.Driver
url=jdbc:mysql://127.0.0.1:3306/db
username=root
password=root
initialSize=5
maxActive=10
maxWait=3000
minIdle=3 # 最小连接池数量

2.获取连接池对象

Properties prop = new Properties();
InputStream is = DruidDemo.class.getClassLoader().
getResourceAsStream("mydruid.properties");
prop.load(is);
//druid工厂根据配置文件创建druid连接池对象
DataSource dataSource = DruidDataSourceFactory.createDataSource(prop);

DRUID工具类封装

1.配置文件（参上）

2.关键代码

private static DataSource dataSource;
static{
try {
// 解析druid的配置文件
Properties prop = new Properties();
InputStream is = JDBCUtil.class.getClassLoader().
getResourceAsStream("druid.properties");
prop.load(is);
// druid工厂使用配置文件创建druid连接池对象
dataSource = DruidDataSourceFactory.createDataSource(prop);
} catch (Exception e) {
e.printStackTrace();
}
}
//获取druid连接池
public static DataSource getDataSource(){
return dataSource;
}
//获取druid连接池中的连接
public static Connection getConnection() throws SQLException {
return dataSource.getConnection();
}
//释放资源(归还连接)
public static void close(ResultSet rs, Statement st,Connection conn) {
if(rs!=null){
try {
rs.close();
} catch (SQLException e) {
e.printStackTrace();
}
}
if(st!=null){
try {
st.close();
} catch (SQLException e) {
e.printStackTrace();
}
}
if(conn!=null){
try {
conn.close();
} catch (SQLException e) {
e.printStackTrace();
}
}
}
public static void close(Statement st,Connection conn) {
close(null,st,conn);
}

Tips:

// 将properties文件放到src下时
JdbcUtils.class.getResourceAsStream("/jdbc.properties")
//两种方式的参数不一样
JdbcUtils.class.getClassLoader().getResourceAsStream("jdbc.properties")

赞 (0)

相关推荐

  • druid 参数配置详解

    4 不同配置文件 本部分只通过示例的方式展示在不同的环境中进行配置的语法格式,具体要配置哪些参数,请参照 参数配置及说明. 其中 spring boot application.properties ...

  • JDBC使用+数据库连接池+springJDBC

    一.JDBC基本概念和下载 JDBC(Java DataBase Connectivity),通俗来讲就是用java语言操作数据库 本质 sun公司定义的一套操作所有关系型数据库的规则,即接口. 各个 ...

  • jdbc预编译对象，事务，数据库连接池

    jdbc预编译对象 原始的jdbc使用声明对象进行sql的执行,对于执行的sql参数使用字符串拼接的形式进行添加 Class.forName("com.mysql.jdbc.Driver&q ...

  • Data Source与数据库连接池简介 JDBC简介（八）

    DataSource是作为DriverManager的替代品而推出的,DataSource 对象是获取连接的首选方法. 原文地址: Data Source与数据库连接池简介 JDBC简介(八) 起源 ...

  • Hikari 数据库连接池配置详解

    <!-- Hikari Datasource --> <bean id="dataSourceHikari" class="com.zaxxer.hik ...

  • SpringBoot 2.0 中 HikariCP 数据库连接池原理解析

    作为后台服务开发,在日常工作中我们天天都在跟数据库打交道,一直在进行各种CRUD操作,都会使用到数据库连接池.按照发展历程,业界知名的数据库连接池有以下几种:c3p0.DBCP.Tomcat JDBC ...

  • Springboot 整合阿里数据库连接池 druid

    Spring boot 整合 druid druid的maven依赖 <!-- 阿里数据库连接池fhadmin.cn --> <dependency> <groupId& ...

  • 数据库连接池到底应该设多大？这篇文章可能会颠覆你的认知

    数据库连接池的配置是开发者们常常搞出坑的地方,在配置数据库连接池时,有几个可以说是和直觉背道而驰的原则需要明确. 1万并发用户访问 想象你有一个网站,压力虽然还没到Facebook那个级别,但也有个1 ...

  • 一个比 c3p0 快200倍的数据库连接池，这么牛？

    大家好,我是磊哥. 什么是数据库连接池 连接池是一种常用的技术,为什么需要连接池呢?这个需要从TCP说起.假如我们的服务器跟数据库没有部署在同一台机器,那么,服务器每次查询数据库都要先建立连接,一般都 ...

  • java学习——120.JDBC数据库连接（二）

    如果已经有了项目,可以直接在项目那里添加驱动包,不一定非得新建项目时才添加. 如图,我在已有的项目Lay_lunwenpinyue中添加JDBC驱动包. 首先,在项目处右键,在弹出来的快捷菜单中选中& ...