var mysql  = require('mysql');  
var express = require('express');
var app = express();
var bodyParser = require('body-parser');

var addMysql = function (addSqlParams) {
  var connection = mysql.createConnection({     
    host     : 'localhost',       
    user     : 'root',              
    password : 'root',       
    port: '3306',                   
    database: 'test' 
  }); 
   
  connection.connect();
  
  console.log(addSqlParams);
  var  addSql = 'INSERT INTO websites(Id,name,url,alexa,country) VALUES(0,?,?,?,?)';
  connection.query(addSql,addSqlParams,function (err, result) {
    if(err){
     console.log('[INSERT ERROR] - ',err.message);
     return;
    }        

   console.log('--------------------------INSERT----------------------------');
   //console.log('INSERT ID:',result.insertId);        
   console.log('INSERT ID:',result);        
   console.log('-----------------------------------------------------------------\n\n');  
});
   
  connection.end();
}
// 创建 application/x-www-form-urlencoded 编码解析
var urlencodedParser = bodyParser.urlencoded({ extended: false })
 
app.post('/process_post', urlencodedParser, function (req, res) {
   // 输出 JSON 格式
   var addParam = [];
  //  addMysql(addParam);
  for (const key in req.body) {
      addParam.push(req.body[key]);
  }
  addMysql(addParam);
  res.end(JSON.stringify({success:true}));
})
 
var server = app.listen(8081, function () {
  console.log(server.address());
  var host = server.address().address
  var port = server.address().port
 
  console.log("应用实例，访问地址为 http://%s:%s", host, port)
 
})