chore: move db to mysql

Author: ToastedDev

api/drizzle.config.ts

@@ -1,10 +1,14 @@
 import { defineConfig } from "drizzle-kit";
 
 export default defineConfig({
-  dialect: "postgresql",
+  dialect: "mysql",
   schema: "./src/utils/db/schema.ts",
   dbCredentials: {
-    url: process.env.DATABASE_URL!,
+    host: process.env.DATABASE_HOST!,
+    port: parseInt(process.env.DATABASE_PORT!),
+    user: process.env.DATABASE_USER!,
+    password: process.env.DATABASE_PASSWORD!,
+    database: process.env.DATABASE_NAME!,
   },
   verbose: true,
 });

api/package.json

@@ -13,7 +13,7 @@
     "@trpc/server": "^10.45.2",
     "drizzle-orm": "^0.32.1",
     "hono": "^4.5.2",
-    "postgres": "^3.4.4",
+    "mysql2": "^3.11.0",
     "zod": "^3.23.8"
   },
   "devDependencies": {

api/src/router/channels.ts

@@ -50,16 +50,13 @@ export const channelsRouter = router({
           message: "Channel already exists",
         });
 
-      const createdChannels = await ctx.db
-        .insert(channels)
-        .values({
-          id: input.channelId,
-          guildId: input.guildId,
-          name: input.name,
-          count: 0,
-        })
-        .returning();
-      return createdChannels[0];
+      await ctx.db.insert(channels).values({
+        id: input.channelId,
+        guildId: input.guildId,
+        name: input.name,
+        count: 0,
+      });
+      return { success: true };
     }),
   setCount: procedure
     .input(

api/src/router/guilds.ts

@@ -6,13 +6,10 @@ export const guildsRouter = router({
   createGuild: procedure
     .input(z.object({ id: z.string(), name: z.string() }))
     .mutation(async ({ ctx, input }) => {
-      const createdGuilds = await ctx.db
-        .insert(guilds)
-        .values({
-          id: input.id,
-          name: input.name,
-        })
-        .returning();
-      return createdGuilds[0];
+      await ctx.db.insert(guilds).values({
+        id: input.id,
+        name: input.name,
+      });
+      return { success: true };
     }),
 });

api/src/utils/db/index.ts

@@ -1,8 +1,13 @@
-import { drizzle } from "drizzle-orm/postgres-js";
-import postgres from "postgres";
+import { drizzle } from "drizzle-orm/mysql2";
+import mysql from "mysql2/promise";
 import * as schema from "./schema";
 
-const connectionString = process.env.DATABASE_URL!;
-const client = postgres(connectionString);
+const poolConnection = mysql.createPool({
+  host: process.env.DATABASE_HOST!,
+  port: parseInt(process.env.DATABASE_PORT!),
+  user: process.env.DATABASE_USER!,
+  password: process.env.DATABASE_PASSWORD!,
+  database: process.env.DATABASE_NAME!,
+});
 
-export const db = drizzle(client, { schema });
+export const db = drizzle(poolConnection, { mode: "default", schema });

api/src/utils/db/schema.ts

@@ -1,14 +1,14 @@
-import { integer, pgTable, text } from "drizzle-orm/pg-core";
+import { int, mysqlTable, text, varchar } from "drizzle-orm/mysql-core";
 
-export const guilds = pgTable("guilds", {
-  id: text("id").primaryKey(),
+export const guilds = mysqlTable("guilds", {
+  id: varchar("id", { length: 255 }).primaryKey(),
   name: text("name"),
 });
 
-export const channels = pgTable("channels", {
-  id: text("id").primaryKey(),
+export const channels = mysqlTable("channels", {
+  id: varchar("id", { length: 255 }).primaryKey(),
   name: text("name"),
-  guildId: text("guild_id").references(() => guilds.id),
-  count: integer("count").default(0),
+  guildId: varchar("guild_id", { length: 255 }).references(() => guilds.id),
+  count: int("count").default(0),
   lastUserId: text("last_user_id"),
 });

bot/src/commands/configuration/channels.ts

@@ -52,10 +52,14 @@ export default {
               return interaction.followUp(
                 `Added ${channel} as a counting channel.`,
               );
-            } else {
-              return interaction.followUp(err.message);
+            } else if (err.message === "Channel already exists") {
+              return interaction.followUp(
+                `${channel} has already been added as a counting channel.`,
+              );
             }
           }
+
+          console.error(err);
         }
       }
     }