P = console.log;
// 3.直连mysql
var mysql  = require('mysql');  //调用MySQL模块
//创建一个connection
var connection = mysql.createConnection({
    host: 'hyc.cosmodworld.com',       //主机
    user: 'crawler',               //MySQL认证用户名
    password: '123',        //MySQL认证用户密码
    database: 'crawler',
    port: '3306'                   //端口号
});
//创建一个connection
connection.connect(function(err){
    if(err){
        console.log('[query] - :'+err);
        return;
    }
    console.log('[connection connect]  succeed!');
});

//----插入
var userAddSql = 'insert into test2 (title,company,url,updatetime,info) values(?,?,?,?,?)';
// var param = [obj.h1, obj.company, obj.url, obj.updateT, obj.info];
var param = ['aaaa','aaaa','aaaa','aaaa','aaaa',];
connection.query(userAddSql,param,function(err,rs){
    if(err){
        console.log('insert err:',err.message);
        return;
    }
        console.log('insert success');
});
//-----------------------------------------------------------

//执行查询
connection.query('SELECT * from user where uid=?',[2], function(err, rs) {
    if (err) {
        console.log('[query] - :'+err);
        return;
    }
    for(var i=0;i<rs.length;i++){
        console.log('The solution is: ', rs[i].uname);
    }
});

//关闭connection
connection.end(function(err){
    if(err){
        console.log(err.toString());
        return;
    }
    console.log('[connection end] succeed!');
});