Backup_Repos/komga
1
0
Fork 0
mirror of https://github.com/gotson/komga.git synced 2025-12-20 15:34:17 +01:00
Code Issues Projects Releases Wiki Activity

fix: fix potential database inconsistencies

Browse source
This commit is contained in:
Gauthier Roebroeck 2021-06-24 17:25:29 +08:00
parent 4d2393f500
commit 75ecbe15ba
1 changed files with 46 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

46
komga/src/flyway/kotlin/db/migration/sqlite/V20210624165023__missing_series_metadata.kt Normal file
View file

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