From 75ecbe15baee9c91d209675cd20f488fff907fce Mon Sep 17 00:00:00 2001
From: Gauthier Roebroeck <gauthier.roebroeck@gmail.com>
Date: Thu, 24 Jun 2021 17:25:29 +0800
Subject: [PATCH] fix: fix potential database inconsistencies

---
 ...20210624165023__missing_series_metadata.kt | 46 +++++++++++++++++++
 1 file changed, 46 insertions(+)
 create mode 100644 komga/src/flyway/kotlin/db/migration/sqlite/V20210624165023__missing_series_metadata.kt

diff --git a/komga/src/flyway/kotlin/db/migration/sqlite/V20210624165023__missing_series_metadata.kt b/komga/src/flyway/kotlin/db/migration/sqlite/V20210624165023__missing_series_metadata.kt
new file mode 100644
index 000000000..32cd1a9de
--- /dev/null
+++ b/komga/src/flyway/kotlin/db/migration/sqlite/V20210624165023__missing_series_metadata.kt
@@ -0,0 +1,46 @@
+package db.migration.sqlite
+
+import mu.KotlinLogging
+import org.apache.commons.lang3.StringUtils
+import org.flywaydb.core.api.migration.BaseJavaMigration
+import org.flywaydb.core.api.migration.Context
+import org.springframework.jdbc.core.JdbcTemplate
+import org.springframework.jdbc.datasource.SingleConnectionDataSource
+
+private val logger = KotlinLogging.logger {}
+
+class V20210624165023__missing_series_metadata : BaseJavaMigration() {
+  override fun migrate(context: Context) {
+    val jdbcTemplate = JdbcTemplate(SingleConnectionDataSource(context.connection, true))
+
+    val seriesWithoutMetada = jdbcTemplate.queryForList(
+      """select s.ID, s.NAME from SERIES s where s.ID not in (select sm.SERIES_ID from SERIES_METADATA sm)"""
+    )
+
+    if (seriesWithoutMetada.isNotEmpty()) {
+      logger.info { "Found ${seriesWithoutMetada.size} series without metadata" }
+
+      seriesWithoutMetada
+        .map {
+          // fields for SERIES_METADATA: SERIES_ID, STATUS=ONGOING, TITLE, TITLE_SORT, READING_DIRECTION=null, AGE_RATING=null
+          arrayOf(it["ID"], "ONGOING", it["NAME"], StringUtils.stripAccents(it["NAME"].toString()), null, null)
+        }.let { parameters ->
+          jdbcTemplate.batchUpdate(
+            "INSERT INTO SERIES_METADATA(SERIES_ID, STATUS, TITLE, TITLE_SORT, READING_DIRECTION, AGE_RATING) VALUES (?,?,?,?,?,?)",
+            parameters,
+          )
+        }
+
+      seriesWithoutMetada
+        .map {
+          // fields for BOOK_METADATA_AGGREGATION: SERIES_ID, RELEASE_DATE=null
+          arrayOf(it["ID"], null)
+        }.let { parameters ->
+          jdbcTemplate.batchUpdate(
+            "INSERT INTO BOOK_METADATA_AGGREGATION(SERIES_ID, RELEASE_DATE) VALUES (?,?)",
+            parameters,
+          )
+        }
+    }
+  }
+}