Function getDatabases

src/lib/connectors/postgres/index.ts:76–93

(connection: Connection)

};

const getDatabases = async (connection: Connection): Promise<string[]> => {
  const client = await newPostgresClient(connection);
  if (connection.database) {
    await client.end();
    return [connection.database];
  }

  const { rows } = await client.query(`SELECT datname FROM pg_database;`);
  await client.end();
  const databaseList = [];
  for (const row of rows) {
    if (row["datname"]) {
      databaseList.push(row["datname"]);
    }
  }
  await client.end();
  return databaseList;
};

const getTableSchema = async (connection: Connection, databaseName: string): Promise<Schema[]> => {
  connection.database = databaseName;