Initialize psql database

toddnni · Sep 16, 2024 · 7521405 · 7521405
1 parent 59fe5d2
commit 7521405
Showing 1 changed file with 12 additions and 0 deletions.
diff --git a/go-k8s-app/internal/db/db.go b/go-k8s-app/internal/db/db.go
@@ -76,6 +76,18 @@ func initPostgresDB() (DB, error) {
 	}
 
 	log.Println("Connected to the database")
+
+	createTableQuery := `
+	CREATE TABLE IF NOT EXISTS messages (
+		id INTEGER PRIMARY KEY AUTOINCREMENT,
+		content TEXT NOT NULL
+	);`
+	_, err = db.Exec(createTableQuery)
+	if err != nil {
+		return nil, fmt.Errorf("could not create table: %w", err)
+	}
+	log.Println("Initialized postgre database")
+
 	return &postgresDB{}, nil
 }