事物

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);
    }
}
最后编辑于
©著作权归作者所有,转载或内容合作请联系作者
平台声明:文章内容(如有图片或视频亦包括在内)由作者上传并发布,文章内容仅代表作者本人观点,简书系信息发布平台,仅提供信息存储服务。

推荐阅读更多精彩内容