From b177e311e48e328e9ce9934f10920591852026cc Mon Sep 17 00:00:00 2001
From: Michael Thomson <michael@michaelthomson.dev>
Date: Thu, 6 Feb 2025 12:41:54 -0500
Subject: [PATCH] migrations

---
 cmd/main.go                 |   8 +++--
 habits.db                   | Bin 0 -> 16384 bytes
 internal/migrate/migrate.go |  64 ++++++++++++++++++++++++++++++++++++
 migrations/1-init_db.sql    |   4 +++
 4 files changed, 74 insertions(+), 2 deletions(-)
 create mode 100644 habits.db
 create mode 100644 internal/migrate/migrate.go
 create mode 100644 migrations/1-init_db.sql

diff --git a/cmd/main.go b/cmd/main.go
index 8117330..99b0216 100644
--- a/cmd/main.go
+++ b/cmd/main.go
@@ -1,7 +1,11 @@
 package main
 
-import "fmt"
+import (
+	"fmt"
+
+	"gitea.michaelthomson.dev/mthomson/habits/internal/migrate"
+)
 
 func main() {
-	fmt.Println("Hello, world")
+	migrate.Migrate();
 }
diff --git a/habits.db b/habits.db
new file mode 100644
index 0000000000000000000000000000000000000000..2d097c6cd309cede20744c38324d0990de7324a2
GIT binary patch
literal 16384
zcmeI%&r8B!7{KxOb(ty1yolG=lS(B?bn4QQQIbV15j@10Y{fub>Wb**rDK0;e?#vp
zh(+M7i+o@9ZtpL)=l$&TZ1;EFIE~a}G8+e}Iu<1%r8rYc2w~~EqwA_<bmM1Vt|m5I
zEzx|R7VQsV*;!$K+FAQy!)m4wKmY**5I_I{1Q0*~0R#~EPl0|WS1Fg}!cK$XC`yws
zG1Y2&uG4c>&pGe9%8b+tN|!iPotvJz^*Yy%H&9pZ;9xmE3C5A?J6`+J@#-f>jY6Yl
z?N(09QpA%mdYey2I@9)pmo!=SeRD^@WzHt6-ZL9~mbpr`Di{09K*sUYEJ)*IGGDhc
zzk*ti*9&>2UZdGuFE`=27q0g^L_Pl}!hEBspDOJyp$`fI2q1s}0tg_000IagfB*sr
zY=uBcTB6oEj3;sGhr_1+Bw_M@{nMX<00IagfB*srAb<b@2q1s}0$VIlFnc5a-{LpS
X)(}7d0R#|0009ILKmY**5D?-UO!HQe

literal 0
HcmV?d00001

diff --git a/internal/migrate/migrate.go b/internal/migrate/migrate.go
new file mode 100644
index 0000000..a613a30
--- /dev/null
+++ b/internal/migrate/migrate.go
@@ -0,0 +1,64 @@
+package migrate
+
+import (
+	"database/sql"
+	"fmt"
+	"log"
+	"os"
+
+	_ "github.com/mattn/go-sqlite3"
+)
+
+type Migration struct {
+	Version int
+	Name    string
+}
+
+func Migrate() {
+	db, err := sql.Open("sqlite3", "./habits.db")
+	if err != nil {
+		log.Fatal("Failed to open db pool")
+	}
+
+	defer db.Close()
+
+	migrationTableSql := `
+	CREATE TABLE IF NOT EXISTS migrations(
+	  version INTEGER PRIMARY KEY,
+	  name VARCHAR(50)
+	);`
+
+	_, err = db.Exec(migrationTableSql)
+	if err != nil {
+		log.Fatal(err)
+	}
+
+	files, err := os.ReadDir("./migrations")
+	if err != nil {
+		log.Fatal("Failed to read migrations directory")
+	}
+
+	for _, file := range files {
+		fmt.Printf("Checking file: %s\n", file.Name())
+		var migration Migration
+		row := db.QueryRow("SELECT * FROM migrations WHERE name = ?;", file.Name())
+		err = row.Scan(&migration.Version, &migration.Name)
+		if err == sql.ErrNoRows {
+			fmt.Printf("Running migration: %s\n", file.Name())
+			migrationSql, err := os.ReadFile(fmt.Sprintf("./migrations/%s", file.Name()))
+			if err != nil {
+				log.Fatal(err)
+			}
+
+			_, err = db.Exec(string(migrationSql))
+			if err != nil {
+				log.Fatal(err)
+			}
+
+			_, err = db.Exec("INSERT INTO migrations(name) VALUES(?);", file.Name())
+			if err != nil {
+				log.Fatal(err)
+			}
+		}
+	}
+}
diff --git a/migrations/1-init_db.sql b/migrations/1-init_db.sql
new file mode 100644
index 0000000..d197aef
--- /dev/null
+++ b/migrations/1-init_db.sql
@@ -0,0 +1,4 @@
+CREATE TABLE todo(
+    id INT PRIMARY KEY,
+    name VARCHAR(50)
+);