nodeJs链接Mysql做增删改查的简单操作

varmysql = require('mysql');

//选择数据库和表

varTEST_DATABASE ='nodetry1'

varTEST_TABLE ='table2'

varconnection = mysql.createConnection({

  host:'localhost',

  user:'root',

  password:�'

});

//连接数据库

connection.connect();

//选择查询的数据库

connection.query("use "+ TEST_DATABASE);

// 增加

connection.query('insert into '+ TEST_TABLE +' (id,name,age) values (12, "二次添加会报错" , 77)');

// 删除

connection.query('delete from '+ TEST_TABLE +' where name = "sony"');

// 修改

connection.query('update '+ TEST_TABLE +' set name = "jiying.bao" where id = 5');

//查询

connection.query('SELECT * from '+ TEST_TABLE ,function(err, rows) {

  if(err)throwerr;

  console.log("SELECT ==> ");

  for(variinrows) {

    console.log(rows[i]);

  }

});

//关闭数据库连接

connection.end();