node.js MongoDB 데 이 터 를 MySQL 로 동기 화 하 는 절차

머리말
최근 업무 상 필요 에 따라 앱 엔 드 백 엔 드 는 MongoDB 의 데 이 터 를 자바 엔 드 백 엔 드 의 MySQL 에 동기 화한 다음 MySQL 에서 계산 한 데 이 터 를 MongoDB 데이터베이스 에 동기 화해 야 한다.
이 과정 은 매우 번 거 로 워 보이 지만,사실은 이것 이 바로 서로 표를 쓰 는 과정 이다.
다음은 node.js 가 MongoDB 의 데 이 터 를 MySQL 데이터베이스 에 대량으로 삽입 하 는 실현 과정 을 살 펴 보 겠 습 니 다.더 이상 할 말 이 없 으 니 상세 한 소 개 를 해 봅 시다.
환경.
  • node.js
  • MongoDB
  • MySQL
  • npm
  • 필요 한 모듈
  • mongoose
  • MySQL
  • MongoDB 의 데 이 터 를 준비 하 세 요.
  • 예 를 들 어 제 가 동기 화 하려 는 것 은 사용자 표 입 니 다.사용자 표 에는 username,email,password 가 포함 되 어 있 습 니 다.
  • MongoDB 셸 명령 을 통 해 데이터 1000 개 삽입
  • 이루어지다
    Mongoose 의 Schema 는 여기 쓰 지 않 겠 습 니 다.여러분 은 인터넷 으로 볼 수 있 습 니 다.node.js 는 MongoDB 와 MySQL 의 pool 을 연결 하여 아래 를 보 세 요.
    node.js MongoDB 연결:https://www.jb51.net/article/98813.htm
    Nodejs mysql pool 사용 실례:
    mysql 모듈 은felixge/node-mysql
    원본 코드 는 다음 과 같 습 니 다.
    
    /**
    * 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;
    아래 위 키 코드  
    생각:
    MongoDB 에서 데 이 터 를 조회 한 다음 MySQL 에 옮 겨 다 니 며 삽입 합 니 다.
    
    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 ('" + username + "','" + email + "','" + password + "');";
     pool.query(sql,(err, rows) => {
      if (err)
      res.send(err); 
    
      res.json({
      message:'      ',
      rows
      });  
     });
     }
    });
    총결산
    이상 은 이 글 의 전체 내용 입 니 다.본 논문 의 내용 이 여러분 의 학습 이나 업무 에 어느 정도 참고 학습 가치 가 있 기 를 바 랍 니 다.궁금 한 점 이 있 으 시 면 댓 글 을 남 겨 주 셔 서 저희 에 대한 지지 에 감 사 드 립 니 다.

    좋은 웹페이지 즐겨찾기