insert-worker.cjs

// Worker module for Postgres batch inserts
// Loaded by tasklets worker threads via MODULE: prefix

const { Client } = require('pg')

async function insertBatch(items) {
    const client = new Client({
        user: 'erickwendel',
        host: process.env.POSTGRES_HOST || 'localhost',
        database: 'school',
        password: 'mypassword',
        port: 5432,
    })

    await client.connect()

    try {
        // Build a single bulk INSERT for performance
        const values = []
        const placeholders = []
        let idx = 1

        for (const item of items) {
            placeholders.push(`($${idx++}, $${idx++}, $${idx++}, $${idx++})`)
            values.push(item.name, item.email, item.age, item.registeredAt)
        }

        const query = `INSERT INTO students (name, email, age, registered_at) VALUES ${placeholders.join(', ')}`
        await client.query(query, values)
    } finally {
        await client.end()
    }

    return items.length
}

module.exports = insertBatch