Уровень изоляции в Nest

Представим, что два клиента одновременно читают и пишут одни и те же строки. Блок по умолчанию не всегда защищает от гонок, и итог зависит от того, как база видит чужие незавершённые изменения.

Первым аргументом метода transaction можно передать имя уровня изоляции. Значение SERIALIZABLE задаёт самый строгий режим для PostgreSQL в рамках одного callback: параллельные блоки ведут себя так, будто выполняются по очереди.

Покажем на примере постов. Опишем сущность:

import { Column, Entity, PrimaryGeneratedColumn } from 'typeorm';

@Entity()
export class Post {
	@PrimaryGeneratedColumn()
	id: number;

	@Column()
	title: string;
}

Сервис откроет блок с уровнем SERIALIZABLE и сохранит две строки через менеджер:

import { Injectable } from '@nestjs/common';
import { DataSource } from 'typeorm';
import { Post } from '../post.entity.js';

@Injectable()
export class PostService {
	dataSource: DataSource;

	constructor(dataSource: DataSource) {
		this.dataSource = dataSource;
	}

	addPairStrict() {
		return this.dataSource.transaction(
			'SERIALIZABLE',
			async (manager) => {
				const first = await manager.save(Post, {
					title: 'Morning note',
				});
				const second = await manager.save(Post, {
					title: 'Evening note',
				});
				return [first, second];
			},
		);
	}
}

Контроллер вызывает операцию сервиса по адресу:

import { Controller, Post } from '@nestjs/common';
import { PostService } from './post.service.js';

@Controller('posts')
export class PostController {
	postService: PostService;

	constructor(postService: PostService) {
		this.postService = postService;
	}

	@Post('pair-strict')
	addPairStrict() {
		return this.postService.addPairStrict();
	}
}

Модуль темы и корень настраивают базу так же, как при обычном блоке без уровня:

import { Module } from '@nestjs/common';
import { TypeOrmModule } from '@nestjs/typeorm';
import { Post } from '../post.entity.js';
import { PostController } from './post.controller.js';
import { PostService } from './post.service.js';

@Module({
	imports: [TypeOrmModule.forFeature([Post])],
	controllers: [PostController],
	providers: [PostService],
})
export class PostsModule {}

import { Module } from '@nestjs/common';
import { TypeOrmModule } from '@nestjs/typeorm';
import { PostsModule } from './posts/posts.module.js';

@Module({
	imports: [
		TypeOrmModule.forRoot({
			type: 'postgres',
			host: 'localhost',
			port: 5432,
			username: 'postgres',
			password: 'postgres',
			database: 'site',
			autoLoadEntities: true,
			synchronize: true,
		}),
		PostsModule,
	],
})
export class AppModule {}

Сохраните две строки работника в блоке со строгим уровнем изоляции в WorkerService, откройте действие в WorkerController и подключите WorkersModule к базе в корне.