-
Notifications
You must be signed in to change notification settings - Fork 0
/
index.ts
30 lines (23 loc) · 884 Bytes
/
index.ts
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
import { read, utils } from "xlsx";
import { knex } from "knex";
import { readdir } from "node:fs/promises";
const mKnex = knex({ client: "mysql" });
const files = await readdir(import.meta.dir + "/sourcefiles");
for await (const fileName of files) {
if (!fileName.endsWith(".xlsx")) continue;
const file = Bun.file("sourcefiles/" + fileName);
const b64 = await file.arrayBuffer();
const workbook = read(b64, { type: "base64" });
const worksheet = workbook.Sheets[workbook.SheetNames[0]];
const toJson = utils.sheet_to_json(worksheet);
await Bun.write(
`export/${fileName.replace(".xlsx", "")}.json`,
JSON.stringify(toJson)
);
const query = mKnex("targetTable")
.insert(toJson)
.into("targetTable")
.toString();
const sqlFileResult = query + ";" + "\n";
await Bun.write(`export/${fileName.replace(".xlsx", "")}.sql`, sqlFileResult);
}