Как я могу вставить массив в несколько строк в psql, используя knexjs - PullRequest
0 голосов
/ 08 сентября 2018

Я использую транзакцию outta knexjs для вставки значений в 2 таблицы (1. результат, 2. результат подробно). при вставке значений в таблицу 2 (resultdetail) у меня есть массив объектов, размер которых меняется с каждой записью (в зависимости от количества предметов).

{
	"name": "Sally",
	"fathername": "John",
	"rollno": "85a76",
	"classname": "class1",
	"detail": [
		{
			"subject": "History",
			"marksobt": "50",
			"totalmarks": "100"
		},
		{
			"subject": "French",
			"marksobt": "75",
			"totalmarks": "75"
		}
	]
}

Я пытаюсь использовать следующий код для этого. (Опять же, размер массива «detail» варьируется в зависимости от количества предметов)

const { name, fathername, rollno, classname } = req.body;
	db.transaction(trx => {
		db.insert({
			name: name,
			fathername: fathername,
			rollno: rollno,
			classname: classname
		}).into('results')
		.transacting(trx)
		.returning('rollno')
		.then(roll_no => {
			req.body.detail.map(result => {
				return trx('resultdetail')
				.returning('*')
				.insert({
					rollno: roll_no[0],
					subject: result.subject,
					marksobt: result.marksobt,
					totalmarks: result.totalmarks
				}).then(console.log)
			})
		})
		.then(trx.commit)
		.catch(trx.rollback)
	})
	.catch(err => res.status(400).json(err))
Но в итоге получаю следующую ошибку.

Unhandled rejection Error: Transaction query already complete, run with DEBUG=knex:tx for more info

1 Ответ

0 голосов
/ 11 сентября 2018
insertedRows = await knex('results').returning('*').insert([
    {
        "subject": "History",
        "marksobt": "50",
        "totalmarks": "100"
    },
    {
        "subject": "French",
        "marksobt": "75",
        "totalmarks": "75"
    }
]);

Но в основном ваша проблема в том, что вы запускаете несколько запросов + фиксацию одновременно, не дожидаясь готовности более ранних запросов ...

Когда вы добавляете материал во второй стол, он должен выглядеть примерно так:

.then(roll_no => {
  let resultsToAdd = req.body.detail.map(result => {
     return {
       rollno: roll_no[0],
       subject: result.subject,
       marksobt: result.marksobt,
       totalmarks: result.totalmarks
     };
   });

   return return trx('resultdetail')
     .returning('*')
     .insert(resultsToAdd);
})
...