feat: add bulk insert transaction

src/databaseTransactions/FadabHelper.ts

@@ -5,6 +5,7 @@ import { insertAsync } from './insertTransaction';
 import { updateAsync } from './updateTransaction';
 import { deleteAsync } from './deleteTransaction';
 import { countAsync } from './countTransactions';
+import { bulkInsertAsync } from './bulkInsertTransaction';
 import {
   SelectOptions,
   Where,
@@ -45,4 +46,8 @@ export class FadabHelper {
   countAsync(options?: CountOptions) {
     return countAsync(this.baseTable, options);
   }
+
+  bulkInsertAsync(values: Array<DynamicObject>, ignore?: boolean) {
+    return bulkInsertAsync(this.baseTable, values, ignore);
+  }
 }

src/databaseTransactions/bulkInsertTransaction.ts

@@ -0,0 +1,26 @@
+import { DynamicObject } from '../models';
+import { queryAsync } from './queryTransaction';
+import { escapeId } from './escapeTransaction';
+
+export const bulkInsertAsync = (
+  tableName: string,
+  values: Array<DynamicObject>,
+  ignore?: boolean
+) => {
+  if (!values || values.length == 0)
+    throw new Error('The values parameter cannot be sent blank.');
+
+  const fields: Array<string> = Object.keys(values[0]);
+  let valueArray: Array<any>;
+  const mapValuesArray = values.map(value => {
+    valueArray = [];
+    for (const field of fields) valueArray.push(value[field]);
+    return valueArray;
+  });
+  return queryAsync(
+    `INSERT ${ignore ? ' IGNORE' : ''} INTO ${escapeId(
+      tableName
+    )} (${fields.toString()}) VALUES ?`,
+    [mapValuesArray]
+  );
+};

src/index.ts

@@ -9,3 +9,4 @@ export * from './databaseTransactions/formatTransaction';
 export * from './databaseTransactions/FadabHelper';
 export * from './utils';
 export * from './databaseTransactions/countTransactions';
+export * from './databaseTransactions/bulkInsertTransaction';