<十一>JDBC_事务的处理+隔离

Tom给jerry汇款500元

1、如果多个操作,每个操作使用的是自己的单独的连接,则无法保证事务

2、具体步骤:
   1>事务开始操作前,开始事务:取消Connection的默认提交行为

2>如果事务的操作都成功,都提交事务
   3>回滚事务:若出现异常,则在catch块中回滚事务;

3、模板 try {
  
   //开始事务:取消默认提交(默认自动提交) con.setAutoCommit(false);
  
   //...
  
   
  //提交事务 con.commit();
  
  } catch (Exception e) {
  
  //...
  
 //如果出现异常就回滚事

try {

con.rollback();

} catch (SQLException e1) {
            e1.printStackTrace();

}

}

@Test
 public void testTransaction() {
  
    Connection con = null;
    try {

    con = JDBCTools.getConnection();
       System.out.println("默认事务:" + con.getAutoCommit());
       // 开始事务:取消默认提交(默认自动提交)
       con.setAutoCommit(false);
       String sql = "update users set balance=balance-500 where id=1";
       update(con, sql);
       int i = 10 / 0;
       sql = "update users set balance=balance+500 where id=2";
       update(con, sql);
       // 提交事务
       con.commit();

   } catch (Exception e) {
       // 如果出现异常就回滚事务
       try {
          con.rollback();
       } catch (SQLException e1) {
          e1.printStackTrace();
       }
    } finally {
       JDBCTools.release(null, null, con);
    }

}

设置事务的隔离级别

@Test
 public void testTransactionIsolationRead() {
  
  String sql = "select balance from users where id=1";
  Integer balance=getForValue(sql);
  System.out.println("balance="+balance);
 }

/*
  * 测试事务的隔离级别 在JDBC程序中可以通过Connection的setTransactionIsolation()方法 来设置事务的隔离级别
  */
 @Test
 public void testTransactionIsolationUpdate() {

Connection con = null;

try {

con = JDBCTools.getConnection();
   // 开始事务:取消默认提交(默认自动提交)
   con.setAutoCommit(false);
   String sql = "update users set balance=balance-500 where id=1";
   update(con,sql);
   con.commit();

} catch (Exception e) {
   e.printStackTrace();
  } finally {

}
 }

// 返回某个对象的属性值
 @SuppressWarnings("unchecked")
 public <E> E getForValue(String sql, Object... args) {

// 1、得到结果集:该结果集应该只有一行且只有一列
  Connection con = null;
  PreparedStatement ps = null;
  ResultSet rs = null;
  try {

con = JDBCTools.getConnection();
   //con.setTransactionIsolation(Connection.TRANSACTION_READ_UNCOMMITTED);
   con.setTransactionIsolation(Connection.TRANSACTION_READ_COMMITTED);
   ps = con.prepareStatement(sql);
   for (int i = 0; i < args.length; i++) {
    ps.setObject(i + 1, args[i]);
   }
   rs = ps.executeQuery();

if (rs.next()) {
    return (E) rs.getObject(1);
   }

} catch (Exception e) {
   e.printStackTrace();
  } finally {
   JDBCTools.release(rs, ps, con);
  }

// 2、取得结果集的
  return null;
 }

更新后的JDBCTools.java工具类如下:

import java.io.InputStream;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.Properties;

/*
 * JDBC工具类
 * */
public class JDBCTools {

  // 提交事务
   public static void commit(Connection con) {

     if (con != null) {
         try {
            con.commit();
         } catch (SQLException e) {
            e.printStackTrace();
         }
      }
   }

  //回滚事务
   public static void rollback(Connection con) {

    if (con != null) {
         try {
            con.rollback();
           } catch (SQLException e) {
              e.printStackTrace();
           }
        }
   }
 
   //开始事务
   public static void beginTx(Connection con) {

     if (con != null) {
         try {
            con.setAutoCommit(false);
         } catch (SQLException e) {
            e.printStackTrace();
         }
      }
   }

   /*
    * 执行SQL的方法 insert,update,delete
    */
   public static void update(String sql, Object... args) {

     Connection conn = null;
      PreparedStatement ps = null;

     try {
         /*
          * 1、获取Connection连接 2、获取Statement 3、SQL语句 4、关闭数据库连接
          *
          */
         conn = getConnection();
         ps = conn.prepareStatement(sql);

      for (int i = 0; i < args.length; i++) {
            ps.setObject(i + 1, args[i]);
         }

        ps.executeUpdate();

    } catch (Exception e) {
         e.printStackTrace();
      } finally {
         release(null, ps, conn);
      }
   }

  public static Connection getConnection() throws Exception {

    String driverClass = null;
      String jdbcUrl = null;
      String user = null;
      String password = null;

    // 读取类路径下的jdbc.properties文件
      InputStream in = JDBCTools.class.getClassLoader().getResourceAsStream("jdbc.properties");
      Properties properties = new Properties();
      properties.load(in);

    driverClass = properties.getProperty("driver");
      jdbcUrl = properties.getProperty("jdbcUrl");
      user = properties.getProperty("user");
      password = properties.getProperty("password");
      // 加载数据库驱动程序
      Class.forName(driverClass);
      // 通过DriverManager的getConnection()方法获取数据库连接
      Connection connection = DriverManager.getConnection(jdbcUrl, user, password);
      return connection;

  }

  public static void release(ResultSet rs, Statement st, Connection conn) {

    if (rs != null) {
         try {
            rs.close();
         } catch (SQLException e) {
            e.printStackTrace();
         }
      }

     if (st != null) {
         try {
            st.close();
         } catch (SQLException e) {
            e.printStackTrace();
         }
      }

     if (conn != null) {
         try {
            conn.close();
         } catch (SQLException e) {
            e.printStackTrace();
         }
      }
   }
}

时间: 2024-12-16 22:56:30

<十一>JDBC_事务的处理+隔离的相关文章

深入解析Mysql中事务的四大隔离级别及其所解决的读现象

本文详细介绍四种事务隔离级别,并通过举例的方式说明不同的级别能解决什么样的读现象.并且介绍了在关系型数据库中不同的隔离级别的实现原理. 在DBMS中,事务保证了一个操作序列可以全部都执行或者全部都不执行(原子性),从一个状态转变到另外一个状态(一致性).由于事务满足久性.所以一旦事务被提交之后,数据就能够被持久化下来,又因为事务是满足隔离性的,所以,当多个事务同时处理同一个数据的时候,多个事务直接是互不影响的,所以,在多个事务并发操作的过程中,如果控制不好隔离级别,就有可能产生脏读.不可重复读.

SqlServer——事务—锁与隔离级别

隔离实际上是通过锁来实现的,作用于整个事务,它通常在事务开始前指定,如 SET TRANSACTION ISOLATION LEVEL READ Committed,指定后面的事务为 已提交读:而锁是在我们执行某一具体的SQL语句时在from中指定锁模式来实现的,它可以覆盖掉已指定隔离级别下应用的锁类型.隔离级别牺牲并发性来实现一致性. 并发:是指在相同的时间,多个用户访问相同的数据.它通常引起以下问题:脏读:丢失更新:不可重复度:幻读: 脏读:一个进程读取了另一个进程尚未提交的数据. 不可重复

Spring事务传播、隔离等级

事务传播 PROPAGATION_REQUIRED 如果当前没有事务,就新建一个事务,如果已经存在一个事务中,加入到这个事务中.这是最常见的选择. PROPAGATION_SUPPORTS 支持当前事务,如果当前没有事务,就以非事务方式执行. PROPAGATION_MANDATORY 使用当前的事务,如果当前没有事务,就抛出异常. PROPAGATION_REQUIRES_NEW 新建事务,如果当前存在事务,把当前事务挂起. PROPAGATION_NOT_SUPPORTED 以非事务方式执行

数据事务四种隔离机制和七种传播行为

一.隔离级别: 数据库事务的隔离级别有4个,由低到高依次为Read uncommitted.Read committed.Repeatable read.Serializable,这四个级别可以逐个解决脏读.不可重复读.幻读这几类问题. 1. ISOLATION_READ_UNCOMMITTED:这是事务最低的隔离级别,它充许令外一个事务可以看到这个事务未提交的数据.      这种隔离级别会产生脏读,不可重复读和幻像读.2. ISOLATION_READ_COMMITTED:保证一个事务修改的

MySQL事务四个隔离级别

MySQL事务隔离级别详解             MySQL数据结构SQL SQL标准定义了4类隔离级别,包括了一些具体规则,用来限定事务内外的哪些改变是可见的,哪些是不可见的.低级别的隔离级一般支持更高的并发处理,并拥有更低的系统开销. Read Uncommitted (读取未提交的内容)  在该隔离级别,所有事务都可以看到其他未提交事务的执行结果.本隔离级别很少用于实际应用,因为它的性能也不比其他级别好多少.读取未提交的数据,也被称之为脏读(Dirty Read).Read Commit

数据库事务中的隔离级别和锁+spring Transactional注解

数据库事务中的隔离级别和锁 数据库事务在后端开发中占非常重要的地位,如何确保数据读取的正确性.安全性也是我们需要研究的问题. ACID 首先总结一下数据库事务正确执行的四个要素(ACID): 原子性(Atomicity):即事务是不可分割的最小工作单元,事务内的操作要么全做,要么全不做,不能只做一部分:一致性(Consistency):在事务执行前数据库的数据处于正确的状态,而事务执行完成后数据库的数据还是处于正确的状态,即数据完整性约束没有被破坏:比如我们做银行转账的相关业务,A转账给B,要求

数据库事务的四大特性以及事务的隔离级别-与-Spring事务传播机制&amp;隔离级别

本篇讲诉数据库中事务的四大特性(ACID),并且将会详细地说明事务的隔离级别. 如果一个数据库声称支持事务的操作,那么该数据库必须要具备以下四个特性: ⑴ 原子性(Atomicity) 原子性是指事务包含的所有操作要么全部成功,要么全部失败回滚,这和前面两篇博客介绍事务的功能是一样的概念,因此事务的操作如果成功就必须要完全应用到数据库,如果操作失败则不能对数据库有任何影响. ⑵ 一致性(Consistency) 一致性是指事务必须使数据库从一个一致性状态变换到另一个一致性状态,也就是说一个事务执

事务并发之隔离级别

事务 事务是作为单个逻辑工作单元执行的一系列操作.一个逻辑工作单元必须有四个属性,称为原子性.一致性.隔离性和持久性 (ACID) 属性,只有这样才能成为一个事务. 事务并发 数据库是多个用户(事务)共享的,当多个用户同时访问数据时,那么在这种情况下就叫做并发. 事务并发下可能出现的问题 更新丢失 两个事务都同时更新一行数据,一个事务对数据的更新把另一个事务对数据的更新覆盖了.这是因为系统没有执行任何的锁操作,因此并发事务并没有被隔离开来. 脏读 一个事务读取到了另一个事务未提交的数据操作结果.

SqlServer——事务—锁和隔离的总结

锁定提示对SQL语句进行特别指定,这个指定将覆盖事务的隔离级别.下面对各个锁定提示分别予以介绍(更多资料请查看SQLserver的联机帮助),笔者做出了以下分类. ④     UPDLOCK:发出更新锁,保持到事务事务结束.(更新锁:不阻塞别的事物,允许别的事物读数据(即更新锁可与共享锁兼容),但他确保自上次读取数据后数据没有被更新) 在很多系统中,经常会遇到这种情况,要保持一个编号的唯一,如会计软件中的凭证的编号.一种编号的处理是这样的,把表中的最大编号保存到表中,然后在这个编号上累加,形成新