Update R2DBC configuration to use MariadbConnectionFactoryProvider and refine runtime classpath exclusions

Author: twisti-dev

build.gradle.kts

@@ -19,7 +19,7 @@ dependencies {
     implementation(libs.bundles.databaseDriver)
 }
 
-configurations.all {
+configurations.runtimeClasspath {
     exclude("io.projectreactor", "reactor-core")
     exclude("org.reactivestreams")
 }

src/main/kotlin/dev/slne/surf/database/DatabaseApi.kt

@@ -12,6 +12,7 @@ import org.jetbrains.exposed.v1.core.vendors.MariaDBDialect
 import org.jetbrains.exposed.v1.r2dbc.R2dbcDatabase
 import org.jetbrains.exposed.v1.r2dbc.R2dbcDatabaseConfig
 import org.jetbrains.exposed.v1.r2dbc.transactions.TransactionManager
+import org.mariadb.r2dbc.MariadbConnectionFactoryProvider
 import java.nio.file.Path
 import java.time.Duration.ofMillis
 
@@ -44,16 +45,19 @@ class DatabaseApi internal constructor(val database: R2dbcDatabase) {
 
             val connectionFactoryOptions = ConnectionFactoryOptions.builder().apply {
                 option(DRIVER, "pool")
-                option(PROTOCOL, "mariadb")
+                option(PROTOCOL, MariadbConnectionFactoryProvider.MARIADB_DRIVER)
                 option(HOST, config.credentials.host)
                 option(PORT, config.credentials.port)
                 option(USER, config.credentials.username)
                 option(PASSWORD, config.credentials.password)
                 option(DATABASE, config.credentials.database)
             }.build()
 
+            val connectionFactory = MariadbConnectionFactoryProvider()
+                .create(connectionFactoryOptions)
+
             val poolConfig = ConnectionPoolConfiguration.builder()
-                .connectionFactory(ConnectionFactories.get(connectionFactoryOptions))
+                .connectionFactory(connectionFactory)
                 .acquireRetry(1)
                 .initialSize(config.pool.sizing.initialSize)
                 .minIdle(config.pool.sizing.minIdle)
@@ -66,6 +70,8 @@ class DatabaseApi internal constructor(val database: R2dbcDatabase) {
                 .name(poolName)
                 .build()
 
+
+
             val pool = ConnectionPool(poolConfig)
             return create(pool, configCustomizer)
         }