如何分解 JSON 对象以插入 MySQL 表？

Question

总结

我收到了一些 JSON 数据：

// Now Get Only New Listings
 finalArray = _.difference(existingResults, items);

我需要将这些值插入其中：

有些进来的数据不能填满所有的列。在这种情况下，我想将它们留空。

这是数据的样子（可能是众多数据之一）...

{
    price: '$6,000',
    title: '1999 Jeep Wrangler SE Sport Utility 2D',
    location: 'Auburndale, Florida',
    miles: '12K miles',
    imgUrl: 'http://www.example.com/pic.jpg',
    itemURL: '/products/item/36427/'
  }

所以我需要弄清楚如何遍历每个 JSON 对象，并插入到正确的列中。

var insertQuery = 'Your code here! :)  ';

我想查询需要在某个地方循环吗？还是一个大的插入语句？

任何建议或代码将不胜感激。谢谢。

---

注意

使用：NodeJS 和 JawsDB MySQL（如果信息很重要）

Answer 1

以下方法仅在您的有效负载没有任何嵌套对象时才有效。使用 ES6 地图来完成这项工作。我使用connection.escape() 删除了 JSON 中的任何可注入脚本，以防止 SQL 注入攻击。我希望你已经为 node.js 安装了mysql 连接器。

const mysql      = require('mysql');
const connection = mysql.createConnection({
  host     : 'localhost',
  user     : 'me',
  password : 'secret',
  database : 'my_db'
});

connection.connect();

const payload = {
    price: '$6,000',
    title: '1999 Jeep Wrangler SE Sport Utility 2D',
    location: 'Auburndale, Florida',
    miles: '12K miles',
    imgUrl: 'http://www.example.com/pic.jpg',
    itemURL: '/products/item/36427/'
}

const map = new Map(Object.entries(payload));
const keys = map.keys();
const values =  map.values();

const insertQuery = `
INSERT INTO TABLE_NAME (${connection.escape(keys.next().value)},
                        ${connection.escape(keys.next().value)},
                        ${connection.escape(keys.next().value)},
                        ${connection.escape(keys.next().value)},
                        ${connection.escape(keys.next().value)},
                        ${connection.escape(keys.next().value)})
            VALUES     (${connection.escape(values.next().value)},
                        ${connection.escape(values.next().value)},
                        ${connection.escape(values.next().value)},
                        ${connection.escape(values.next().value)},
                        ${connection.escape(values.next().value)},
                        ${connection.escape(values.next().value)});
`
connection.query(insertQuery, function (error, results, fields) {
  if (error) throw error;
  // ...
});
console.log(insertQuery);