Node.js injiziert massiv Daten in MySQL

Dieses Mal zeige ich Ihnen Node.js, wie Sie eine große Datenmenge in MySQL einfügen können, und welche Vorsichtsmaßnahmen es gibt, wenn Sie mit Node eine große Datenmenge in MySQL einfügen .js. Das Folgende sind praktische Fälle.

1. Datenbankverbindung

var mysql = require('mysql');
// 数据库信息
var connection = mysql.createConnection({
 host  : 'localhost',
 user  : '数据库用户名',
 password : '数据库登录密码',
 database : '操作数据库名'
});

Konvertieren Sie Daten einfügen in ein verschachteltes Array

Zum Beispiel zwei einzufügende Daten:

Datensatz 1:

from:"index" 
to:“www.alibaba.com”
status:1
is_new:0

Datensatz 2:

from:"index1"
to:"www.google.com"
status:1
is_new:0

Konvertieren Sie in das folgende Format:

var values = [
 ["index","www.alibaba.com",1,0],
 ["index1","www.google.com",1,0]
];

Schreiben Sie eine Einfügeerklärung

var sql = "INSERT INTO url(`from`,`to`,`status`, `is_new`) VALUES ?";

Rufen Sie die Abfragefunktion auf, um die Dateneinfügung abzuschließen

connection.query(sql, [values], function (err, rows, fields) {
 if(err){
    console.log('INSERT ERROR - ', err.message);
    return;
   }
   console.log("INSERT SUCCESS");
});

Vollständiger Code:

var mysql = require('mysql');
// 数据库信息
var connection = mysql.createConnection({
 host  : 'localhost',
 user  : '数据库用户名',
 password : '数据库登录密码',
 database : '操作数据库名'
});
var values = [
 ["index","www.alibaba.com",1,0],
 ["index1","www.google.com",1,0]
];
var sql = "INSERT INTO url(`from`,`to`,`status`, `is_new`) VALUES ?";
connection.query(sql, [values], function (err, rows, fields) {
 if(err){
    console.log('INSERT ERROR - ', err.message);
    return;
   }
   console.log("INSERT SUCCESS");
});

Gleichzeitig wird hier ein transaktionsbasierter Vorgang erfasst (dieser wurde noch nicht praktiziert und der spezifische Effekt ist unbekannt)

Einfügen mithilfe einer Transaktionsschleife und Rollback, wenn eine Einfügung fehlschlägt

MySQL-Modul „connection.beginTrans“Aktion besteht darin, Transaktionen durchzuführen

Dann habe ich hier eine Funktion gekapselt, um Vorgänge wie das Einfügen einer Schleife oder das Aktualisieren des eingehenden Arrays auszuführen. Wenn ein Element fehlschlägt, führen Sie einen Rollback durch.

Ich glaube, Sie haben den Fall hier bereits gelesen Nachdem Sie die Methode gemeistert haben, lesen Sie bitte andere verwandte Artikel auf der chinesischen PHP-Website, um weitere spannende Inhalte zu erhalten!

Empfohlene Lektüre:

Eine detaillierte Erklärung der Schritte zur Überprüfung des AngularJS-Registrierungsformulars

Eine detaillierte Erklärung der Schritte um die Kopierfunktion in clipboard.js zu implementieren

Das obige ist der detaillierte Inhalt vonNode.js injiziert massiv Daten in MySQL. Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!