使用 node.js 将 JSON 写入 mysql 数据库

Question

我正在尝试使用 node.js 将 JSON 对象（或字符串，不确定）写入我的 mysql 数据库。我首先使用 xml2js 通过 xml url 检索 JSON。我可以通过 JSON.stringify 在我的控制台中记录 json 字符串结果，但我不确定如何从这里开始。

这是我从中获取 xml 的网址：https://water.weather.gov/ahps2/hydrograph_to_xml.php?gage=deld1&output=xml

我想将 JSON 字符串中的每个实例写入一行，并将列作为数据的名称。它看起来像这样：

这是我在 index.js 中的代码，我在控制台上使用节点 index.js 执行：

var parseString = require('xml2js').parseString;
var http = require('http');
var https = require('https');
var mysql = require('mysql');

var con = mysql.createConnection({
  host: "localhost",
  user: "root",
  password: "password",
  database: "mydb"
});




function xmlToJson(url, callback) {
  var req = https.get(url, function(res) {
    var xml = '';

    res.on('data', function(chunk) {
      xml += chunk;
    });

    res.on('error', function(e) {
      callback(e, null);
    }); 

    res.on('timeout', function(e) {
      callback(e, null);
    }); 

    res.on('end', function() {
      parseString(xml, function(err, result) {
        callback(null, result);
      });
    });
  });
}

var url = "https://water.weather.gov/ahps2/hydrograph_to_xml.php?gage=deld1&output=xml"

xmlToJson(url, function(err, data) {
  if (err) {
    return console.err(err);
  }

  strungout = JSON.stringify(data, null, 1);
  console.log(strungout);
  //strungout contains my json string

})

  con.connect(function(err) {
  if (err) throw err;
  //below is where I might make an insert statement to insert my values into a mysql table
  var sql = someinsertstatement
  con.query(sql, function (err, result) {
    if (err) throw err;
    console.log("records inserted");
     res.end();
  });
});

如前所述，当我在控制台中运行上述代码时，控制台返回 JSON，但我不确定如何将其分配给一个变量，然后我可以将其写入我的 mysql 数据库。

或者，如果有一种更简单的方法可以将网站中的 xml 直接写入我的 mysql 数据库，我当然会很感激任何指针。我觉得它应该比这更容易，但我几乎是新手。

编辑： 添加 JSON。我删除了换行符以巩固它。试图将结果“4.68”分配给一个变量。

data = {"site": {"observed": [{"datum": [{"valid": [{"_": "2019-02-21T19:42:00-00:00","$": {"timezone": "UTC"}}],"primary": [{"_": "4.68","$": {"name": "Stage","units": "ft"}}]}]}]}};

谢谢。

Answer 1

这对我有用。发现你找的主要数据是site.observed.datum

const parser = require('xml2json');
const request = require("request");
var mysql = require('mysql');

var con = mysql.createConnection({
    host: "localhost",
    user: "root",
    password: "password",
    database: "mydb"
  });

var api_url = 'https://water.weather.gov/ahps2/hydrograph_to_xml.php?gage=deld1&output=xml';

function xmlToJson(url, callback){
    return request({
        method: 'GET',
        url: api_url,
    }, function (error, response, body) {
        if (error) {
           return callback({
               errorResponse: error,
               rowsToInsert: false
            });
        }else{
            let jsonRes = JSON.parse(parser.toJson(body));
            let datumResult = jsonRes.site.observed.datum;//I had to log Object.keys multple time to get the 
            const readyForDB = datumResult.map(x => {
                let timeOfReading = x.valid.$t;
                let stage = x.primary.$t;
                let flow = x.secondary.$t;
                return [
                    timeOfReading, stage, flow
                ]
            });
            return callback({
                errorResponse: false,
                rowsToInsert: readyForDB
            });
        }
    })
}
return xmlToJson(api_url, ({errorResponse, rowsToInsert}) => {
    if(errorResponse){
       throw callback.errorResponse;
    }
    return con.connect(function(err) {
        if (err) throw err;
        //below is where I might make an insert statement to insert my values into a mysql table
        var sql = "INSERT INTO forecast (timeOfReading, stage, flow) VALUES ?"
        con.query(sql, [rowsToInsert], function (err, result) {
        if (err) throw err;
            console.log(result.affectedRows + " rows inserted");
        });
    });
});

Answer 2

听起来您拥有所需的 JSON，但不确定如何访问其中的数据。如果我错了，请纠正我。

假设您有一个名为“test”的 JSON 对象：

    {
        a:1
        b:{
            x:2
        }
    }

你可以通过调用test.a访问1的值，同样通过调用test.b.x访问2的值