Node.js injecte massivement des données dans MySQL

Cette fois, je vais vous apporter Node.js pour injecter une grande quantité de données dans MySQL, et quelles sont les précautions pour injecter une grande quantité de données dans MySQL à l'aide de Node .js Voici des cas pratiques. Levez-vous et jetez un œil.

1. Connexion à la base de données

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

Convertir insérer des données en tableau imbriqué

Par exemple, deux données à insérer :

Enregistrement 1 :

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

Enregistrement 2 :

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

Convertir au format suivant :

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

Écrivez une déclaration d'insertion

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

Appelez la fonction de requête pour terminer l'insertion des données

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

Code complet :

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");
});

En même temps, une opération basée sur les transactions est enregistrée ici (elle n'a pas encore été pratiquée et l'effet spécifique est inconnu)

Insérer à l'aide de la boucle de transaction et annuler si une insertion échoue

module mysql, connection.beginTransaction consiste à effectuer des transactions

Ensuite, j'ai encapsulé ici une fonction pour effectuer des opérations telles que l'insertion de boucle ou la mise à jour sur le tableau entrant. Si un élément échoue, revenez en arrière. Si tout est correct, validez

Je pense que vous avez lu le cas dans cet article. .Après avoir maîtrisé la méthode, veuillez prêter attention aux autres articles connexes sur le site Web chinois de php pour un contenu plus passionnant !

Lecture recommandée :

Une explication détaillée des étapes de vérification du formulaire d'inscription AngularJS

Une explication détaillée des étapes pour implémenter la fonction de copie dans clipboard.js

Ce qui précède est le contenu détaillé de. pour plus d'informations, suivez d'autres articles connexes sur le site Web de PHP en chinois!