import { Pool } from "pg";

// Next.js 개발 모드의 핫 리로드에서 Pool이 중복 생성되지 않도록 전역에 보관
const globalForDb = globalThis as unknown as { pgPool?: Pool };

export const db =
  globalForDb.pgPool ??
  new Pool({
    connectionString: process.env.DATABASE_URL,
    max: 10,
  });

if (process.env.NODE_ENV !== "production") {
  globalForDb.pgPool = db;
}

export async function query<T extends Record<string, unknown>>(
  text: string,
  params?: unknown[],
) {
  const result = await db.query(text, params);
  return result.rows as T[];
}