在将几条记录插入 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)