如何使用nodejs和mysql插入多个对象？

cmssoen2 于 2021-06-20 发布在 Mysql

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

如何使用nodejs和mysql插入多个对象？
我有如下数据：

[
   {
      "id":"317",
      "stock":"200",
      "status":"y"
   },
   {
      "id":"1224",
      "stock":"400",
      "status":"y"
   }
]

这是我的密码：

function create(req, res) {
  pool.getConnection((err, connection) => {
    if (err) return res.send(err)
    let { id, stock, status } = req.body
    let values = [{
      id: id,
      stock: stock,
      status: status
    }]
    let sql = 'INSERT INTO tbl_stock SET ?'
    connection.query(sql, values, (err, results) => {
      if (err) {
        return res.send(err)
      } else {
        connection.release()
        return res.status(HttpStatus.OK).json({ message: 'ok', status: HttpStatus.OK })
      }
    })
  })
}

如果datajson有一个对象，那么这段代码就可以工作了，但是我想插入多个json格式的对象，比如上面的datajson，怎么做？

mysql node.js express

来源：https://stackoverflow.com/questions/50691096/how-to-insert-multiple-object-with-nodejs-and-mysql

2条答案

按热度按时间

5ssjco0h1#

我用Map和承诺解决了

function create(req, res) {
  pool.getConnection((err, connection) => {
    if (err) return res.send(err)
    let promises = []
    req.body.values.map((n) => {
      promises.push(new Promise(resolve => {
        let { id, stock, status } = n
        let values = {
          id: id,
          stock: stock,
          status: 'y',
        }
        let sql = 'INSERT INTO tbl_stock SET ?'
        connection.query(sql, values, (err, results) => {
          if (err) {
            return res.send(err)
          } else {
            return res.status(HttpStatus.OK).json({ message: 'ok', status: HttpStatus.OK })
          }
        })
      }))

      Promise.all(promises).then(result => {
        connection.release
      })
    })
  })
}

数据json如下：

{
   "values":[
      {
         "id":"317",
         "stock":"200",
         "status":"y"
      },
      {
         "id":"1224",
         "stock":"400",
         "status":"y"
      }
   ]
}

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

jv2fixgn2#

可以使用数组数组批量插入多行，因此 values 应该是这样的，

let values = [[317, 200, 'y'], [1224, 400, 'y']];

查询应该是这样的，

let sql = 'INSERT INTO tbl_stock(id, stock, status) VALUES ?';

然后使用连接运行查询，

connection.query(sql, values, (err, results) => {
      if (err) {
        return res.send(err)
      } else {
        connection.release()
        return res.status(HttpStatus.OK).json({ message: 'ok', status: HttpStatus.OK })
      }
    })

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

我来回答

如何使用nodejs和mysql插入多个对象？

2条答案

相关问题

热门标签

最新问答