feat(test/misc): utils for verifying sequelize has no running/pending queries

lib/sequelize.js

@@ -198,6 +198,17 @@ module.exports = (function() {
 
 
     this.importCache = {};
     this.importCache = {};
 
 
+    this.test = {
+      $trackRunningQueries: false,
+      $runningQueries: 0,
+      trackRunningQueries: function() {
+        this.$trackRunningQueries = true;
+      },
+      verifyNoRunningQueries: function() {
+        if (this.$runningQueries > 0) throw new Error('Expected 0 running queries. '+this.$runningQueries+' queries still running');
+      }
+    };
+
     Sequelize.runHooks('afterInit', this);
     Sequelize.runHooks('afterInit', this);
   };
   };
 
 
@@ -731,6 +742,10 @@ module.exports = (function() {
       return Promise.reject(options.transaction.finished+' has been called on this transaction, you can no longer use it');
       return Promise.reject(options.transaction.finished+' has been called on this transaction, you can no longer use it');
     }
     }
 
 
+    if (this.test.$trackRunningQueries) {
+      this.test.$runningQueries++;
+    }
+
     return Promise.resolve(
     return Promise.resolve(
       options.transaction ? options.transaction.connection : self.connectionManager.getConnection(options)
       options.transaction ? options.transaction.connection : self.connectionManager.getConnection(options)
     ).then(function (connection) {
     ).then(function (connection) {
@@ -739,6 +754,10 @@ module.exports = (function() {
         if (options.transaction) return;
         if (options.transaction) return;
         return self.connectionManager.releaseConnection(connection);
         return self.connectionManager.releaseConnection(connection);
       });
       });
+    }).finally(function () {
+      if (self.test.$trackRunningQueries) {
+        self.test.$runningQueries--;
+      }
     });
     });
   };
   };
 
 

test/integration/support.js

@@ -20,7 +20,12 @@ before(function() {
 });
 });
 
 
 beforeEach(function() {
 beforeEach(function() {
+  this.sequelize.test.trackRunningQueries();
   return Support.clearDatabase(this.sequelize);
   return Support.clearDatabase(this.sequelize);
 });
 });
 
 
+afterEach(function () {
+  this.sequelize.test.verifyNoRunningQueries();
+});
+
 module.exports = Support;
 module.exports = Support;