Как сделать массивную вставку в mySQL, если вы используете что-то вроде https://github.com/felixge/node-mysql
Как сделать объемную вставку в mySQL с помощью node.js
Ответ 1
Массовые вставки возможны с помощью вложенного массива, см. страница github
Вложенные массивы превращаются в сгруппированные списки (для объемных вставок), например.
[['a', 'b'], ['c', 'd']]превращается в('a', 'b'), ('c', 'd')
Вы просто вставляете вложенный массив элементов.
Пример приведен в здесь
var mysql = require('node-mysql');
var conn = mysql.createConnection({
...
});
var sql = "INSERT INTO Test (name, email, n) VALUES ?";
var values = [
['demian', '[email protected]', 1],
['john', '[email protected]', 2],
['mark', '[email protected]', 3],
['pete', '[email protected]', 4]
];
conn.query(sql, [values], function(err) {
if (err) throw err;
conn.end();
});
Примечание: values - массив массивов, завернутый в массив
[ [ [...], [...], [...] ] ]
Ответ 2
@Ragnar123 ответ правильный, но я вижу, что многие люди говорят в комментариях, что это не работает. У меня была та же проблема, и кажется, что вам нужно обернуть ваш массив в [] следующим образом:
var pars = [
[99, "1984-11-20", 1.1, 2.2, 200],
[98, "1984-11-20", 1.1, 2.2, 200],
[97, "1984-11-20", 1.1, 2.2, 200]
];
Его нужно передать как [pars] в метод.
Ответ 3
Я искал ответ на массовое вложение объектов.
Ответ Ragnar123 привел меня к выполнению этой функции:
function bulkInsert(connection, table, objectArray, callback) {
let keys = Object.keys(objectArray[0]);
let values = objectArray.map( obj => keys.map( key => obj[key]));
let sql = 'INSERT INTO ' + table + ' (' + keys.join(',') + ') VALUES ?';
connection.query(sql, [values], function (error, results, fields) {
if (error) callback(error);
callback(null, results);
});
}
bulkInsert(connection, 'my_table_of_objects', objectArray, (error, response) => {
if (error) res.send(error);
res.json(response);
});
Надеюсь, что это поможет!
Ответ 4
Все реквизиты для Ragnar123 для его ответа.
Я просто хотел расширить его после вопроса, заданного Джошем Харингтоном, чтобы поговорить о вставленных идентификаторах.
Они будут последовательными. См. Этот ответ: Вставляет ли многострочная вставка MySQL последовательные идентификаторы автоинкремента?
Следовательно, вы можете просто сделать это (обратите внимание, что я сделал с result.insertId):
var statement = 'INSERT INTO ?? (' + sKeys.join() + ') VALUES ?';
var insertStatement = [tableName, values];
var sql = db.connection.format(statement, insertStatement);
db.connection.query(sql, function(err, result) {
if (err) {
return clb(err);
}
var rowIds = [];
for (var i = result.insertId; i < result.insertId + result.affectedRows; i++) {
rowIds.push(i);
}
for (var i in persistentObjects) {
var persistentObject = persistentObjects[i];
persistentObject[persistentObject.idAttributeName()] = rowIds[i];
}
clb(null, persistentObjects);
});
(Я вытащил значения из массива объектов, которые я назвал persistentObjects.)
Надеюсь, что это поможет.
Ответ 5
Я столкнулся с этим сегодня (MySQL 2.16.0) и думал, что поделюсь своим решением:
const items = [
{name: 'alpha', description: 'describes alpha', value: 1},
...
];
db.query(
'INSERT INTO my_table (name, description, value) VALUES ?',
[items.map(item => [item.name, item.description, item.value])],
(error, results) => {...}
);
Ответ 6
В случае необходимости здесь мы решаем вставку массива
запрос от почтальона (вы увидите "гостей" )
{
"author_id" : 3,
"name" : "World War II",
"date" : "01 09 1939",
"time" : "16 : 22",
"location" : "39.9333635/32.8597419",
"guests" : [2, 3, 1337, 1942, 1453]
}
И как мы скриптировали
var express = require('express');
var utils = require('./custom_utils.js');
module.exports = function(database){
var router = express.Router();
router.post('/', function(req, res, next) {
database.query('INSERT INTO activity (author_id, name, date, time, location) VALUES (?, ?, ?, ?, ?) ON DUPLICATE KEY UPDATE name = VALUES(name), date = VALUES(date), time = VALUES(time), location = VALUES(location)',
[req.body.author_id, req.body.name, req.body.date, req.body.time, req.body.location], function(err, results, fields){
if(err){
console.log(err);
res.json({ status: utils.respondMSG.DB_ERROR });
}
else {
var act_id = results.insertId;
database.query('INSERT INTO act_guest (user_id, activity_id, status) VALUES ? ON DUPLICATE KEY UPDATE status = VALUES(status)',
[Array.from(req.body.guests).map(function(g){ return [g, act_id, 0]; })], function(err, results, fields){
if(err){
console.log(err);
res.json({ status: utils.respondMSG.DB_ERROR });
}
else {
res.json({
status: utils.respondMSG.SUCCEED,
data: {
activity_id : act_id
}
});
}
});
}
});
});
return router;
};
Ответ 7
Если ответ Ragnar не работает для вас. Вот, наверное, почему (по моему опыту) -
-
Я не использовал пакет
node-mysql, как показано на рисункеRagnar. Я использовал пакетmysql. Они разные (если вы не заметили - точно так же, как я). Но я не уверен, что это связано с тем, что?не работает, поскольку он, похоже, работает для многих людей, использующих пакетmysql. -
Попробуйте использовать переменную вместо
?
Следующие работали для меня -
var mysql = require('node-mysql');
var conn = mysql.createConnection({
...
});
var sql = "INSERT INTO Test (name, email, n) VALUES :params";
var values = [
['demian', '[email protected]', 1],
['john', '[email protected]', 2],
['mark', '[email protected]', 3],
['pete', '[email protected]', 4]
];
conn.query(sql, { params: values}, function(err) {
if (err) throw err;
conn.end();
});
Надеюсь, это поможет кому-то.
Ответ 8
Несколько вещей, которые я хочу упомянуть, это то, что я использую пакет mysql для соединения с моей базой данных, и то, что вы видели ниже, это рабочий код, написанный для массового запроса на вставку.
const values = [
[1, 'DEBUG', 'Something went wrong. I have to debug this.'],
[2, 'INFO', 'This just information to end user.'],
[3, 'WARNING', 'Warning are really helping users.'],
[4, 'SUCCESS', 'If everything works then your request is successful']
];
const query = "INSERT INTO logs(id, type, desc) VALUES ?";
const query = connection.query(query, [values], function(err, result) {
if (err) {
console.log('err', err)
}
console.log('result', result)
});
Ответ 9
У меня была похожая проблема. Он просто вставлял один из списка массивов. Это сработало после внесения следующих изменений.
- Передано [params] в метод запроса.
- Изменил запрос из insert (a, b) в значения table1 (?) ==> вставить (a, b) в значения table1? , то есть. Убрал парантез вокруг вопросительного знака.
Надеюсь это поможет. Я использую mysql npm.
Ответ 10
Это быстрое "сырое копирование-вставка", отсекаемое для отправки столбца файла в MySQL с помощью node.js> = 11
250 тысяч строк за несколько секунд
'use strict';
const mysql = require('promise-mysql');
const fs = require('fs');
const readline = require('readline');
async function run() {
const connection = await mysql.createConnection({
host: '1.2.3.4',
port: 3306,
user: 'my-user',
password: 'my-psw',
database: 'my-db',
});
const rl = readline.createInterface({ input: fs.createReadStream('myfile.txt') });
let total = 0;
let buff = [];
for await (const line of rl) {
buff.push([line]);
total++;
if (buff.length % 2000 === 0) {
await connection.query('INSERT INTO Phone (Number) VALUES ?', [buff]);
console.log(total);
buff = [];
}
}
if (buff.length > 0) {
await connection.query('INSERT INTO Phone (Number) VALUES ?', [buff]);
console.log(total);
}
console.log('end');
connection.close();
}
run().catch(console.log);