pg.ts

import { Client } from 'pg';
import env from 'dotenv';

// Load .env file.
env.config();

const connectionURL = process.env.DATABASE_URL;
if (!connectionURL) throw new Error('Missing DATABASE_URL environment variable.');

const defaultSchemaUrl = connectionURL.replace(/\/[^/]*$/, '/postgres');
const client = new Client({ connectionString: defaultSchemaUrl });

(async () => {
	try {
		await client.connect();

		const dbName = connectionURL?.replace(/.*\//, '');
		const result = await client.query(`SELECT 1 FROM pg_database WHERE datname = '${dbName}'`);

		if (result.rows.length !== 0) console.log('Database already exists.');
		else {
			console.log(dbName);
			await client.query(`CREATE DATABASE "${dbName}"`);
			console.log('Database created.');
		}
	} catch (error) {
		console.error('Error:', error);
	} finally {
		await client.end();
	}
})();