node.js同步MongoDB數據到MySQL

前言

• 因爲業務須要，APP端後臺須要將MongoDB中的數據同步到Java端後臺的MySQL中，而後又將MySQL中算好的數據，同步到MongoDB數據庫。
• 這個過程看是很繁瑣，實際上這就是一個互相寫表的過程。
• 接下來就看看node.js將MongoDB中的數據批量插入到MySQL數據庫的實現過程。

1. 環境

   • node.js
   • MongoDB
   • MySQL
   • npm

2. 須要的模塊

   • mongoose
   • MySQL

3. 準備好MongoDB中的數據

   • 好比說：我這裏要同步的是用戶表，用戶表中包含username,email,password...
   • 經過MongoDB shell命令插入1000條數據

4. 實現

   • mongoose的Schema、node.js鏈接MongoDB和MySQL的pool我這裏就不寫了，直接上關鍵代碼。
   • 思路：先從MongoDB查詢數據而後經過遍歷插入MySQL中。

   User.find({}, (err, user) => {
   
       if (err)
           res.send(err);
   
       for( let i = 0 ; i < user.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 ('" + username + "','" + email + "','" + password + "');";
   
           pool.query(sql,(err, rows) => {
   
               if (err)
               res.send(err); 
   
               res.json({
                   message:'數據插入成功',
                   rows
               }); 
                
           });
   
       }
   
   });