00_db_helper.R

# 00_db_helper.R
library(DBI)
library(RPostgres)

# Cek apakah file .env ada di folder (biasanya saat di laptop lokal)
# Jika tidak ada (seperti di Hugging Face), lewati saja agar tidak error
if (file.exists(".env")) {
  library(dotenv)
  load_dot_env(".env")
}


# Fungsi sentral untuk koneksi ke Supabase
connect_supabase <- function() {
  dbConnect(
    RPostgres::Postgres(),
    host     = Sys.getenv("DB_HOST1"), 
    dbname   = Sys.getenv("DB_NAME1"),
    user     = Sys.getenv("DB_USER1"),
    password = Sys.getenv("DB_PSWD1"),
    port     = as.integer(Sys.getenv("DB_PORT1")),
    bigint   = "integer", 
    options  = "-c search_path=mlops"
  ) 
}