Forcing any new (given) DB. Create tables. Show tables in DB.

server/src/db/db_init.ts

@@ -2,15 +2,18 @@ import Customer from "./models/Customer";
 import Boat from "./models/Boat";
 import Worker from "./models/Worker";
 import CheckIn from "./models/CheckIn";
+import { checkDB } from "./seqConnection";
 
 const isDev = process.env.NODE_ENV === "development";
 
-const dbInit = () =>
-  Promise.all([
-    Customer.sync({ alter: isDev }),
-    Boat.sync({ alter: isDev }),
-    Worker.sync({ alter: isDev }),
-    CheckIn.sync({ alter: isDev }),
-  ]);
-
-export default dbInit;
+const dbInit = async () => {
+  await Customer.sync({ alter: isDev });
+  await Boat.sync({ alter: isDev });
+  await Worker.sync({ alter: isDev });
+  await CheckIn.sync({ alter: isDev });
+};
+const connectAndInit = async () => {
+  await checkDB();
+  await dbInit();
+};
+export default connectAndInit;

server/src/db/seqConnection.ts

-import envVars from "./config";
 import { Sequelize } from "sequelize";
+import envVars from "./config";
+import { Client } from "pg";
 
-const sequelizeConnection = new Sequelize(
+let sequelizeConnection = new Sequelize(
   envVars.dbName,
   envVars.dbUser,
   envVars.dbPassword,
@@ -11,12 +12,40 @@ const sequelizeConnection = new Sequelize(
     logging: false,
   }
 );
-export const testConnection = async () => {
-  try {
-    await sequelizeConnection.authenticate();
-    console.log("Connection has been established successfully.");
-  } catch (error) {
-    console.error("Unable to connect to the database:", error);
-  }
+//check if DB in env exists. If not, create a one
+export const checkDB = async () => {
+  const client = new Client({
+    host: envVars.dbHost,
+    port: 5432, //envVars.dbPort does not exist!
+    user: envVars.dbUser,
+    password: envVars.dbPassword,
+  });
+  await client.connect();
+
+  //search for db in pg-catalog. if not found, create a one
+  await client
+    .query(`SELECT * FROM pg_database WHERE datname = '${envVars.dbName}'`)
+    .then((res) => {
+      //------------------------------------------------then
+      if (res.rows.length === 0) {
+        //given db not found
+        console.log(
+          `${envVars.dbName} not found!\n${envVars.dbName} created..!`
+        );
+        client.query(`CREATE DATABASE "${envVars.dbName}"`);
+        sequelizeConnection = new Sequelize(
+          envVars.dbName,
+          envVars.dbUser,
+          envVars.dbPassword,
+          {
+            host: envVars.dbHost,
+            dialect: envVars.dbDriver,
+            logging: false,
+          }
+        );
+      } else {
+        console.log("-------\nres:\n", res.rows);
+      }
+    });
 };
 export default sequelizeConnection;

server/src/db/showDBTables.ts

+import sequelizeConnection from "./seqConnection";
+import { QueryTypes } from "sequelize";
+import envVars from "./config";
+
+const showTables = async () => {
+  //list all tables of the actual database
+  sequelizeConnection
+    .query(
+      `SELECT TABLE_NAME FROM information_schema.tables WHERE TABLE_TYPE = 'BASE TABLE' AND TABLE_CATALOG='${envVars.dbName}' AND TABLE_SCHEMA='public';`,
+      { type: QueryTypes.SELECT }
+    )
+    .then((res) => {
+      //------------------------------------------------then
+      console.log(`TABELS IN ${envVars.dbName}\n-------------\n`, res);
+    });
+};
+
+export default showTables;

server/src/server.ts

 import "dotenv/config";
 import express from "express";
-import dbInit from "./db/db_init";
-import { testConnection } from "./db/seqConnection";
-//import apiRouter from "./routes";
+import connectAndInit from "./db/db_init";
+import showTables from "./db/showDBTables";
 
 let init = async () => {
-  testConnection();
-  await dbInit();
+  await connectAndInit();
+  await showTables();
   const app = express();
 
   app.use(express.json());
-  //app.use(apiRouter);
   const port = process.env.PORT || 4000;
   app.listen(port, () => console.log(`Server listening on port: ${port}`));
   app.get("/", (req, res) => res.send("hello in server"));

[alrwasheda]

• Database will be forced if not exists.
• Tables will be created into any new (given) Database.
• Problem of some tables being created before others, solved.
• Testing Sequelize-Connection deleted.

Could need installation of "pg".

To test it:

• change the name in .env to "Fahrtenbuch" (or any other name) and run normally using docker.

[alrwasheda]

By getting this error: "src/db/seqConnection.ts(28,12): error TS7006: Parameter 'res' implicitly has an 'any' type.\n" set the value of "noImplicitAny": true in tsconfig.json to false

[fu1106jv]

this is not an error - you can't have function arguments without a type with this setting(and it should be true in the tsconfig)

[leandet98]

you can annotate the res as res: QueryResult