From 1ba7142045430f85837f0b3f85a1bf542ddf0cb3 Mon Sep 17 00:00:00 2001
From: Brage <bskjon@outlook.com>
Date: Tue, 25 Jul 2023 00:30:38 +0200
Subject: [PATCH] Update

---
 .../src/main/resources/application.properties |  3 ++
 Reader/build.gradle.kts                       |  7 +++-
 .../content/reader/ReaderApplication.kt       | 35 +++++++++++++++++++
 3 files changed, 44 insertions(+), 1 deletion(-)
 create mode 100644 Convert/src/main/resources/application.properties

diff --git a/Convert/src/main/resources/application.properties b/Convert/src/main/resources/application.properties
new file mode 100644
index 00000000..f0fe28f8
--- /dev/null
+++ b/Convert/src/main/resources/application.properties
@@ -0,0 +1,3 @@
+spring.output.ansi.enabled=always
+logging.level.org.apache.kafka=WARN
+#logging.level.root=DEBUG
diff --git a/Reader/build.gradle.kts b/Reader/build.gradle.kts
index 44ad7a41..80d7294a 100644
--- a/Reader/build.gradle.kts
+++ b/Reader/build.gradle.kts
@@ -22,13 +22,18 @@ repositories {
     }
 }
 
+val exposedVersion = "0.38.2"
 dependencies {
     implementation("no.iktdev.streamit.library:streamit-library-kafka:0.0.2-alpha74")
     implementation("no.iktdev:exfl:0.0.12-SNAPSHOT")
 
     implementation("no.iktdev.streamit.library:streamit-library-db:0.0.6-alpha7")
 
-
+    implementation("org.jetbrains.exposed:exposed-core:$exposedVersion")
+    implementation("org.jetbrains.exposed:exposed-dao:$exposedVersion")
+    implementation("org.jetbrains.exposed:exposed-jdbc:$exposedVersion")
+    implementation("org.jetbrains.exposed:exposed-java-time:$exposedVersion")
+    implementation ("mysql:mysql-connector-java:8.0.29")
 
     implementation("com.github.pgreze:kotlin-process:1.3.1")
     implementation("com.github.vishna:watchservice-ktx:master-SNAPSHOT")
diff --git a/Reader/src/main/kotlin/no/iktdev/streamit/content/reader/ReaderApplication.kt b/Reader/src/main/kotlin/no/iktdev/streamit/content/reader/ReaderApplication.kt
index 617fd128..2f128c99 100644
--- a/Reader/src/main/kotlin/no/iktdev/streamit/content/reader/ReaderApplication.kt
+++ b/Reader/src/main/kotlin/no/iktdev/streamit/content/reader/ReaderApplication.kt
@@ -1,10 +1,22 @@
 package no.iktdev.streamit.content.reader
 
+import kotlinx.coroutines.launch
+import mu.KotlinLogging
+import no.iktdev.exfl.coroutines.Coroutines
 import no.iktdev.streamit.content.reader.analyzer.encoding.helpers.PreferenceReader
+import no.iktdev.streamit.library.db.datasource.MySqlDataSource
+import no.iktdev.streamit.library.db.tables.*
+import no.iktdev.streamit.library.db.tables.helper.cast_errors
+import no.iktdev.streamit.library.db.tables.helper.data_audio
+import no.iktdev.streamit.library.db.tables.helper.data_video
+import org.jetbrains.exposed.sql.SchemaUtils
+import org.jetbrains.exposed.sql.transactions.transaction
 import org.springframework.boot.autoconfigure.SpringBootApplication
 import org.springframework.boot.runApplication
 import org.springframework.context.ApplicationContext
 
+private val logger = KotlinLogging.logger {}
+
 @SpringBootApplication
 class ReaderApplication
 
@@ -17,6 +29,29 @@ fun getContext(): ApplicationContext? {
 }
 fun main(args: Array<String>) {
 
+    val ds = MySqlDataSource.fromDatabaseEnv().createDatabase()
+    System.out.println(ds)
+
+    Coroutines.default().launch {
+        val tables = arrayOf(
+            catalog,
+            genre,
+            movie,
+            serie,
+            subtitle,
+            summary,
+            users,
+            progress,
+            data_audio,
+            data_video,
+            cast_errors
+        )
+        transaction {
+            SchemaUtils.createMissingTablesAndColumns(*tables)
+            logger.info {"Database transaction completed"}
+        }
+    }
+
     context = runApplication<ReaderApplication>(*args)
 
 }