From c96473af48f650ac568a9a9203f3d6bbe74ff080 Mon Sep 17 00:00:00 2001
From: Marvin Borner
Date: Sat, 18 Jul 2020 21:05:49 +0200
Subject: Whoops forgot adding the significant files, fixing the test :)
---
src/db/DBController.ts | 13 ++++++-------
1 file changed, 6 insertions(+), 7 deletions(-)
(limited to 'src/db/DBController.ts')
diff --git a/src/db/DBController.ts b/src/db/DBController.ts
index 4188bd1..416f695 100644
--- a/src/db/DBController.ts
+++ b/src/db/DBController.ts
@@ -10,7 +10,8 @@ export default class DBController {
const sql = await readFileStr("./src/db/tables.sql");
const queries = sql.split(";");
queries.pop();
- queries.forEach(async (query) => await this.execute(query));
+ for (const query of queries) await this.execute(query);
+ // queries.forEach(async (query) => await this.execute(query));
console.log("Tables created");
} catch (e) {
console.error("Could not create tables");
@@ -18,7 +19,7 @@ export default class DBController {
}
}
- async connect() {
+ async connect(): Promise<Client> {
try {
this.client = await new Client().connect({
hostname: Deno.env.get("DBHost"),
@@ -26,6 +27,7 @@ export default class DBController {
db: Deno.env.get("DBName"),
password: Deno.env.get("DBPassword"),
});
+ return this.client;
} catch (e) {
console.error("Could not connect to database");
throw e;
@@ -52,15 +54,12 @@ export default class DBController {
}
}
- // deno-lint-ignore no-explicit-any
- async execute_multiple(queries: any[][]) {
+ async execute_multiple(queries: (string[] | string)[][]) {
if (!this.client) throw Error("Database isn't initialized yet!");
try {
await this.client!.transaction(async (conn) => {
- queries.forEach(async (query) => {
- await conn.execute(query[0], query[1]);
- });
+ for (const query of queries) await conn.execute(query[0] as string, query[1] as string[]); // ez
});
} catch (e) {
throw e;
--
cgit v1.2.3