【WEEK8】 【DAY1】【DAY2】JDBC—事务数据库连接池【中文版】

2024-04-16 15:12
文章标签 jdbc 数据库 连接池 day2 事务 day1 中文版 week8

本文主要是介绍【WEEK8】 【DAY1】【DAY2】JDBC—事务数据库连接池【中文版】，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

接上文【WEEK7】 【DAY5】JDBC—PreparedStatement对象【中文版】

目录

  • 2024.4.15 Monday
  • 10.5.事务
    • 10.5.1.要么都成功，要么都失败
    • 10.5.2.ACID原则（详见6.2.事务的ACID原则）
    • 10.5.3.实例
      • 10.5.3.1.成功的
      • 10.5.3.2.失败的
      • 10.5.3.3.步骤总结
  • 10.6.数据库连接池
    • 10.6.1.“数据库连接——执行完毕——释放”这个“连接+释放”的过程十分浪费资源
    • 10.6.2.池化技术：预先准备一些资源，需要使用资源时就可以直接使用预先准备好的
    • 10.6.3.编写连接池只需要实现一个接口：DataSource
    • 10.6.4.开源数据源实现
    • 10.6.5.DBCP
      • 10.6.5.1.需要用到的jar包
      • 10.6.5.2.新建dbcpconfig.properties文件
      • 10.6.5.3.新建utils文件
  • 2024.4.16 Tuesday
      • 10.6.5.4.新建TestDBCP文件
    • 10.6.6.C3P0
      • 10.6.6.1.需要用到的jar包
      • 10.6.6.2.新建c3p0-config.xml文件
      • 10.6.6.3.新建utils文件
      • 10.6.6.4.新建TestC3P0文件
      • 10.6.6.5.结论：无论使用什么数据源，本质相同，DataSource接口不会变，方法就不会变
    • 10.6.7.下载jar包网址备份

2024.4.15 Monday

10.5.事务

10.5.1.要么都成功，要么都失败

10.5.2.ACID原则（详见6.2.事务的ACID原则）

10.5.2.1.原子性：要么全部完成，要么都不完成
10.5.2.2.一致性：总数不变
10.5.2.3.隔离性：多个进程互不干扰
10.5.2.4.持久性：一旦提交不可逆，持久化到数据库
10.5.2.5.隔离性的问题：

  • 脏读：一个事物读取了另一个没有提交的事物
  • 不可重复读：在同一个事务内，重复读取表中的数据，表数据发生了改变
  • 虚读（幻读）：在一个事务内，读取到了别人插入的数据，导致前后读出来结果不一致

10.5.3.实例

10.5.3.1.成功的

package lesson.four;import lesson.two.utils.JdbcUtils;import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;public class TestTransaction1 {public static void main(String[] args) {Connection conn = null;PreparedStatement st = null;ResultSet rs = null;try {conn = JdbcUtils.getConnection();//关闭数据库的自动提交功能，此时会自动开启事务。即：关闭自动提交=开启事务conn.setAutoCommit(false);String sql1 = "UPDATE account SET money = money - 100 WHERE `NAME` = 'A'";st = conn.prepareStatement(sql1);st.executeUpdate();String sql2 = "UPDATE account SET money = money + 100 WHERE `NAME` = 'B'";st = conn.prepareStatement(sql2);st.executeUpdate();//业务完毕，提交事务conn.commit();;System.out.println("成功");} catch (SQLException e) {try {conn.rollback();} catch (SQLException ex) {throw new RuntimeException(ex);}throw new RuntimeException(e);} finally {{JdbcUtils.release(conn,st,rs);}}}
}
  • 结果
    在这里插入图片描述
    在这里插入图片描述->在这里插入图片描述

10.5.3.2.失败的

package lesson.four;import lesson.two.utils.JdbcUtils;import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;public class TestTransaction2 {public static void main(String[] args) {Connection conn = null;PreparedStatement st = null;ResultSet rs = null;try {conn = JdbcUtils.getConnection();//关闭数据库的自动提交功能，此时会自动开启事务。即：关闭自动提交=开启事务conn.setAutoCommit(false);String sql1 = "UPDATE account SET money = money - 100 WHERE `NAME` = 'A'";st = conn.prepareStatement(sql1);st.executeUpdate();int x = 1/0;    //一定会出现异常（为了使该事务不能完全执行成功写的错误行）用于测试回滚String sql2 = "UPDATE account SET money = money + 100 WHERE `NAME` = 'B'";st = conn.prepareStatement(sql2);st.executeUpdate();//业务完毕，提交事务conn.commit();;System.out.println("成功");} catch (SQLException e) {try {conn.rollback();    //如果失败则默认回滚事务（这行不一定要写）} catch (SQLException ex) {throw new RuntimeException(ex);}throw new RuntimeException(e);} finally {{JdbcUtils.release(conn,st,rs);}}}
}
  • 结果
    在这里插入图片描述

执行conn.rollback(); //如果失败则默认回滚事务（这行不一定要写）
即使sql1对应的语句部分修改曾经执行成功过，但是由于回滚导致表中的最终结果不变
在这里插入图片描述

10.5.3.3.步骤总结

  • 开启事务conn.setAutoCommit(false);
  • 一组业务执行完毕，提交事务
  • 可以在catch语句中显示地定义‘回滚语句’，但即使不写，默认情况就会回滚

10.6.数据库连接池

10.6.1.“数据库连接——执行完毕——释放”这个“连接+释放”的过程十分浪费资源

10.6.2.池化技术：预先准备一些资源，需要使用资源时就可以直接使用预先准备好的

10.6.2.1.相当于：“开门——业务员：等待——服务”
10.6.2.2.最小连接数 根据 常用连接数 决定。e.g.常用10个连接->最小连接数是10
10.6.2.3.最大连接数：业务最高承载上限。e.g.承载上限是15则最大连接数是15。超出部分需要排队等待，如果排队等待的时间超过某个阈值（如：100ms’），则称为 超时等待

10.6.3.编写连接池只需要实现一个接口：DataSource

10.6.4.开源数据源实现

10.6.4.1.DBCP(DataBase connection pool)
10.6.4.2.C3P0
10.6.4.3.Druid：阿里巴巴的
10.6.4.4.使用了这些数据库连接池之后，个人在项目开发中就不需要编写连接数据库的代码了

10.6.5.DBCP

10.6.5.1.需要用到的jar包

下载地址都是官网，可参考这篇博客，导入方式和connector相同：https://blog.csdn.net/qq_45523411/article/details/121517140
在进行到新TestDBCP文件运行时发现报错：问题是2.0以上版本的dbcp需要再导入logging包，教程（内附有下载链接）如下：https://blog.csdn.net/qq_41115379/article/details/108947898
在这里插入图片描述
在这里插入图片描述

10.6.5.2.新建dbcpconfig.properties文件

在这里插入图片描述

#连接设置：这里的名字是DBCP数据源中定义好的
driverClassName = com.mysql.cj.jdbc.Driver
url = jdbc:mysql://localhost:3306/p37jdbc?useUnicode=true & characterEncoding=utf8 & useSSL=true
username = root
password = 123456#以下所有内容都可以不手动设置
#<!-- 初始化连接 -->
initialSize=10#最大连接数量
maxActive=50#<!-- 最大空闲连接 -->
maxIdle=20#<!-- 最小空闲连接 -->
minIdle=5#<!-- 超时等待时间以毫秒为单位 60000毫秒/1000等于60秒 -->
maxWait=60000#JDBC驱动建立连接时附带的连接属性属性的格式必须为这样：【属性名=property;】
#注意："user" 与 "password" 两个属性会被明确地传递，因此这里不需要包含他们。
connectionProperties=useUnicode=true;characterEncoding=utf8#指定由连接池所创建的连接的自动提交（auto-commit）状态。
defaultAutoCommit=true#driver default 指定由连接池所创建的连接的只读（read-only）状态。
#如果没有设置该值，则“setReadOnly”方法将不被调用。（某些驱动并不支持只读模式，如：Informix）
defaultReadOnly=#driver default 指定由连接池所创建的连接的事务级别（TransactionIsolation）。
#可用值为下列之一：（详情可见javadoc。）NONE,READ_UNCOMMITTED, READ_COMMITTED, REPEATABLE_READ, SERIALIZABLE
defaultTransactionIsolation=READ_COMMITTED

10.6.5.3.新建utils文件

和JdbcUtils几乎一样，仅更换了输入流的来源
在这里插入图片描述

package lesson.five.utils;import org.apache.commons.dbcp2.BasicDataSource;
import org.apache.commons.dbcp2.BasicDataSourceFactory;import javax.sql.DataSource;
import java.io.InputStream;
import java.sql.*;
import java.util.Properties;public class JdbcUtils_DBCP {private static  DataSource dataSource = null;static {try{//获得类加载器.获取资源，获取的资源的名字:是src文件夹下的文件名，会返回一个输入流InputStream in = JdbcUtils_DBCP.class.getClassLoader().getResourceAsStream("dbcpconfig.properties");//把流读到properties类里Properties properties = new Properties();properties.load(in);//创建数据源 工厂模式（用于创建对象）//点开BasicDataSourceFactory查看可见封装完毕的各种类，和lesson.two.utils中相比，个人所需书写的代码量减少了dataSource = BasicDataSourceFactory.createDataSource(properties);} catch (Exception e) {throw new RuntimeException(e);  //这是默认生成的
//            e.printStackTrace();  //这两行任选一行亦可}}//获取连接public static Connection getConnection() throws SQLException {return dataSource.getConnection();  //只需要在这里修改直接（从数据源中）获取连接即可}// 释放连接资源public static void release(Connection conn, Statement st, ResultSet rs){if(rs != null){try {rs.close();} catch (SQLException e) {throw new RuntimeException(e);}}if(st != null){try {st.close();} catch (SQLException e) {throw new RuntimeException(e);}}if(conn != null){try {conn.close();} catch (SQLException e) {throw new RuntimeException(e);}}}}

2024.4.16 Tuesday

10.6.5.4.新建TestDBCP文件

参考lesson.TestInsert，只修改部分的代码

package lesson.five;import lesson.five.utils.JdbcUtils_DBCP;import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.SQLException;public class TestDBCP {public static void main(String[] args) {Connection conn = null;PreparedStatement st = null;try {//本质是更换了数据源（在获取连接和关闭连接时代码有所区别），和lesson.three的TestInsert其他部分没有任何区别conn = JdbcUtils_DBCP.getConnection();//和一般的statement区别：使作为用问号作为占位符String sql = "INSERT INTO users(id,`NAME`,`PASSWORD`,`email`,`birthday`) VALUES (?,?,?,?,?)";st = conn.prepareStatement(sql);   //预编译SQL：先生成SQL但不执行//手动给参数赋值st.setInt(1,4); //idst.setString(2,"lqf");st.setString(3,"987654");st.setString(4,"27046873@qq.com");st.setDate(5,new java.sql.Date(new java.util.Date().getTime()));//执行int i = st.executeUpdate();if(i > 0){System.out.println("插入成功");}} catch (SQLException e) {e.printStackTrace();} finally {JdbcUtils_DBCP.release(conn,st,null);}}
  • 结果
    在这里插入图片描述
    在这里插入图片描述

10.6.6.C3P0

10.6.6.1.需要用到的jar包

参考教程：
打开压缩包后注意使用的jar包的名称不含有source，是lib文件夹下的文件
https://blog.csdn.net/YyjYsj/article/details/108854804
在这里插入图片描述

10.6.6.2.新建c3p0-config.xml文件

在这里插入图片描述

<?xml version="1.0" encoding="UTF-8"?>
<c3p0-config><!--
c3p0的缺省（默认）配置
如果在代码中"ComboPooledDataSource ds=new ComboPooledDataSource();"这样写就表示使用的是c3p0的缺省（默认）-->
<default-config><property name="driverClass">com.mysql.cj.jdbc.Driver</property><property name="jdbcUrl">jdbc:mysql://localhost:3306/p37jdbc?useUnicode=true &amp; characterEncoding=utf8 &amp; useSSL=true &amp; serverTimezone=UTC</property><property name="user">root</property><property name="password">123456</property><property name="acquiredIncrement">5</property><property name="initialPoolSize">10</property><property name="minPoolSize">5</property><property name="maxPoolSize">20</property>
</default-config><!--
c3p0的命名配置
如果在代码中"ComboPooledDataSource ds=new ComboPooledDataSource("MySQL");"这样写就表示使用的是name是mysql
&ndash;&gt;
--><named-config name="MySQL"><property name="driverClass">com.mysql.jdbc.Driver</property><property name="jdbcUrl">jdbc:mysql://localhost:3306/p37jdbc?useUnicode=true &amp; characterEncoding=utf8 &amp; useSSL=true</property><property name="user">root</property><property name="password">123456</property><property name="acquiredIncrement">5</property><property name="initialPoolSize">10</property><property name="minPoolSize">5</property><property name="maxPoolSize">20</property></named-config></c3p0-config>
<!--        这里人话说就是可以创建多个不同的数据库连接池~~-->

10.6.6.3.新建utils文件

在这里插入图片描述

package lesson.five.utils;import com.mchange.v2.c3p0.ComboPooledDataSource;import javax.sql.DataSource;
import java.io.InputStream;
import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.Properties;public class JdbcUtils_C3P0 {private static  ComboPooledDataSource dataSource = null;static {try {//代码版配置（但是一般不使用）
//            dataSource = new ComboPooledDataSource();
//            dataSource.setDriverClass();
//            dataSource.setUser();
//            dataSource.setPassword();
//            dataSource.setJdbcUrl();
//
//            dataSource.setMaxPoolSize();
//            dataSource.setMinPoolSize();//创建数据源 工厂模式（用于创建对象）dataSource = new ComboPooledDataSource("MySQL");   //配置文件写法。也可在()内添加已完成的“命名配置”} catch (Exception e) {throw new RuntimeException(e);  //这是默认生成的
//            e.printStackTrace();  //这两行任选一行亦可}}//获取连接public static Connection getConnection() throws SQLException {return dataSource.getConnection();  //只需要在这里修改直接（从数据源中）获取连接即可}// 释放连接资源public static void release(Connection conn, Statement st, ResultSet rs){if(rs != null){try {rs.close();} catch (SQLException e) {throw new RuntimeException(e);}}if(st != null){try {st.close();} catch (SQLException e) {throw new RuntimeException(e);}}if(conn != null){try {conn.close();} catch (SQLException e) {throw new RuntimeException(e);}}}}

10.6.6.4.新建TestC3P0文件

package lesson.five;import lesson.five.utils.JdbcUtils_C3P0;
import lesson.five.utils.JdbcUtils_DBCP;import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.SQLException;public class TestC3P0 {public static void main(String[] args) {Connection conn = null;PreparedStatement st = null;try {//本质是更换了数据源（在获取连接和关闭连接时代码有所区别），和lesson.three的TestInsert其他部分没有任何区别conn = JdbcUtils_C3P0.getConnection();  //和lesson.five.TestDBCP相比的区别就是修改了这（使用外部包）//和一般的statement区别：使作为用问号作为占位符String sql = "INSERT INTO users(id,`NAME`,`PASSWORD`,`email`,`birthday`) VALUES (?,?,?,?,?)";st = conn.prepareStatement(sql);   //预编译SQL：先生成SQL但不执行//手动给参数赋值//set...的语法对应了传入函数参数每个位置以及希望设置成的参数st.setInt(1,5); //idst.setString(2,"wlj");st.setString(3,"456789");st.setString(4,"27046873@qq.com");st.setDate(5,new java.sql.Date(new java.util.Date().getTime()));//new Date().getTime()即：外层括号内是计算机的时间，需要转化成mysql的时间//sql.Date是数据库时间，util.Date是Java的//因为setDate的源码中时间的参数是数据库类型的：void setDate(int parameterIndex, java.sql.Date x)//所以要另外用new Date().getTime()获得时间戳(这个版本里需要使用“new java.util.Date().getTime()”才不报错)//执行int i = st.executeUpdate();if(i > 0){System.out.println("插入成功");}} catch (SQLException e) {e.printStackTrace();} finally {JdbcUtils_C3P0.release(conn,st,null);}}
}
  • 结果
    在这里插入图片描述
    在这里插入图片描述

10.6.6.5.结论：无论使用什么数据源，本质相同，DataSource接口不会变，方法就不会变

10.6.7.下载jar包网址备份

https://mvnrepository.com/

这篇关于【WEEK8】 【DAY1】【DAY2】JDBC—事务数据库连接池【中文版】的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！


http://www.chinasem.cn/article/909144。

相关文章

Spring Security基于数据库验证流程详解

Spring Security基于数据库验证流程详解

Spring Security 校验流程图 相关解释说明（认真看哦） AbstractAuthenticationProcessingFilter 抽象类 /*** 调用 #requiresAuthentication(HttpServletRequest, HttpServletResponse) 决定是否需要进行验证操作。* 如果需要验证，则会调用 #attemptAuthentica
阅读更多...
MySQL数据库宕机，启动不起来，教你一招搞定！

MySQL数据库宕机，启动不起来，教你一招搞定！

作者介绍：老苏，10余年DBA工作运维经验，擅长Oracle、MySQL、PG、Mongodb数据库运维（如安装迁移，性能优化、故障应急处理等）公众号：老苏畅谈运维欢迎关注本人公众号，更多精彩与您分享。 MySQL数据库宕机，数据页损坏问题，启动不起来，该如何排查和解决，本文将为你说明具体的排查过程。 查看MySQL error日志 查看 MySQL error日志，排查哪个表（表空间
阅读更多...
滚雪球学Java(87)：Java事务处理：JDBC的ACID属性与实战技巧！真有两下子！

滚雪球学Java(87)：Java事务处理：JDBC的ACID属性与实战技巧！真有两下子！

咦咦咦，各位小可爱，我是你们的好伙伴——bug菌，今天又来给大家普及Java SE啦，别躲起来啊，听我讲干货还不快点赞，赞多了我就有动力讲得更嗨啦！所以呀，养成先点赞后阅读的好习惯，别被干货淹没了哦~ 🏆本文收录于「滚雪球学Java」专栏，专业攻坚指数级提升，助你一臂之力，带你早日登顶🚀，欢迎大家关注&&收藏！持续更新中，up！up！up！！ 环境说明：Windows 10
阅读更多...
深入理解数据库的 4NF：多值依赖与消除数据异常

深入理解数据库的 4NF：多值依赖与消除数据异常

在数据库设计中， "范式" 是一个常常被提到的重要概念。许多初学者在学习数据库设计时，经常听到第一范式（1NF）、第二范式（2NF）、第三范式（3NF）以及 BCNF（Boyce-Codd范式）。这些范式都旨在通过消除数据冗余和异常来优化数据库结构。然而，当我们谈到 4NF（第四范式）时，事情变得更加复杂。本文将带你深入了解 多值依赖 和 4NF，帮助你在数据库设计中消除更高级别的异常。 什么是
阅读更多...
如何确定 Go 语言中 HTTP 连接池的最佳参数？

如何确定 Go 语言中 HTTP 连接池的最佳参数？

确定 Go 语言中 HTTP 连接池的最佳参数可以通过以下几种方式： 一、分析应用场景和需求 并发请求量： 确定应用程序在特定时间段内可能同时发起的 HTTP 请求数量。如果并发请求量很高，需要设置较大的连接池参数以满足需求。例如，对于一个高并发的 Web 服务，可能同时有数百个请求在处理，此时需要较大的连接池大小。可以通过压力测试工具模拟高并发场景，观察系统在不同并发请求下的性能表现，从而
阅读更多...
DM8数据库安装后配置

DM8数据库安装后配置

1 前言 在上篇文章中，我们已经成功将库装好。在安装完成后，为了能够更好地满足应用需求和保障系统的安全稳定运行，通常需要进行一些基本的配置。下面是一些常见的配置项： 数据库服务注册：默认包含14个功能模块，将这些模块注册成服务后，可以更好的启动和管理这些功能；基本的实例参数配置：契合应用场景和发挥系统的最大性能；备份：有备无患；… 2 注册实例服务 注册了实例服务后，可以使用系统服务管理，
阅读更多...
速了解MySQL 数据库不同存储引擎

速了解MySQL 数据库不同存储引擎

快速了解MySQL 数据库不同存储引擎 MySQL 提供了多种存储引擎，每种存储引擎都有其特定的特性和适用场景。了解这些存储引擎的特性，有助于在设计数据库时做出合理的选择。以下是 MySQL 中几种常用存储引擎的详细介绍。 1. InnoDB 特点： 事务支持：InnoDB 是一个支持 ACID（原子性、一致性、隔离性、持久性）事务的存储引擎。行级锁：使用行级锁来提高并发性，减少锁竞争
阅读更多...
MySql 事务练习

MySql 事务练习

事务（transaction） -- 事务 transaction-- 事务是一组操作的集合，是一个不可分割的工作单位，事务会将所有的操作作为一个整体一起向系统提交或撤销请求-- 事务的操作要么同时成功，要么同时失败-- MySql的事务默认是自动提交的，当执行一个DML语句，MySql会立即自动隐式提交事务-- 常见案例：银行转账-- 逻辑：A给B转账1000：1.查询
阅读更多...
开源分布式数据库中间件

开源分布式数据库中间件

转自：https://www.csdn.net/article/2015-07-16/2825228 MyCat：开源分布式数据库中间件 为什么需要MyCat？ 虽然云计算时代，传统数据库存在着先天性的弊端，但是NoSQL数据库又无法将其替代。如果传统数据易于扩展，可切分，就可以避免单机（单库）的性能缺陷。 MyCat的目标就是：低成本地将现有的单机数据库和应用平滑迁移到“云”端
阅读更多...
ORACLE 11g 创建数据库时 Enterprise Manager配置失败的解决办法 无法打开OEM的解决办法

ORACLE 11g 创建数据库时 Enterprise Manager配置失败的解决办法 无法打开OEM的解决办法

在win7 64位系统下安装oracle11g，在使用Database configuration Assistant创建数据库时，在创建到85%的时候报错，错误如下： 解决办法： 在listener.ora中增加对BlueAeri-PC或ip地址的侦听，具体步骤如下： 1.启动Net Manager，在“监听程序”--Listener下添加一个地址，主机名写计
阅读更多...

Copyright China编程 23002807@qq.com

沪ICP备2023033072号-2