2020年9月

如何使用Mysql正确的处理财务数据

财务数据相比于普通的互联网应用数据，对数据的一致性有更高的要求。因为涉及到用户金钱的流动，出现问题就意味金钱和声誉上的损失。在用 Mysql 处理财务数据时，我认为应该遵循以下原则：

  1. 使用 DECIMAL 数据类型存储金额。因为浮点数精度是有限的，并且无法精确的表示一些数字。应用程序也应该使用 Decimal 函数库来进行金额的加减乘除的运算，比如 Python 的 decimal 模块，C++ 的 boost Multiprecision 库。
  2. 使用事务来更新数据库。涉及到数据库多个记录更新时，事务能够做到要么全部成功，要么全部失败，这保证了数据的一致性。Mysql 使用事务需要 InnoDB 引擎。
  3. 更新数据库时使用悲观锁。更新数据前使用 SELECT …  FOR UPDATE; 来查询，这样防止并发的请求读到脏数据，导致数据错乱。虽然加锁会影响性能，但为了数据的一致性也是值得的。
  4. 记录资金变化的流水日志。不能简单的只记录用户的金额，还要记录每笔资金的来龙去脉，包括变化的大小、时间、业务、更新前金额、更新后金额、备注等，另外还有记录业务ID防止重复更新金额。这样在对账的时候才能有理有据。

下面以一个完整的示例来说明如何设计一个完备的记账系统用来记录人民币余额，这里精度只需要2位小数就可以了。

假设已经有一个用户表，每个用户有一个唯一ID。我们需要创建两张表，一张余额表，一张流水表：

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
CREATE TABLE `balance` (
  `id` int NOT NULL AUTO_INCREMENT PRIMARY KEY,
  `user_id` int NOT NULL,
  `item` varchar(10) NOT NULL,
  `balance` decimal(20,2) NOT NULL
) ENGINE=InnoDB;
 
CREATE TABLE `history` (
  `id` int NOT NULL AUTO_INCREMENT PRIMARY KEY,
  `time` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP,
  `user_id` int NOT NULL,
  `item` varchar(10) NOT NULL,
  `amount` decimal(20,2) NOT NULL,
  `befor` decimal(20,2) NOT NULL,
  `after` decimal(20,2) NOT NULL,
  `business` varchar(30) NOT NULL,
  `business_id` varchar(100) NOT NULL,
  `detail` text
) ENGINE=InnoDB;

为了加快查询速度，另外为了有效利用 InnoDB 的行级锁，我们需要给两张表加上联合索引。另外，我们需要保证流水记录中 user_id, item, business, business_id 的组合是唯一的，避免重复更新数据。

1
2
3
4
5
ALTER TABLE balance ADD INDEX `user_item_idx` (`user_id`, `item`);
 
ALTER TABLE history ADD INDEX `user_item_idx` (`user_id`, `item`);
 
ALTER TABLE history ADD UNIQUE update_unique (user_id, item, business, business_id);

假设这时候用户 ID 为 1 的用户充值了 100 元人民币，我们需要把用户的人民币余额加上 100 元，我们要如何处理呢？

这里我们还需要一个充值表用来保存用户的充值记录，同时，我们再创建一个提现表来表示用户提现记录，如下所示:

1
2
3
4
5
6
7
8
9
10
11
12
13
CREATE TABLE `deposit` (
  `id` int NOT NULL AUTO_INCREMENT PRIMARY KEY,
  `user_id` int NOT NULL,
  `item` varchar(10) NOT NULL,
  `amount` decimal(20,2) NOT NULL
) ENGINE=InnoDB;
 
CREATE TABLE `withdraw` (
  `id` int NOT NULL AUTO_INCREMENT PRIMARY KEY,
  `user_id` int NOT NULL,
  `item` varchar(10) NOT NULL,
  `amount` decimal(20,2) NOT NULL
) ENGINE=InnoDB;

首先，开始一个事务，创建充值记录：

1
2
3
START TRANSACTION;
 
INSERT INTO deposit VALUES (NULL, 1, 'CNY', '100')

插入成功后，我们可以使用 MYSQL 的 API 获取到上次插入后生成的自增 ID 的值，假设这里也为 1. 然后我们需要从数据库查询当前余额。查询的时候注意要使用 FOR UPDATE 来锁住该记录，避免其它并发的请求读到脏数据。即使当前该记录不存在，在事务提交之前，其它读请求仍然被阻塞读不到数据的。

1
SELECT id, balance FROM balance where user_id = 1 and item = 'CNY' FOR UPDATE;

由于用户是新注册的，查询到的数据为空，所以我们创建新的记录：

1
INSERT INTO balance VALUES (NULL, 1, 'CNY', '100');

然后我们要在流水表中记录下这次的变更操作：

1
INSERT INTO history VALUES (NULL, NULL, 1, 'CNY', '100', '0', '100', 'deposit', '1', '');

最后提交事务：

1
COMMIT;

事务提交后，所有的数据都写入到数据库中了，中间如果有异常发生，则执行

1
ROLLBACK;

来放弃所有的变更。

假设过了一段时间用户要求提现 50 元，操作流程如下：

1
2
3
START TRANSACTION;
 
SELECT id, balance FROM balance where user_id = 1 and item = 'CNY' FOR UPDATE;

假设读出的 id 也为 1. 由于用户之前充值了 100 元还没有使用，所以余额是 100，大于 50 满足提现条件。如果不满足的话需要执行 ROLLBACK. 然后：

1
2
3
4
5
6
7
INSERT INTO withdraw VALUES (NULL, 1, 'CNY', '50');
 
UPDATE balance set balance = '50' WHERE id = 1;
 
INSERT INTO history VALUES (NULL, NULL, 1, 'CNY', '-50', '100', '50', 'withdraw', '1', '');
 
COMMIT;

这就完整的实现了整个充值和提现的流程。

当然，这里示例的充值和提现是最简化的流程，实际业务中，充值和提现往往涉及到多种状态的流转。并且在提现中，用户发起提现和实际进行转账不可能是同时进行的，中间可能会取消操作，直接扣除资金不太妥当，更妥当的做法是把待提现的资金冻结起来，冻结操作其实就是创建一个新的 item: CNY_FREEZE, 在 CNY 上扣减，然后在 CNY_FREEZE 上增加来实现。转账后再从 CNY_FREEZE 中扣除。如果取消操作则取消冻结，从 CNY_FREEZE 扣减，增加到 CNY 上面，这样整个流程在流水日志上都有体现。

https://web.archive.org/web/20170617125020/http://blog.haipo.me/?p=1266

https://zhuanlan.zhihu.com/p/143866444