Edits history of script submission #22492 for ' Execute Query and return results (postgresql)'

• bun

  Ap­pro­ved version

  Edit in Windmill

  Embed

  import { type Sql } from "windmill-client@1";
  
  import { Client } from "pg"
  
  type Postgresql = {
    host: string;
    port: number;
    user: string;
    dbname: string;
    sslmode: string;
    password: string;
  };
  export async function main(db: Postgresql, query: Sql = "SELECT * FROM demo;") {
    if (!query) {
      throw Error("Query must not be empty.");
    }
    const client = pgClient(db);
    await client.connect();
    const { rows } = await client.query(query);
    await client.end();
    return rows;
  }
  
  export function pgClient(db: any) {
    let db2 = {
      ...db,
      host: db.host,
      database: db.dbname,
      ssl: false,
    }
    return new Client(db2)
  }
  

  Submitted by hugo989 2 days ago