mysql fix getDBObject

mideveloper · May 8, 2014 · 692737f · 692737f
1 parent b9b0ec8
commit 692737f
Showing 1 changed file with 5 additions and 5 deletions.
diff --git a/lib/models/mysql.js b/lib/models/mysql.js
@@ -146,15 +146,15 @@ function initialize(params) {
 
         Model.prototype.save = function save() {
             var self = this;
-            return _knex.raw(getInsertSQL(self, self.input));
+            return _knex.raw(getInsertSQL(self, self.getDBObject(self.input)));
         };
 
         Model.prototype.saveInBatch = function saveInBatch() {
             var self = this;
             var batch_statement = "";
 
             for (var index = 0; index < self.input.length; index++) {
-                batch_statement += getInsertSQL(self, self.input[index]);
+                batch_statement += getInsertSQL(self, self.getDBObject(self.input[index]));
             }
 
             return _knex.raw(batch_statement);
@@ -167,7 +167,7 @@ function initialize(params) {
             var self = this;
             if (arguments.length > 0) {
 
-                return _knex(self.tableName).where(self.input).select(_.toArray(arguments)).then(function(obj) {
+                return _knex(self.tableName).where(self.getDBObject(self.input)).select(_.toArray(arguments)).then(function(obj) {
                     if (obj.length > 0) {
                         return self.getObjectFromDBObject(obj.shift());
                     }else{
@@ -176,7 +176,7 @@ function initialize(params) {
                 });
             }
             else {
-                return _knex(self.tableName).where(self.input).select().then(function(obj) {
+                return _knex(self.tableName).where(self.getDBObject(self.input)).select().then(function(obj) {
                     if (obj.length > 0) {
                         return self.getObjectFromDBObject(obj.shift());
                     }else{
@@ -190,7 +190,7 @@ function initialize(params) {
         Model.prototype.getInBatch = function getInBatch() {
             var self = this;
             var result = [];
-            return _knex(self.tableName).whereIn(((self.idAttribute) ? self.idAttribute : "id"), self.input).then(function(output) {
+            return _knex(self.tableName).whereIn(((self.idAttribute) ? self.idAttribute : "id"), self.getDBObject(self.input)).then(function(output) {
 
                 while (output.length > 0) {
                     result.push(self.getObjectFromDBObject(output.shift()));