Update dialect support

Author: ammodev

api/surf-database-r2dbc.api

@@ -5,9 +5,9 @@ public final class dev/slne/surf/database/DatabaseApi {
 }
 
 public final class dev/slne/surf/database/DatabaseApi$Companion {
-	public final fun create (Lio/r2dbc/spi/ConnectionFactory;Lnet/kyori/adventure/text/logger/slf4j/ComponentLogger;Lorg/slf4j/event/Level;Lkotlin/jvm/functions/Function1;)Ldev/slne/surf/database/DatabaseApi;
+	public final fun create (Lio/r2dbc/spi/ConnectionFactory;Lorg/jetbrains/exposed/v1/core/vendors/DatabaseDialect;Lnet/kyori/adventure/text/logger/slf4j/ComponentLogger;Lorg/slf4j/event/Level;Lkotlin/jvm/functions/Function1;)Ldev/slne/surf/database/DatabaseApi;
 	public final fun create (Ljava/nio/file/Path;Ljava/lang/String;Ljava/lang/String;Lkotlin/jvm/functions/Function1;)Ldev/slne/surf/database/DatabaseApi;
-	public static synthetic fun create$default (Ldev/slne/surf/database/DatabaseApi$Companion;Lio/r2dbc/spi/ConnectionFactory;Lnet/kyori/adventure/text/logger/slf4j/ComponentLogger;Lorg/slf4j/event/Level;Lkotlin/jvm/functions/Function1;ILjava/lang/Object;)Ldev/slne/surf/database/DatabaseApi;
+	public static synthetic fun create$default (Ldev/slne/surf/database/DatabaseApi$Companion;Lio/r2dbc/spi/ConnectionFactory;Lorg/jetbrains/exposed/v1/core/vendors/DatabaseDialect;Lnet/kyori/adventure/text/logger/slf4j/ComponentLogger;Lorg/slf4j/event/Level;Lkotlin/jvm/functions/Function1;ILjava/lang/Object;)Ldev/slne/surf/database/DatabaseApi;
 	public static synthetic fun create$default (Ldev/slne/surf/database/DatabaseApi$Companion;Ljava/nio/file/Path;Ljava/lang/String;Ljava/lang/String;Lkotlin/jvm/functions/Function1;ILjava/lang/Object;)Ldev/slne/surf/database/DatabaseApi;
 }
 

gradle.properties

@@ -3,4 +3,4 @@ kotlin.stdlib.default.dependency=false
 org.gradle.parallel=true
 #org.gradle.caching=true
 #org.gradle.configureondemand=true
-version=2.0.1
+version=2.0.2

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

@@ -11,6 +11,7 @@ import io.r2dbc.postgresql.PostgresqlConnectionFactory
 import io.r2dbc.spi.ConnectionFactory
 import io.r2dbc.spi.IsolationLevel
 import net.kyori.adventure.text.logger.slf4j.ComponentLogger
+import org.jetbrains.exposed.v1.core.vendors.DatabaseDialect
 import org.jetbrains.exposed.v1.core.vendors.MariaDBDialect
 import org.jetbrains.exposed.v1.core.vendors.PostgreSQLDialect
 import org.jetbrains.exposed.v1.r2dbc.R2dbcDatabase
@@ -115,8 +116,14 @@ class DatabaseApi internal constructor(val database: R2dbcDatabase) {
             val logger = ComponentLogger.logger(caller)
             val logLevel = config.logLevel
 
+            val dialect = when (databaseType) {
+                DatabaseType.MARIADB -> MariaDBDialect()
+                DatabaseType.POSTGRESQL -> PostgreSQLDialect()
+            }
+
             return create(
                 connectionFactory = pool,
+                dialect = dialect,
                 logger = logger,
                 logLevel = logLevel,
                 configCustomizer = configCustomizer
@@ -131,21 +138,19 @@ class DatabaseApi internal constructor(val database: R2dbcDatabase) {
          * [create(Path, String, R2dbcDatabaseConfig.Builder.() -> Unit)] for normal usage.
          *
          * @param connectionFactory The factory to connect with (e.g., testcontainers, in-memory, custom pool).
+         * @param dialect The database dialect to use (e.g., MariaDB, Postgres).
+         * @param logger Optional logger for Exposed's SQL logging (defaults to a logger named "DatabaseApi").
+         * @param logLevel Optional log level for Exposed's SQL logging (
          * @param configCustomizer Optional customization hook for Exposed's [R2dbcDatabaseConfig].
          */
         @TestOnlyDatabaseApi
         fun create(
             connectionFactory: ConnectionFactory,
+            dialect: DatabaseDialect,
             logger: ComponentLogger = ComponentLogger.logger("DatabaseApi"),
             logLevel: Level = Level.DEBUG,
             configCustomizer: R2dbcDatabaseConfig.Builder.() -> Unit = {}
         ): DatabaseApi {
-            val dialect = when (connectionFactory) {
-                is MariadbConnectionFactory -> MariaDBDialect()
-                is PostgresqlConnectionFactory -> PostgreSQLDialect()
-                else -> throw IllegalArgumentException("Unsupported ConnectionFactory type: ${connectionFactory::class.java.name}")
-            }
-
             val database = R2dbcDatabase.connect(connectionFactory, R2dbcDatabaseConfig {
                 explicitDialect = dialect
                 sqlLogger = ComponentSqlLogger(logger, logLevel)