typeorm中最简单的事务使用typeorm系列

Posted 2021-12-07 狼丶宇先生

tags:

篇首语：本文由小常识网(cha138.com)小编为大家整理，主要介绍了typeorm中最简单的事务使用typeorm系列相关的知识，希望对你有一定的参考价值。

一、写在前面

喜欢nestjs的小伙伴在开发后台接口的时候可能会遇到同时给2个或者以上的表写入数据的情况，那么万一其中的某一张表失败了，那其它的表又成功了。这样就会导致一个很严重的问题，数据的一致性与准确性异常了。

很简单的一个例子，假如小明给小张转账10块钱，需要的操作如下：

1、小明的账户需要减去10块钱。
2、小张的账户需要加上10块钱。
3、给小明的转账记录表里面写入一条转出数据。
4、给小张的转账记录表里面写入一条转入数据。

上述的简介，你能想到这样的四个步骤是怎么样操作的吗？

本系列文章，迟来的更新。

关注公众号“笔优站长”可阅读全部文章哟。

二、直接上代码

为了简单一点我就直接写方法内的代码了，不写依赖类的了。需要注意的是本次使用的typeorm操作的是MySQL数据库，需要数据库的引擎为InnoDB。

typeorm 中文网中有具体的操作步骤，我这里就写简单点的伪代码了。

https://typeorm.biunav.com/zh/transactions.html

 try {
   			//假设前面都已经算好了，我们就直接写数据库的操作部分
            // 获取连接并创建新的queryRunner
            const queryRunner = getConnection().createQueryRunner();
            try {
                // 使用我们的新queryRunner建立真正的数据库连
                await queryRunner.connect();
                // 开始事务：
                await queryRunner.startTransaction();
				//小明的账户需要减去10块钱。
               	await this.小明的账户表对象Repository.createQueryBuilder(null, queryRunner).update('小明的账户表对象').set('账户字段').where('条件对象').execute();
               	//给小明的转账记录表里面写入一条转出数据
                await this.小明的账户转账记录表对象Repository.createQueryBuilder(null, queryRunner).insert().into('小明的账户转账记录表对象').values('转账记录对象').execute();
                //小张的账户需要加上10块钱。
                await this.小张的账户表对象Repository.createQueryBuilder(null, queryRunner).update('小张的账户表对象').set('账户字段').where('条件对象').execute();
                //给小张的转账记录表里面写入一条转入数据。
                await this.小张的账户转账记录表对象Repository.createQueryBuilder(null, queryRunner).insert().into('小张的账户转账记录表对象').values('转账记录对象').execute();
                // 提交事务：
                await queryRunner.commitTransaction();
            } catch (error) {
                // 有错误做出回滚更改
                await queryRunner.rollbackTransaction();
                return new Error('转账失败',error);
            }
            return '转账成功';
        } catch (error) {
             return new Error('服务异常',error);
        }