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

Mysql事务操作失败如何解决

程序员文章站 2022-06-05 22:25:23
mysql事务操作失败如何解决 事务的原子性 :事务是数据库的逻辑工作单位,事务中包含的各操作要么都做,要么都不做 。 要实现事务的原子性,单单靠一条commit或是r...

mysql事务操作失败如何解决

事务的原子性 :事务是数据库的逻辑工作单位,事务中包含的各操作要么都做,要么都不做 。

要实现事务的原子性,单单靠一条commit或是rollback命令还是不行的,因为例如commit命令它只是将一个事务中执行成功的dml语句提交给数据库里。如果要实现事务的原子性,则就需要commit和rollback命令配合上程序上的一个业务逻辑才能可以,具体业务逻辑代码如下示例代码:

1.现象

     程序中打开了事务进行插入,但是没有commit,表中的数据已经存在,就是回滚也不能删除插入的数据

2.原因

    本表的storage engine 为myisam,不是innodb,不支持事务处理 rollback()

3.解决方法

    使用 alter table xxxx engine = innodb ; 将表改为 innodb 引擎,结果回滚正常。

4.代码

 private void testcrud() {
     connection conn = null;      //连接对象
     preparedstatement pstmt = null;  //预编译的sql语句对象
      try{
        //加载mysql驱动程序
        class.forname("com.mysql.jdbc.driver");
        //连接字符串
        string url = "jdbc:mysql://localhost:3306/test";
        //建立数据库连接
        conn = drivermanager.getconnection(url,"root","");
        //设置事务的隔离级别
        // conn.settransactionisolation(connection. transaction_repeatable_read);
        //设置自动提交为false,开始事务
        conn.setautocommit(false);
        //带参数的更新语句
        string sql = "insert into user_info (username ,password ,age )values(?,?,?)";
        //准备语句
        pstmt = conn.preparestatement(sql);
        //绑定参数,执行更新语句,将张三的账户金额减去1000元
        pstmt.setstring(1, "zhangui");
        pstmt.setstring(2, "1111");
        pstmt.setint(3, 300);
        pstmt.execute();
        
        //绑定参数,执行更新语句,将李四的账户金额增加1000元
        // pstmt.setstring(1, "zzzzzzzzzzzzzzzzz"); //绑定了非法参数
        //pstmt.setstring(2, "1111111111");
        //pstmt.setint(3, 500);
        //pstmt.execute(); //将抛出sql异常
        //提交事务
        //conn.commit();
        system.out.println("事务已提交,转账成功!");
        //关闭语句、连接
        pstmt.close(); conn.close();
      }catch(exception e){
        try{
          conn.rollback();  //回滚事务
          system.out.println("事务回滚成功,没有任何记录被更新!");
        }catch(exception re){
          system.out.println("回滚事务失败!");
        }
        e.printstacktrace();
      }finally{
        if(pstmt!=null) try{pstmt.close();}catch(exception ignore){}
        if(conn!=null) try{conn.close();}catch(exception ignore){}
      }
    
  }

感谢阅读,希望能帮助到大家,谢谢大家对本站的支持!