小编use*_*818的帖子

在将几条记录插入 Postgres 数据库后,使用 knex 的 Nodejs 应用程序中断

在将几条记录插入 Postgres 数据库后,我使用 knex 的 Nodejs 应用程序中断,出现以下错误:

未处理的拒绝错误

aborted at PendingOperation.abort (/mnt/c/Users/*********/node_modules/tarn/lib/PendingOperation.js:25:17)
at Promise.all.pendingAcquires.map.acquire (/mnt/c/Users/*********/node_modules/tarn/lib/Pool.js:190:23)
at Array.map (native)
at Promise.all.then.then (/mnt/c/Users/*********/node_modules/tarn/lib/Pool.js:189:34)
Run Code Online (Sandbox Code Playgroud)

从之前的活动:

at Client_PG.acquireConnection (/mnt/c/Users/*********/node_modules/knex/lib/client.js:335:34)
at /mnt/c/Users/*********/node_modules/knex/lib/transaction.js:191:41
Run Code Online (Sandbox Code Playgroud)

从之前的活动:

at Transaction.acquireConnection (/mnt/c/Users/*********/node_modules/knex/lib/transaction.js:190:34)
at new Transaction (/mnt/c/Users/*********/node_modules/knex/lib/transaction.js:68:53)
at Client_PG.transaction (/mnt/c/Users/*********/node_modules/knex/lib/client.js:159:12)
at Function.transaction (/mnt/c/Users/*********/node_modules/knex/lib/util/make-knex.js:75:21)
Run Code Online (Sandbox Code Playgroud)

这是它中断的代码:

const writeOrdersToDB$ = (order: Order): Observable<Order> => {
  const orderToInsert = cleanOrder(order);
  return Observable.fromPromise(knex.transaction((trx: Transaction) => trx('order')
    .insert(orderToInsert)
    .returning('*')));
};
Run Code Online (Sandbox Code Playgroud)

javascript node.js observable rxjs knex.js

5
推荐指数
1
解决办法
1127
查看次数

标签 统计

javascript ×1

knex.js ×1

node.js ×1

observable ×1

rxjs ×1