53 lines
986 B
Go
53 lines
986 B
Go
package database
|
|
|
|
|
|
import (
|
|
"log"
|
|
//"time"
|
|
"fmt"
|
|
"gorm.io/driver/postgres"
|
|
"gorm.io/gorm"
|
|
)
|
|
|
|
type DatabaseHandle struct {
|
|
initialized bool
|
|
dbh *gorm.DB
|
|
}
|
|
|
|
func New() *DatabaseHandle {
|
|
var db DatabaseHandle
|
|
// inject the whole database configuration via the well-known PG* env variables
|
|
conn, err := gorm.Open(postgres.Open(""))
|
|
if err != nil {
|
|
log.Printf("Unable to open database connection: %s", err)
|
|
db.initialized = false
|
|
} else {
|
|
db.dbh = conn
|
|
db.initialized = true
|
|
//log.Println("Database connection opened")
|
|
}
|
|
return &db
|
|
}
|
|
|
|
func (self *DatabaseHandle) GetPersonById(id string) (string, error) {
|
|
if ! self.initialized {
|
|
err := fmt.Errorf("Database connection not initialized")
|
|
return "", err
|
|
}
|
|
|
|
var person Person
|
|
result := self.dbh.
|
|
Where("id = ?", id).
|
|
First(&person)
|
|
|
|
if result.Error != nil {
|
|
err := fmt.Errorf("Query failed: %s", result.Error)
|
|
return "", err
|
|
}
|
|
|
|
return person.Name, nil
|
|
}
|
|
|
|
|
|
|