欢迎您访问程序员文章站本站旨在为大家提供分享程序员计算机编程知识!
您现在的位置是: 首页

java——事务

程序员文章站 2022-05-23 11:26:42
...

--什么是事务?

事务是与数据库紧密联系在一起的,指的是利用一组sql语句对数据库进行操作的过程,每一次操作都是一次事务,如果数据库操作在某一步没有执行或出现异常而导致事务失败,那么就必须返回到事务操作前的状态。

--事务的四大特性

(1)原子性 原子性即不可分割性,含义是一个事务必须把它产生的所有更改作为一个单独的工作单元进行提交或者回滚。无论有多少变动都将作为一个整体来处理。怎么来保证事务的原子性首先在事务开始之前对事务进行拆解,分析哪些动作是必须同时成功,同时失败的,把这些绑在一起的动作看成一个完整的工作单元,这些动作要步调一致。这其实也就是做好一件事之前的准备阶段。用窗口购票的例子来说就是把乘客付钱和得到火车票看成是一个整体。

(2)一致性 一致性的意思是事务执行的结果必须是使数据库从一个一致性状态变到另一个一致性状态(其实也就意味着在事务期间,对数据的增删改要符合数据的完整性约束)。像这种比较正式的说法往往是用一个抽象的描述去形容另外一个抽象的东西,结果是更加糊涂了。购票这个例子中,所谓的一致性就是现金必须从乘客的手中扣除,而同时火车票也必须被卖出并交到乘客的手上。所以简单点说,就是工作单元中每个动作的执行结果必须被落实,不能出现有的成功了而有的失败了。这就是做好一件事所要达到的既定目标,只要当这件事的所有环节都完成以后才能算这件事完成了。

(3)隔离性 隔离性,在有的地方也叫独立性,其实意思都差不多。隔离性指的是各个独立事务之间的交互程度,是由一致性和并发性共同决定的。像购票的这个例子,如果同时有多名乘客在不同的窗口购票,如果处理不当,很可能在购票的时候会出现两个或两个以上的窗口锁定同一张火车票,并进行售卖的情况,最终不能保证事务的一致性。并发性越低,事务的隔离性越高,一致性也就越高。当提高事务的隔离性的时候,就很可能需要牺牲数据库的并发性来保证数据的一致性。所以当设置事务的隔离级别的时候,就需要综合考虑事务的一致性和并发性。因此通俗讲事务的隔离性就是指的事情应该怎么做。关于事务的隔离性以及隔离级别稍后会有详细说明。

(4)持久性 持久性指的是一个事务一旦提交,那它对数据库的更改就应该是永久的,不会因系统的失败而丢失。当完成购票以后,售票员得到乘客的车票钱,乘客得到售票员给的车票,不能因为售票系统的崩溃就对既有事实进行抵赖,所以从某种程度上来说,持久性也可以指不可抵赖性,签字盖章,交易完成。这就是事情的最终结果。

--事务简单举例

利用转账举例说明:张三有2000元,李四也有2000元,现在要进行的操作是:张三向李四转账1000元,如果操作成功的话应该是张三的账户余额为1000元,李四的账户余额为3000元,假如转账过程中有一方发生问题导致转帐失败,那么结果只能是双方的余额依然保持转账前的数目,否则交易就出现问题,也就是说是一个不可分割的整体,交易过程中一旦发生问题那就导致整个进程失败。

--利用jdbc进行简单的事务演示

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


/**
 * 事务的基本用法
 *
 */
public class Test 
{
    public static void main(String[] args) 
    {
        Connection conn = null;//获得连接数据库对象
        PreparedStatement ps1 = null;//数据库操作对象
        PreparedStatement ps2 = null;

        try
        {
            //加载驱动类
            Class.forName("com.mysql.jdbc.Driver");
            conn = DriverManager.getConnection("jdbc:mysql://localhost:3306/testjdbc","root","123456");
            
            conn.setAutoCommit(false); //JDBC中默认是true,我们改成false,然后在后面手动提交
            
            ps1 = conn.prepareStatement("insert into t_user (username,pwd) values (?,?)");//?是占位符
            ps1.setObject(1, "张三");
            ps1.setObject(2, "666666");
            ps1.execute();
            System.out.println("插入一个用户张三");
            
            try 
            {
                Thread.sleep(3000);
            } 
            catch (InterruptedException e) 
            {
                e.printStackTrace();
            }
            
            ps2 = conn.prepareStatement("insert into t_user (username,pwd) values (?,?)");
            ps2.setObject(1, "李四");
            ps2.setObject(2, "123456");
            ps2.execute();            
            System.out.println("插入一个用户李四");
            
            conn.commit();//提交事务
         }
         catch (ClassNotFoundException e)
         {
            e.printStackTrace();
            try 
            {
                conn.rollback();//某一条数据添加失败时,回滚
            } 
            catch (SQLException e1) 
            {
                e1.printStackTrace();
            }
        } 
        catch (SQLException e) 
        {
            e.printStackTrace();
        }
        finally
        {
            try 
            {
                if(ps1!=null)
                {
                    ps1.close();
                }
            } 
            catch (SQLException e) 
            {
                e.printStackTrace();
            }
            try 
            {
                if(conn!=null)
                {
                    conn.close();
                }
            } 
            catch (SQLException e) 
            {
                e.printStackTrace();
            }
        }
    }
}

利用Mysql数据库进行操作,连续插入两条数据,如果提交失败则捕获异常,并且进行事务回滚,这里的失败有这几种可能,第一条数据插入失败,第二条数据插入失败。所以,即使第一条插入成功,第二条插入失败,整个进程也是失败的,数据库中没有插入的记录,回滚后达到事务未提交前的状态。