类型安全类型异常错误处理

Question

我想使用MongoDB用NestJs和TypeORM创建一个应用程序。假设我有一个实体，除了ID字段外，还有两个唯一的字段

@Entity()
export class Module extends BaseEntity {
  @ObjectIdColumn()
  public id: ObjectID;

  @Column({ unique: true })
  public moduleName: string;

  @Column({ unique: true })
  public displayName: string;
}

当我想用已经存在的moduleName或displayName创建一个新模块时，我得到了以下异常错误

[Nest] 6624   - 2020-02-20 16:31:36   [ExceptionsHandler] E11000 duplicate key error collection: test-mongo.module index: UQ_61128bd419e3c3a6d8d7d565ed9 dup key: { moduleName: "firstModule" } +23849ms
BulkWriteError: E11000 duplicate key error collection: test-mongo.module index: UQ_61128bd419e3c3a6d8d7d565ed9 dup key: { moduleName: "firstModule" }
    at OrderedBulkOperation.handleWriteError (C:\Users\mhermsen\Gitlab Repositories\server\node_modules\mongodb\lib\bulk\common.js:1210:11)
    at resultHandler (C:\Users\mhermsen\Gitlab Repositories\server\node_modules\mongodb\lib\bulk\common.js:519:23)
    at C:\Users\mhermsen\Gitlab Repositories\server\node_modules\mongodb\lib\core\connection\pool.js:404:18
    at processTicksAndRejections (internal/process/task_queues.js:76:11)

因此，在catch语句中，我必须处理传入的错误。我要做的是

try {
  // create module
} catch (error) {
  if (/* error is TypeORM error */) {
    if (/* wrong attribute is the module name */) {
      // module name exists ...
    }

    if (/* wrong attribute is the display name */) {
      // display name exists ...
    }
  }
}

TypeORM是否公开预制异常？是否有我可以使用的枚举？获取这些TypeORM数据库错误的好方法是什么？

这里似乎列出了一些错误

https://github.com/typeorm/typeorm/tree/master/src/error

但我无法导入它们，也没有找到有关BulkWriteError

在我的声明中，有可能做这样的事情

const code: number = error.code;

if (code === 11000) {
  throw new ConstraintException(error.errmsg);
}

throw error;

但是你知道这不是最好的方法。此外，此错误对象不会告诉我moduleName或displayName是否无效。一触即发

errmsg:'E11000重复密钥错误集合：test mongo。模块索引：UQ_61128bd419e3c3a6d8d7d565ed9 dup键：{moduleName:“firstModule”}，

我必须创建自己的从这些错误代码到异常的映射吗？

Answer 1

我不确定你是否找到了答案，但这里有一个替代方法，我使用。无论数据库类型是什么，这都是有效的。

我尝试在调用数据库服务时使用自定义装饰器捕捉异常（任何类似于这样的crud操作）

所以这里是我的自定义装饰器（函数装饰器。您可以选择装饰器的类型。它也可以是类装饰器）

目标：-当前对象的原型

属性：-方法的名称

描述符：-方法即对象的属性描述符。GetOwnProperteDescriptor

注意：Nestjs的当前实现方式与swagger的实现方式相同——如果方法的args/返回值发生更改，则不会使用正确的响应对象呈现swagger API部分。因此使用代理的概念来改变行为

export const DatabaseFailureHandler = (target: any, property: string, descriptor: PropertyDescriptor): any => {
  const className = target.constructor.name;
 // 
  const original = descriptor.value;

  let customException;
  // const proxyHandlerFn = function(target, )
  descriptor.value = new Proxy(original, {
    apply: async function(target, thisArg, args) {
      console.log(`Call with args: ${args} -------${className}#`);
      let result;
      try {
        result = await target.apply(thisArg, args);
        console.log('result in databasefailure handling"', result);
        //WARNING!!! - Test only
        // throw new Error('DatabaseException');
        return result;
      } catch (err) {
        // TODO: Replace with the actual logger with the logs of service and class names
        console.log('err capt:', err);

// Below is my custom exception implementation that has my required details. You can 
 //modify it to have the className, methodName args, etc...
        customException = new AppConfigService(new AppUtilService()).retrieveCustomHttpException(
          HttpStatus.INTERNAL_SERVER_ERROR,
          MATRIX_API.ERROR_MSG.DATABASE_ERROR + `:${err.name}`,
          err,
          HttpStatus.INTERNAL_SERVER_ERROR.toString(),
          MATRIX_API.DATABASE.ERR_TYPE.DATABASE_EXCEPTION_ERR_TYPE,
          err.message
        );
        throw customException;
      }
    }
  });
};

现在在我的service.ts中实现了像这样的自定义装饰器

@DatabaseFailureHandler
  async updateXXXXSkill(
    corpId: string,
    skillId: number,
    skillUpdate: UpdateRequestModel
  ): Promise<UpdateResponseModel> {
// Either get the repo from connection or entity manager or Inject them if TypeORMModule is used
    const entity: Employee = this.repository.create({
      ...skillUpdate,
      corpId,
      skillId
    });
    await this.repository.update(
      {
        corpId,
        skillId
      },
      entity
    );
    return XXXXX;
  }

希望这种方法能够让您捕获所有错误详细信息，并通过自定义异常过滤器抛出它们。这是我编写的用于捕获任何异常的集中式过滤器。它是在服务器的开始处注册的。您可以遵循官方的nestjs文档