var fs = require('fs');
var mysql = require('mysql');
/*var db_config = require('dbinfo.json');*/

var json = fs.readFileSync("tag.json", "utf-8");

var connection = mysql.createConnection({
    host : "192.168.0.38",
    user : "baraka",
    port : 3306,
    password : "baraka",
    database : "baseball"
});

var obj = JSON.parse(json);

var items = obj;

connection.connect();

var sql = "DELETE FROM tbl_news";
connection.query(sql, function (err, result) {
    if (err) throw err;
    console.log("Number of records deleted: " + result.affectedRows);
});


for (var i in items){

    var item = items[i];
    var teamname = item.teamname;
    var url = item.url;
    var title = item.title;

    console.log(teamname);
    console.log(url);
    console.log(title);

    var params = [teamname,url,title]

    connection.query('insert into tbl_news (teamname,url,title) values (?,?,?)',params, function(err, rows, fields) {
        if (err) {
            console.log("error");
        };

        console.log(teamname+url+title);
    });
    /*console.log('name:'+pname+',price:'+oprice);*/
    /*console.log(teamname+url+title);*/
};
connection.end();