completed mssql connection

Author: mikebionic

app.go

@@ -6,6 +6,7 @@ import (
 	"log"
 	"net/http"
 
+	_ "github.com/denisenkom/go-mssqldb"
 	"github.com/gorilla/mux"
 	_ "github.com/lib/pq"
 )
@@ -15,12 +16,18 @@ type App struct {
 	DB     *sql.DB
 }
 
-func (a *App) Initialize(db_type, db_user, db_password, db_host, db_database string) {
+func (a *App) Initialize(db_type, db_user, db_password, db_host, db_database, db_params string) {
 
-	connStr := fmt.Sprintf("%s://%s:%s@%s/%s?sslmode=disable", db_type, db_user, db_password, db_host, db_database)
+	var connStr string
+	switch db_type {
+	case "sqlserver":
+		connStr = fmt.Sprintf("%s://%s:%s@%s/instance?database=%s&%s", db_type, db_user, db_password, db_host, db_database, db_params)
+	default:
+		connStr = fmt.Sprintf("%s://%s:%s@%s/%s?%s", db_type, db_user, db_password, db_host, db_database, db_params)
+	}
 
 	var err error
-	a.DB, err = sql.Open("postgres", connStr)
+	a.DB, err = sql.Open(db_type, connStr)
 	if err != nil {
 		log.Fatal(err)
 	}

configs/gatewaygo.config.mssql.sample.json

@@ -0,0 +1,9 @@
+{
+  "listen_address": "0.0.0.0:8000",
+	"db_type": "postgres",
+	"db_user": "postgres",
+	"db_password": "123456",
+	"db_host": "localhost",
+	"db_database": "database",
+  "db_params": "sslmode=disable"
+}

configs/gatewaygo.config.sample.json

@@ -4,5 +4,6 @@
 	"db_user": "postgres",
 	"db_password": "123456",
 	"db_host": "localhost",
-	"db_database": "database"
+	"db_database": "database",
+  "db_params": "sslmode=disable"
 }

go.mod

@@ -3,7 +3,7 @@ module github.com/mike-bionic/db-gateway-go
 go 1.16
 
 require (
-	github.com/go-sql-driver/mysql v1.6.0 // indirect
+	github.com/denisenkom/go-mssqldb v0.10.0 // indirect
 	github.com/gorilla/mux v1.8.0 // indirect
 	github.com/joho/godotenv v1.3.0 // indirect
 	github.com/lib/pq v1.10.2 // indirect

go.sum

@@ -1,6 +1,8 @@
 github.com/davecgh/go-spew v1.1.1/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38=
-github.com/go-sql-driver/mysql v1.6.0 h1:BCTh4TKNUYmOmMUcQ3IipzF5prigylS7XXjEkfCHuOE=
-github.com/go-sql-driver/mysql v1.6.0/go.mod h1:DCzpHaOWr8IXmIStZouvnhqoel9Qv2LBy8hT2VhHyBg=
+github.com/denisenkom/go-mssqldb v0.10.0 h1:QykgLZBorFE95+gO3u9esLd0BmbvpWp0/waNNZfHBM8=
+github.com/denisenkom/go-mssqldb v0.10.0/go.mod h1:xbL0rPBG9cCiLr28tMa8zpbdarY27NDyej4t/EjAShU=
+github.com/golang-sql/civil v0.0.0-20190719163853-cb61b32ac6fe h1:lXe2qZdvpiX5WZkZR4hgp4KJVfY3nMkvmwbVkpv1rVY=
+github.com/golang-sql/civil v0.0.0-20190719163853-cb61b32ac6fe/go.mod h1:8vg3r2VgvsThLBIFL93Qb5yWzgyZWhEmBwUJWevAkK0=
 github.com/gorilla/mux v1.8.0 h1:i40aqfkR1h2SlN9hojwV5ZA91wcXFOvkdNIeFDP5koI=
 github.com/gorilla/mux v1.8.0/go.mod h1:DVbg23sWSpFRCP0SfiEN6jmj59UnW/n46BH5rLB71So=
 github.com/joho/godotenv v1.3.0 h1:Zjp+RcGpHhGlrMbJzXTrZZPrWj+1vfm90La1wgB6Bhc=
@@ -13,5 +15,8 @@ github.com/pmezard/go-difflib v1.0.0/go.mod h1:iKH77koFhYxTK1pcRnkKkqfTogsbg7gZN
 github.com/sirupsen/logrus v1.8.1 h1:dJKuHgqk1NNQlqoA6BTlM1Wf9DOH3NBjQyu0h9+AZZE=
 github.com/sirupsen/logrus v1.8.1/go.mod h1:yWOB1SBYBC5VeMP7gHvWumXLIWorT60ONWic61uBYv0=
 github.com/stretchr/testify v1.2.2/go.mod h1:a8OnRcib4nhh0OaRAV+Yts87kKdq0PP7pXfy6kDkUVs=
+golang.org/x/crypto v0.0.0-20190325154230-a5d413f7728c h1:Vj5n4GlwjmQteupaxJ9+0FNOmBrHfq7vN4btdGoDZgI=
+golang.org/x/crypto v0.0.0-20190325154230-a5d413f7728c/go.mod h1:djNgcEr1/C05ACkg1iLfiJU5Ep61QUkGW8qpdssI0+w=
+golang.org/x/sys v0.0.0-20190215142949-d0b11bdaac8a/go.mod h1:STP8DvDyc/dI5b8T5hshtkjS+E42TnysNCUPdjciGhY=
 golang.org/x/sys v0.0.0-20191026070338-33540a1f6037 h1:YyJpGZS1sBuBCzLAR1VEpK193GlqGZbnPFnPV/5Rsb4=
 golang.org/x/sys v0.0.0-20191026070338-33540a1f6037/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=

main.go

@@ -18,6 +18,7 @@ type config struct {
 	DB_Password   string `json:"db_password"`
 	DB_Host       string `json:"db_host"`
 	DB_Database   string `json:"db_database"`
+	DB_Params     string `json:"db_params"`
 }
 
 func ReadConfig(source string) (c *config, err error) {
@@ -62,6 +63,7 @@ func run() error {
 	db_password := conf.DB_Password
 	db_host := conf.DB_Host
 	db_database := conf.DB_Database
+	db_params := conf.DB_Params
 
 	a := App{}
 	a.Initialize(
@@ -70,6 +72,7 @@ func run() error {
 		db_password,
 		db_host,
 		db_database,
+		db_params,
 	)
 
 	a.Run(conf.ListenAddress)