Skip to content

Commit 6c84c23

Browse files
committed
Use query method in sqlRunner instead of using instance directly
1 parent 4467198 commit 6c84c23

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

src/sqlRunner.ts

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -112,7 +112,7 @@ export function runSequentially(
112112
const promises = files.map(file => {
113113
logDb(`Running ${file.name}`);
114114

115-
return connection.instance.raw(file.sql);
115+
return connection.query(file.sql);
116116
});
117117

118118
return promise.runSequentially(promises);
@@ -138,7 +138,7 @@ export async function rollbackSequentially(
138138
for (const sql of reverse(sqlFiles)) {
139139
logDb(`Rolling back: ${sql.fqon}`);
140140

141-
await connection.instance.raw(sql.dropStatement);
141+
await connection.query(sql.dropStatement);
142142

143143
logDb('Executed: ', sql.dropStatement);
144144
}

0 commit comments

Comments
 (0)