fix count transaction

README.md

@@ -5,7 +5,6 @@ Offshore-sql is an adapter for sql databases, created for [Offshore](https://git
 [![npm version](https://badge.fury.io/js/offshore-sql.svg)](https://www.npmjs.com/offshore-sql)
 [![Build Status](https://travis-ci.org/Atlantis-Software/offshore-sql.svg?branch=master)](https://travis-ci.org/Atlantis-Software/offshore-sql)
 [![Coverage Status](https://coveralls.io/repos/github/Atlantis-Software/offshore-sql/badge.svg?branch=master)](https://coveralls.io/github/Atlantis-Software/offshore-sql?branch=master)
-[![NSP Status](https://nodesecurity.io/orgs/atlantis/projects/fa52b94f-44de-4f15-a196-4a44a79bce1d/badge)](https://nodesecurity.io/orgs/atlantis/projects/fa52b94f-44de-4f15-a196-4a44a79bce1d)
 [![Dependencies Status](https://david-dm.org/Atlantis-Software/offshore-sql.svg)](https://david-dm.org/Atlantis-Software/offshore-sql)
 
 

index.js

@@ -212,7 +212,7 @@ module.exports = (function() {
       if (transaction) {
         query.transacting(transaction);
       }
-      query.asCallback(function(err, record) {
+      query.then(function(cnt){ return cnt[0]['cnt']; }).asCallback(function(err, record) {
           if (err) {
             return cb(err);
           }

lib/dialect.js

@@ -139,7 +139,7 @@ GenericDialect.prototype.count = function(connection, collection, opts) {
   var options = this.Utils.normalizeCriteria(opts);
   var query = new this.CriteriaProcessor(connection, tableName, options, connection.client(tableName)).getQuery();
   query.count('* as cnt');
-  return query.then(function(cnt){ return cnt[0]['cnt']; });
+  return query;
 };
 
 GenericDialect.prototype.select = function(connection, collection, opts) {

package.json

@@ -1,6 +1,6 @@
 {
   "name": "offshore-sql",
-  "version": "1.0.7",
+  "version": "1.0.8",
   "description": "Sql Databases adapter for offshore",
   "main": "index.js",
   "scripts": {