add connectable tests

Author: particlebanana

test/connectable/create-manager.js

@@ -0,0 +1,37 @@
+var assert = require('assert');
+var Pack = require('../../');
+
+describe('Connectable ::', function() {
+  describe('Create Manager', function() {
+    it('should validate the connection string has a protocol', function(done) {
+      Pack.createManager({
+        connectionString: 'localhost:5432/mppg'
+      })
+      .exec(function(err) {
+        assert(err);
+        assert.equal(err.exit, 'malformed');
+
+        return done();
+      });
+    });
+
+    it('should successfully return a Pool', function(done) {
+      Pack.createManager({
+        connectionString: 'mysql://mp:mp@localhost:5432/mppg'
+      })
+      .exec(function(err, report) {
+        if (err) {
+          return done(err);
+        }
+
+        // Assert that the manager has a pool object
+        assert(report.manager.pool);
+
+        // Assert that the manager has a getConnection function
+        assert(report.manager.pool.getConnection);
+
+        return done();
+      });
+    });
+  });
+});

test/connectable/destroy-manager.js

@@ -0,0 +1,34 @@
+var assert = require('assert');
+var Pack = require('../../');
+
+describe('Connectable ::', function() {
+  describe('Destroy Manager', function() {
+    var manager;
+
+    // Create a manager
+    before(function(done) {
+      Pack.createManager({
+        connectionString: 'mysql://mp:mp@localhost:3306/mppg'
+      })
+      .exec(function(err, report) {
+        if (err) {
+          return done(err);
+        }
+
+        manager = report.manager;
+        return done();
+      });
+    });
+
+
+    it('should successfully destroy the manager', function(done) {
+      Pack.destroyManager({
+        manager: manager
+      })
+      .exec(function(err) {
+        assert(!err);
+        return done();
+      });
+    });
+  });
+});

test/connectable/get-connection.js

@@ -0,0 +1,45 @@
+var assert = require('assert');
+var Pack = require('../../');
+
+describe('Connectable ::', function() {
+  describe('Get Connection', function() {
+    var manager;
+
+    // Create a manager
+    before(function(done) {
+      // Needed to dynamically get the host using the docker container
+      var host = process.env.MYSQL_PORT_3306_TCP_ADDR || 'localhost';
+
+      Pack.createManager({
+        connectionString: 'mysql://mp:mp@' + host + ':3306/mppg'
+      })
+      .exec(function(err, report) {
+        if (err) {
+          return done(err);
+        }
+
+        manager = report.manager;
+        return done();
+      });
+    });
+
+    it('should successfully return a connection instance', function(done) {
+      Pack.getConnection({
+        manager: manager
+      })
+      .exec(function(err, report) {
+        if (err) {
+          return done(err);
+        }
+
+        // Assert that the report has a client object
+        assert(report.connection);
+
+        // Assert that the connection has a release function
+        assert(report.connection.release);
+
+        return done();
+      });
+    });
+  });
+});

test/connectable/release-connection.js

@@ -0,0 +1,67 @@
+var assert = require('assert');
+var Pack = require('../../');
+
+describe('Connectable ::', function() {
+  describe('Release Connection', function() {
+    var manager;
+    var connection;
+
+    // Create a manager and connection
+    before(function(done) {
+      // Needed to dynamically get the host using the docker container
+      var host = process.env.MYSQL_PORT_3306_TCP_ADDR || 'localhost';
+
+      Pack.createManager({
+        connectionString: 'mysql://mp:mp@' + host + ':3306/mppg'
+      })
+      .exec(function(err, report) {
+        if (err) {
+          return done(err);
+        }
+
+        manager = report.manager;
+
+        Pack.getConnection({
+          manager: manager
+        })
+        .exec(function(err, report) {
+          if (err) {
+            return done(err);
+          }
+
+          connection = report.connection;
+          return done();
+        });
+      });
+    });
+
+    it('should successfully release a connection', function(done) {
+      // Grab the number of free connections before releasing the current one
+      var freeConnectionsPreRelease = manager.pool._freeConnections.length;
+
+      // Release the connection
+      Pack.releaseConnection({
+        connection: connection
+      })
+      .exec(function(err) {
+        if (err) {
+          return done(err);
+        }
+
+        // If the connection was successfully released the _allConnections and the
+        // _freeConnections should be equal.
+        // https://github.com/mysqljs/mysql/blob/master/lib/Pool.js
+        var poolSize = manager.pool._allConnections.length;
+        var freeConnectionsPostRelease = manager.pool._freeConnections.length;
+
+        // Ensure we end up with different counts after releasing the connection
+        assert.notEqual(freeConnectionsPostRelease, freeConnectionsPreRelease);
+
+        // Ensure that all the available connections are free
+        assert.equal(poolSize, freeConnectionsPostRelease);
+
+        return done();
+      });
+    });
+  });
+});