Add option for using different promise implementation

README.md

@@ -60,3 +60,9 @@ Using [mysql2](https://github.com/sidorares/node-mysql2)
 
 	db.configure(opts, require('mysql2'));
 
+
+Use different promise implementation
+
+	var db = require('mysql-promise')();
+
+	db.configure(dbOpts, null, PromiseImpl);

index.js

@@ -1,6 +1,6 @@
 'use strict';
 
-var Promise = require('bluebird');
+var BlueBird = require('bluebird');
 var instances = {};
 var defaultMysqlDriver;
 
@@ -9,21 +9,26 @@ var defaultMysqlDriver;
  */
 function DB() {
 	this.pool = null;
+	this.PromiseImpl = BlueBird;
 }
 
 /**
  * Setup the Database connection pool for this instance
  * @param  {Object} config
  * @param {Object} [mysql] mysql driver
+ * @param {Object} [PromiseImpl] PromiseImpl promise implementation to use
  */
-DB.prototype.configure = function (config, mysql) {
+DB.prototype.configure = function (config, mysql, PromiseImpl) {
 	if (!mysql) {
 		if (!defaultMysqlDriver) {
 			defaultMysqlDriver = require('mysql');
 		}
 		mysql = defaultMysqlDriver;
 	}
 
+	if (PromiseImpl) {
+		this.PromiseImpl = PromiseImpl;
+	}
 	this.pool = mysql.createPool(config);
 };
 
@@ -42,7 +47,7 @@ DB.prototype.isConfigured = function () {
 DB.prototype.getConnection = function () {
 	var self = this;
 
-	return new Promise(function (resolve, reject) {
+	return new self.PromiseImpl(function (resolve, reject) {
 		self.pool.getConnection(function (err, con) {
 			if (err) {
 				if (con) {
@@ -63,12 +68,13 @@ DB.prototype.getConnection = function () {
  * @return {Promise}
  */
 DB.prototype.query = function (query, params) {
+	var self = this;
 	params = params || {};
 
 	return this
 		.getConnection()
 		.then(function (con) {
-			return new Promise(function (resolve, reject) {
+			return new self.PromiseImpl(function (resolve, reject) {
 				con.query(query, params, function (err) {
 					if (err) {
 						if (con) {
@@ -91,7 +97,7 @@ DB.prototype.query = function (query, params) {
 DB.prototype.end = function () {
 	var self = this;
 
-	return new Promise(function (resolve, reject) {
+	return new self.PromiseImpl(function (resolve, reject) {
 		self.pool.end(function (err) {
 			if (err) {
 				return reject(err);

test/index.test.js

@@ -40,6 +40,30 @@ describe('mysql-promise', function () {
 
 	});
 
+	describe('Configureable Promise Implementation', function () {
+
+		it('should use bundled bluebird promise by default', function () {
+			var db = mysql('promise-by-default');
+			db.configure(dbConfig);
+
+			db.PromiseImpl.should.equal(require('bluebird'));
+			var promise = db.getConnection();
+			promise.spread.should.be.a.Function;
+		});
+
+		it('should use configured promise implementation', function () {
+			var db = mysql('native-promise');
+			db.configure(dbConfig, null, Promise); // eslint-disable-line
+
+			db.PromiseImpl.should.equal(Promise); // eslint-disable-line
+
+			var promise = db.getConnection();
+			should.not.exist(promise.spread);
+			promise.then.should.be.a.Function;
+		});
+
+	});
+
 	describe('getConnection()', function () {
 
 		it('should return a connection', function (done) {