Init Database Methods

utils/database/databaseConnector.go

@@ -0,0 +1,63 @@
+package database
+
+import (
+	"database/sql"
+	"log"
+
+	_ "github.com/mattn/go-sqlite3"
+)
+
+func InitDB(filepath string) *sql.DB {
+	log.Printf("Init DB")
+	db, err := sql.Open("sqlite3", filepath)
+	if err != nil {
+		panic(err)
+	}
+	if db == nil {
+		panic("DB couldn't be initialized")
+	}
+
+	handleError(initDeviceTable(db))
+	handleError(initEventTable(db))
+	handleError(initRoomTable(db))
+	handleError(initTransactionTable(db))
+	handleError(initUserTable(db))
+
+	return db
+}
+
+func handleError(err error) {
+	if err != nil {
+		// TODO: Add Error Message
+		panic("Could not execute Database Query")
+	}
+}
+
+/*
+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()
+*/

utils/database/deviceDatabaseConnector.go

@@ -0,0 +1,29 @@
+package device
+
+import (
+	"database/sql"
+	
+	"nutfactory.org/Matrix/entities/device"
+)
+
+func initDeviceTable(db *sql.DB) err error {
+	// TODO: Change to correct Table-Structure
+	statement, err := db.Prepare("CREATE TABLE IF NOT EXISTS people (id INTEGER PRIMARY KEY, firstname TEXT, lastname TEXT)")
+	statement.Exec()
+}
+
+func createDevice(db *sql.DB, device *Device) err error {
+
+}
+
+func readDevice(db *sql.DB, id string) (device *Device, err error) {
+
+}
+
+func updateDevice(db *sql.DB, device *Device) err error {
+
+}
+
+func deleteDevice(db *sql.DB, id string) err error {
+
+}

utils/database/eventDatabaseConnector.go

@@ -0,0 +1,29 @@
+package event
+
+import (
+	"database/sql"
+
+	"nutfactory.org/Matrix/entities/event"
+)
+
+func initEventTable(db *sql.DB) err error {
+	// TODO: Change to correct Table-Structure
+	statement, err := db.Prepare("CREATE TABLE IF NOT EXISTS people (id INTEGER PRIMARY KEY, firstname TEXT, lastname TEXT)")
+	statement.Exec()
+}
+
+func createEvent(db *sql.DB, event *Event) err error {
+
+}
+
+func readEvent(db *sql.DB, id string) (event *Event, err error) {
+
+}
+
+func updateEvent(db *sql.DB, event *Event) err error {
+
+}
+
+func deleteEvent(db *sql.DB, id string) err error {
+
+}

utils/database/roomDatabaseConnector.go

@@ -0,0 +1,29 @@
+package room
+
+import (
+	"database/sql"
+
+	"nutfactory.org/Matrix/entities/room"
+)
+
+func initRoomTable(db *sql.DB) err error {
+	// TODO: Change to correct Table-Structure
+	statement, err := db.Prepare("CREATE TABLE IF NOT EXISTS people (id INTEGER PRIMARY KEY, firstname TEXT, lastname TEXT)")
+	statement.Exec()
+}
+
+func createRoom(db *sql.DB, room *Room) err error {
+
+}
+
+func readRoom(db *sql.DB, id string) (room *Room, err error) {
+
+}
+
+func updateRoom(db *sql.DB, room *Room) err error {
+
+}
+
+func deleteRoom(db *sql.DB, id string) err error {
+
+}

utils/database/transactionDatabaseConnector.go

@@ -0,0 +1,29 @@
+package transaction
+
+import (
+	"database/sql"
+
+	"nutfactory.org/Matrix/entities/transaction"
+)
+
+func initTransactionTable(db *sql.DB) err error {
+	// TODO: Change to correct Table-Structure
+	statement, err := db.Prepare("CREATE TABLE IF NOT EXISTS people (id INTEGER PRIMARY KEY, firstname TEXT, lastname TEXT)")
+	statement.Exec()
+}
+
+func createTransaction(db *sql.DB, transaction *Transaction) err error {
+
+}
+
+func readTransaction(db *sql.DB, id string) (transaction *Transaction, err error) {
+
+}
+
+func updateTransaction(db *sql.DB, transaction *Transaction) err error {
+
+}
+
+func deleteTransaction(db *sql.DB, id string) err error {
+
+}

utils/database/userDatabaseConnector.go

@@ -0,0 +1,29 @@
+package user
+
+import (
+	"database/sql"
+
+	"nutfactory.org/Matrix/entities/user"
+)
+
+func initUserTable(db *sql.DB) err error {
+	// TODO: Change to correct Table-Structure
+	statement, err := db.Prepare("CREATE TABLE IF NOT EXISTS people (id INTEGER PRIMARY KEY, firstname TEXT, lastname TEXT)")
+	statement.Exec()
+}
+
+func createUser(db *sql.DB, user *User) err error {
+
+}
+
+func readUser(db *sql.DB id string) (user *User, err error) {
+
+}
+
+func updateUser(db *sql.DB, user *User) err error {
+
+}
+
+func deleteUser(db *sql.DB, id string) err error {
+
+}