mongodb同步mysql

const MongoClient = require('mongodb').MongoClient;
const mysql = require('mysql');

// MongoDB 连接配置
const mongoUrl = 'mongodb://localhost:27017';
const dbName = 'myMongoDB';
const collectionName = 'myCollection';

// MySQL 连接配置
const mysqlConfig = {
  host: 'localhost',
  user: 'root',
  password: 'password',
  database: 'myMySQLDB'
};

// 连接 MongoDB
MongoClient.connect(mongoUrl, { useUnifiedTopology: true }, (err, client) => {
  if (err) throw err;
  const db = client.db(dbName);
  const collection = db.collection(collectionName);

  // 连接 MySQL
  const mysqlConnection = mysql.createConnection(mysqlConfig);
  mysqlConnection.connect((err) => {
    if (err) throw err;

    // 查询 MongoDB 数据并同步到 MySQL
    collection.find({}).toArray((err, docs) => {
      if (err) throw err;
      docs.forEach(doc => {
        // 根据需要转换数据格式
        const mysqlQuery = `INSERT INTO myTable SET ?`;
        mysqlConnection.query(mysqlQuery, doc, (err, result) => {
          if (err) throw err;
          console.log(`Inserted ${result.affectedRows} row(s) into MySQL`);
        });
      });

      // 关闭连接
      mysqlConnection.end();
      client.close();
    });
  });
});