Add a close method to sequelize to close the pool and unbind the process.exit handler. Closes #2020

lib/dialects/abstract/connection-manager.js

@@ -39,13 +39,22 @@ ConnectionManager = function(dialect, sequelize) {
   if (config.pool.maxConnections) config.pool.max = config.pool.maxConnections;
   if (config.pool.maxConnections) config.pool.max = config.pool.maxConnections;
   if (config.pool.minConnections) config.pool.min = config.pool.minConnections;
   if (config.pool.minConnections) config.pool.min = config.pool.minConnections;
 
 
-  this.onProcessExit = function() {
-    // Cleanup
-    self.pool.drain();
-    return;
-  }.bind(this);
+  process.on('exit', this.onProcessExit.bind(this));
+};
+
+ConnectionManager.prototype.onProcessExit = function() {
+  if (this.pool) {
+    this.pool.drain();
+  }
+};
+
+ConnectionManager.prototype.close = function () {
+  this.onProcessExit();
+  process.removeListener('exit', this.onProcessExit); // Remove the listener, so all references to this instance can be garbage collected.
 
 
-  process.on('exit', this.onProcessExit);
+  this.getConnection = function () {
+    return Promise.reject(new Error("ConnectionManager.getConnection was called after the connection manager was closed!"));
+  };
 };
 };
 
 
 // This cannot happen in the constructor because the user can specify a min. number of connections to have in the pool
 // This cannot happen in the constructor because the user can specify a min. number of connections to have in the pool

lib/sequelize.js

@@ -802,5 +802,15 @@ module.exports = (function() {
     }
     }
   };
   };
 
 
+  /**
+   * Close all connections used by this sequelize instance, and free all references so the instance can be garbage collected.
+   *
+   * Normally this is done on process exit, so you only need to call this method if you are creating multiple instances, and want
+   * to garbage collect some of them.
+   */
+  Sequelize.prototype.close = function () {
+    this.connectionManager.close();
+  };
+
   return Sequelize;
   return Sequelize;
 })();
 })();