有许多解决方案可用，它们都应该基于SQL事务管理。
个人认为最简单的方法是在执行与数据库相关的代码时使用相同的EntityManager实例。然后你可以使用类似以下方式：
getConnection().transaction(entityManager -> {
service1.doStuff1(entityManager);
service2.doStuff2(entityManager);
});
您可以从EntityManager实例中生成一个QueryRunner，在执行ORM操作之外的原始SQL时，它将被包装在同一事务中。您还需要从EntityManager中生成Repository实例，否则它们将在主事务之外执行代码。
typeorm-transactional使用CLS（Continuation Local Storage）来处理和传播不同存储库和服务方法之间的事务。
@Injectable()
export class PostService {
constructor(
private readonly authorRepository: AuthorRepository,
private readonly postRepository: PostRepository,
) {}
@Transactional() // will open a transaction if one doesn't already exist
async createPost(authorUsername: string, message: string): Promise<Post> {
const author = await this.authorRepository.create({ username: authorUsername });
return this.postRepository.save({ message, author_id: author.id });
}
}
由于我需要使用悲观锁，以下是我解决此问题的方法。
我认为这是使用“Nest”处理事物的最佳方式，因为您只需请求NestJS注入一个 Typeorm Connection 实例即可开始工作。
@Injectable()
class MyService {
// 1. Inject the Typeorm Connection
constructor(@InjectConnection() private connection: Connection) { }
async findById(id: number): Promise<Thing> {
return new Promise(resolve => {
// 2. Do your business logic
this.connection.transaction(async entityManager => {
resolve(
await entityManager.findOne(Thing, id, {
lock: { mode: 'pessimistic_write' },
}),
);
});
});
}
}
只需将您需要的任何其他逻辑放置在.transaction块内，然后您就可以开始了。
注意: 您必须使用.transaction方法提供的entityManager，否则它将无法工作。
function assignChildToParent(nestedObj, parentIdKey) {
const parentMap = {};
for (const prop in nestedObj) {
if (nestedObj.hasOwnProperty(prop)) {
const obj = nestedObj[prop];
const parentId = obj[parentIdKey];
parentMap[prop] = { ...obj, children: {} };
if (parentId !== null && parentMap.hasOwnProperty(parentId)) {
parentMap[parentId].children[prop] = parentMap[prop];
}
}
}
const result = {};
for (const prop in parentMap) {
if (parentMap.hasOwnProperty(prop) && parentMap[prop][parentIdKey] === null) {
result[prop] = parentMap[prop];
}
}
return result;
}
const nestedObj = {
obj1: { name: 'Parent 1', parentId: null },
obj2: { name: 'Parent 2', parentId: 'obj1' },
obj3: { name: 'Parent 3', parentId: null }
};
const parentIdKey = 'parentId';
const result = assignChildToParent(nestedObj, parentIdKey);
console.log(result);
@TransactionManager？ - Alfonso