shadow-mysql

对mysql进行了一层封装，mysql连接只是用连接池。
添加了makeSQL,makeSQLSelect等简单方法。
对conn没有正常release会打印日志。
对于一个conn的事务是否开启多个做了错误判断。

##安装
npm install shadow-mysql

##使用说明 ###初始化

var mysql = require('shadow-mysql');
var options = {
    host: xx,
    user: xx,
    password: xx,
    database: xx,
    multipleStatements: 'true' //一次执行多条sql
}
var pool = new mysql.Pool(options);

###执行sql
提供两种query方式:

连接池上直接query

pool.query(sql,function(err,rows,fields){
   ...
})

连接池上获取连接，再query

//获取连接，connectionName为连接名，如若忘记归还连接，则会根据这个连接名提示
pool.getConnection(connectionName, function (err,conn) {
    conn.query(sql, function (err, data) {
        if(err) ...;
        //释放连接，若超过1min不归还，底层会提示
        conn.release();
    })
});

###事务处理

//connection需要通过pool.getConnection()获取
connection.beginTransaction(function(err) {
  if (err) { throw err; }
  connection.query('INSERT INTO posts SET title=?', title, function(err, result) {
    if (err) {
      return connection.rollback(function() {
        throw err;
      });
    }

    var log = 'Post ' + result.insertId + ' added';

    connection.query('INSERT INTO log SET data=?', log, function(err, result) {
      if (err) {
        return connection.rollback(function() {
          throw err;
        });
      }  
      connection.commit(function(err) {
        if (err) {
          return connection.rollback(function() {
            throw err;
          });
        }
        console.log('success!');
      });
    });
  });
});

###单表执行sql的简单方法(单表尽量用下面五种方法，解决了sql注入问题)

makeSQL

var mysql = require('shadow-mysql');
var sql = "select * from table where id = @id@";
sql = mysql.makeSQL(sql,{id:2});

makeSQLSelect

var sql = mysql.makeSQLSelect('hs_t',['id','name'],{id:3});
console.log(sql); //select id,name from hs_t where id = 3;

makeSQLInsert

var sql = mysql.makeSQLInsert('hs_t',{id:3,name:'xc'});
console.log(sql);//insert into hs_t(id,name) values (3,'xc');

makeSQLUpdate

var sql = mysql.makeSQLUpdate('hs_t',{name:'xc'},{id:3});
console.log(sql);//update hs_t set name = 'xc' where id = 3;

makeSQLDelete

var sql = mysql.makeSQLDelete('hs_t',{name:'xc'});
console.log(sql);//delete from hs_t where name = 'xc';

###防sql注入
如果自己写sql时，所有参数都需要用mysql.escape(param)过滤下，防止sql注入

kkmapgo/shadow-mysql

shadow-mysql