Nestjs+TypeORM操作MySQL时唯一约束错误的信息提取方案问询

我正在开发一个基于NestJS的服务，使用TypeORM与MySQL交互。已创建包含col1和col2的test_table表，其中col1带有UNIQUE约束。插入重复值时触发如下错误：

{
  query: 'INSERT INTO `test_table`(`col1`, `col2`) VALUES (?, ?)',
  parameters: [ 'test-val-1', 'test-val-2' ],
  driverError: {
    code: 'ER_DUP_ENTRY',
    errno: 1062,
    sqlState: '23000',
    sqlMessage: "Duplicate entry 'test-val-1' for key 'test_table.col1'",
    sql: "INSERT INTO `test_table`(`col1`, `col2`) VALUES ('test-val-1', 'test-val-2')"
  },
  code: 'ER_DUP_ENTRY',
  errno: 1062,
  sqlState: '23000',
  sqlMessage: "Duplicate entry 'test-val-1' for key 'test_table.col1'",
  sql: "INSERT INTO `test_table`(`col1`, `col2`) VALUES ('test-val-1', 'test-val-2')"
}

直接返回sqlMessage会暴露表名和列名，且无法直接提取引发错误的列名及错误类型。目前想到两种方案：

• 插入前查询数据库检查重复，但会增加额外调用导致延迟
• 编写解析器提取信息，但存在因消息格式变更失效的风险

请问是否有更优方式提取引发错误的列名及错误类型？

1. 结合TypeORM实体元数据+轻量错误解析 #

TypeORM的实体元数据包含了表结构和约束的完整信息，我们可以用它来验证解析出的约束信息，比纯字符串解析更可靠：

import { getRepository } from 'typeorm';
import { TestTable } from './entities/test-table.entity';

function extractDuplicateColumn(err: any): string | null {
  if (err.code !== 'ER_DUP_ENTRY') return null;
  
  // 从错误消息中提取约束标识（如test_table.col1）
  const constraintMatch = err.sqlMessage.match(/for key '([^']+)'/);
  if (!constraintMatch) return null;
  
  const [tableName, columnName] = constraintMatch[1].split('.');
  // 用实体元数据验证并返回实体属性名（可选，也可直接返回数据库列名）
  const entityMeta = getRepository(TestTable).metadata;
  if (entityMeta.tableName === tableName) {
    const targetColumn = entityMeta.columns.find(col => col.databaseName === columnName);
    return targetColumn ? targetColumn.propertyName : columnName;
  }
  return null;
}

这种方式既避免了预查询的性能损耗，又通过实体元数据降低了纯字符串解析的失效风险，只要MySQL约束名的格式（表名.列名）不变，就能稳定工作。

2. 预加载MySQL约束映射缓存 #

服务启动时一次性查询information_schema获取所有唯一约束的映射关系并缓存，之后处理错误时直接匹配，完全避免重复解析或查询：

import { getConnection } from 'typeorm';

let uniqueConstraintMap: Map<string, string>;

// 服务初始化时加载
async function initConstraintMap() {
  const conn = getConnection();
  const result = await conn.query(`
    SELECT TABLE_NAME, COLUMN_NAME, CONSTRAINT_NAME
    FROM information_schema.KEY_COLUMN_USAGE
    WHERE CONSTRAINT_TYPE = 'UNIQUE' AND TABLE_SCHEMA = DATABASE()
  `);
  
  uniqueConstraintMap = new Map();
  result.forEach(row => {
    // 同时映射约束全名和短名，适配不同错误消息格式
    uniqueConstraintMap.set(`${row.TABLE_NAME}.${row.CONSTRAINT_NAME}`, row.COLUMN_NAME);
    uniqueConstraintMap.set(row.CONSTRAINT_NAME, row.COLUMN_NAME);
  });
}

// 错误处理时使用
function getDuplicateColumn(err: any): string | null {
  if (err.code !== 'ER_DUP_ENTRY') return null;
  const constraintMatch = err.sqlMessage.match(/for key '([^']+)'/);
  return constraintMatch ? uniqueConstraintMap.get(constraintMatch[1]) : null;
}

3. NestJS全局异常过滤器统一处理 #

在NestJS中实现全局异常过滤器，把上述逻辑封装起来，统一拦截并处理重复插入错误，返回友好且不暴露敏感信息的响应：

import { ExceptionFilter, Catch, ArgumentsHost } from '@nestjs/common';
import { Response } from 'express';
import { QueryFailedError } from 'typeorm';

@Catch(QueryFailedError)
export class DuplicateEntryFilter implements ExceptionFilter {
  constructor(private readonly constraintMap: Map<string, string>) {}

  catch(exception: QueryFailedError, host: ArgumentsHost) {
    const response = host.switchToHttp().getResponse<Response>();
    const driverErr = exception.driverError;

    if (driverErr.code === 'ER_DUP_ENTRY') {
      const constraintMatch = driverErr.sqlMessage.match(/for key '([^']+)'/);
      const column = constraintMatch ? this.constraintMap.get(constraintMatch[1]) : 'unique field';
      return response.status(400).json({
        message: `该${column}已存在`,
        error: '重复条目',
        statusCode: 400
      });
    }

    // 其他数据库错误默认处理
    response.status(500).json({
      message: '数据库操作失败',
      statusCode: 500
    });
  }
}

在模块中注册过滤器后，所有数据库重复插入错误都会被自动处理，无需在业务代码中重复编写逻辑。

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