Приложение Nodejs, использующее разрывы knex после вставки нескольких записей в базу данных Postgres - PullRequest
0 голосов
/ 10 июня 2018

Приложение My Nodejs, использующее knex, разрывается после вставки нескольких записей в базу данных Postgres со следующей ошибкой:

Ошибка необработанного отклонения

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)

Отпредыдущее событие:

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

Из предыдущего события:

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)

Вот код, в котором он ломается:

const writeOrdersToDB$ = (order: Order): Observable<Order> => {
  const orderToInsert = cleanOrder(order);
  return Observable.fromPromise(knex.transaction((trx: Transaction) => trx('order')
    .insert(orderToInsert)
    .returning('*')));
};
Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...