test(sql-example): add e2e test for pool connection

Verifies the node-sql template can connect to postgres via pool
and complete a job through the queue.

Co-Authored-By: Claude Opus 4.5 <noreply@anthropic.com>

Author: theothersideofgod

tests/e2e/__tests__/sql-example.e2e.test.ts

@@ -0,0 +1,64 @@
+import { Client } from 'pg';
+
+const PG_CONFIG = {
+  host: process.env.PGHOST || 'localhost',
+  port: Number(process.env.PGPORT) || 5432,
+  user: process.env.PGUSER || 'postgres',
+  password: process.env.PGPASSWORD || 'postgres123!',
+  database: process.env.PGDATABASE || 'constructive',
+};
+
+const JOB_TIMEOUT = 30000;
+
+describe('sql-example e2e', () => {
+  let client: Client;
+  let databaseId: string;
+
+  beforeAll(async () => {
+    client = new Client(PG_CONFIG);
+    await client.connect();
+
+    const dbResult = await client.query(
+      `SELECT id FROM metaschema_public.database LIMIT 1`
+    );
+    if (dbResult.rows.length === 0) {
+      throw new Error('No database record found in metaschema_public.database');
+    }
+    databaseId = dbResult.rows[0].id;
+  });
+
+  afterAll(async () => {
+    await client.end();
+  });
+
+  it('should connect to postgres via pool and complete job', async () => {
+    const insertResult = await client.query(
+      `SELECT * FROM app_jobs.add_job($1, 'sql-example'::text, $2::json)`,
+      [databaseId, JSON.stringify({})]
+    );
+
+    const jobId = insertResult.rows[0].id;
+    expect(jobId).toBeDefined();
+
+    const startTime = Date.now();
+    while (Date.now() - startTime < JOB_TIMEOUT) {
+      const statusResult = await client.query(
+        `SELECT * FROM app_jobs.jobs WHERE id = $1`,
+        [jobId]
+      );
+
+      if (statusResult.rows.length === 0) {
+        return; // Job completed successfully
+      }
+
+      const job = statusResult.rows[0];
+      if (job.last_error) {
+        throw new Error(`Job failed: ${job.last_error}`);
+      }
+
+      await new Promise((r) => setTimeout(r, 500));
+    }
+
+    throw new Error('Job did not complete within timeout');
+  });
+});