Stan
41 lines
1.1 KiB
JavaScript
41 lines
1.1 KiB
JavaScript
import * as mariadb from 'mariadb';
|
|
|
|
import { env } from '../config/env.js';
|
|
|
|
/*
|
|
* One shared pool is enough for the current backend because the service is read-
|
|
* heavy and low volume. Centralizing pool creation here prevents each route or
|
|
* service module from opening its own connections and makes shutdown predictable.
|
|
*/
|
|
const pool = mariadb.createPool({
|
|
host: env.db.host,
|
|
port: env.db.port,
|
|
database: env.db.database,
|
|
user: env.db.user,
|
|
password: env.db.password,
|
|
connectionLimit: env.db.connectionLimit,
|
|
bigIntAsNumber: true
|
|
});
|
|
|
|
export async function query(sql, params = []) {
|
|
let connection;
|
|
|
|
try {
|
|
/*
|
|
* The helper deliberately exposes a low-level query primitive instead of a
|
|
* custom repository abstraction. For the PoC that keeps SQL visible and easy
|
|
* to reason about while still ensuring every query uses the same pool.
|
|
*/
|
|
connection = await pool.getConnection();
|
|
return await connection.query(sql, params);
|
|
} finally {
|
|
if (connection) {
|
|
connection.release();
|
|
}
|
|
}
|
|
}
|
|
|
|
export async function closePool() {
|
|
await pool.end();
|
|
}
|