diff --git a/package.json b/package.json index d1cdec8..8104c2b 100755 --- a/package.json +++ b/package.json @@ -15,7 +15,7 @@ "lodash": "^4.17.21", "md5": "^2.3.0", "midwayjs-cool-alipay": "^1.0.3", - "midwayjs-cool-core": "^3.2.2", + "midwayjs-cool-core": "^3.2.5", "midwayjs-cool-oss": "^1.0.12", "midwayjs-cool-queue": "^1.0.7", "midwayjs-cool-redis": "^1.1.6", diff --git a/src/app/modules/demo/service/goods.ts b/src/app/modules/demo/service/goods.ts index 7537bba..c2f826d 100644 --- a/src/app/modules/demo/service/goods.ts +++ b/src/app/modules/demo/service/goods.ts @@ -1,7 +1,7 @@ import { Inject, Provide } from '@midwayjs/decorator'; -import { BaseService, Cache } from 'midwayjs-cool-core'; +import { BaseService, Cache, CoolTransaction } from 'midwayjs-cool-core'; import { InjectEntityModel } from '@midwayjs/orm'; -import { Repository } from 'typeorm'; +import { Repository, QueryRunner } from 'typeorm'; import { DemoAppGoodsEntity } from '../entity/goods'; import { ICoolCache } from 'midwayjs-cool-core'; @@ -23,4 +23,19 @@ export class DemoGoodsService extends BaseService { async all() { return this.demoAppGoodsEntity.find(); } + + /** + * 事务 + * @param params + * @param queryRunner + */ + @CoolTransaction({ isolation: 'SERIALIZABLE' }) + async testTransaction(params: any, queryRunner?: QueryRunner) { + await queryRunner.manager.insert(DemoAppGoodsEntity, { + title: '这是个商品', + pic: '商品图', + price: 99.0, + type: 1, + }); + } }