diff --git a/src/sql/api.ts b/src/sql/api.ts index 7c08c79..5515007 100644 --- a/src/sql/api.ts +++ b/src/sql/api.ts @@ -12,6 +12,8 @@ export interface Transaction { fetchRow(stmt: sql.SelectStatement): Promise; fetchRows(stmt: sql.SelectStatement): Promise; + + raw(sql: string): Promise; } export interface DataSource { diff --git a/src/sql/sqlite.ts b/src/sql/sqlite.ts index 8904bf5..3e828bb 100644 --- a/src/sql/sqlite.ts +++ b/src/sql/sqlite.ts @@ -75,6 +75,12 @@ class SqliteTransaction implements Transaction { return Promise.resolve(result); } + + raw(sql: string): Promise { + this._db.exec(sql); + + return Promise.resolve(); + } } class SqliteDataSource implements DataSource {