Блог

Моя проблема в том, что я выполняю транзакцию, которая включает несколько запросов, и если один из этих запросов завершается неудачно, те, которые указаны выше, не откатываются, но должны. Транзакция имеет следующую структуру (рекомендуется в официальной документации nestjs):

     public async create(createUserDto: RegisterUserDto): Promise<UserEntity> {
        const queryRunner = this.connection.createQueryRunner();
        await queryRunner.connect();
        await queryRunner.startTransaction();
        try {
            const firstReqResult = await this.firstMethod(queryRunner, createUserDto);
            const secondReqResult = await this.secondMethod(firstReqResult, queryRunner);
            await queryRunner.commitTransaction();
            return secondReqResu<
        } catch (err) {
            await queryRunner.rollbackTransaction();
            throw new HttpException(err.message, HttpStatus.BAD_REQUEST);
        } finally {
            await queryRunner.release();
        }
    }
  

Итак, если первый метод записывает некоторые данные в некоторые таблицы данных и secondMethod по какой-то причине выдает ошибку, то эти данные не удаляются при откате и, следовательно, в БД появляются потерянные записи.

Одна важная вещь: эти два метода firstMethod и secondMethod сами не являются транзакциями, это просто обычные методы, которые используют queryRunner переданный им параметр.

Как правильно выполнить typeorm откат такой транзакции?

Редактировать:

Похоже, что моя попытка не сработала. Поэтому я опубликую более подробную информацию:

Вот основной метод:

     public async create(createUserDto: RegisterUserDto): Promise<UserEntity> {
        const queryRunner = this.connection.createQueryRunner();
        await queryRunner.connect();
        await queryRunner.startTransaction();
        try {
            // some code
            const profilePrivacyPermissions = await this.profilePrivacyPermissionsService.generateInitSettings(queryRunner);
            const registeredUser = await this.registerUser(user);
            await queryRunner.commitTransaction();
            return registeredUser;
        } catch (err) {
            await queryRunner.rollbackTransaction();
            throw new HttpException(err.message, HttpStatus.BAD_REQUEST);
        } finally {
            await queryRunner.release();
        }
    }
  

registerUser Метод выдает исключение.

Метод generateInitSettings выглядит следующим образом:

     public async generateInitSettings(qr: QueryRunner): Promise<ProfilePrivacyEntity[]> {
        const generatedSettings = [];
        const screenTypeIds = Object.values(EScreenType).filter(value => typeof value === 'number') as number[];
        for (const stId of screenTypeIds) {
            const setting = this.createAndSaveInitSetting(stId, qr);
            generatedSettings.push(setting);
        }
        return await Promise.all(generatedSettings);
    }
  

и createAndSaveInitSetting :

     private async createAndSaveInitSetting(screenType: number, qr: QueryRunner): Promise<ProfilePrivacyEntity> {
        const permission = new ProfilePrivacyEntity();
        permission.setScreenType(screenType)
                  .setIsEverybody(true)
                  .setIsContacts(false)
                  .setIsNobody(false);
        const createdPermission = qr.manager.getRepository(ProfilePrivacyEntity).create(permission);
        return await createdPermission.save();
    }
  

Поэтому, когда registerUser метод выдает исключение, изменения, внесенные DB generateInitSettings , не откатываются.