package main

import (
	"database/sql"
	"fmt"
	"log"

	_ "github.com/lib/pq"
)

// Set a new db connection
func (s *Switch) newDBConn() error {
	// open pgsql database
	if s.PGhost == "" {
		s.PGhost = "localhost"
	}
	if s.PGport == "" {
		s.PGport = "5432"
	}
	openQuery := "user=" + s.PGuser +
		" password=" + s.PGpasswd +
		" dbname=" + s.PGdbname +
		" host=" + s.PGhost +
		" port=" + s.PGport +
		" sslmode=disable"

	log.Printf("%v", openQuery) // user=gerep password= dbname=managerdev host=localhost port=5432 sslmode=disable
	db, err := sql.Open("postgres", openQuery)

	// test and open pgsql connection
	err = db.Ping()
	log.Printf("%v", err)
	if err == nil {
		lock.Lock()
		s.DB = db
		//s.DB.SetMaxIdleConns(700)
		//s.DB.SetMaxOpenConns(700)
		lock.Unlock()
	} else {
		err = fmt.Errorf("cannot connect to the database err=%v\n", err)
	}

	return err
}