Merge 2b14dd9 into beb9308

README.md

@@ -537,6 +537,7 @@ var db = require('priam')({
 
 Release Notes
 -------------
+ - `0.8.15`: Add isBatch method to base driver to check if an object is a Priam batch.
  - `0.8.14`: Fix `resultTransformer` bug when query generates an error.
  - `0.8.13`: Fix `Batch.add()` when given empty `Batch` or `Query` objects.
  - `0.8.12`: Remove github dependency via `priam-connection-cql` module. Added versioning logic around `cqlVersion` to use the appropriate driver.

lib/drivers/base-driver.js

@@ -486,6 +486,10 @@ BaseDriver.prototype.connectionResolverFetchHandler = function connectionResolve
   }
 };
 
+BaseDriver.prototype.isBatch = function isBatch(obj){
+  return obj instanceof Batch;
+};
+
 function setDefaultConsistency(defaultConsistencyLevel, options, callback) {
   var p = checkOptionalParameters(options, callback);
   if (!p.options.consistency) {

package.json

@@ -1,6 +1,6 @@
 {
   "name": "priam",
-  "version": "0.8.14",
+  "version": "0.8.15",
   "description": "A simple Cassandra driver. It wraps the helenus and node-cassandra-cql drivers with additional error/retry handling, external .cql file support, and connection option resolution from an external source, among other improvements.",
   "keywords": [
     "cassandra",

test/unit/drivers/base-driver.tests.js

@@ -377,4 +377,36 @@ describe('lib/drivers/base-driver.js', function () {
       expect(type).to.equal(driver.dataType.text);
     });
   });
+
+  describe('isBatch', function(){
+    var driver;
+
+    beforeEach(function () {
+      driver = new getDefaultInstance();
+    });
+
+    it('returns true if passed a batch', function(){
+      var batch = driver.beginBatch();
+      expect(driver.isBatch(batch)).to.be.true;
+    });
+
+    it('returns false if passed a non-batch', function(){
+      var notBatch = {
+        add: function(){},
+        foo: 'bar'
+      };
+      expect(driver.isBatch(notBatch)).to.be.false;
+    });
+
+    it('handles weird values', function(){
+      expect(driver.isBatch()).to.be.false;
+      expect(driver.isBatch(null)).to.be.false;
+      expect(driver.isBatch(undefined)).to.be.false;
+      expect(driver.isBatch({})).to.be.false;
+      expect(driver.isBatch(true)).to.be.false;
+      expect(driver.isBatch(false)).to.be.false;
+      expect(driver.isBatch([])).to.be.false;
+    });
+
+  });
 });