class PRQLDatabaseClientWrapper {
constructor(db) {
this.db = db;
}
async queryStream(query, params, options) {
return this.db.queryStream(prql([query], params), options);
}
async query(query, params, options) {
return this.db.query(prql([query], params), options);
}
async describeTables({ schema } = {}) {
return this.db.describeTables({ schema });
}
async describeColumns({ schema, table } = {}) {
return this.db.describeColumns({ schema, table });
}
async sql(strings, ...params) {
return this.db.sql([prql(strings, params)]);
}
queryTag(strings, ...params) {
return [String.raw(strings, ...(params || [])), []];
}
}