В общем победил. Воспользовался немного другим классом для этого.
В целом мой класс получился вот таким:
const connectionString = "Строка подключения";
const {Pool} = require('pg');
class Database {
constructor (autoConnect = false) {
if (autoConnect)
this.connect();
}
connect() {
this.pool = new Pool({
connectionString: connectionString
});
}
disconnect() {
this.pool.end();
}
query(sql, func) {
this.pool.query(sql, (error, result) => {
func(error, result);
});
}
}
const database = new Database(true);
database.query('Мой код SQL', (error, result) => {
console.log(result);
});
database.disconnect();