使用node-mysql中的连接池
发布于 3 年前 作者 xuanye 11817 次浏览

根据原来generic-pool的例子修改过来的,这样可以少一个依赖了,哈哈 mysql-pool.js

var mysql       = require('mysql');
var mysqlConfig = require('../config/mysql');

var env = process.env.NODE_ENV || 'development';
if(mysqlConfig[env]) {
  mysqlConfig = mysqlConfig[env];
}
exports.createMysqlPool= module.exports.createMysqlPool = function(){
  return mysql.createPool({
        host: mysqlConfig.host,
        user: mysqlConfig.user,
        password: mysqlConfig.password,
        database: mysqlConfig.database
  });
}

创建一个简单的客户端链接帮助类 mysqlclient

  // mysql CRUD
var sqlclient = module.exports;

var _pool = null;

var NND = {};

/*
 * Innit sql connection pool
 * [@param](/user/param) {Object} app The app for the server.
 */
NND.init = function(){
  if(!_pool)
    _pool = require('./mysql-pool').createMysqlPool();
};

/**
 * Excute sql statement
 * [@param](/user/param) {String} sql Statement The sql need to excute.
 * [@param](/user/param) {Object} args The args for the sql.
 * [@param](/user/param) {fuction} callback Callback function.
 * 
 */
NND.query = function(sql, args, callback){
  _pool.getConnection(function(err, client) {
    if (!!err) {
      console.error('[sqlqueryErr] '+err.stack);
      return;
    }
    client.query(sql, args, function(err, res) {
      _pool.releaseConnection(client);
      callback.apply(null, [err, res]);
    });
  });
};

/**
 * Close connection pool.
 */
NND.shutdown = function(){
  _pool.end();
};

/**
 * init database
 */
sqlclient.init = function() {
  if (!!_pool){
    return sqlclient;
  } else {
    NND.init();
    sqlclient.insert = NND.query;
    sqlclient.update = NND.query;
    //sqlclient.delete = NND.query;
    sqlclient.query = NND.query;
    return sqlclient;
  }
};

/**
 * shutdown database
 */
sqlclient.shutdown = function() {
  NND.shutdown();
};

实际调用类

var utils = require('../lib/utils');
var mysqlClient = require('./mysqlcliet').init();

var orgdao = module.exports;

orgdao.queryOrgByPId = function (pid, cb){
    var sql = 'YOUR SQL';
    var args = [pid];
    mysqlClient.query(sql,args,function(err, res){
        if(err !== null){
            utils.invokeCallback(cb, err.message, null);
        } 
        else {
            if (!!res) {
                utils.invokeCallback(cb, null, res);
            }
            else{
                utils.invokeCallback(cb, null, null);
            }
        }
    });
};
9 回复

invokeCallback 这个函数是做啥的。

  • -很像 pomelo代码风格。

就是调用下毁掉,如果有一些特殊的逻辑,比如说日志神马的,可以在这里记录

'…/lib/utils’我没有调到阿,是哪个模块的;还有数据库端口也没有。

请问,你使用的Mysql 这个库的版本是多少? 我用的官方推荐的:npm install mysql@2.0.0-alpha9,这个版本。 但是在使用时,发现如果这样用是有Bug的:

var columns = [“id”, “name”]; conn.query(“select ?? form table where id = ?;”, [columns, 1]);

发现columns并不会被解析成字段,会报错,即不能被解析成: "select id, name form table where id = 1;" 随后,看了Mysql库的源码,确实有个问题,自己改了源码。但是官方文档中是可以这样使用的。

utils.invokeCallback貌似是丁磊搞的,不知道复制过来会不会有问题。

这个不影响 只是额外的一个类库啊。 封装一些功能的方法,这里只用了invokeCallback 就是调用下回调函数,可以做一些日志记录什么的工作。。

我在pool里面重新定义了queryFormat 啊,如果不想按照我的格式来,可以把那个配置删除掉

哪个丁磊?

回到顶部