Update

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

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")

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)
 
 }