|
|
|
package database
|
|
|
|
|
|
|
|
import (
|
|
|
|
"database/sql"
|
|
|
|
"log"
|
|
|
|
|
|
|
|
"gitlab.dedyn.io/AUDIAG/rtcusertr/domain"
|
|
|
|
|
|
|
|
_ "github.com/go-sql-driver/mysql"
|
|
|
|
)
|
|
|
|
|
|
|
|
var (
|
|
|
|
dbConnection = "rtcusertrdbuser:hurtz3585@tcp(ubodroid-1:3306)/rtcusertrdb"
|
|
|
|
dbType = "mysql"
|
|
|
|
)
|
|
|
|
|
|
|
|
// Tool Funktionen
|
|
|
|
func CreateKnoten(knoten domain.KnotenE) (resKnoten domain.KnotenE, 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 = ", knoten.Fachbereich)
|
|
|
|
defer conn.Close()
|
|
|
|
|
|
|
|
res, err := conn.Exec("INSERT INTO knoten VALUES(?,?,?,?)", knoten.Id, knoten.Fachbereich, knoten.Anzahl, knoten.Tag)
|
|
|
|
if err != nil {
|
|
|
|
log.Println("Error while executing insert statement", err)
|
|
|
|
}
|
|
|
|
lastId, err := res.LastInsertId()
|
|
|
|
knoten.Id = uint(lastId)
|
|
|
|
resKnoten = knoten
|
|
|
|
|
|
|
|
return resKnoten, err
|
|
|
|
}
|
|
|
|
|
|
|
|
func DeleteKnoten(knotenId 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 knoten WHERE id = ?", knotenId)
|
|
|
|
if err != nil {
|
|
|
|
log.Fatal("Error while executing DELETE statement", err)
|
|
|
|
}
|
|
|
|
return result, err
|
|
|
|
}
|
|
|
|
|
|
|
|
func ShowKnoten() (knotenArray []domain.KnotenE, 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 knoten")
|
|
|
|
if err != nil {
|
|
|
|
log.Fatal("Error while executing SELECt statement", err)
|
|
|
|
}
|
|
|
|
|
|
|
|
var knoten domain.KnotenE
|
|
|
|
for results.Next() {
|
|
|
|
err = results.Scan(&knoten.Id, &knoten.Fachbereich, &knoten.Anzahl, &knoten.Tag)
|
|
|
|
if err != nil {
|
|
|
|
log.Fatal("Error: ", err)
|
|
|
|
}
|
|
|
|
knotenArray = append(knotenArray, knoten)
|
|
|
|
}
|
|
|
|
return knotenArray, err
|
|
|
|
}
|
|
|
|
|
|
|
|
func GetKnoten(id uint) (knoten domain.KnotenE, 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 knoten WHERE id=?", id)
|
|
|
|
if err != nil {
|
|
|
|
log.Fatal("Error while executing SELECt statement", err)
|
|
|
|
}
|
|
|
|
for results.Next() {
|
|
|
|
err = results.Scan(&knoten.Id, &knoten.Fachbereich, &knoten.Anzahl, &knoten.Tag)
|
|
|
|
if err != nil {
|
|
|
|
log.Fatal("Error: ", err)
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
return knoten, err
|
|
|
|
}
|
|
|
|
|
|
|
|
func UpdateKnoten(knoten domain.KnotenE) (resKnoten domain.KnotenE, 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 = ", knoten.Fachbereich)
|
|
|
|
defer conn.Close()
|
|
|
|
|
|
|
|
_, err = conn.Exec("UPDATE knoten SET fachbereich=?, anzahl=?, tag=? WHERE id=?", knoten.Fachbereich, knoten.Anzahl, knoten.Tag, knoten.Id)
|
|
|
|
if err != nil {
|
|
|
|
log.Println("Error while executing insert statement", err)
|
|
|
|
}
|
|
|
|
|
|
|
|
resKnoten = knoten
|
|
|
|
|
|
|
|
return resKnoten, err
|
|
|
|
}
|