2016-01-22 191 views
3

我在使用NodeJS將JSON數據存儲在MySQL表中時遇到了問題。將JSON數據存儲在MySQL表中

JSON數據看起來像這樣:

{ 
    "header": 
    { 
     "file1":0, 
     "file2":1, 
     "subfiles":{ 
      "subfile1":"true", 
      "subfile2":"true", 
     } 
    }, 

    "response": 
    { 
     "number":678, 
     "start":0, 
     "docs":[ 
      { 
       "id":"d3f3d", 
       "code":"l876s", 
       "country_name":"United States", 
       "city":"LA" 
      }, 
      { 
       "id":"d2f2d", 
       "code":"2343g", 
       "country_name":"UK", 
       "city":"London" 
      } 
     ] 
    } 
} 

,我想存儲在文檔陣列(或反應物)僅字段。 我試圖獲取數據並存儲在MySQL中是這樣的:

var express = require('express'); 
var mysql = require('mysql'); 
var request = require("request"); 

var app = express(); 

app.use('/', express.static('../client/app')); 
app.use('/bower_components', express.static('../client/bower_components/')); 

var server = require('http').createServer(app); 

var bodyParser = require('body-parser'); 
app.jsonParser = bodyParser.json(); 
app.urlencodedParser = bodyParser.urlencoded({ extended: true }); 

//mysql connection setup 
var connection = mysql.createConnection({ 
    host : "localhost", 
    port: "3306", 
    user : "root", 
    password : "root", 
    database : "db", 
    multipleStatements: true 
}); 

request('http://url.com', function (error, response, body) { 
    if (!error && response.statusCode == 200) { 
    //console.log(body) // 
    } 

    var data = body.toString(); 

    console.log(string); 
    var query = connection.query('INSERT INTO table SET ?', data, function(err, result) { 
     // Finish 
    }); 
    console.log(query.sql); 
});   

server.listen(3000, function() { 
    'use strict'; 
}); 

在日誌中我得到了

INSERT INTO table SET '{\n \"header\":{\n \"file1\":0,\n \"file2\":1,\n \"subfiles\":{\n  \"subfile1\":\"true\",\n  \"subfile2\":\"true\"}},\n \"response\":{\"number\":678,\"start\":0,\"docs\":[\n  {\n  \"id\":\"d3f3d\",\n  \"code\":\"l876s\",\n.... 

輸出消息,但我並沒有在MySQL表中的數據。 我是否需要指定查詢中的每一列?

回答

3

在你的//Finish評論你應該添加一些console.log(err)看看爲什麼沒有插入數據。

這裏的解決方案:

var data = JSON.parse(body); 
var responseJson = JSON.stringify(data.response); 

var query = connection.query('INSERT INTO table SET column=?', responseJson, function(err, result) { 
    if(err) throw err; 
    console.log('data inserted'); 
}); 
+0

好吧,那麼我就需要將儲存在responseJson數據。我是否需要在sql查詢中定義所有列(我仍然沒有db中的數據)?例如'connection.query(「INSERT INTO表VALUES('',?,?,?...)」,[id,country_name,city ....],函數(err,rows,fields)' – corry

+1

@ corry:我想你可以使用下面的其中一個:'query('INSERT INTO tbl_name(col)VALUES(?)','value')'或'query('INSERT INTO tbl_name SET col =?','value') '或 '查詢('INSERT INTO tbl_name SET?',{col:'value'})' –

+0

我試圖插入數據到數據庫[如這裏解釋](http://stackoverflow.com/questions/8899802/how-do-i-do-a-bulk-insert-in-mysql-using-node-js?lq = 1),我得到一個錯誤:錯誤:ER_PARSE_ERROR:你的SQL語法錯誤;檢查手冊,它對應於您的MySQL服務器版本,以便在''[[\'id \':\「d3f3d \」,\「code \」:\''第1行'附近使用正確的語法。Query is defined:'' var sql =「INSERT INTO table(id,code,country_name,city)VALUES?」;'你知道哪裏可能是問題的原因嗎?謝謝 – corry