nodejs之mysql的增删改查

------------------------------------查询
var mysql      = require('mysql');
var connection = mysql.createConnection({
  host     : 'localhost',
  user     : 'root',
  password : '123456',
  database : 'test'
});
var data='';
connection.connect();

connection.query('SELECT * from userinfo', function (error, results, fields) {

for(var i =0;i<=results.length;i++){
if (error) throw error;
console.log('The '+i +'result is: ', results[i]);
}
console.log(results);
});
------------------------------------增加
var mysql      = require('mysql');
var connection = mysql.createConnection({
  host     : 'localhost',
  user     : 'root',
  password : '123456',
  database : 'test'
});

connection.connect();

var  addSql = 'INSERT INTO userinfo(useId,useName,usePwd) VALUES(1006,?,?)';
var  addSqlParams = ['ceshi001','23453'];

connection.query(addSql,addSqlParams, function (err, result) {
if(err){
         console.log('[INSERT ERROR] - ',err.message);
         return;
        }  
  console.log('--------------------------INSERT----------------------------');   
       console.log('INSERT ID:',result);       
       console.log('-----------------------------------------------------------------\n\n'); 
});
------------------------------------删除

var mysql      = require('mysql');
var connection = mysql.createConnection({
  host     : 'localhost',
  user     : 'root',
  password : '123456',
  database : 'test'
});

connection.connect();

var  deleteSql = 'delete from  userinfo where useId =?';
var  deleteSqlParams = ['1006'];

connection.query(deleteSql,deleteSqlParams, function (err, result) {
if(err){
         console.log('[delete ERROR] - ',err.message);
         return;
        }  
  console.log('--------------------------delete----------------------------');   
       console.log('delete ID:',result);       
       console.log('-----------------------------------------------------------------\n\n'); 
});

------------------------------------修改

var mysql      = require('mysql');
var connection = mysql.createConnection({
  host     : 'localhost',
  user     : 'root',
  password : '123456',
  database : 'test'
});

connection.connect();

var  updateSql = 'update userinfo set useName= ?,usePwd =? where useId =?';
var  updateSqlParams = ['kaige','666666','1006'];

connection.query(updateSql,updateSqlParams, function (err, result) {
if(err){
         console.log('[update ERROR] - ',err.message);
         return;
        }  
  console.log('--------------------------update----------------------------');   
       console.log('update ID:',result);       
       console.log('-----------------------------------------------------------------\n\n'); 
});