如何在拦截器中使用TypeORM保存到数据库

import { Injectable, NestInterceptor, ExecutionContext, CallHandler } from '@nestjs/common';
import { Observable } from 'rxjs';
import { tap } from 'rxjs/operators';
import { getConnection } from 'typeorm';

@Injectable()
export class SaveToDatabaseInterceptor implements NestInterceptor {
  intercept(context: ExecutionContext, next: CallHandler): Observable<any> {
    // 在请求处理之前执行的逻辑
    return next.handle().pipe(
      tap(data => {
        // 在请求处理之后执行的逻辑
        const connection = getConnection();
        const repository = connection.getRepository(YourEntity);
        const entity = repository.create(data);
        repository.save(entity);
      }),
    );
  }
}

import { Controller, Get, UseInterceptors } from '@nestjs/common';
import { SaveToDatabaseInterceptor } from './save-to-database.interceptor';

@Controller('example')
@UseInterceptors(SaveToDatabaseInterceptor)
export class ExampleController {
  @Get()
  getData() {
    // 处理请求的逻辑
  }
}