Merge pull request #198 from ttrolololll/sequelize-insertmany

sequelize adaptor insertMany to accept an options object
moleculerjs · Jun 27, 2020 · 23a0c31 · 23a0c31
2 parents da42811 + 61d7f3a
commit 23a0c31
Show file tree

Hide file tree

Showing 2 changed files with 14 additions and 2 deletions.
diff --git a/packages/moleculer-db-adapter-sequelize/src/index.js b/packages/moleculer-db-adapter-sequelize/src/index.js
@@ -200,12 +200,13 @@ class SequelizeDbAdapter {
 	 * Insert many entities
 	 *
 	 * @param {Array} entities
+	 * @param {Object} opts
 	 * @returns {Promise}
 	 *
 	 * @memberof SequelizeDbAdapter
 	 */
-	insertMany(entities) {
-		return this.model.bulkCreate(entities, { returning: true });
+	insertMany(entities, opts = { returning: true }) {
+		return this.model.bulkCreate(entities, opts);
 	}
 
 	/**

diff --git a/packages/moleculer-db-adapter-sequelize/test/unit/index.spec.js b/packages/moleculer-db-adapter-sequelize/test/unit/index.spec.js
@@ -373,6 +373,17 @@ describe("Test SequelizeAdapter", () => {
 				expect(adapter.model.bulkCreate).toHaveBeenCalledWith(entities, { returning: true });
 			});
 		});
+
+		it("call inserts with option param", () => {
+			adapter.model.create.mockClear();
+			let entities = [{ name: "John" }, { name: "Jane" }];
+			let opts = { ignoreDuplicates: true, returning: false }
+
+			return adapter.insertMany(entities, opts).catch(protectReject).then(() => {
+				expect(adapter.model.bulkCreate).toHaveBeenCalledTimes(2);
+				expect(adapter.model.bulkCreate).toHaveBeenCalledWith(entities, opts);
+			});
+		});
 
 		it("call updateMany", () => {
 			let where = {};