使用mysql和mongodb插入节点循环

r3i60tvu 于 2021-06-25 发布在 Mysql

关注(0)|答案(1)|浏览(365)

我有一个带有一个字段的表单，允许用户通过逗号分隔（ab1234，bc5678）输入多个开发人员id。
提交表单后，我将执行以下任务：
获取项目的
使用mysql遍历开发人员id数组以获取其全名
使用mongodb更新项目
我是新的，相信这是可能的，我下面的代码是不适合我。有人能告诉我下面的代码是否接近吗。

const mongoose = require('mongoose'
    const mysql = require('mysql');

    // Create mySQL connection
    const mySQLdb = mysql.createConnection({
      host     : 'localhost',
      user     : 'root',
      password : 'root',
      database : 'projects'
    });

    const Project = mongoose.model('project');

    router.post('/developerSave', async (req, res) => {
      let devList = req.body.dev_ids,
      devIdArr = devList.split(','),
      rData = {};

    // get project
    const project = await Project.findById(req.body.projectID);

    mySQLdb.connect();

    for(var i=0, len=devIdArr.length; i < len; i++) {      
      let sql = `SELECT CONCAT(first_name, ' ', last_name) as full_name FROM users WHERE id= '${devIdArr[i]}'`;

      mySQLdb.query(sql, function (err, results) {
        if (err) throw err;    

    let newDev = {
          userId: devIdArr[i],
          fullName: results[0].full_name
        }

        project.developers.unshift(newDev);
        await project.save();

      });

    }

    mySQLdb.end();

    rData.success = true;
    rData.msg = 'Developer was added successfully.';

    res.status(200).json(rData);
    });

mysql mongodb node.js Nodes mongoose

来源：https://stackoverflow.com/questions/50243651/node-loop-insert-with-mysql-and-mongodb

1条答案

按热度按时间

oxalkeyp1#

你看到这个的原因是 await project.save(); 在回调函数中。main函数不会等待所有回调完成并关闭db连接。让我们看看下面的例子

const myCallback = (param, callback) => {
  setTimeout(() => {
    console.log('callback function', param);
    callback();
  }, 1000)

}
const myAsync = async () => {
  console.log('inside async');
  const result = await axios.get('http://google.com/');
  for (let i = 0; i < 10; i++) {
    myCallback(i, () => {
      console.log('this is the actual callback function');
    });
  }
  const result2 = await axios.get('http://bing.com/');
  console.log('after second call');
}

myAsync();

它的输出是

inside async
after second call
callback function 0
this is the actual callback function
...

如你所见 after second call 在回调函数之前打印。
为了解决这个问题，您可以将回调函数 Package 成一个承诺，并在保存完成后解决这个问题。

赞(0）回复(0）举报 2021-06-25

我来回答

使用mysql和mongodb插入节点循环

1条答案

相关问题

热门标签

最新问答