Implemented bulk imports. Fixes #3.

Author: pluma

README.md

@@ -386,13 +386,43 @@ Deletes the collection from the database.
 
 ### Manipulating documents
 
+#### collection.import(data, [opts,] callback)
+
+Bulk imports the given *data* into the collection.
+
+The *data* can be an array of documents:
+
+```js
+[
+  {key1: value1, key2: value2}, // document 1
+  {key1: value1, key2: value2}, // document 2
+  ...
+]
+```
+
+Or it can be an array of value arrays following an array of keys.
+
+```js
+[
+  ['key1', 'key2'], // key names
+  [value1, value2], // document 1
+  [value1, value2], // document 2
+  ...
+]
+```
+
+If *opts* is set, it must be an object with any of the following properties:
+
+* *waitForSync*: Wait until the documents have been synced to disk. Default: *false*.
+* *details*: Whether the response should contain additional details about documents that could not be imported. Default: *false*.
+
 #### collection.replace(documentHandle, data, [opts,] callback)
 
 Replaces the content of the document with the given *documentHandle* with the given *data*.
 
 If *opts* is set, it must be an object with any of the following properties:
 
-* *waitForSync*: Wait until document has been synced to disk. Default: `false`.
+* *waitForSync*: Wait until the document has been synced to disk. Default: `false`.
 * *rev*: Only replace the document if it matches this revision. Optional.
 * *policy*: Determines the behaviour when the revision is not matched:
  * if *policy* is set to `"last"`, the document will be replaced regardless of the revision.

lib/collection.js

@@ -105,7 +105,7 @@ extend(BaseCollection.prototype, {
     var self = this;
     self._api.delete('collection/' + self.name, function (err, body) {
       if (err) callback(err);
-      else callback(null);
+      else callback(null, body);
     });
   },
   replace: function (documentHandle, data, opts, callback) {
@@ -141,7 +141,7 @@ extend(BaseCollection.prototype, {
     opts = extend({}, opts, {collection: this.name});
     this._api.delete(this._documentPath(documentHandle), opts, function (err, body) {
       if (err) callback(err);
-      else callback(null);
+      else callback(null, body);
     });
   },
   all: function (type, callback) {
@@ -157,6 +157,19 @@ extend(BaseCollection.prototype, {
       if (err) callback(err);
       else callback(null, body.documents);
     });
+  },
+  import: function (data, opts, callback) {
+    if (typeof opts === 'function') {
+      callback = opts;
+      opts = undefined;
+    }
+    if (!callback) callback = noop;
+    this._api.post('import', data, extend({}, opts, {
+      collection: this.name
+    }), function (err, body) {
+      if (err) callback(err);
+      else callback(null, body);
+    });
   }
 });