NextJS/NestJS+TypeORM连接PostgreSQL时UTF-8编码异常求助

根据你描述的现象——重启应用后恢复、多次提交特殊字符后失效、psql直接插入正常，问题大概率出在应用端的连接配置或连接池复用逻辑上，以下是具体排查和修复方案：

1. 强制TypeORM连接的编码配置 #

确保TypeORM在建立数据库连接时明确指定UTF-8编码，避免连接池中的连接出现编码漂移。在app.module.ts的TypeORM配置中添加charset和初始化查询：

TypeOrmModule.forRoot({
  type: 'postgres',
  host: '你的数据库地址',
  port: 5432,
  username: '用户名',
  password: '密码',
  database: '数据库名',
  entities: [__dirname + '/**/*.entity{.ts,.js}'],
  synchronize: process.env.NODE_ENV !== 'production',
  charset: 'UTF8', // 明确指定连接编码
  initQuery: 'SET client_encoding = \'UTF8\';', // 每次建立连接时强制设置编码
}),

2. 排查连接池的异常编码修改 #

如果某个请求中意外执行了修改客户端编码的SQL（比如SET client_encoding TO 'LATIN1'），且未重置，后续复用该连接的请求就会触发编码错误。可以通过以下方式修复：

• 在TypeORM配置中添加initQuery（如上一步），确保每个连接初始化时都重置编码
• 实现NestJS拦截器，在请求结束后执行编码重置语句：

  @Injectable()
  export class ResetEncodingInterceptor implements NestInterceptor {
    constructor(@InjectConnection() private connection: Connection) {}
  
    async intercept(context: ExecutionContext, next: CallHandler): Promise<Observable<any>> {
      await this.connection.query('SET client_encoding = \'UTF8\';');
      return next.handle().pipe(
        finalize(async () => {
          await this.connection.query('SET client_encoding = \'UTF8\';');
        }),
      );
    }
  }
  

  在模块中注册拦截器，确保所有数据库请求都执行编码重置。

3. 确认请求体的编码解析 #

检查NestJS的body解析中间件是否正确处理UTF-8，避免前端传来的字符被错误转码。在main.ts中显式设置编码：

import { NestFactory } from '@nestjs/core';
import { AppModule } from './app.module';
import * as bodyParser from 'body-parser';

async function bootstrap() {
  const app = await NestFactory.create(AppModule);
  // 显式指定body解析的编码为UTF-8
  app.use(bodyParser.urlencoded({ extended: true, encoding: 'utf-8' }));
  app.use(bodyParser.json({ encoding: 'utf-8' }));
  await app.listen(3000);
}
bootstrap();

同时确认前端NextJS提交表单时，请求头设置为Content-Type: application/json; charset=utf-8，表单添加accept-charset="UTF-8"属性。

4. 验证实体字段的字符集配置 #

确保存储特殊字符的数据库字段使用UTF-8编码，在实体类中显式指定：

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

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

  @Column({ charset: 'UTF8', collation: 'utf8_general_ci' })
  content: string;
}

如果表已创建，手动执行SQL修改字段编码：

ALTER TABLE user_form ALTER COLUMN content TYPE VARCHAR(255) CHARACTER SET UTF8;

5. 优化连接池的健康检测 #

配置连接池的超时和检测机制，避免复用异常连接：

TypeOrmModule.forRoot({
  // 其他配置...
  extra: {
    connectionLimit: 10,
    idleTimeoutMillis: 30000, // 空闲连接30秒后回收
    enableKeepAlive: true,
    keepAliveInitialDelay: 30000,
  },
  testOnBorrow: true, // 每次获取连接时验证可用性
  acquireTimeoutMillis: 60000, // 获取连接超时时间
}),

验证方法 #

修改配置后，持续提交含“é”的表单测试；若问题重现，开启TypeORM的日志功能（logging: true），查看所有执行的SQL语句，定位是否有修改编码的异常操作。

内容的提问来源于stack exchange，提问作者MrKim