|
|
|
package main
|
|
|
|
|
|
|
|
import (
|
|
|
|
"database/sql"
|
|
|
|
"log"
|
|
|
|
|
|
|
|
_ "github.com/go-sql-driver/mysql"
|
|
|
|
)
|
|
|
|
|
|
|
|
var (
|
|
|
|
dbConnection = "wdmdbuser:wdmdbpass@tcp(ubodroid-2:3300)/wdmdb"
|
|
|
|
dbType = "mysql"
|
|
|
|
)
|
|
|
|
|
|
|
|
// Tool Funktionen
|
|
|
|
func CreateTyp(typ Typ) (resTyp Typ, err error) {
|
|
|
|
conn, err := sql.Open(dbType, dbConnection)
|
|
|
|
if err != nil {
|
|
|
|
log.Println("Error while connecting DB: ", err)
|
|
|
|
}
|
|
|
|
log.Println("Verbindung hergestellt")
|
|
|
|
log.Println("Name = ", typ.Bezeichnung)
|
|
|
|
defer conn.Close()
|
|
|
|
res, err := conn.Exec("INSERT INTO typ VALUES(?,?)", typ.Id, typ.Bezeichnung)
|
|
|
|
if err != nil {
|
|
|
|
log.Println("Error while executing insert statement", err)
|
|
|
|
}
|
|
|
|
lastId, err := res.LastInsertId()
|
|
|
|
typ.Id = uint(lastId)
|
|
|
|
resTyp = typ
|
|
|
|
return resTyp, err
|
|
|
|
}
|
|
|
|
|
|
|
|
func DeleteTyp(typId uint) (result, err error) {
|
|
|
|
conn, err := sql.Open(dbType, dbConnection)
|
|
|
|
if err != nil {
|
|
|
|
log.Println("Error while connecting DB: ", err)
|
|
|
|
}
|
|
|
|
log.Println("DB Verbindung hergestellt")
|
|
|
|
defer conn.Close()
|
|
|
|
_, err = conn.Exec("DELETE FROM ncinstanz WHERE id = ?", typId)
|
|
|
|
if err != nil {
|
|
|
|
log.Fatal("Error while executing DELETE statement", err)
|
|
|
|
}
|
|
|
|
return result, err
|
|
|
|
}
|
|
|
|
|
|
|
|
func ShowTyp() (typArray []Typ, err error) {
|
|
|
|
conn, err := sql.Open(dbType, dbConnection)
|
|
|
|
if err != nil {
|
|
|
|
log.Println("Error while connecting DB: ", err)
|
|
|
|
}
|
|
|
|
log.Println("DB Verbindung hergestellt")
|
|
|
|
defer conn.Close()
|
|
|
|
results, err := conn.Query("SELECT * FROM typ")
|
|
|
|
if err != nil {
|
|
|
|
log.Fatal("Error while executing SELECt statement", err)
|
|
|
|
}
|
|
|
|
var typ Typ
|
|
|
|
for results.Next() {
|
|
|
|
err = results.Scan(&typ.Id, &typ.Bezeichnung)
|
|
|
|
if err != nil {
|
|
|
|
log.Fatal("Error: ", err)
|
|
|
|
}
|
|
|
|
typArray = append(typArray, typ)
|
|
|
|
}
|
|
|
|
return typArray, err
|
|
|
|
}
|
|
|
|
|
|
|
|
func GetTyp(id uint) (typ Typ, err error) {
|
|
|
|
conn, err := sql.Open(dbType, dbConnection)
|
|
|
|
if err != nil {
|
|
|
|
log.Println("Error while connecting DB: ", err)
|
|
|
|
}
|
|
|
|
log.Println("DB Verbindung hergestellt")
|
|
|
|
defer conn.Close()
|
|
|
|
results, err := conn.Query("SELECT * FROM typ WHERE id=?", id)
|
|
|
|
if err != nil {
|
|
|
|
log.Fatal("Error while executing SELECt statement", err)
|
|
|
|
}
|
|
|
|
for results.Next() {
|
|
|
|
err = results.Scan(&typ.Id, &typ.Bezeichnung)
|
|
|
|
if err != nil {
|
|
|
|
log.Fatal("Error: ", err)
|
|
|
|
}
|
|
|
|
}
|
|
|
|
return typ, err
|
|
|
|
}
|
|
|
|
|
|
|
|
func UpdateTyp(typ Typ) (resTyp Typ, err error) {
|
|
|
|
conn, err := sql.Open(dbType, dbConnection)
|
|
|
|
if err != nil {
|
|
|
|
log.Println("Error while connecting DB: ", err)
|
|
|
|
}
|
|
|
|
log.Println("Verbindung hergestellt")
|
|
|
|
log.Println("Name = ", typ.Bezeichnung)
|
|
|
|
defer conn.Close()
|
|
|
|
_, err = conn.Exec("UPDATE typ SET bezeichnung=? WHERE id=?", typ.Bezeichnung, typ.Id)
|
|
|
|
if err != nil {
|
|
|
|
log.Println("Error while executing insert statement", err)
|
|
|
|
}
|
|
|
|
resTyp = typ
|
|
|
|
return resTyp, err
|
|
|
|
}
|