pleblancq
11/03/2021, 2:51 PM...
var consumeSQL = new Promise((resolve) => {
decompressFile.on("data", async (chunk: Buffer) => {
decompressFile.pause();
partSql += chunk.toString("utf8");
var sql = partSql.split("\n");
let incompleteSql = "";
for (var i = 0; i < sql.length; i++) {
if (sql[i].endsWith(";")) {
try {
...
await prisma.$executeRaw(sql[i]));
...
} catch (err) {
console.log(err);
process.exit(1);
}
} else {
incompleteSql += sql[i];
}
}
partSql = incompleteSql;
decompressFile.resume();
});
decompressFile.on("end", async () => {
resolve("ended");
connection.end();
});
});
...Ryan
11/05/2021, 6:46 AM