Make /api/init drop any existing database if it exists.

rocicorp · Mar 30, 2021 · f2aa0a0 · f2aa0a0
1 parent 9db0f49
commit f2aa0a0
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 17 deletions.
diff --git a/backend/rds.ts b/backend/rds.ts
@@ -76,22 +76,9 @@ export async function transact(body: TransactionBodyFn) {
   );
 }
 
-/**
- * Creates our databse in RDS if necessary.
- */
-export async function ensureDatabase() {
-  const result = await executeStatementInDatabase(null, "SHOW DATABASES");
-  if (result.records) {
-    if (result.records.find((record) => record[0].stringValue === dbName)) {
-      // TODO: Maybe migrate version
-      return;
-    }
-  }
-
-  await createDatabase();
-}
+export async function createDatabase() {
+  await executeStatementInDatabase(null, `DROP DATABASE IF EXISTS ${dbName}`);
 
-async function createDatabase() {
   await executeStatementInDatabase(
     null,
     `CREATE DATABASE ${dbName}

diff --git a/pages/api/init.ts b/pages/api/init.ts
@@ -1,7 +1,7 @@
-import { ensureDatabase } from "../../backend/rds";
+import { createDatabase } from "../../backend/rds";
 import type { NextApiRequest, NextApiResponse } from "next";
 
 export default async (req: NextApiRequest, res: NextApiResponse) => {
-  await ensureDatabase();
+  await createDatabase();
   res.end("OK");
 };