Class PostgresConnection

src/pg.ts:453–501

}

export class PostgresConnection implements AbstractSqlConnection {
    public client: Client
    public readonly dialect: PostgresSqlDialect
    public connected: boolean = false

    constructor(
        public readonly host: string,
        public readonly port: number,
        public readonly username: string,
        public readonly password: string,
        public readonly database: string
    ) {
        this.dialect = new PostgresSqlDialect()
    }

    getDialect(): AbstractSqlDialect {
        return this.dialect
    }

    execute(query: ExecutableSqlQuery): Promise<SqlQueryExecuteResult> {
        return this.client.query(
            query[0],
            query.slice(1)
        )
    }

    async isConnected(): Promise<boolean> {
        return this.connected
    }

    connect(): Promise<void> {
        this.client = new PgClient({
            host: this.host,
            port: this.port,
            user: this.username,
            password: this.password,
            database: this.database,
        })
        return this.client.connect().then(() => {
            this.connected = true
        })
    }

    close(): Promise<void> {
        return this.client.end().then(() => {
            this.connected = false
        })
    }
}