Fixing issue with base postgres integration.
This commit is contained in:
parent
ba09f2df4b
commit
a930a05eb6
|
@ -73,7 +73,7 @@ const TYPE_MAP = {
|
||||||
|
|
||||||
async function internalQuery(client, sql) {
|
async function internalQuery(client, sql) {
|
||||||
try {
|
try {
|
||||||
return await client.query(sql)
|
return await client.query(sql.sql, sql.bindings)
|
||||||
} catch (err) {
|
} catch (err) {
|
||||||
throw new Error(err)
|
throw new Error(err)
|
||||||
}
|
}
|
||||||
|
@ -174,7 +174,6 @@ class PostgresIntegration extends Sql {
|
||||||
}
|
}
|
||||||
|
|
||||||
async query(json) {
|
async query(json) {
|
||||||
// TODO: get the schema
|
|
||||||
const operation = this._operation(json).toLowerCase()
|
const operation = this._operation(json).toLowerCase()
|
||||||
const input = this._query(json)
|
const input = this._query(json)
|
||||||
const response = await internalQuery(this.client, input)
|
const response = await internalQuery(this.client, input)
|
||||||
|
|
Loading…
Reference in New Issue