数据库事务的陷阱

本贴最后更新于 4454 天前,其中的信息可能已经物是人非

    写几个例子, 来示范一下 数据库事务 的误区。

    下面的例子场景为转账,使用mysql,innodb, 缺省read committed隔离级别,spring+hibernate.  不考虑边界条件,如余额不足等。

    我只要声明了 事务,就万事大吉了么?

               先给一个entity的代码   

@Entity
public class Money {
    private Long id;
private Long balance; private long version; @Id @GeneratedValue(strategy = GenerationType.IDENTITY) public Long getId() { return id; } public void setId(Long uid) { this.id = uid; } public Long getBalance() { return balance; } public void setBalance(Long balance) { this.balance = balance; }

}

   在给一个service的代码,一切从简,没有dao.

   

@Service
public class MoneyService {
    @Autowired
    private HibernateTemplate template;
@Transactional public void transfer(Long from, Long to, Long amount) { Money fromAcount = template.load(Money.class, from); Money toAccount = template.load(Money.class, to); fromAcount.setBalance(fromAcount.getBalance() - amount); // just for test try { Thread.sleep(1000l); } catch (InterruptedException e) { e.printStackTrace(); } // //////////////// toAccount.setBalance(toAccount.getBalance() + amount); template.save(fromAcount); template.save(toAccount); }

}

 你觉得这段代码有问题么?同时起2个线程,一个让用户A(余额100)给C(余额100)转账10,另一个让用户B(余额100)给用户C(余额100)转账10, 结果是A(余额90),B(余额90), C(余额110), 丢失了10块钱。。。。。。

  这里面可能引发另外一个疑问,数据库教程书也是这么用的啊,设了事务,人家转账咋就没问题。

  好吧,让我们把数据库教程里的sql代码翻译成同样的hibernate代码。

@Transactional
    public void transfer2(final Long from, final Long to, final Long amount) {
template.execute(new HibernateCallback&lt;Void&gt;() { public Void doInHibernate(Session session) throws HibernateException, SQLException { SQLQuery q = session .createSQLQuery(&quot;update money set balance = (balance - ?) where id = ?&quot;); q.setLong(0, amount); q.setLong(1, from); q.executeUpdate(); return null; } }); // just for test try { Thread.sleep(1000l); } catch (InterruptedException e) { e.printStackTrace(); } // //////////////// template.execute(new HibernateCallback&lt;Void&gt;() { public Void doInHibernate(Session session) throws HibernateException, SQLException { SQLQuery q = session .createSQLQuery(&quot;update money set balance = (balance + ?) where id = ?&quot;); q.setLong(0, amount); q.setLong(1, to); q.executeUpdate(); return null; } }); }</pre>

     这里需要指出,事务保证的只是sql的完整性,如果是程序搞砸的,那事务也爱莫能助。

     transfer产生的sql代码为

            select * from money where id=A.id;

            select * from money where id=C.id;

            update money set balance=90 where id=A.id;

            update money set balance=110 where id=C.id;

     和

            select * from money where id=B.id;

            select * from money where id=C.id;

            update money set balance=90 where id=B.id;

            update money set balance=110 where id=C.id;

      余额90 和 110 都是程序计算出来的,所以事务也爱莫能助。

      而transfer2 产生的sql代码为

            update money set balance=balance - 10 where id=A.id;

            update money set balance=balance + 10 where id=C.id;

      和
            update money set balance=balance - 10 where id=B.id;

            update money set balance=balance + 10 where id=C.id;

      数据库事务保证结果是A(余额90),B(余额90), C(余额120)。

 
      问题虽然解决了,但不能只能写sql啊,我还是需要使用hibernate,怎么办呢?
      这里需要借助悲观锁或乐观锁了。
 
      悲观锁:
    @Transactional
    public void transfer3(Long from, Long to, Long amount) {
        Money fromAcount = template.load(Money.class, from,
                LockMode.PESSIMISTIC_WRITE);
        Money toAccount = template.load(Money.class, to,
                LockMode.PESSIMISTIC_WRITE);
fromAcount.setBalance(fromAcount.getBalance() - amount); // //////////////// try { Thread.sleep(1000l); } catch (InterruptedException e) { e.printStackTrace(); } // //////////////// toAccount.setBalance(toAccount.getBalance() + amount); template.save(fromAcount); template.save(toAccount); }

      这样在进行select的时候,会同时将记录锁住,另外一个线程在对同一条记录进行查询的时候,必须等待锁的释放。需要小心使用悲观锁,不正确的顺序会大大增加数据库死锁的概率。

      结果,余额对了, 但你会发现 其中一个线程的 select 花费了 1秒钟,因为它一直在等待 另外一个线程释放锁。

 

       还有一种解决方案是乐观锁:

       列一下代码:

       

package com.wuxudong.entity;

import javax.persistence.Entity;
import javax.persistence.GeneratedValue;
import javax.persistence.GenerationType;
import javax.persistence.Id;
import javax.persistence.Version;

@Entity
public class Money {
private Long id;

private Long balance; private long version; @Id @GeneratedValue(strategy = GenerationType.IDENTITY) public Long getId() { return id; } public void setId(Long uid) { this.id = uid; } public Long getBalance() { return balance; } public void setBalance(Long balance) { this.balance = balance; } @Version public long getVersion() { return version; } public void setVersion(long version) { this.version = version; }

}

  

 @Transactional
 public void transfer4(Long from, Long to, Long amount) {
        Money fromAcount = template
                .load(Money.class, from, LockMode.OPTIMISTIC);
        Money toAccount = template.load(Money.class, to, LockMode.OPTIMISTIC);
fromAcount.setBalance(fromAcount.getBalance() - amount); // //////////////// try { Thread.sleep(1000l); } catch (InterruptedException e) { e.printStackTrace(); } // //////////////// toAccount.setBalance(toAccount.getBalance() + amount); template.save(fromAcount); template.save(toAccount);

}

   换成乐观锁后,一个线程的事务顺利执行成功, 而另一个线程则抛出了乐观锁异常回滚掉了。

  • 数据库

    据说 99% 的性能瓶颈都在数据库。

    345 引用 • 755 回帖
  • 事务
    23 引用 • 21 回帖 • 1 关注

相关帖子

欢迎来到这里!

我们正在构建一个小众社区,大家在这里相互信任,以平等 • 自由 • 奔放的价值观进行分享交流。最终,希望大家能够找到与自己志同道合的伙伴,共同成长。

注册 关于
请输入回帖内容 ...

推荐标签 标签

  • NGINX

    NGINX 是一个高性能的 HTTP 和反向代理服务器,也是一个 IMAP/POP3/SMTP 代理服务器。 NGINX 是由 Igor Sysoev 为俄罗斯访问量第二的 Rambler.ru 站点开发的,第一个公开版本 0.1.0 发布于 2004 年 10 月 4 日。

    315 引用 • 547 回帖
  • Sandbox

    如果帖子标签含有 Sandbox ,则该帖子会被视为“测试帖”,主要用于测试社区功能,排查 bug 等,该标签下内容不定期进行清理。

    440 引用 • 1238 回帖 • 593 关注
  • TextBundle

    TextBundle 文件格式旨在应用程序之间交换 Markdown 或 Fountain 之类的纯文本文件时,提供更无缝的用户体验。

    1 引用 • 2 回帖 • 87 关注
  • 创造

    你创造的作品可能会帮助到很多人,如果是开源项目的话就更赞了!

    186 引用 • 1021 回帖
  • SpaceVim

    SpaceVim 是一个社区驱动的模块化 vim/neovim 配置集合,以模块的方式组织管理插件以
    及相关配置,为不同的语言开发量身定制了相关的开发模块,该模块提供代码自动补全,
    语法检查、格式化、调试、REPL 等特性。用户仅需载入相关语言的模块即可得到一个开箱
    即用的 Vim-IDE。

    3 引用 • 31 回帖 • 111 关注
  • Sublime

    Sublime Text 是一款可以用来写代码、写文章的文本编辑器。支持代码高亮、自动完成,还支持通过插件进行扩展。

    10 引用 • 5 回帖 • 2 关注
  • 职场

    找到自己的位置,萌新烦恼少。

    127 引用 • 1708 回帖 • 1 关注
  • 学习

    “梦想从学习开始,事业从实践起步” —— 习近平

    172 引用 • 540 回帖
  • Maven

    Maven 是基于项目对象模型(POM)、通过一小段描述信息来管理项目的构建、报告和文档的软件项目管理工具。

    188 引用 • 319 回帖 • 240 关注
  • WiFiDog

    WiFiDog 是一套开源的无线热点认证管理工具,主要功能包括:位置相关的内容递送;用户认证和授权;集中式网络监控。

    1 引用 • 7 回帖 • 615 关注
  • ZeroNet

    ZeroNet 是一个基于比特币加密技术和 BT 网络技术的去中心化的、开放开源的网络和交流系统。

    1 引用 • 21 回帖 • 649 关注
  • etcd

    etcd 是一个分布式、高可用的 key-value 数据存储,专门用于在分布式系统中保存关键数据。

    6 引用 • 26 回帖 • 546 关注
  • jQuery

    jQuery 是一套跨浏览器的 JavaScript 库,强化 HTML 与 JavaScript 之间的操作。由 John Resig 在 2006 年 1 月的 BarCamp NYC 上释出第一个版本。全球约有 28% 的网站使用 jQuery,是非常受欢迎的 JavaScript 库。

    63 引用 • 134 回帖 • 735 关注
  • Word
    13 引用 • 41 回帖 • 1 关注
  • MyBatis

    MyBatis 本是 Apache 软件基金会 的一个开源项目 iBatis,2010 年这个项目由 Apache 软件基金会迁移到了 google code,并且改名为 MyBatis ,2013 年 11 月再次迁移到了 GitHub。

    173 引用 • 414 回帖 • 366 关注
  • Shell

    Shell 脚本与 Windows/Dos 下的批处理相似,也就是用各类命令预先放入到一个文件中,方便一次性执行的一个程序文件,主要是方便管理员进行设置或者管理用的。但是它比 Windows 下的批处理更强大,比用其他编程程序编辑的程序效率更高,因为它使用了 Linux/Unix 下的命令。

    125 引用 • 74 回帖
  • CSS

    CSS(Cascading Style Sheet)“层叠样式表”是用于控制网页样式并允许将样式信息与网页内容分离的一种标记性语言。

    198 引用 • 543 回帖
  • AWS
    11 引用 • 28 回帖 • 8 关注
  • 创业

    你比 99% 的人都优秀么?

    82 引用 • 1395 回帖
  • HHKB

    HHKB 是富士通的 Happy Hacking 系列电容键盘。电容键盘即无接点静电电容式键盘(Capacitive Keyboard)。

    5 引用 • 74 回帖 • 519 关注
  • Kotlin

    Kotlin 是一种在 Java 虚拟机上运行的静态类型编程语言,由 JetBrains 设计开发并开源。Kotlin 可以编译成 Java 字节码,也可以编译成 JavaScript,方便在没有 JVM 的设备上运行。在 Google I/O 2017 中,Google 宣布 Kotlin 成为 Android 官方开发语言。

    19 引用 • 33 回帖 • 83 关注
  • 外包

    有空闲时间是接外包好呢还是学习好呢?

    26 引用 • 233 回帖 • 5 关注
  • Tomcat

    Tomcat 最早是由 Sun Microsystems 开发的一个 Servlet 容器,在 1999 年被捐献给 ASF(Apache Software Foundation),隶属于 Jakarta 项目,现在已经独立为一个顶级项目。Tomcat 主要实现了 JavaEE 中的 Servlet、JSP 规范,同时也提供 HTTP 服务,是市场上非常流行的 Java Web 容器。

    162 引用 • 529 回帖 • 8 关注
  • NetBeans

    NetBeans 是一个始于 1997 年的 Xelfi 计划,本身是捷克布拉格查理大学的数学及物理学院的学生计划。此计划延伸而成立了一家公司进而发展这个商用版本的 NetBeans IDE,直到 1999 年 Sun 买下此公司。Sun 于次年(2000 年)六月将 NetBeans IDE 开源,直到现在 NetBeans 的社群依然持续增长。

    78 引用 • 102 回帖 • 709 关注
  • 知乎

    知乎是网络问答社区,连接各行各业的用户。用户分享着彼此的知识、经验和见解,为中文互联网源源不断地提供多种多样的信息。

    10 引用 • 66 回帖 • 1 关注
  • H2

    H2 是一个开源的嵌入式数据库引擎,采用 Java 语言编写,不受平台的限制,同时 H2 提供了一个十分方便的 web 控制台用于操作和管理数据库内容。H2 还提供兼容模式,可以兼容一些主流的数据库,因此采用 H2 作为开发期的数据库非常方便。

    11 引用 • 54 回帖 • 670 关注
  • V2Ray
    1 引用 • 15 回帖 • 3 关注