Fix LiveMysql.resume() and test case for removing queryCache buffer

Author: numtel

.gitignore

@@ -1,5 +1,6 @@
 *.*~
 *.swp
 *.swo
+*.swn
 .npm
 node_modules

lib/LiveMysql.js

@@ -44,7 +44,7 @@ function LiveMysql(settings, callback){
           queryCache.invalidate();
         }
       }
-    });
+    })
 
     // Wait for Zongji to be ready before executing callback
     var zongjiInitTime = Date.now();
@@ -149,9 +149,12 @@ LiveMysql.prototype.resume = function(){
   self.zongji.set(self.zongjiSettings);
 
   // Update all select statements
-  self._select.forEach(function(select) {
-    select.update();
-  });
+  for(var query in self._queryCache){
+    if (!self._queryCache.hasOwnProperty(query)){
+      continue;
+    }
+    self._queryCache[query].invalidate();
+  }
 };
 
 LiveMysql.prototype.end = function(){

lib/QueryCache.js

@@ -1,4 +1,4 @@
- /* mysql-live-select, MIT License [email protected]
+ /* mysql-live-select, MIT License [email protected], [email protected]
    lib/QueryCache.js - Query Results Cache Class */
 
 // Many LiveMysqlSelect objects can share the same query cache if they have the

test/index.js

@@ -266,7 +266,7 @@ module.exports = {
             this.stop();
             // When all instances of query removed, resultsBuffer removed too
             // TODO: Update for queryCache
-            // test.equal(typeof conn._resultsBuffer[query], 'undefined');
+            test.equal(typeof conn._queryCache[query], 'undefined');
 
             test.ok(!this.active());
             conn.db.query('DELETE FROM ' + escId(table));