Update rethinkdb adapters

biggora · Dec 31, 2015 · 7fb38de · 7fb38de
1 parent 55e9c33
commit 7fb38de
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/lib/adapters/rethinkdb.js b/lib/adapters/rethinkdb.js
@@ -327,7 +327,7 @@ RethinkDB.prototype.save = function (model, data, callback) {
             if (data[key] === undefined)
                 data[key] = null;
         });
-        r.db(self.database).table(model).insert(data, {upsert: true}).run(client, function (err, notice) {
+        r.db(self.database).table(model).insert(data, {conflict: 'replace'}).run(client, function (err, notice) {
             self.pool.release(client);
             err = err || notice.first_error && new Error(notice.first_error);
             callback(err, notice);
@@ -383,7 +383,7 @@ RethinkDB.prototype.updateOrCreate = function updateOrCreate(model, data, callba
                 data[key] = null;
             }
         });
-        r.db(self.database).table(model).insert(data, {upsert: true}).run(client, function (err, m) {
+        r.db(self.database).table(model).insert(data, {conflict: 'replace'}).run(client, function (err, m) {
             self.pool.release(client);
             err = err || m.first_error && new Error(m.first_error);
             callback(err, err ? null : m['generated_keys'][0]);
@@ -686,4 +686,4 @@ function _processWhere(self, model, where, promise) {
     });
 
     return promise;
-}
+}