fix(be): migrations

db/Migration.go

@@ -19,7 +19,7 @@ func (m Migration) HumanoidVersion() string {
 
 func GetMigrations() []Migration {
 	return []Migration{
-		{},
+		{Version: "0.0.0"},
 		{Version: "1.0.0"},
 		{Version: "1.2.0"},
 		{Version: "1.3.0"},

db/sql/SqlDb.go

@@ -343,9 +343,6 @@ func (d *SqlDb) Sql() *gorp.DbMap {
 }
 
 func (d *SqlDb) IsInitialized() (bool, error) {
-	exists, err := d.sql.SelectInt(d.prepareQuery("select count(1) from migrations"))
-	if err != nil {
-		return false, nil
-	}
-	return exists > 0, nil
+	_, err := d.sql.SelectInt(d.prepareQuery("select count(1) from migrations"))
+	return err == nil, nil
 }

db/sql/migration.go

@@ -62,24 +62,44 @@ func (d *SqlDb) prepareMigration(query string) string {
 
 // IsMigrationApplied queries the database to see if a migration table with this version id exists already
 func (d *SqlDb) IsMigrationApplied(migration db.Migration) (bool, error) {
-	exists, err := d.sql.SelectInt(d.prepareQuery("select count(1) as ex from migrations where migration=?"), migration.Version)
+	initialized, err := d.IsInitialized()
 
-	if err == nil {
-		return exists > 0, nil
+	if err != nil {
+		return false, err
+	}
+
+	if !initialized {
+		return false, nil
 	}
 
-	fmt.Println("Creating migrations table")
-	query := d.prepareMigration(initialSQL)
-	_, err = d.exec(query)
+	exists, err := d.sql.SelectInt(
+		d.prepareQuery("select count(1) as ex from migrations where version = ?"),
+		migration.Version)
+
 	if err != nil {
-		panic(err)
+		return false, err
 	}
 
-	return d.IsMigrationApplied(migration)
+	return exists > 0, nil
 }
 
 // ApplyMigration runs executes a database migration
 func (d *SqlDb) ApplyMigration(migration db.Migration) error {
+	initialized, err := d.IsInitialized()
+
+	if err != nil {
+		return err
+	}
+
+	if !initialized {
+		fmt.Println("Creating migrations table")
+		query := d.prepareMigration(initialSQL)
+		_, err = d.exec(query)
+		if err != nil {
+			return err
+		}
+	}
+
 	tx, err := d.sql.Begin()
 	if err != nil {
 		return err
@@ -103,7 +123,7 @@ func (d *SqlDb) ApplyMigration(migration db.Migration) error {
 		}
 	}
 
-	_, err = tx.Exec(d.prepareQuery("insert into migrations(migration, upgraded_date) values (?, ?)"), migration.Version, time.Now())
+	_, err = tx.Exec(d.prepareQuery("insert into migrations(version, upgraded_date) values (?, ?)"), migration.Version, time.Now())
 	if err != nil {
 		handleRollbackError(tx.Rollback())
 		return err