im/db/mysqldb.js

"use strict";

var config = require('../config');
var log = require('../util/log');

/**
 * 执行查询
 */
exports.execQuery = function(pool, options) {
	pool.getConnection(function(err, connection) {
		// 查询参数
		var sql = options['sql'];
		var args = options['args'];
		var handler = options['handler'];
		
		if(err) {
			log.error('db-getConnection err:' + err);
			handler(err, 'db-getConnection');
			return;
		}

		// 执行查询
		if (!args) {
			var query = connection.query(sql, function(err, results) {
				if(err) {
					log.error('db-query err:' + err);
					handler(err, results);
					return;
				}

				// 处理结果
				handler(err, results);
			});
		}else {
			var query = connection.query(sql, args, function(err, results) {
				if(err) {
					log.error('db-query err:' + err);
					handler(err, results);
					return;
				}

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

		// 返回连接池
		connection.release(function(err) {
			if(error) {
				log.error('db-release err:' + err);
			}
		});
	});
};