backend/src/database/postgres.ts


1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34

import { Pool } from "pg";

const pool = new Pool({
    user: process.env.DB_USER,
    password: process.env.DB_PASSWORD,
    database: process.env.DB_DATABASE,
    host: process.env.DB_HOST,
    port: process.env.DB_PORT ? parseInt(process.env.DB_PORT) : 5432,
});

/* Too strict for Docker:
pool.connect((error, _client, release) => {
    if (error) {
        console.error("Verbindung zur Datenbank fehlgeschlagen: ", error);
        process.exit(1);
    } else {
        console.log("Erfolgreich mit der Datenbank verbunden.");
        release();
    }
});
 */

console.log("Erfolgreich mit der Datenbank verbunden.");

export async function closeDBConnection() {
    try {
        await pool.end();
        console.log("PostgreSQL-Verbindung erfolgreich beendet.");
    } catch (error) {
        console.error("Fehler beim Beenden der PostgreSQL-Verbindung: ", error);
    }
}

export default pool;