数据库事务

2018-08-10 本文已影响0人虫儿飞ZLEI

layout: post
title: 数据库事务
subtitle: 用法
date: 2018-04-24
author: ZL
header-img: img/20180424.jpg
catalog: true
tags:
- 数据库事务

事务

某些数据库的操作是一系列的，只要其中某一条出现了问题，执行失败，那么前面已经执行的语句在逻辑上就不应该生效。
一件事情有n个组成单元要不这n个组成单元同时成功要不n个单元就同时失败
就是将n个组成单元放到一个事务中。

其实，每一条sql语句都是自动事务的，就是说为每一条语句开一个事务。
同时，也可以收到那个开启事务，让多条语句在一个事务中执行。

MySQL的事务

命令：

开启：start transaction
事务提交：commit

只有commit以后，开启事务之后执行的sql语句才会真正的执行，没有commit之前只是一种假的执行。
事务回滚：rollback

从开启事务到事务回滚中间的所有的 sql操作都认为无效数据库没有被更新

JDBC的事务

数据库的命令支持事务这种操作，那么JDBC作为封装的api肯定也是支持的。

在JDBC上面主要就是一些api罢了。
开启事务：conn.setAutoCommit(false);
提交事务：conn.commit();
回滚事务：conn.rollback();

封装的c3p0连接池

不包含事务的：

package com.itheima.utils;

import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;

import javax.sql.DataSource;

import com.mchange.v2.c3p0.ComboPooledDataSource;

public class DataSourceUtils {

  private static DataSource dataSource = new ComboPooledDataSource();

  private static ThreadLocal<Connection> tl = new ThreadLocal<Connection>();

  // 直接可以获取一个连接池
  public static DataSource getDataSource() {
      return dataSource;
  }
  
  public static Connection getConnection() throws SQLException{
      return dataSource.getConnection();
  }

  // 获取连接对象
  public static Connection getCurrentConnection() throws SQLException {

      Connection con = tl.get();
      if (con == null) {
          con = dataSource.getConnection();
          tl.set(con);
      }
      return con;
  }

  // 开启事务
  public static void startTransaction() throws SQLException {
      Connection con = getCurrentConnection();
      if (con != null) {
          con.setAutoCommit(false);
      }
  }

  // 事务回滚
  public static void rollback() throws SQLException {
      Connection con = getCurrentConnection();
      if (con != null) {
          con.rollback();
      }
  }

  // 提交并且 关闭资源及从ThreadLocall中释放
  public static void commitAndRelease() throws SQLException {
      Connection con = getCurrentConnection();
      if (con != null) {
          con.commit(); // 事务提交
          con.close();// 关闭资源
          tl.remove();// 从线程绑定中移除
      }
  }

  // 关闭资源方法
  public static void closeConnection() throws SQLException {
      Connection con = getCurrentConnection();
      if (con != null) {
          con.close();
      }
  }

  public static void closeStatement(Statement st) throws SQLException {
      if (st != null) {
          st.close();
      }
  }

  public static void closeResultSet(ResultSet rs) throws SQLException {
      if (rs != null) {
          rs.close();
      }
  }

}

=======================================================

//使用
@Test
  public void testQueryAll() {
      try {
          // 1.获取核心类queryRunner
          QueryRunner qr = new QueryRunner(C3P0Utils.getDataSource());
          // 2.编写sql语句
          String sql = "select * from tbl_user";
          // 3.执行查询操作
          List<User> users = qr.query(sql, new BeanListHandler<User>(User.class));
          // 4.对结果集集合进行遍历
          for (User user : users) {
              System.out.println(user.getUname() + " : " + user.getUpassword());
          }
      } catch (SQLException e) {
          throw new RuntimeException(e);
      }
  }

包含事务的

package com.itheima.utils;

import java.sql.Connection;
import java.sql.SQLException;

import com.mchange.v2.c3p0.ComboPooledDataSource;

public class MyDataSourceUtils {

  //获得Connection ----- 从连接池中获取
  private static ComboPooledDataSource dataSource = new ComboPooledDataSource();
  
  //创建ThreadLocal
  private static ThreadLocal<Connection> tl = new ThreadLocal<Connection>();
  
  //开启事务
  public static void startTransaction() throws SQLException{
      Connection conn = getCurrentConnection();
      conn.setAutoCommit(false);
  }
  
  //获得当前线程上绑定的conn
  public static Connection getCurrentConnection() throws SQLException{
      //从ThreadLocal寻找 当前线程是否有对应Connection
      Connection conn = tl.get();
      if(conn==null){
          //获得新的connection
          conn = getConnection();
          //将conn资源绑定到ThreadLocal（map）上
          tl.set(conn);
      }
      return conn;
  }
  
  public static Connection getConnection() throws SQLException{
      return dataSource.getConnection();
  }

  //回滚事务
  public static void rollback() throws SQLException {
      getCurrentConnection().rollback();
  }

  //提交事务
  public static void commit() throws SQLException {
      Connection conn = getCurrentConnection();
      conn.commit();
      //将Connection从ThreadLocal中移除
      tl.remove();
      conn.close();
      
  }

}


=====================================================
//使用
Connection conn = null;
try {
  QueryRunner runner = new QueryRunner();
  
  //runner.update("update account set money=15000 where name='tom'");
  //获得一个Connection
  conn = DataSourceUtils.getConnection();
  
  //开启事务
  conn.setAutoCommit(false);
  
  runner.update(conn, "update account set money=15000 where name='tom'");
  //提交或回滚事务
  conn.commit();
  
} catch (SQLException e) {
  try {
    conn.rollback();
  } catch (SQLException e1) {
    e1.printStackTrace();
  }
  e.printStackTrace();
}

事务的特性和隔离级别

事务的特性ACID
- 原子性（Atomicity）：在事务中的操作要么全部发生，要么全部不发生。
- 一致性（Consistency）：事务前后的数据的完整性必须保持一致。举例子：转账时，转账的账户-100，转到的账户应该+100，如果+10000，数据的完整性就不一致了。
- 隔离性（Isolation）：多个并发事务之间的数据必须相互隔离，事务的隔离性是指多个用户并发访问数据库时，一个用户的事务不能被其它用户的事务所干扰。
- 持久性（Durability）：持久性是指一个事务一旦被提交，它对数据库中数据的改变就是永久性的，接下来即使数据库发生故障也不应该对其有任何影响。

事务所带来的问题
- 脏读：B事务读取到了A事务尚未提交的数据
- 不可重复读：一个事务中两次读取的数据的内容不一致
- 幻读&虚读：一个事务中两次读取的数据的数量不一致

解决事务所带来的问题--隔离级别
- 查看mysql的数据库的隔离级别
  select @@tx_isolation
  
  image
- 设置mysql的隔离级别
  set session transaction isolation level 事务隔离级别
  
  image
- 隔离级别
  - read uncommitted : 读取尚未提交的数据：哪个问题都不能解决
  - read committed：读取已经提交的数据：可以解决脏读 ---- oracle默认的
  - repeatable read：重读读取：可以解决脏读和不可重复读 ---mysql默认的
  - serializable：串行化：可以解决脏读不可重复读和虚读---相当于锁表

隔离级别的性能：
read uncommitted>read committed>repeatable read>serialazable
安全性：
read uncommitted<read committed<repeatable read<serialazable

数据库事务

事务

MySQL的事务

JDBC的事务

封装的c3p0连接池

事务的特性和隔离级别

猜你喜欢

热点阅读