From c658916dde0dbfaf6ffb0acf6875ec8f3652b2a4 Mon Sep 17 00:00:00 2001 From: Peder Vatn Austad Date: Sat, 25 May 2024 10:29:49 +0200 Subject: [PATCH] 0.2.2 insert into db fiorst iteration hardcoded --- config/conf.json | 12 +----------- database/ServiceDeliveryDB.go | 23 +++++++++++++++++++++++ main.go | 13 +++++++++++-- 3 files changed, 35 insertions(+), 13 deletions(-) create mode 100644 database/ServiceDeliveryDB.go diff --git a/config/conf.json b/config/conf.json index 6082579..222ba71 100644 --- a/config/conf.json +++ b/config/conf.json @@ -1,11 +1 @@ -{ - "database": { - "host": "localhost", - "port": "5432", - "user": "postgres", - "password": "postgres", - "dbname": "ti1", - "sslmode": "disable" - }, - "temp": "value" -} \ No newline at end of file +just in case i ducked up .gitignore \ No newline at end of file diff --git a/database/ServiceDeliveryDB.go b/database/ServiceDeliveryDB.go new file mode 100644 index 0000000..2c26bd8 --- /dev/null +++ b/database/ServiceDeliveryDB.go @@ -0,0 +1,23 @@ +package database + +import ( + "database/sql" + "fmt" +) + +func InsertServiceDelivery(db *sql.DB) (int, error) { + fmt.Println("Inserting ServiceDelivery...") + var id int + + responseTimestamp := "2024-05-25T10:24:29.353864654+02:00" + recordedAtTime := "2024-05-25T10:24:29.353864654+02:00" + + err := db.QueryRow("INSERT INTO public.ServiceDelivery (ResponseTimestamp, RecordedAtTime) VALUES ($1, $2) RETURNING ID", responseTimestamp, recordedAtTime).Scan(&id) + fmt.Println(err) + if err != nil { + return 0, err + } + fmt.Println("ID:", id) + fmt.Println("ServiceDelivery inserted successfully!") + return id, nil +} diff --git a/main.go b/main.go index 4d23ae2..1ef0e37 100644 --- a/main.go +++ b/main.go @@ -3,7 +3,8 @@ package main import ( "log" "ti1/config" - "ti1/data" // Import the data package + "ti1/data" + "ti1/database" "ti1/export" ) @@ -11,7 +12,15 @@ func main() { config.PrintDBConfig() config.ConnectToPostgreSQL() - data, err := data.FetchData() // Use the FetchData function from the data package + db, err := config.ConnectToPostgreSQL() + if err != nil { + log.Fatal(err) + } + //log.Printf("DB: %+v", db) + + database.InsertServiceDelivery(db) + + data, err := data.FetchData() if err != nil { log.Fatal(err) }