✨ Add mysql helpers

Author: AnandChowdhary

src/config.ts

@@ -1,6 +1,9 @@
 import { config } from "dotenv";
 config();
 
+// Server
+export const PORT = process.env.PORT || 7008;
+
 // Database
 export const DB_HOST = process.env.DB_HOST || "localhost";
 export const DB_PORT = process.env.DB_PORT

src/helpers/crud.ts

@@ -0,0 +1,6 @@
+import { query } from "./mysql";
+import { User } from "../interfaces/tables/user";
+
+export const listAllUsers = async () => {
+  return <User[]>await query("SELECT * from users");
+};

src/helpers/mysql.ts

@@ -0,0 +1,31 @@
+import { createPool, PoolConnection } from "mysql";
+import {
+  DB_HOST,
+  DB_USERNAME,
+  DB_PORT,
+  DB_PASSWORD,
+  DB_DATABASE
+} from "../config";
+
+export const pool = createPool({
+  host: DB_HOST,
+  port: DB_PORT,
+  user: DB_USERNAME,
+  password: DB_PASSWORD,
+  database: DB_DATABASE
+});
+
+export const query = (
+  queryString: string,
+  values?: (string | number | boolean | Date)[]
+) =>
+  new Promise((resolve, reject) => {
+    pool.getConnection((error, connection) => {
+      if (error) return reject(error);
+      connection.query(queryString, values, (error, result) => {
+        connection.destroy();
+        if (error) return reject(error);
+        resolve(result);
+      });
+    });
+  });

src/index.ts

@@ -1,17 +1,18 @@
 import express from "express";
-// import { create } from "./helpers/crud";
+import { PORT } from "./config";
+import { listAllUsers } from "./helpers/crud";
 
 const app = express();
 
 app.get("/", (req, res) => res.json({ hello: "world" }));
 app.get("/create-account", async (req, res) => {
   try {
-    // res.json({ success: true, data: await create() });
-    res.json({ success: true });
+    const users = await listAllUsers();
+    res.json({ success: true, users });
   } catch (error) {
     console.log("Error", error);
     res.json({ success: false });
   }
 });
 
-app.listen(process.env.PORT || 7007, () => console.log("App running"));
+app.listen(PORT, () => console.log("App running"));

src/interfaces/tables/user.ts

@@ -1,37 +1,16 @@
-import { QueryTable, NumberColumn, StringColumn, DateColumn, BooleanColumn } from "type-sql";
-
 export interface User {
   id: number;
   name: string;
   nickname: string;
   primaryEmail?: number;
   password: string;
   twoFactorEnabled?: boolean;
-  twoFactorSecret?: boolean;
-  country?: string;
+  twoFactorSecret?: string;
+  countryCode?: string;
   timezone?: string;
   notificationEmails?: 1 | 2 | 3 | 4;
   preferredLanguage?: string;
   prefersReducedMotion?: boolean;
   createdAt?: Date;
   updatedAt?: Date;
 }
-
-export class UserTable extends QueryTable<User, number> {
-  id = new NumberColumn(this, "id");
-  name = new StringColumn(this, "name");
-  nickname = new StringColumn(this, "nickname");
-  primaryEmail = new NumberColumn(this, "primaryEmail");
-  password = new StringColumn(this, "password");
-  twoFactorEnabled = new BooleanColumn(this, "twoFactorEnabled");
-  twoFactorSecret = new StringColumn(this, "twoFactorSecret");
-  country = new StringColumn(this, "country");
-  timezone = new StringColumn(this, "timezone");
-  notificationEmails = new NumberColumn(this, "notificationEmails");
-  preferredLanguage = new StringColumn(this, "preferredLanguage");
-  prefersReducedMotion = new BooleanColumn(this, "prefersReducedMotion");
-  createdAt = new DateColumn(this, "createdAt");
-  updatedAt = new DateColumn(this, "updatedAt");
-}
-
-export const USER = new UserTable("User");