fix: changed the database sqlite -> postgresql

2 files changed, 17 insertions, 18 deletions

diff --git a/opendc-experiments/opendc-experiments-base/src/main/kotlin/org/opendc/experiments/base/runner/ConfigParser.kt b/opendc-experiments/opendc-experiments-base/src/main/kotlin/org/opendc/experiments/base/runner/ConfigParser.kt
index 0e354cbd..26244544 100644
--- a/opendc-experiments/opendc-experiments-base/src/main/kotlin/org/opendc/experiments/base/runner/ConfigParser.kt
+++ b/opendc-experiments/opendc-experiments-base/src/main/kotlin/org/opendc/experiments/base/runner/ConfigParser.kt
@@ -4,17 +4,12 @@ import kotlinx.serialization.ExperimentalSerializationApi
 import kotlinx.serialization.Serializable
 import kotlinx.serialization.json.Json
 import kotlinx.serialization.json.decodeFromStream
-import java.io.BufferedReader
-import java.io.BufferedWriter
+
 import java.io.File
 import java.io.IOException
 import java.io.InputStream
-import java.io.InputStreamReader
 import java.io.OutputStream
-import java.io.OutputStreamWriter
-import java.net.ServerSocket
 import java.net.Socket
-import java.net.SocketImpl
 import java.sql.Connection
 import java.sql.DriverManager
 import java.sql.SQLException
@@ -29,16 +24,20 @@ import java.sql.SQLException
  */
 @Serializable
 public data class Config(
-    var name: String = "",
+    val name: String = "",
     var backlog: Int = 0,
-    val databasePath: String = "",
+    val database: Int = 5342,
     val address: String = "",
     val port: Int = 8080,
+    val username : String = "",
+    val password : String = "",
+    val schema: String = ""
 ){
+
     public companion object{
         public var input: InputStream? = null
         public var output: OutputStream? = null
-        public var database: Connection? = null
+        public var connection : Connection? = null
 
         public var socket: Socket? = null
 
@@ -60,17 +59,17 @@ public data class Config(
             return output
         }
 
-        public fun setupDatabase(path : String) : Connection?{
-            val url = "jdbc:sqlite:$path"
+        public fun setupDatabase(address : String, port : Int, dbUser : String, dbPassword : String, dbSchema : String){
+            val dbUrl = "jdbc:postgresql://$address:$port/$dbSchema"
+            println(dbUrl)
             try {
-                this.database = DriverManager.getConnection(url)
-                return database
-            } catch (e : SQLException) {
-                print("${e.message}")
-                return null
+                connection = DriverManager.getConnection(dbUrl, dbUser, dbPassword)
+                } catch (e: SQLException) {
+                    print("${e.message}")
+                }
             }
+
         }
-    }
 }
 /**
  * Reads `config.json` into Config data class.
diff --git a/opendc-experiments/opendc-experiments-base/src/main/kotlin/org/opendc/experiments/base/runner/ExperimentCli.kt b/opendc-experiments/opendc-experiments-base/src/main/kotlin/org/opendc/experiments/base/runner/ExperimentCli.kt
index b9395001..96eb3b21 100644
--- a/opendc-experiments/opendc-experiments-base/src/main/kotlin/org/opendc/experiments/base/runner/ExperimentCli.kt
+++ b/opendc-experiments/opendc-experiments-base/src/main/kotlin/org/opendc/experiments/base/runner/ExperimentCli.kt
@@ -91,7 +91,7 @@ internal class ExperimentListener: CliktCommand(name = "listener") {
 
         try {
             serverSocket = ServerSocket(config.port, config.backlog, inetAddress)
-            Config.setupDatabase(config.databasePath)
+            Config.setupDatabase(config.address, config.database, config.username, config.password, config.schema)
             runListener(serverSocket)
         } catch (e: IOException) {
             println("${e.message}")