Node + pg. Как вставить множество строк в таблицу?

Question

[Виктор]

Подскажите, никак не могу вставить множество строк из объекта в базу.
Сервер на Node+express, для подключения к базе использую pg
Данные для примера.

const data = [
   { id: 1, status: 'ok', type: 'def',  time: '22:15' },
   { id: 2, status: 'error', type: 'error',  time: '22:15'  },
   { id: 3, status: 'ok', type: 'def',  time: '22:15'  },
]

await pool.query(
	`INSERT INTO public.orders(id, status, type, time) \
	VALUES ($1, $2, $3, $4) RETURNING *`,
	data.map((item) => [item.id, item.status, item.type, item.time])
)

Получаю ошибку bind message supplies 3 parameters, but prepared statement "" requires 4
Т.е. при переборе, он каждый массив считает как отдельный параметр, а не как набор параметров.

Отдельно отправлять запросы с каждой строкой не вариант, таких строк может быть несколько десятков тысяч, и положить сервер не хочется.
Как правильно писать множество данных в базу одним запросом?

Comments

[Akina]

А зачем Вам RETURNING? Убедиться, что масло таки масляное, а сервер в остальные поля записал именно значения по умолчанию, а не какую-нибудь придуманную на лету хрень?

Answer 1

[Alexandroppolus]

как-то так

await pool.query(
  `INSERT INTO public.orders(id, status, type, time) \
  SELECT unnest(array[%1]), unnest(array[%2]), unnest(array[%3]), unnest(array[%4])`,
  [
    data.map(item => item.id),
    data.map(item => item.status),
    data.map(item => item.type),
    data.map(item => item.time),
  ]
)

Comments

[Виктор]

Такой вариант не подходит, т.к. unnest пишет полученный результат массивом. Т.е. в колонку id будет записан результат [1, 2, 3]

Answer 2

[Виктор]

Проблема решена использованием библиотеки pg-format

Упрощённый пример ниже

const format = require('pg-format');

const data = [
   { id: 1, status: 'ok', type: 'def',  time: '22:15' },
   { id: 2, status: 'error', type: 'error',  time: '22:15'  },
   { id: 3, status: 'ok', type: 'def',  time: '22:15'  },
]

const queryData = data.map((item) => [item.id, item.status, item.type, item.time])
const query = format('INSERT INTO public.orders(id, status, type, time)  VALUES %L', queryData)
await pool.query(query)