feat: method for insertMany itens on postgres

Author: WillianAgostini

package-lock.json

@@ -24,6 +24,7 @@
     "draftlog": "^1.0.13",
     "mongodb": "^6.5.0",
     "pg": "^8.11.5",
+    "pg-format": "^1.0.4",
     "sqlite3": "^5.1.7"
   }
-}
+}

package.json

@@ -5,13 +5,11 @@ const db = await getPostgresConnection()
 
 process.on('message', (items) => {
     // console.log(` ${process.pid} received ${items.length} items`,);
-    for (const item of items) {
-        db.students.insert(item)
-            .then(() => {
-                process.send('item-done');
-            })
-            .catch((error) => {
-                console.error(error);
-            });
-    }
+    db.students.insertMany(items)
+        .then(() => {
+            process.send(items.length);
+        })
+        .catch((error) => {
+            console.error(error);
+        });
 });

src/background-task.js

@@ -1,5 +1,6 @@
 import { MongoClient } from 'mongodb';
 import pg from 'pg';
+import format from 'pg-format';
 const { Client } = pg;
 // Connection URL for MongoDB
 
@@ -47,6 +48,15 @@ async function getPostgresConnection() {
 
                 await client.query(query, values);
 
+            },
+            async insertMany(persons) {
+                const query = format(
+                    'INSERT INTO students (name, email, age, registered_at) VALUES %L',
+                    persons.map((person) => [person.name, person.email, person.age, person.registered_at])
+                );
+
+                await client.query(query);
+
             },
             async list(limit = 100) {
                 const query = 'SELECT * FROM students LIMIT $1';