如何在NestJS中使用TypeORM创建触发器？以及实现更新时自动递增列且支持直接MySQL操作的触发器

Nice questions! Let's tackle them one by one, with practical examples you can use right away.

1. 通用创建方法：数据库级触发器（支持直接操作MySQL生效） #

TypeORM本身没有提供专门的装饰器来定义数据库触发器，所以最可靠的方式是创建MySQL原生触发器——这种触发器是在数据库层面生效的，不管你是通过NestJS/TypeORM操作数据，还是直接用MySQL客户端执行SQL，都会触发逻辑。

实现步骤通常分为两步：

• 编写创建触发器的原生SQL
• 在NestJS中执行这段SQL（推荐用TypeORM迁移或模块初始化钩子）

2. 实现“更新时自动递增指定列”的触发器 #

假设我们有一个Post实体，需要在每次更新行数据时，自动递增version列的值。下面是完整的实现流程：

第一步：定义实体 #

先创建包含目标列的TypeORM实体：

// src/posts/entities/post.entity.ts
import { Entity, Column, PrimaryGeneratedColumn } from 'typeorm';

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

  @Column()
  title: string;

  @Column({ default: 1 }) // 初始值设为1
  version: number;
}

第二步：编写MySQL触发器SQL #

我们需要创建一个BEFORE UPDATE触发器，在每行数据更新前自动把version列加1：

CREATE TRIGGER increment_version_on_update
BEFORE UPDATE ON posts
FOR EACH ROW
SET NEW.version = OLD.version + 1;

注意：触发器名称要唯一，posts是你的实体对应的数据库表名。

第三步：在NestJS中执行SQL创建触发器 #

有两种推荐方式：

方式一：用TypeORM迁移（生产环境首选）

迁移可以帮你跟踪数据库结构变化，便于团队协作和版本控制：

1. 创建迁移文件：

   npx typeorm migration:create src/migrations/CreateIncrementVersionTrigger
   

2. 在生成的迁移文件中写入触发器逻辑：

   // src/migrations/1699999999999-CreateIncrementVersionTrigger.ts
   import { MigrationInterface, QueryRunner } from "typeorm";
   
   export class CreateIncrementVersionTrigger1699999999999 implements MigrationInterface {
       public async up(queryRunner: QueryRunner): Promise<void> {
           await queryRunner.query(`
               CREATE TRIGGER increment_version_on_update
               BEFORE UPDATE ON posts
               FOR EACH ROW
               SET NEW.version = OLD.version + 1;
           `);
       }
   
       public async down(queryRunner: QueryRunner): Promise<void> {
           // 回滚时删除触发器
           await queryRunner.query(`DROP TRIGGER IF EXISTS increment_version_on_update`);
       }
   }
   

3. 运行迁移：

   npx typeorm migration:run -d src/data-source.ts
   

方式二：在模块初始化时执行（快速测试用）

如果只是快速验证，可以在服务的onModuleInit钩子中执行SQL：

// src/posts/posts.service.ts
import { Injectable, OnModuleInit } from '@nestjs/common';
import { DataSource } from 'typeorm';

@Injectable()
export class PostsService implements OnModuleInit {
  constructor(private dataSource: DataSource) {}

  async onModuleInit() {
    const queryRunner = this.dataSource.createQueryRunner();
    await queryRunner.connect();
    try {
      // 先检查触发器是否存在，避免重复创建
      const triggerExists = await queryRunner.query(`
        SELECT TRIGGER_NAME FROM INFORMATION_SCHEMA.TRIGGERS 
        WHERE TRIGGER_SCHEMA = DATABASE() AND TRIGGER_NAME = 'increment_version_on_update'
      `);
      if (triggerExists.length === 0) {
        await queryRunner.query(`
          CREATE TRIGGER increment_version_on_update
          BEFORE UPDATE ON posts
          FOR EACH ROW
          SET NEW.version = OLD.version + 1;
        `);
        console.log('版本递增触发器创建成功');
      }
    } finally {
      await queryRunner.release();
    }
  }

  // 你的其他业务方法...
}

第四步：验证效果 #

不管是通过NestJS服务更新数据：

await this.postsRepository.update(1, { title: 'Updated Title' });

还是直接在MySQL客户端执行更新：

UPDATE posts SET title = 'Direct MySQL Update' WHERE id = 1;

你都会看到version列自动递增了1，完全符合需求。

内容的提问来源于stack exchange，提问作者Open Wings Infotech