Backup_Repos/komga
1
0
Fork 0
mirror of https://github.com/gotson/komga.git synced 2026-05-08 12:35:30 +02:00
Code Issues Projects Releases Wiki Activity

fix: expose configuration for transaction mode

Browse source
This commit is contained in:
Gauthier Roebroeck 2022-07-22 11:55:21 +08:00
parent ce8f80e6ee
commit 218e3006f9
3 changed files with 11 additions and 5 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

3
komga/src/main/kotlin/org/gotson/komga/infrastructure/configuration/KomgaProperties.kt
View file

@ -4,6 +4,7 @@ import org.springframework.boot.context.properties.ConfigurationProperties
import org.springframework.boot.convert.DurationUnit import org.springframework.boot.convert.DurationUnit
import org.springframework.stereotype.Component import org.springframework.stereotype.Component
import org.springframework.validation.annotation.Validated import org.springframework.validation.annotation.Validated
import org.sqlite.SQLiteConfig.TransactionMode
import java.time.Duration import java.time.Duration
import java.time.temporal.ChronoUnit import java.time.temporal.ChronoUnit
import javax.validation.constraints.NotBlank import javax.validation.constraints.NotBlank
@ -73,6 +74,8 @@ class KomgaProperties {
@get:Positive @get:Positive
var maxPoolSize: Int = 8 var maxPoolSize: Int = 8
var transactionMode: TransactionMode = TransactionMode.DEFERRED
} }
class Lucene { class Lucene {

5
komga/src/main/kotlin/org/gotson/komga/infrastructure/datasource/DataSourcesConfiguration.kt
View file

@ -20,10 +20,13 @@ class DataSourcesConfiguration(
val sqliteUdfDataSource = DataSourceBuilder.create() val sqliteUdfDataSource = DataSourceBuilder.create()
.driverClassName("org.sqlite.JDBC") .driverClassName("org.sqlite.JDBC")
.url("jdbc:sqlite:${komgaProperties.database.file}?foreign_keys=on;") .url("jdbc:sqlite:${komgaProperties.database.file}")
.type(SqliteUdfDataSource::class.java) .type(SqliteUdfDataSource::class.java)
.build() .build()
sqliteUdfDataSource.setEnforceForeignKeys(true)
sqliteUdfDataSource.setTransactionMode(komgaProperties.database.transactionMode.name)
val poolSize = val poolSize =
if (komgaProperties.database.file.contains(":memory:")) 1 if (komgaProperties.database.file.contains(":memory:")) 1
else Runtime.getRuntime().availableProcessors().coerceAtMost(komgaProperties.database.maxPoolSize) else Runtime.getRuntime().availableProcessors().coerceAtMost(komgaProperties.database.maxPoolSize)

8
komga/src/main/kotlin/org/gotson/komga/infrastructure/datasource/SqliteUdfDataSource.kt
View file

@ -3,15 +3,15 @@ package org.gotson.komga.infrastructure.datasource
import com.ibm.icu.text.Collator import com.ibm.icu.text.Collator
import mu.KotlinLogging import mu.KotlinLogging
import org.gotson.komga.language.stripAccents import org.gotson.komga.language.stripAccents
import org.springframework.jdbc.datasource.SimpleDriverDataSource
import org.sqlite.Collation import org.sqlite.Collation
import org.sqlite.Function import org.sqlite.Function
import org.sqlite.SQLiteConnection import org.sqlite.SQLiteConnection
import org.sqlite.SQLiteDataSource
import java.sql.Connection import java.sql.Connection
private val log = KotlinLogging.logger {} private val log = KotlinLogging.logger {}
class SqliteUdfDataSource : SimpleDriverDataSource() { class SqliteUdfDataSource : SQLiteDataSource() {
companion object { companion object {
const val udfStripAccents = "UDF_STRIP_ACCENTS" const val udfStripAccents = "UDF_STRIP_ACCENTS"
@ -21,8 +21,8 @@ class SqliteUdfDataSource : SimpleDriverDataSource() {
override fun getConnection(): Connection = override fun getConnection(): Connection =
super.getConnection().also { addAllUdf(it as SQLiteConnection) } super.getConnection().also { addAllUdf(it as SQLiteConnection) }
override fun getConnection(username: String, password: String): Connection = override fun getConnection(username: String?, password: String?): SQLiteConnection =
super.getConnection(username, password).also { addAllUdf(it as SQLiteConnection) } super.getConnection(username, password).also { addAllUdf(it) }
private fun addAllUdf(connection: SQLiteConnection) { private fun addAllUdf(connection: SQLiteConnection) {
createUdfRegexp(connection) createUdfRegexp(connection)