import pg from "pg";

const cypressDatabaseUrl = process.env?.CYPRESS_DATABASE_URL || "postgres://postgres@localhost:5432/vbv_lernwelt_cypress";

if(!cypressDatabaseUrl) {
  throw new Error(
    "CYPRESS_DATABASE_URL must be set"
  );
}

export async function runSql(sqlString) {
  // I could not make postgres.js make work, so I use pg directly
  const client = new pg.Client(cypressDatabaseUrl);
  await client.connect();
  const res = await client.query(sqlString);
  await client.end();
  return res;
}