节点js从函数返回值

cqoc49vn 于 2021-06-19 发布在 Mysql

关注(0)|答案(2)|浏览(391)

我生活在php世界，但我正在尝试使用node构建restapi。
我整天都在尝试从for循环返回一系列结果。基本上我是通过一系列的领域_name:field_value. 我想将更新的结果推送到一个数组中返回。我可以让它登录到控制台，但不能再继续了。
下面是一个post-json数据示例

{
    "first_name":"Jeff",
    "phone":"4855555555"
}

下面是函数和循环

function UpdateKey(user_id, key, value, cb) {
    connection.query('UPDATE users SET ' + key + ' = ? WHERE id = ? LIMIT 1', [value, user_id], function(err, results) {
    if (err) {
        callback = key + " update failed.";
    } else {
        callback = key + " was updated.";
    }
    cb(callback);

  });
}    

for (myKey in post_data) {
  UpdateKey(user_id, myKey, post_data[myKey], function(id) {
    console.log(id);
  });
}

res.send(JSON.stringify({ "status": 200, "error": "", "response": my_results_here }));

我一直在研究异步，但不确定这里的最佳路线。任何帮助都太好了！

mysql JavaScript node.js node-modules

来源：https://stackoverflow.com/questions/52582883/node-js-returning-values-from-function

2条答案

按热度按时间

3z6pesqy1#

您可以收集数组中的所有结果，并在数组大小等于键大小时发送：

const keys = Object.keys(post_data);
const response = [];

for(const myKey of keys) {
  UpdateKey(user_id, myKey, post_data[myKey], function(id) {
    response.push(id);
    if(keys.length === response.length) {
      res.send(JSON.stringify({ 
       status: 200, 
       error: "", 
       response
      }));
    }
  });
}

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

ttvkxqim2#

您想要的解决方案：

const updateUserField = (userId, field, value) => {
  return Promise((resolve) => {
    const query = 'UPDATE users SET ' + field + ' = ? WHERE id = ?';
    const data = [value, userId];
    connection.query(query, data, (error) => {
      if (error) return resolve(field + ' update failed');
      resolve(field + ' was updated');
    });
  });
};

router.post('/user/:id', async (req, res) => {
    const userId = req.params.id;
    const data = req.body;

    const response = [];
    for (const field in data) {
      response.push(
        await updateUserField(userId, field, data[field])
      );
    }

    res.status(200).send({
      response
    });
});

或并行：

router.post('/user/:id', async (req, res) => {
    const userId = req.params.id;
    const data = req.body;

    const response = await Promise.all(
      Object
        .keys(data)
        .map(field => updateUserField(userId, field, data[field]))
    );

    res.status(200).send({
      response
    });
});

正确的解决方案
据我所知，您希望获取post数据并更新users表中的记录。
为什么不在一个查询中完成呢？
请这样做：

const updateUser = (userId, data) => {
  return Promise((resolve, reject) => {
    const query = 'UPDATE users SET ? WHERE id = ?';
    connection.query(query, [data, userId], (error) => {
      if (error) return reject(error);
      resolve();
    });
  });
};

router.post('/user/:id', async (req, res) => {
  try {
    const userId = req.params.id;
    const data = req.body;
    await updateUser(userId, data);
    res.status(200).send({
      message: 'User account successfully updated'
    })
  }
  catch (error) {
    console.error(error);
    res.status(500).send({
      message: 'Failed update user account'
    });
  }
});

但最好考虑使用orm，即sequelize来实现安全性、验证等特性，以简化开发人员的工作。

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

我来回答

节点js从函数返回值

2条答案

相关问题

热门标签

最新问答