13-事务&数据库连接池&DBUtiles

提示：扫一扫查出行
【扫一扫了解最新限行尾号】
复制提示

事务&数据库连接池&DBUtils

事务

Transaction 其实指的一组操作，里面包含许多个单一的逻辑。只要有一个逻辑没有执行成功，那么都算失败。所有的数据都回归到最初的状态(回滚)

为什么要有事务?

为了确保逻辑的成功。例子：银行的转账。

使用命令行方式演示事务。

开启事务

start transaction;

提交或者回滚事务

commit; 提交事务，数据将会写到磁盘上的数据库
rollback ; 数据回滚，回到最初的状态。

1. 关闭自动提交功能。

2. 演示事务

使用代码方式演示事务
代码里面的事务，主要是针对连接来的。

1. 通过conn.setAutoCommit（false ）来关闭自动提交的设置。

2. 提交事务 conn.commit();

3. 回滚事务 conn.rollback();

 @Test

    public void testTransaction(){

        Connection conn = null;

        PreparedStatement ps = null;

        ResultSet rs = null;

        try {

            conn = JDBCUtil.getConn();

            //连接，事务默认就是自动提交的。 关闭自动提交。

            conn.setAutoCommit(false);

            String sql = "update account set money = money - ? where id = ?";

            ps = conn.prepareStatement(sql);

            //扣钱， 扣ID为1 的100块钱

            ps.setInt(1, 100);

            ps.setInt(2, 1);

            ps.executeUpdate();

            int a = 10 /0 ;

            //加钱， 给ID为2 加100块钱

            ps.setInt(1, -100);

            ps.setInt(2, 2);

            ps.executeUpdate();

            //成功： 提交事务。

            conn.commit();

        } catch (SQLException e) {

            try {

                //事变： 回滚事务

                conn.rollback();

            } catch (SQLException e1) {

                e1.printStackTrace();

            }

            e.printStackTrace();

        }finally {

            JDBCUtil.release(conn, ps, rs);

        }

    }

事务的特性

* 原子性

> 指的是事务中包含的逻辑，不可分割。

* 一致性

> 指的是事务执行前后。数据完整性

* 隔离性

> 指的是事务在执行期间不应该受到其他事务的影响

* 持久性

> 指的是事务执行成功，那么数据应该持久保存到磁盘上。

事务的安全隐患

不考虑隔离级别设置，那么会出现以下问题。

* 读
脏读不可重读读幻读.

* 脏读

一个事务读到另外一个事务还未提交的数据

* 不可重复读

一个事务读到了另外一个事务提交的数据，造成了前后两次查询结果不一致。

读未提交演示

1. 设置A窗口的隔离级别为读未提交

2. 两个窗口都分别开启事务

* 写

丢失更新

读已提交演示

1. 设置A窗口的隔离级别为读已提交

2. A B 两个窗口都开启事务，在B窗口执行更新操作。

3. 在A窗口执行的查询结果不一致。一次是在B窗口提交事务之前，一次是在B窗口提交事务之后。

这个隔离级别能够屏蔽脏读的现象，但是引发了另一个问题，不可重复读。

可串行化

如果有一个连接的隔离级别设置为了串行化，那么谁先打开了事务，谁就有了先执行的权利，谁后打开事务，谁就只能得着，等前面的那个事务，提交或者回滚后，才能执行。但是这种隔离级别一般比较少用。容易造成性能上的问题。效率比较低。

* 按效率划分，从高到低

读未提交 > 读已提交 > 可重复读 > 可串行化

* 按拦截程度，从高到底

可串行化 > 可重复读 > 读已提交 > 读未提交

事务总结

需要掌握的

1. 在代码里面会使用事务

        conn.setAutoCommit(false);

        conn.commit();

        conn.rollback();

2. 事务只是针对连接连接对象，如果再开一个连接对象，那么那是默认的提交。

3. 事务是会自动提交的。

需要了解的

安全隐患

读
脏读
一个事务读到了另一个事务未提交的数据
不可重复读
一个事务读到了另一个事务已提交的数据，造成前后两次查询结果不一致
幻读
一个事务读到了另一个事务insert的数据，造成前后查询结果不一致。

写

丢失更新。

隔离级别

读未提交

引发问题：脏读

读已提交

解决：脏读，引发：不可重复读

可重复读

解决：脏读、不可重复读，未解决：幻读

可串行化

解决：脏读、不可重复读、幻读。

mySql 默认的隔离级别是可重复读

Oracle 默认的隔离级别是读已提交

丢失更新

解决丢失更新

* 悲观锁

可以在查询的时候，加入 for update

* 乐观锁

> 要求程序员自己控制。

数据库连接池

1. 数据库的连接对象创建工作，比较消耗性能。

2.一开始现在内存中开辟一块空间（集合），一开先往池子里面放置多个连接对象。后面需要连接的话，直接从池子里面去。不要去自己创建连接了。使用完毕，要记得归还连接。确保连接对象能循环利用。

自定义数据库连接池

* 代码实现

* 出现的问题：

1. 需要额外记住 addBack方法

2. 单例。

3. 无法面向接口编程。

UserDao dao = new UserDaoImpl();
dao.insert();

DataSource dataSource = new MyDataSource();

因为接口里面没有定义addBack方法。

4. 怎么解决? 以addBack 为切入点。

解决自定义数据库连接池出现的问题。

由于多了一个addBack 方法，所以使用这个连接池的地方，需要额外记住这个方法，并且还不能面向接口编程。

我们打算修改接口中的那个close方法。原来的Connection对象的close方法，是真的关闭连接。
打算修改这个close方法，以后在调用close，并不是真的关闭，而是归还连接对象。

如何扩展某一个方法?

原有的方法逻辑，不是我们想要的。想修改自己的逻辑

1. 直接改源码无法实现。

2. 继承，必须得知道这个接口的具体实现是谁。

3. 使用装饰者模式。

开源连接池

DBCP

1. 导入jar文件

2. 不使用配置文件：

public void testDBCP01(){

            Connection conn = null;

            PreparedStatement ps = null;

            try {

                //1. 构建数据源对象

                BasicDataSource dataSource = new BasicDataSource();

                //连的是什么类型的数据库， 访问的是哪个数据库 ， 用户名， 密码。。

                //jdbc:mysql://localhost/bank 主协议：子协议 ://本地/数据库

                dataSource.setDriverClassName("com.mysql.jdbc.Driver");

                dataSource.setUrl("jdbc:mysql://localhost/bank");

                dataSource.setUsername("root");

                dataSource.setPassword("root");

                //2. 得到连接对象

                conn = dataSource.getConnection();

                String sql = "insert into account values(null , ? , ?)";

                ps = conn.prepareStatement(sql);

                ps.setString(1, "admin");

                ps.setInt(2, 1000);

                ps.executeUpdate();

            } catch (SQLException e) {

                e.printStackTrace();

            }finally {

                JDBCUtil.release(conn, ps);

            }

        }

2. 使用配置文件方式：

        Connection conn = null;

        PreparedStatement ps = null;

        try {

            BasicDataSourceFactory factory = new BasicDataSourceFactory();

            Properties properties = new Properties();

            InputStream is = new FileInputStream("src//dbcpconfig.properties");

            properties.load(is);

            DataSource dataSource = factory.createDataSource(properties);

            //2. 得到连接对象

            conn = dataSource.getConnection();

            String sql = "insert into account values(null , ? , ?)";

            ps = conn.prepareStatement(sql);

            ps.setString(1, "liangchaowei");

            ps.setInt(2, 100);

            ps.executeUpdate();

        } catch (Exception e) {

            e.printStackTrace();

        }finally {

            JDBCUtil.release(conn, ps);

        }

* C3P0

拷贝jar文件到 lib目录

不使用配置文件方式

  Connection conn = null;

        PreparedStatement ps = null;

        try {

            //1. 创建datasource

            ComboPooledDataSource dataSource = new ComboPooledDataSource();

            //2. 设置连接数据的信息

            dataSource.setDriverClass("com.mysql.jdbc.Driver");

            //忘记了---> 去以前的代码 ---> jdbc的文档

            dataSource.setJdbcUrl("jdbc:mysql://localhost/bank");

            dataSource.setUser("root");

            dataSource.setPassword("root");

            //2. 得到连接对象

            conn = dataSource.getConnection();

            String sql = "insert into account values(null , ? , ?)";

            ps = conn.prepareStatement(sql);

            ps.setString(1, "admi234n");

            ps.setInt(2, 103200);

            ps.executeUpdate();

        } catch (Exception e) {

            e.printStackTrace();

        }finally {

            JDBCUtil.release(conn, ps);

        }

使用配置文件方式

 //默认会找 xml 中的 default-config 分支。

            ComboPooledDataSource dataSource = new ComboPooledDataSource();

            //2. 设置连接数据的信息

            dataSource.setDriverClass("com.mysql.jdbc.Driver");

            //忘记了---> 去以前的代码 ---> jdbc的文档

            dataSource.setJdbcUrl("jdbc:mysql://localhost/bank");

            dataSource.setUser("root");

            dataSource.setPassword("root");

            //2. 得到连接对象

            conn = dataSource.getConnection();

            String sql = "insert into account values(null , ? , ?)";

            ps = conn.prepareStatement(sql);

            ps.setString(1, "admi234n");

            ps.setInt(2, 103200);

DBUtils

增删改

                //dbutils 只是帮我们简化了CRUD 的代码， 但是连接的创建以及获取工作。 不在他的考虑范围

        QueryRunner queryRunner = new QueryRunner(new ComboPooledDataSource());

        //增加

        //queryRunner.update("insert into account values (null , ? , ? )", "aa" ,1000);

        //删除

        //queryRunner.update("delete from account where id = ?", 5);

        //更新

        //queryRunner.update("update account set money = ? where id = ?", 10000000 , 6);

查询

1. 直接new接口的匿名实现类

        QueryRunner queryRunner = new QueryRunner(new ComboPooledDataSource());

        Account  account =  queryRunner.query("select * from account where id = ?", new ResultSetHandler<Account>(){

            @Override

            public Account handle(ResultSet rs) throws SQLException {

                Account account  =  new Account();

                while(rs.next()){

                    String name = rs.getString("name");

                    int money = rs.getInt("money");

                    account.setName(name);

                    account.setMoney(money);

                }

                return account;

            }

         }, 6);

        System.out.println(account.toString());

2. 直接使用框架已经写好的实现类。

* 查询单个对象

QueryRunner queryRunner = new QueryRunner(new ComboPooledDataSource());
//查询单个对象
Account account = queryRunner.query("select * from account where id = ?",
new BeanHandler<Account>(Account.class), 8);

* 查询多个对象

QueryRunner queryRunner = new QueryRunner(new ComboPooledDataSource());
List<Account> list = queryRunner.query("select * from account ",
new BeanListHandler<Account>(Account.class));

ResultSetHandler 常用的实现类
以下两个是使用频率最高的

  BeanHandler,  查询到的单个数据封装成一个对象

    BeanListHandler, 查询到的多个数据封装 成一个List<对象>

------------------------------------------

    ArrayHandler,  查询到的单个数据封装成一个数组

    ArrayListHandler,  查询到的多个数据封装成一个集合 ，集合里面的元素是数组。 

    MapHandler,  查询到的单个数据封装成一个map

    MapListHandler,查询到的多个数据封装成一个集合 ，集合里面的元素是map。

ColumnListHandler
KeyedHandler
ScalarHandler

总结

事务

使用命令行演示

使用代码演示

脏读、

不可重复读、

幻读
丢失更新

    悲观锁

    乐观锁

    4个隔离级别

        读未提交

        读已提交

        可重复读

        可串行化

数据连接池

* DBCP

不使用配置

使用配置

* C3P0

不使用配置

使用配置（必须掌握）

* 自定义连接池

装饰者模式

DBUtils

简化了我们的CRUD ，里面定义了通用的CRUD方法。

    queryRunner.update();

    queryRunner.query

13-事务&数据库连接池&DBUtiles的更多相关文章

事务&数据库连接池&DBUtils
事务的特性原子性指的是事务中包含的逻辑,不可分割. 一致性指的是事务执行前后.数据完整性隔离性指的是事务在执行期间不应该受到其他事务的影响持久性指的是事务执行成功,那么数据应该持 ...

第13章—数据库连接池（Druid）
spring boot 系列学习记录:http://www.cnblogs.com/jinxiaohang/p/8111057.html 码云源码地址:https://gitee.com/jinxia ...

第77节:Java中的事务和数据库连接池和DBUtiles
第77节:Java中的事务和数据库连接池和DBUtiles 前言看哭你,字数:8803,承蒙关照,谢谢朋友点赞! 事务 Transaction事务,什么是事务,事务是包含一组操作,这组操作里面包含许 ...

day13_Mysql事务与数据库连接池学习笔记
一.Mysql事务事务: 事务指逻辑上的一组操作,组成这组操作的各个单元,要么全部成功,要么全部不成功(数据回滚). 例如:A给B转帐,对应于如下两条sql语句 : update account ...

理解数据库连接池和ThreadLocal实现的事务控制
我发现不少人误解了这两者. csdn上也有人提出过这种疑问: http://bbs.csdn.net/topics/250061733 经过查阅资料和认真分析,我特说明一下这两者概念上的区别. 我 ...

14mysql事务、数据库连接池、Tomcat
14mysql事务.数据库连接池.Tomcat-2018/07/26 1.mysql事务事务指逻辑上的一组操作,组成这组操作的各个单元,要么全部成功,要么全部不成功. MySQL手动控制事务开启事 ...

SSM框架之Mybatis（5）数据库连接池及事务
Mybatis(5)数据库连接池及事务 1.Mybatis连接池 Mybatis 中也有连接池技术,但是它采用的是自己的连接池技术.在 Mybatis 的 SqlMapConfig.xml 配置文 ...

java_JDBC，连接数据库方式，RestSet结果集，Statement，PreparedStatement，事务，批处理，数据库连接池（c3p0和Druid）、Apache-DBUtils、
一.JDBC的概述 1.JDBC为访问不同的数据薛是供了统一的接口,为使用者屏蔽了细节问题.2. Java程序员使用JDBC,可以连接任何提供了JDBC驱动程序的数据库系统,从而完成对数据库的各种操作 ...

Mybatis-update - 数据库死锁 - 获取数据库连接池等待
最近学习测试mybatis,单个增删改查都没问题,最后使用mvn test的时候发现了几个问题: update失败,原因是数据库死锁 select等待,原因是connection连接池被用光了,需要等 ...

随机推荐

背景上实现阴影——linear-gradient
/从元素顶部有条阴影,两种方式,第二种更好,能控制阴影的宽度/background-image: linear-gradient(0deg, rgba(226, 226, 226, 0) 97%, ...

mysql并发控制之数据库锁
1.mysql和redis的区别 mysql是一种关系型数据库,数据会最终存储在磁盘上.而redis是一种非关系型的nosql数据库,以key-value的形式存储数据,将数据存储在内存.从性能上来说 ...

ssm多数据源配置
1.在.properties配置文件中添加第二个数据源信息(type2,driver2, url2,username2,pawwword2) 2.修改spring-context.xml(src/m ...

Spring框架-IOC和AOP简单总结
参考博客: https://blog.csdn.net/qq_22583741/article/details/79589910 1.Spring框架是什么,为什么,怎么用 1.1 Spring框架是 ...

好奇，项目根目录下的.editorconfig文件
一..editorconfig文件是什么? 在项目里,大多时候都能看到.editorconfig文件,刚开始总是忽视掉它,认为它不太重要.但是,它的存在,必定有它的理由,于是,抽空来研究一下,它是什么 ...

spring boot集成swagger，自定义注解，拦截器，xss过滤，异步调用，guava限流，定时任务案例, 发邮件
本文介绍spring boot集成swagger,自定义注解,拦截器,xss过滤,异步调用,定时任务案例集成swagger--对于做前后端分离的项目,后端只需要提供接口访问,swagger提供了接口 ...

机器学习基石8-Noise and Error
注: 文章中所有的图片均来自台湾大学林轩田<机器学习基石>课程. 笔记原作者:红色石头微信公众号:AI有道上一节课,我们主要介绍了VC Dimension的概念.如果Hypothese ...

前端笔记知识点整合之JavaScript（一）初识JavaScript
一.JavaScript简介 1.1网页分层 web前端一共分三层: 结构层 HTML : 负责搭建页面结构样式层 CSS : 负责页面的美观行为层 JavaSc ...

QT windeployqt
qt发布release版本时需要打包一些dll,需要哪些呢?请看截图: 在qt的安装包下找到这些文件,放在release文件夹下即可,当然有些时候也会需要一些其他的,比如含有串口的程序还需要加入Qt5 ...

Ipa 脱壳工具 Clutch dumpdecrypted 使用
1 Clutch 使用下载地址 : https://github.com/kjcracks/clutch/releases 下载之后去掉去掉版本号拖入手机的 /usr/bin/ 目录下执行 c ...

正文

相关阅读

射击游戏找手感软件，射击手速游戏

thinkphp修改主页，thinkphp修改数据

小程序朋友圈地址怎么设置，朋友圈小程序怎么关闭

游戏公司经营状况，游戏公司基本情况

虚拟机镜像文件创建不了，虚拟机镜像文件创建不了怎么办

家装品牌如何网络推广，家装品牌如何网络推广销售

捕猎动作游戏，捕猎类手游

人很少但很好玩的射击游戏，什么射击游戏很好玩

目录[+]