处理Knex pg数据库错误的正确方法是什么

Question

我正在使用带有knex javascript库的postgres来构建我的sql查询。我想要处理所有从postgres服务器抛出的错误，所以我想要这样做的方式是通过检查抛出错误的类型。

try {
   // knex query here
} catch(error) {
    if(error instanceof DatabaseError) {
      // handle pg error by checking error.code or something else
      // then send an custom error message to the client
    }

    // handle another error here which is not caused by the postgres server
}

有没有办法处理这样的错误？

Answer 1

可以使用Async/Await语法：

async function() {
    try {
       await knex(/* knex query here*/)
    } catch(error) {
        if(error instanceof DatabaseError) {
          // handle pg error by checking error.code or something else
          // then send an custom error message to the client
        }

        // handle another error here which is not caused by the postgres server
    }

如果由于某种原因不想使用那个（较新的）语法，也可以将.catch...

knex(/* knex query here*/)
    .then(doWhatever)
    .catch(error => {
         if(error instanceof DatabaseError) { // ...
    });

另外，您还可以使用Knex的query-error(https://knexjs.org/#interfaces-query-error)...但我个人从来没有看到内置的promise处理程序能够正常工作的意义。

编辑：重读你的帖子后，我想我可能读错了，你的重点可能是“我如何区分PG错误和Knex错误？”。在这种情况下,您可以挂起特定于PG的错误处理程序,如下所示：

function afterCreate(connection, callback) {
  connection.on("error", connectionError);
  callback(null, connection);
}

db.client.pool.config.afterCreate = afterCreate;

如果这样做，就不需要error instanceof databaseerror，因为connection.on捕获的所有错误都将是PG错误。

您可能还会发现这个问题线程（我从那里获得了这些代码）很有用:https://github.com/KNex/KNex/issues/522，因为它讨论了KNex中的错误处理，特别是底层DB错误的处理。