Chunk inserts so that you can insert more than 1000 items

SierraSoftworks · Jun 2, 2015 · 690f96c · 690f96c
1 parent b65a913
commit 690f96c
Show file tree

Hide file tree

Showing 2 changed files with 13 additions and 2 deletions.
diff --git a/lib/Model.ts b/lib/Model.ts
@@ -461,14 +461,14 @@ class Model<TDocument extends { _id?: any }, TInstance> implements ModelInterfac
                 });
             }
             else
-                return this._handlers.creatingDocuments(objects).then((objects) => {
+                return this._handlers.creatingDocuments(objects).then(objects => _.chunk(objects, 1000)).map((objects: any[]) => {
                     return new Bluebird<any[]>((resolve, reject) => {
                         this.collection.insertMany(objects, queryOptions,(err, result) => {
                             if (err) return reject(err);
                             return resolve(result.ops);
                         });
                     });
-                });
+                }).then(results => _.flatten(results));
         }).map((inserted: any) => {
             return this._handlers.documentReceived(null, inserted,(document, isNew?, isPartial?) => this._helpers.wrapDocument(document, isNew, isPartial), { cache: options.cache });
         }).then((results: TInstance[]) => {

diff --git a/typings/DefinitelyTyped/lodash/lodash.d.ts b/typings/DefinitelyTyped/lodash/lodash.d.ts
@@ -277,6 +277,17 @@ declare module _ {
         **/
         compact(): LoDashArrayWrapper<T>;
     }
+
+    //_.chunk
+    interface LoDashStatic {
+        /**
+         * Creates an array of elements split into groups the length of size. If collection can’t be split evenly, the final chunk will be the remaining elements.
+         * @param array The array to process.
+         * @param size The length of each chunk.
+         * @return Returns the new array containing chunks.
+         */
+        chunk<T>(array: T[], size?: number): T[][];
+    }
 
     //_.difference
     interface LoDashStatic {