So synchronisieren Sie MongoDB-Daten mit MySQL in node.js

Dieser Artikel führt Sie hauptsächlich in die relevanten Informationen zur Synchronisierung von MongoDB-Daten mit MySQL ein. Er bietet einen gewissen Referenz-Lernwert für alle, die ihn benötigen Lernen Sie unten gemeinsam.

Vorwort

Aus geschäftlichen Gründen muss das APP-Backend in letzter Zeit die Daten in MongoDB mit MySQL im Java-Backend synchronisieren Synchronisieren Sie dann die berechneten Daten in MySQL mit der MongoDB-Datenbank.

Dieser Prozess scheint sehr umständlich zu sein, aber in Wirklichkeit handelt es sich um einen Prozess, bei dem gegenseitig Listen geschrieben werden.

Als Nächstes werfen wir einen Blick auf den Implementierungsprozess von node.js, bei dem Daten aus MongoDB stapelweise in die MySQL-Datenbank eingefügt werden. Es gibt nicht viel zu sagen, werfen wir einen Blick auf die ausführliche Einführung.

Umgebung

• node.js

• MongoDB

• MySQL

• npm

Erforderliche Module

• Mungo

• MySQL

Daten in MongoDB vorbereiten

• Zum Beispiel: Was ich hier synchronisieren möchte, ist die Benutzertabelle, die Benutzername, E-Mail, Passwort enthält...

• Fügen Sie 1000 Daten über den MongoDB-Shell-Befehl ein

Ich kenne das Schema von Mungo hier nicht, Sie können es online überprüfen Die Verbindung von node.js zum MongoDB- und MySQL-Pool ist wie folgt:

//www.jb51.net/article/98813 .htm

Nodejs MySQL-Pool-Nutzungsbeispiel:

MySQL-Modul ist felixge/node-mysqlDer Quellcode lautet wie folgt:

/**
* Created by kevalin on 2015/4/22.
*/
var express = require('express');
var router = express.Router();
var mysql = require('mysql');
var conf = require('../config/dbconnection');
//定义pool池
var pool = mysql.createPool(
{
host : conf.dbMysql.host,
user : conf.dbMysql.user,
password : conf.dbMysql.password,
database : conf.dbMysql.database,
port : conf.dbMysql.port
}
);
router.get('/', function(req, res) {
var selectSites = "select *, date_format(do_time, '%Y-%m-%d %H:%i:%s') as time from siteinfo order by id";
pool.getConnection(function(err, connection) {
if (err) throw err;
connection.query(selectSites, function(err, rows) {
if (err) throw err;
res.render('sites', {title : '站点分布', results : rows});
//回收pool
connection.release();
});
});
});
module.exports = router;

Der Schlüssel Code unten

Fragen Sie zuerst die Daten von MongoDB ab und fügen Sie sie dann durch Traversal in MySQL ein.

User.find({}, (err, user) => {
 if (err)
 res.send(err);
 for( let i = 0 ; i < family.length ; i ++ ) { 
 console.log("第" + (i + 1) + "条数据");
 let username = user[i].username; 
 let email = user[i].email;
 let password = user[i].password; 
 let sql = "insert into user_table(username, email, password) values (&#39;" + username + "&#39;,&#39;" + email + "&#39;,&#39;" + password + "&#39;);";
 pool.query(sql,(err, rows) => {
  if (err)
  res.send(err); 

  res.json({
  message:&#39;数据插入成功&#39;,
  rows
  });  
 });
 }
});