1.事务特性(ACID)
ACID，指数据库事务正确执行的四个基本要素的缩写。包含：原子性（Atomicity）、一致性（Consistency）、隔离性（Isolation）、持久性（Durability）。一个支持事务（Transaction）的数据库，必须要具有这四种，否则在事务过程当中无法保证数据的正确性，交易过程极可能达不到交易方的要求。
原子性（Atomicity）:整个事务中的所有操作，要么全部完成，要么全部不完成，不可能停滞在中间某个环节。事务在执行过程中发生错误，会被
回滚（Rollback）到事务开始前的状态，就像这个事务从来没有执行过一样。一致性（Consistency）:事务前数据的状态和事务后数据的状态保持一致
持久性（Durability）：在事务完成以后，该事务对数据库所作的更改便持久的保存在数据库之中，并不会被回滚。
-
隔离性（Isolation 重点）：针对多线程并发操作数据资源的时候，每个事务应该是独立的，不会受到其他事务的打扰，如果说数据库软件不支持事务的隔离性，多个线程访问数据的时候，会受到相互的打扰。这种情况不是正确的。
1.png
1.1隔离级别
1.Serializable (串行化)：可避免脏读、不可重复读、幻读的发生。
2.Repeatable read (可重复读)：可避免脏读、不可重复读的发生(mysql默认的隔离级别)，有可能发生幻读。
3.Read committed (读已提交)：可避免脏读的发生(oralce默认的隔离级别)，不可重复读还有幻读有可能发生。
4.Read uncommitted (读未提交)：最低级别，任何情况都无法保证。
1.2如果没有隔离性而言，会出现哪些问题？
1.脏读：两个事务(t1,t2),t1事务开启，修改了李四的账户的钱加上1000，并没有提交事务，t2,查询到了李四已经修改后的数据。这种数据就是脏读。(t2读到了t1没有提交的数据)。
2.不可重复读:两个事务(t1,t2),t1事务开启，t2事务开启，t2查询一次李四的账户的资金，t1修改李四的钱加上1000，t1提交是事务。t2在没有提交事务的前提下，执行了相同的查询，出现了本次查询的数据发生变化。(t2本次事务中部可以能重复读数据)
3.幻读(虚读):两个事务(t1,t2)，一般针对的是数据的添加操作，t1开启事务，t2开启事务，t1查询账户表有5个用户，t2,在账户表中添加了一个用户，t2提交事务。t1又查询账户表发现会6个用户。这就出现了幻读。
2.TCL语句
- SQL语句分类
1. DDL 数据定义语句 (create 、drop.....sql语句)
2. DML 数据操作语句(updat、insert into 、 delete.... sql 语句)
3. DQL 数据查询语句 (select ... 语句 )
4. TCL 事务控制语句
start transaction 开启事务
rollback 事务回滚，本次事务就结束
commit 事务提交，本次事务就结束
select @@tx_isolation 针对mysql查看隔离级别
set tx_isolation ='隔离级别' 设置隔离级别
3.编程式事务管理
编码方式实现事务管理(JDBC编程来管理事务)
声明式事务管理：可知编程式事务每次实现都要单独实现，但业务量大功能复杂时，使用编程式事务无疑是痛苦的，而声明式事务不同，声明式事务属于无侵入式，不会影响业务逻辑的实现(通过配置方案就实现了事务的管理)
3.1 JDBC编程式管理
public void update(UserModel entity) {
// 1.创建三大对象引用
Connection conn = null;
PreparedStatement pstmt = null;
// 2.初始化引用对象
// 2.1 try-catch-finally
try {
conn = DBUtil.getConn();
// 关闭了事务的自动提交，关闭自动事务提交也就意味着手动开启了事务。
// 开启事务
conn.setAutoCommit(false);
pstmt = conn.prepareStatement(UPDATE_SQL);
pstmt.setObject(1, entity.getName());
pstmt.setObject(2, entity.getPassword());
pstmt.setObject(3, entity.getEmail());
pstmt.setObject(4, entity.getBirthday());
pstmt.setObject(5, entity.getId());
pstmt.executeUpdate();
int i = 1 / 0;
// 提交事务
conn.commit();
} catch (Exception e) {
try {
// 回滚事务
conn.rollback();
} catch (SQLException e1) {
// TODO Auto-generated catch block
e1.printStackTrace();
}
e.printStackTrace();
} finally {
DBUtil.replease(conn, pstmt, null);
}
}
注意：以上的编程事务管理方式是有问题的，由于把事务的管理操作加入到数据访问层 Dao层,在实际开发过程中事务应该加到业务层。
4.数据源(连接池) JDBC规范中的DataSource 接口
数据源提供了一种简单获取数据库连接的方式，并能在内部通过一个池的机制来复用数据库连接，这样就大大减少创建数据库连接的次数，提高了系统性能。
-
sun公司并没有对DataSource进行实现
-
市面上对数据源主要的实现工具类
1.apache组织开发了一个 DBCP数据源
2.c3p0组织开发的c3p0数据源
3.alibaba温少开发的druid德鲁伊数据源(国产货)
4.1开发druid数据源工具类
1.导入alibaba的druid数据源依赖jar包
2.编写DruidUtil工具类
public class DruidUtil {
private static final DruidDataSource DATASOURCE = new DruidDataSource();
private static final String URL;
private static final String USER;
private static final String PASSWORD;
private static final String DRIVER;
static {
try {
InputStream inStream = Thread.currentThread().getContextClassLoader().getResourceAsStream("jdbc.properties");
Properties p = new Properties();
p.load(inStream);
URL = p.getProperty("jdbc.url");
USER = p.getProperty("jdbc.user");
PASSWORD = p.getProperty("jdbc.password");
DRIVER = p.getProperty("jdbc.driver");
DATASOURCE.setDriverClassName(DRIVER);
DATASOURCE.setPassword(PASSWORD);
DATASOURCE.setUrl(URL);
DATASOURCE.setUsername(USER);
} catch (Exception e) {
throw new ExceptionInInitializerError("数据源配置出错！");
}
}
private DruidUtil() {
}
/**
* 获取连接对象
*/
public static Connection getConn() {
try {
return DATASOURCE.getConnection();
} catch (SQLException e) {
e.printStackTrace();
}
return null;
}
/**
* 释放资源
*
*/
public static void release(Connection conn, Statement stmt, ResultSet rs) {
if (rs != null) {
try {
rs.close();
} catch (SQLException e) {
e.printStackTrace();
}
rs = null;
}
if (stmt != null) {
try {
stmt.close();
} catch (SQLException e) {
e.printStackTrace();
}
stmt = null;
}
if (conn != null) {
try {
conn.close();
} catch (SQLException e) {
e.printStackTrace();
}
conn = null;
}
}
/**
* 得到数据源对象
*
*/
public static DataSource getDataSource() {
return DATASOURCE;
}
}
5.ThreadLocal事务控制
早在JDK 1.2的版本中就提供java.lang.ThreadLocal，ThreadLocal为解决多线程程序的并发问题提供了一种新的思路。使用这个工具类可以很简洁地编写出优美的多线程程序。
当使用ThreadLocal维护变量时，ThreadLocal为每个使用该变量的线程提供独立的变量副本，所以每一个线程都可以独立地改变自己的副本，而不会影响其它线程所对应的副本。
从线程的角度看，目标变量就象是线程的本地变量，这也是类名中“Local”所要表达的意思。
所以，在Java中编写线程局部变量的代码相对来说要笨拙一些，因此造成线程局部变量没有在Java开发者中得到很好的普及。
5.1ThreadLocal接口 api介绍：
- get() 从线程中取变量
- remove() 从线程中移除变量
- set(T value) 向线程中设置变量
5.2 修改DruidUtil工具类
public class DruidUtil {
private static final DruidDataSource DATASOURCE = new DruidDataSource();
// 创建线程局部变量操作对象
private static ThreadLocal<Connection> tl = new ThreadLocal<Connection>();
private static final String URL;
private static final String USER;
private static final String PASSWORD;
private static final String DRIVER;
static {
try {
InputStream inStream = Thread.currentThread().getContextClassLoader().getResourceAsStream("jdbc.properties");
Properties p = new Properties();
p.load(inStream);
URL = p.getProperty("jdbc.url");
USER = p.getProperty("jdbc.user");
PASSWORD = p.getProperty("jdbc.password");
DRIVER = p.getProperty("jdbc.driver");
DATASOURCE.setDriverClassName(DRIVER);
DATASOURCE.setPassword(PASSWORD);
DATASOURCE.setUrl(URL);
DATASOURCE.setUsername(USER);
} catch (Exception e) {
throw new ExceptionInInitializerError("数据源配置出错！");
}
}
private DruidUtil() {
}
/**
* 获取连接对象
*/
public static Connection getConn() {
try {
Connection conn = null;
// 先从线程中取Connection对象
if (tl.get() == null) {
conn = DATASOURCE.getConnection();
// 放入到当前线程中
tl.set(conn);
}
return tl.get();
} catch (SQLException e) {
e.printStackTrace();
throw new RuntimeException("连接对象获取失败！");
}
}
/**
* 释放资源
*
*/
@Deprecated
public static void release(Connection conn, Statement stmt, ResultSet rs) {
if (rs != null) {
try {
rs.close();
} catch (SQLException e) {
e.printStackTrace();
}
rs = null;
}
if (stmt != null) {
try {
stmt.close();
} catch (SQLException e) {
e.printStackTrace();
}
stmt = null;
}
if (conn != null) {
try {
conn.close();
// 从线程中移除掉Connection对象
tl.remove();
} catch (SQLException e) {
e.printStackTrace();
}
conn = null;
}
}
/**
* 得到数据源对象
*
*/
public static DataSource getDataSource() {
return DATASOURCE;
}
/**
* 开启事务
*/
public static void startTransaction() {
Connection conn = getConn();
try {
conn.setAutoCommit(false);
} catch (SQLException e) {
e.printStackTrace();
}
}
/**
* 提交事务
*/
public static void commit() {
try {
Connection conn = getConn();
conn.commit();
conn.close();
tl.remove();
} catch (SQLException e) {
e.printStackTrace();
}
}
/**
* 事务回滚
*/
public static void rollback() {
try {
Connection conn = getConn();
conn.rollback();
conn.close();
tl.remove();
} catch (SQLException e) {
e.printStackTrace();
}
}
}
5.3 业务层代码添加事务
public class AccountServiceImpl implements IAccountService {
private IAccoutDao accountDao = new AccountDaoImpl();
public void transferAccount(Account srcAccout, Account targAccount, double cash) {
srcAccout.setMoney(srcAccout.getMoney() - cash);
targAccount.setMoney(targAccount.getMoney() + cash);
try {
DruidUtil.startTransaction();
accountDao.modifyAccountMoney(srcAccout);
// 测试异常，事务回滚
int i = 1 / 0;
accountDao.modifyAccountMoney(targAccount);
DruidUtil.commit();
} catch (Exception e) {
e.printStackTrace();
DruidUtil.rollback();
}
}
}
5.4 数据访问层代码简化为
public class AccountDaoImpl implements IAccoutDao {
private static final String MODIFY_SQL = "UPDATE ACCOUNT SET MONEY = ? WHERE NAME = ?";
public void modifyAccountMoney(Account srcAccout) throws Exception {
Connection conn = null;
PreparedStatement stmt = null;
conn = DruidUtil.getConn();
stmt = conn.prepareStatement(MODIFY_SQL);
stmt.setObject(1, srcAccout.getMoney());
stmt.setObject(2, srcAccout.getName());
stmt.executeUpdate();
}
}
