diff --git a/src/inc/sql.mjs b/src/inc/sql.mjs index ffacf9d..cb805f7 100644 --- a/src/inc/sql.mjs +++ b/src/inc/sql.mjs @@ -2,4 +2,9 @@ import postgres from "postgres"; import cfg from "./config.mjs"; -export default postgres(cfg.sql); +const db = postgres(cfg.sql); + +if(cfg.sql.schema) + await db.unsafe(`set schema '${cfg.sql.schema}';`); + +export default db;