快速,持续,稳定,傻瓜式
支持Mysql,Sqlserver数据同步

Node.js数据库连接池操作通用工具(MySQL模块)

请联系QQ:1793040 索取软件

出处:OSN开源站点数据库通用工具类,OSN源代码地址,https://github.com/obullxl/osnode-site,百度云演示站点,http://obullxl.duapp.com
使用平台:Node.js
依赖的项目:OSN开源站点

var config=require("https://www.cnblogs.com/zhwl/config");

var options={
'host': config.dbhost,
'port': config.port,
'user': config.user,
'password': config.password,
'database': config.db,
'charset': config.charset,
'connectionLimit': config.maxConnLimit,
'supportBigNumbers': true,
'bigNumberStrings': true
};

var mysql=require('mysql');
var pool=mysql.createPool(options);


exports.release=function(connection) {
connection.end(function(error) {
console.log('Connection closed');
});
};


exports.execQuery=function(options) {
pool.getConnection(function(error, connection) {
if(error) {
console.log('DB-获取数据库连接异常!');
throw error;
}



//查询参数
var sql=options['sql'];
var args=options['args'];
var handler=options['handler'];

//执行查询
if(!args) {
var query=connection.query(sql, function(error, results) {
if(error) {
console.log('DB-执行查询语句异常!');
throw error;
}

//处理结果
handler(results);
});

console.log(query.sql);
} else {
var query=connection.query(sql, args, function(error, results) {
if(error) {
console.log('DB-执行查询语句异常!');
throw error;
}

//处理结果
handler(results);
});

console.log(query.sql);
}

//返回连接池
connection.release(function(error) {
if(error) {
console.log('DB-关闭数据库连接异常!');
throw error;
}
});
});
};

相关推荐

咨询软件
 
QQ在线咨询
售前咨询热线
QQ1793040