node.js操作mysql示例

最好的学习文档就是官方文档，地址如下：
mysql的github地址
普通连接示例代码：

var mysql=require('mysql');
var connection=mysql.createConnection({
    host:'127.0.0.1',
    user     : 'root',            //MySQL认证用户名
    password:'123456',
    port:   '3306',
    database: 'node_demo'
});
connection.connect();
connection.query('select * from t_students where name=?',['小明'],function(err,result,fields){
    if(!err){
        console.log(result[0].name);
        //fields是一个json数组，每个json是一个字段的信息
        fields.forEach(function(field){
            //如果要获取字段名就是field.name
            console.log(field);
        });
    }
});
//每次执行操作后要将连接关闭
connection.end(function(err){
    if(err){       
        console.log('[connection end] fail!');
                return;
            }
            console.log('[connection end] succeed!');
});

连接池示例(官方示例代码)

//和createConnetion()的配置差不多
var pool=mysql.createPool({
    host:'127.0.0.1',      
    user     : 'root',            
    password:'123456',
    port:   '3306',
    database: 'node_demo'
});

pool.getConnection(function(connection){
connection.beginTransaction(function(err) {
    if (err) { throw err; }
    connection.query('INSERT INTO posts SET title=?', title, function (error, results, fields) {
      if (error) {
        return connection.rollback(function() {
          throw error;
        });
      }
  
      var log = 'Post ' + results.insertId + ' added';
  
      connection.query('INSERT INTO log SET data=?', log, function (error, results, fields) {
        if (error) {
          return connection.rollback(function() {
            throw error;
          });
        }
        connection.commit(function(err) {
          if (err) {
            return connection.rollback(function() {
              throw err;
            });
          }
          console.log('success!');
        });
      });
    });
  });
});

个人学习笔记http://www.jianshu.com/p/c70ea4e3b9fd