1:事务的概述:
什么是事务:事务指的是逻辑上的一组操作,组成这组操作的各个单元要么全都成功,要么全都失败.
事务作用:保证在一个事务中多次操作要么全都成功,要么全都失败.
2:创建一个maven工程,进行如下导包操作:
<dependencies>
<dependency>
<groupId>mysql</groupId>
<artifactId>mysql-connector-java</artifactId>
<version>5.1.45</version>
</dependency>
</dependencies>
3:事务有四大特性:
原子性:强调事务的不可分割.
一致性:事务的执行的前后,数据的完整性保持一致.
隔离性:一个事务在执行的过程中,不应该受到其他事务的干扰.
-
持久性:事务一旦结束,数据就持久到数据库中.
4:如果不考虑事务的隔离性,引发一些安全性问题:
读问题:三类- 脏读:一个事务读到了另一个事务未提交的数据.
- 不可重复读:一个事务读到了另一个事务已经提交(update)的数据.引发一个事务中的多次查询结果不一致.
- 虚读/幻读 :一个事务读到了另一个事务已经提交的(insert)数据.导致多次查询的结果不一致
5:解决读问题:
设置事务的隔离级别:
read uncommitted :脏读,不可重复读,虚读都可能发生.
read committed :避免脏读,但是不可重复读和虚读有可能发生.
repeatable read :避免脏读和不可重复读,但是虚读有可能发生的.
serializable :避免脏读,不可重复读和虚读.(串行化的-不可能出现事务并发访问)
安全性:serializable > repeatable read > read committed > read uncommitted
效率 :serializable< repeatable read < read committed < read uncommitted
MYSQL :repeatable read
Oracle :read committed
6:转账案例
package com.com.pp.Money;
import com.com.pp.util.JdbcUtil;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.SQLException;
public class Pay {
public static void main(String[] args) throws SQLException {
Connection connection = JdbcUtil.getConnection();
//事物提交
connection.setAutoCommit(false);//默认不是自动提交
connection.setTransactionIsolation(Connection.TRANSACTION_REPEATABLE_READ);
outMoney("a",1000);
int i=1/0;//异常,保证转出和转入同时执行
inMoney("b",1000);
/*
* 同时成功和同时失败
* */
connection.commit();
connection.close();
}
/*
* 转入
* */
public static void inMoney(String name,double money) throws SQLException {
Connection connection=null;
PreparedStatement preparedStatement=null;
//实例化
String sql="update account set money=money+? where name=?";
PreparedStatement preparedStatement1 = connection.prepareStatement(sql);
preparedStatement.setDouble(1,money);
preparedStatement.setString(2,name);
preparedStatement.executeUpdate();
JdbcUtil.closeResouce(connection,preparedStatement,null);
}
/*
* 转出
* */
public static void outMoney(String name,double money) throws SQLException {
Connection connection=null;
PreparedStatement preparedStatement=null;
//实例化
Connection connection1 = JdbcUtil.getConnection();
String sql="update account set money=money-? where name=?";
PreparedStatement preparedStatement1 = connection.prepareStatement(sql);
preparedStatement.setDouble(1,money);
preparedStatement.setString(2,name);
preparedStatement.executeUpdate();
JdbcUtil.closeResouce(connection,preparedStatement,null);
}
}