Test DB-Connection, Add CRUD Methods

entities/device/deviceController.go

@@ -0,0 +1,19 @@
+package device
+
+import "database/sql"
+
+func createDevice(db *sql.DB) {
+
+}
+
+func readDevice(db *sql.DB) {
+
+}
+
+func updateDevice(db *sql.DB) {
+
+}
+
+func deleteDevice(db *sql.DB) {
+
+}

entities/event/eventController.go

@@ -2,17 +2,20 @@ package event
 
 import (
 	"database/sql"
-
-	_ "github.com/mattn/go-sqlite3"
 )
 
-func InitDB(filepath string) *sql.DB {
-	db, err := sql.Open("sqlite3", filepath)
-	if err != nil {
-		panic(err)
-	}
-	if db == nil {
-		panic("db nil")
-	}
-	return db
+func createEvent(db *sql.DB) {
+
+}
+
+func readEvent(db *sql.DB) {
+
+}
+
+func updateEvent(db *sql.DB) {
+
+}
+
+func deleteEvent(db *sql.DB) {
+
 }

entities/room/roomController.go

@@ -0,0 +1,19 @@
+package room
+
+import "database/sql"
+
+func createRoom(db *sql.DB) {
+
+}
+
+func readRoom(db *sql.DB) {
+
+}
+
+func updateRoom(db *sql.DB) {
+
+}
+
+func deleteRoom(db *sql.DB) {
+
+}

entities/transaction/transactionController.go

@@ -0,0 +1,19 @@
+package transaction
+
+import "database/sql"
+
+func createTransaction(db *sql.DB) {
+
+}
+
+func readTransaction(db *sql.DB) {
+
+}
+
+func updateTransaction(db *sql.DB) {
+
+}
+
+func deleteTransaction(db *sql.DB) {
+
+}

entities/user/userController.go

@@ -0,0 +1,19 @@
+package user
+
+import "database/sql"
+
+func createUser(db *sql.DB) {
+
+}
+
+func readUser(db *sql.DB) {
+
+}
+
+func updateUser(db *sql.DB) {
+
+}
+
+func deleteUser(db *sql.DB) {
+
+}

main.go

@@ -5,6 +5,8 @@ import (
 	"fmt"
 	"log"
 	"net/http"
+	"os"
+	"strconv"
 
 	"nutfactory.org/Matrix/utils"
 	"nutfactory.org/Matrix/utils/router"
@@ -62,7 +64,6 @@ var routes = router.Routes{
 }
 
 func Test(w http.ResponseWriter, r *http.Request) {
-	fmt.Printf("TEST")
 	w.Header().Set("Content-Type", "application/json; charset=UTF-8")
 	w.WriteHeader(http.StatusOK)
 	if err := json.NewEncoder(w).Encode("Test"); err != nil {
@@ -71,9 +72,21 @@ func Test(w http.ResponseWriter, r *http.Request) {
 }
 
 func main() {
+	// TODO: Remove later
+	os.Remove("sqlite.db")
+
 	db := utils.InitDB("sqlite.db")
 	defer db.Close()
 
+	rows, _ := db.Query("SELECT id, firstname, lastname FROM people")
+	var id int
+	var firstname string
+	var lastname string
+	for rows.Next() {
+		rows.Scan(&id, &firstname, &lastname)
+		fmt.Println(strconv.Itoa(id) + ": " + firstname + " " + lastname)
+	}
+
 	router := router.NewRouter(routes)
 
 	//router.PathPrefix("/").Handler(http.FileServer(http.Dir(htmlPath)))

utils/databaseController.go

@@ -14,7 +14,41 @@ func InitDB(filepath string) *sql.DB {
 		panic(err)
 	}
 	if db == nil {
-		panic("db nil")
+		panic("DB couldn't be initialized")
 	}
+
+	// TODO: Change to correct DB-Structure
+	statement, _ := db.Prepare("CREATE TABLE IF NOT EXISTS people (id INTEGER PRIMARY KEY, firstname TEXT, lastname TEXT)")
+	statement.Exec()
+
 	return db
 }
+
+/*
+sqlStmt := fmt.Sprintf(`INSERT INTO data
+    (id, content)
+    VALUES
+    (?, ?)`)
+
+tx, err := db.Begin()
+if err != nil {
+    log.Panic(err)
+}
+
+stmt, err := tx.Prepare(sqlStmt)
+if err != nil {
+    return err
+}
+defer stmt.Close()
+
+for i := 1; i < 10; i++ {
+    id := fmt.Sprintf("%d", i)
+    content := fmt.Sprintf("content #%d %s", i, shortuuid.New())
+    log.Printf("Inserting %s: %s", id, content)
+    _, err := stmt.Exec(id, content)
+    if err != nil {
+        log.Panic(err)
+    }
+}
+tx.Commit()
+*/