Thomas Peetz
51 lines
974 B
Go
51 lines
974 B
Go
package schema
|
|
|
|
import (
|
|
"database/sql"
|
|
"log"
|
|
|
|
"github.com/uptrace/bun"
|
|
"github.com/uptrace/bun/dialect/pgdialect"
|
|
"github.com/uptrace/bun/driver/pgdriver"
|
|
)
|
|
|
|
var DB *bun.DB
|
|
|
|
func Connect() error {
|
|
var err error
|
|
|
|
dsn := "postgres://kontor:kontor@postgres:5432/kontor?sslmode=disable"
|
|
sqldb := sql.OpenDB(pgdriver.NewConnector(pgdriver.WithDSN(dsn)))
|
|
|
|
sqldb.SetMaxOpenConns(4)
|
|
sqldb.SetMaxIdleConns(4)
|
|
|
|
DB := bun.NewDB(sqldb, pgdialect.New())
|
|
|
|
if err = DB.Ping(); err != nil {
|
|
return err
|
|
}
|
|
|
|
log.Println("Connection Opened to Database")
|
|
return nil
|
|
}
|
|
|
|
func GetDatabase() (*bun.DB, error) {
|
|
var err error
|
|
|
|
dsn := "postgres://kontor:kontor@postgres:5432/kontor?sslmode=disable"
|
|
sqldb := sql.OpenDB(pgdriver.NewConnector(pgdriver.WithDSN(dsn)))
|
|
|
|
sqldb.SetMaxOpenConns(4)
|
|
sqldb.SetMaxIdleConns(4)
|
|
|
|
DB := bun.NewDB(sqldb, pgdialect.New())
|
|
|
|
if err = DB.Ping(); err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
log.Println("Returned Database Connection")
|
|
return DB, nil
|
|
}
|