Add general support for more database types

Author: mblaschke

sync/server_deploy_database.go

@@ -6,16 +6,21 @@ import (
 )
 
 func (database *Database) Deploy() {
-	if database.Options.ClearDatabase {
-		database.deployClearDatabase()
-	}
+	switch database.Type {
+	case "mysql":
+		if database.Options.ClearDatabase {
+			database.deployMysqlClearDatabase()
+		}
 
-	database.deployStructure()
-	database.deployData()
+		database.deployMysqlStructure()
+		database.deployMysqlData()
+	default:
+		panic(fmt.Sprintf("Database type %s is not valid or supported", database.Type))
+	}
 }
 
 // Deploy database structure
-func (database *Database) deployClearDatabase() {
+func (database *Database) deployMysqlClearDatabase() {
 
 	// don't use database which we're trying to drop, instead use "mysql"
 	schema := database.Schema
@@ -35,7 +40,7 @@ func (database *Database) deployClearDatabase() {
 }
 
 // Deploy database structure
-func (database *Database) deployStructure() {
+func (database *Database) deployMysqlStructure() {
 	Logger.Step("deploy database structure")
 
 	// Deploy structure only
@@ -47,7 +52,7 @@ func (database *Database) deployStructure() {
 }
 
 // Deploy database data
-func (database *Database) deployData() {
+func (database *Database) deployMysqlData() {
 	Logger.Step("deploy database data")
 
 	// Deploy data only

sync/server_sync_database.go

@@ -8,16 +8,21 @@ import (
 )
 
 func (database *Database) Sync() {
-	if database.Options.ClearDatabase {
-		database.syncClearDatabase()
+	switch database.Type {
+	case "mysql":
+		if database.Options.ClearDatabase {
+			database.syncMysqlClearDatabase()
+		}
+
+		database.syncMysqlStructure()
+		database.syncMysqlData()
+	default:
+		panic(fmt.Sprintf("Database type %s is not valid or supported", database.Type))
 	}
-
-	database.syncStructure()
-	database.syncData()
 }
 
 // Sync database structure
-func (database *Database) syncClearDatabase() {
+func (database *Database) syncMysqlClearDatabase() {
 
 	// don't use database which we're trying to drop, instead use "mysql"
 	schema := database.Local.Schema
@@ -37,7 +42,7 @@ func (database *Database) syncClearDatabase() {
 }
 
 // Sync database structure
-func (database *Database) syncStructure() {
+func (database *Database) syncMysqlStructure() {
 	Logger.Step("syncing database structure")
 
 	tmpfile, err := ioutil.TempFile("", "dump")
@@ -56,7 +61,7 @@ func (database *Database) syncStructure() {
 }
 
 // Sync database data
-func (database *Database) syncData() {
+func (database *Database) syncMysqlData() {
 	Logger.Step("syncing database data")
 
 	tmpfile, err := ioutil.TempFile("", "dump")