Implementing #1

Author: Alex Corbi

lib/Pool.js

@@ -69,6 +69,50 @@ Pool.prototype.getConnection = function (cb) {
   this._enqueueCallback(cb);
 };
 
+Pool.prototype.getNewConnection = function (cb) {
+
+  if (this._closed) {
+    return process.nextTick(function(){
+      return cb(new Error('Pool is closed.'));
+    });
+  }
+
+  var connection;
+  var pool = this;
+
+  if (this.config.connectionLimit === 0 || this._allConnections.length < this.config.connectionLimit) {
+    connection = new PoolConnection(this, { config: this.config.newConnectionConfig() });
+
+    this._acquiringConnections.push(connection);
+    this._allConnections.push(connection);
+
+    return connection.connect({timeout: this.config.acquireTimeout}, function onConnect(err) {
+      spliceConnection(pool._acquiringConnections, connection);
+
+      if (pool._closed) {
+        err = new Error('Pool is closed.');
+      }
+
+      if (err) {
+        pool._purgeConnection(connection);
+        cb(err);
+        return;
+      }
+
+      pool.emit('connection', connection);
+      cb(null, connection);
+    });
+  }
+
+  if (!this.config.waitForConnections) {
+    return process.nextTick(function(){
+      return cb(new Error('No connections available.'));
+    });
+  }
+
+  this._enqueueCallback(cb);
+};
+
 Pool.prototype.acquireConnection = function acquireConnection(connection, cb) {
   if (connection._pool !== this) {
     throw new Error('Connection acquired from wrong pool.');