1.4.1

bin/couchimport.bin.js

@@ -5,7 +5,7 @@ const couchimport = require('../app.js')
 const argv = require('../includes/args.js').parse()
 
 // output selected options
-const options = ['url', 'database', 'delimiter', 'transform', 'meta', 'buffer', 'parallelism', 'type', 'jsonpath', 'preview', 'ignorefields']
+const options = ['url', 'database', 'delimiter', 'transform', 'meta', 'buffer', 'parallelism', 'type', 'jsonpath', 'preview', 'ignorefields', 'overwrite']
 console.log('couchimport')
 console.log('-----------')
 for (const i in options) {

includes/writer.js

@@ -48,12 +48,11 @@ module.exports = function (couchURL, couchDatabase, bufferSize, parallelism, ign
             keys.push(payload.docs[i]._id)
           }
         }
-        const existingData = await db.fetchRevs({ keys: keys })
-
+        const existingData = await db.fetch({ keys: keys })
         // make lookup table between id-->rev
         const lookup = {}
         for (i in existingData.rows) {
-          if (existingData.rows[i].id) {
+          if (existingData.rows[i].id && !existingData.rows[i].value.deleted) {
             lookup[existingData.rows[i].id] = existingData.rows[i].value.rev
           }
         }
@@ -62,6 +61,8 @@ module.exports = function (couchURL, couchDatabase, bufferSize, parallelism, ign
         for (i in payload.docs) {
           if (payload.docs[i]._id && lookup[payload.docs[i]._id]) {
             payload.docs[i]._rev = lookup[payload.docs[i]._id]
+          } else {
+            delete payload.docs[i]._rev
           }
         }
 

package.json

@@ -1,6 +1,6 @@
 {
   "name": "couchimport",
-  "version": "1.4.0",
+  "version": "1.4.1",
   "description": "CouchImport - command-line helper to bulk import/export data from CSV/TSV",
   "repository": "https://github.com/glynnbird/couchimport.git",
   "keywords": [