Fix connection string

cmd/prepare/prepare.go

@@ -7,8 +7,6 @@ import (
 	"github.com/spf13/cobra"
 )
 
-var proxy = services.NewProxy()
-
 func NewCmdPrepare() *cobra.Command {
 	cmd := &cobra.Command{
 		Use:   "prepare",
@@ -21,6 +19,8 @@ func NewCmdPrepare() *cobra.Command {
 
 // Prepare appointments
 func prepareAppointments(cmd *cobra.Command, args []string) {
+	proxy := services.NewProxy()
+
 	msg, err := proxy.AppointmentService.PrepareAppointments()
 	if err != nil {
 		log.Fatal(err)

cmd/upload/upload.go

@@ -11,8 +11,6 @@ import (
 	"github.com/spf13/viper"
 )
 
-var proxy = services.NewProxy()
-
 func NewCmdUpload() *cobra.Command {
 	cmd := &cobra.Command{
 		Use:   "upload",
@@ -24,6 +22,8 @@ func NewCmdUpload() *cobra.Command {
 }
 
 func uploadAppointments(cmd *cobra.Command, args []string) {
+	proxy := services.NewProxy()
+
 	// Fetch appointments
 	appointments, err := proxy.AppointmentService.FetchAppointments()
 	if err != nil {

internal/data/database.go

@@ -16,10 +16,6 @@ type Database struct {
 	DB *sql.DB
 }
 
-func (d *Database) getConnection() sql.DB {
-	return *d.DB
-}
-
 // Close resources used by database
 func Close() error {
 	if database == nil {

internal/data/mssql.go

@@ -2,12 +2,12 @@ package data
 
 import (
 	"database/sql"
-	"os"
 
 	_ "github.com/denisenkom/go-mssqldb"
+	"github.com/spf13/viper"
 )
 
 func getConnection() (*sql.DB, error) {
-	conn := os.Getenv("CONN_STRING")
+	conn := viper.GetString("connection_string")
 	return sql.Open("mssql", conn)
 }

internal/repositories/appointment.go

@@ -32,7 +32,7 @@ func (r *AppointmentRepository) PrepareAppointments() (string, error) {
 		return "", err
 	}
 
-	message := fmt.Sprintf("Rows affected: %v", rowsAffected - 2)
+	message := fmt.Sprintf("Rows affected: %v", rowsAffected-2)
 	return message, nil
 }