add Pool#query

Author: tellnes

lib/Pool.js

@@ -107,6 +107,22 @@ Pool.prototype.end = function (cb) {
   }
 };
 
+Pool.prototype.query = function (sql, values, cb) {
+  if (typeof values === 'function') {
+    cb = values;
+    values = null;
+  }
+
+  this.getConnection(function (err, conn) {
+    if (err) return cb(err);
+
+    conn.query(sql, values, function () {
+      conn.end();
+      cb.apply(this, arguments);
+    });
+  });
+};
+
 Pool.prototype._createConnection = function() {
   var self = this;
   var connection = (this.config.createConnection)

test/integration/pool/test-query.js

@@ -0,0 +1,17 @@
+var common     = require('../../common');
+var assert     = require('assert');
+var pool       = common.createPool();
+
+pool.query('SELECT 1', function (err, _rows, _fields) {
+  if (err) throw err;
+
+  rows = _rows;
+  fields = _fields;
+
+  pool.end();
+});
+
+process.on('exit', function () {
+  assert.deepEqual(rows, [{1: 1}]);
+  assert.equal(fields[0].name, '1');
+});