diff --git a/packages/server/src/integrations/snowflake.ts b/packages/server/src/integrations/snowflake.ts index a4014ff364..f9335ecf4e 100644 --- a/packages/server/src/integrations/snowflake.ts +++ b/packages/server/src/integrations/snowflake.ts @@ -79,7 +79,7 @@ module SnowflakeModule { }) } - async read(query: SqlQuery) { + async internalQuery(query: SqlQuery) { await this.connectAsync() let response: any = await new Promise((resolve, reject) => this.client.execute({ @@ -97,6 +97,22 @@ module SnowflakeModule { ) return response.rows } + + async create(query: SqlQuery) { + return this.internalQuery(query) + } + + async read(query: SqlQuery) { + return this.internalQuery(query) + } + + async update(query: SqlQuery) { + return this.internalQuery(query) + } + + async delete(query: SqlQuery) { + return this.internalQuery(query) + } } module.exports = {