Implement JDBC-based DatabaseProvider and DSL utilities for database module

Author: peco2282

database/database-api/src/main/kotlin/com/peco2282/devcore/database/dsl.kt

@@ -1,2 +1,84 @@
 package com.peco2282.devcore.database
 
+import org.jetbrains.exposed.v1.core.Table
+
+//import org.jetbrains.exposed.sql.Database
+//import org.jetbrains.exposed.sql.SchemaUtils
+//import org.jetbrains.exposed.sql.Table
+//import org.jetbrains.exposed.sql.transactions.transaction
+
+/**
+ * Marker annotation for Database DSL.
+ */
+@DslMarker
+annotation class DatabaseDsl
+
+/**
+ * Data class representing the configuration for a database connection.
+ *
+ * @property driver The JDBC driver class name.
+ * @property url The JDBC connection URL.
+ * @property user The username for the database connection.
+ * @property password The password for the database connection.
+ */
+data class DatabaseConfig(
+  val driver: String,
+  val url: String,
+  val user: String = "",
+  val password: String = ""
+)
+
+/**
+ * Abstract builder class for constructing a [DatabaseProvider].
+ */
+@DatabaseDsl
+abstract class DatabaseBuilder {
+  /**
+   * The database configuration.
+   */
+  var config: DatabaseConfig? = null
+
+  /**
+   * The list of tables to be managed by the database.
+   */
+  protected val tables = mutableListOf<Table>()
+
+  /**
+   * Sets the database configuration.
+   *
+   * @param config The [DatabaseConfig] object.
+   */
+  fun config(config: DatabaseConfig) {
+    this.config = config
+  }
+
+  /**
+   * Sets the database configuration using individual parameters.
+   *
+   * @param driver The JDBC driver class name.
+   * @param url The JDBC connection URL.
+   * @param user The username for the database connection.
+   * @param password The password for the database connection.
+   */
+  fun config(driver: String, url: String, user: String = "", password: String = "") {
+    this.config = DatabaseConfig(driver, url, user, password)
+  }
+
+  /**
+   * Registers one or more tables to the database.
+   * These tables will be created or updated upon initialization.
+   *
+   * @param table The tables to register.
+   */
+  fun table(vararg table: Table) {
+    tables.addAll(table)
+  }
+
+  /**
+   * Builds and returns a [DatabaseProvider] instance.
+   *
+   * @return A [DatabaseProvider] configured with the specified parameters.
+   * @throws IllegalStateException If the database configuration is not specified.
+   */
+  abstract fun build(): DatabaseProvider
+}

database/database-jdbc/build.gradle.kts

@@ -1,7 +1,7 @@
 version = properties["devcore.database.version"] ?: "1.0.0"
 
 dependencies {
-  api(project(":adventure"))
+  api(project(":database:database-api"))
   implementation("org.jetbrains.exposed:exposed-jdbc:1.0.0")
   implementation("com.zaxxer:HikariCP:7.0.0")
   compileOnly(libs.paper.api)

database/database-jdbc/src/main/kotlin/com/peco2282/devcore/database/jdbc/dsl.kt

@@ -0,0 +1,88 @@
+package com.peco2282.devcore.database.jdbc
+
+import com.peco2282.devcore.database.DatabaseBuilder
+import com.peco2282.devcore.database.DatabaseProvider
+import kotlinx.coroutines.Dispatchers
+import kotlinx.coroutines.withContext
+import org.jetbrains.exposed.v1.core.Transaction
+import org.jetbrains.exposed.v1.jdbc.Database
+import org.jetbrains.exposed.v1.jdbc.SchemaUtils
+import org.jetbrains.exposed.v1.jdbc.transactions.transaction
+import java.util.concurrent.CompletableFuture
+
+/**
+ * Creates a [DatabaseProvider] using JDBC.
+ *
+ * @param builder The configuration builder for the database.
+ * @return A configured [DatabaseProvider] instance.
+ * @throws IllegalStateException If the database configuration is not specified.
+ */
+fun createJdbc(builder: DatabaseBuilder.() -> Unit): DatabaseProvider = DatabaseBuilderImpl().apply(builder).build()
+
+/**
+ * Implementation of [DatabaseBuilder] for JDBC connections.
+ */
+internal class DatabaseBuilderImpl : DatabaseBuilder() {
+  /**
+   * Builds a [DatabaseProvider] with a JDBC connection.
+   * Connects to the database and initializes the registered tables.
+   *
+   * @return A [DatabaseProvider] instance.
+   * @throws IllegalStateException If the database configuration is not specified.
+   */
+  override fun build(): DatabaseProvider {
+    val cfg = config ?: throw IllegalStateException("Database config is not specified")
+    val db = Database.connect(
+      url = cfg.url,
+      driver = cfg.driver,
+      user = cfg.user,
+      password = cfg.password
+    )
+
+    // Table initialization
+    transaction(db) {
+      SchemaUtils.create(*tables.toTypedArray())
+    }
+
+    return DatabaseProviderImpl(db)
+  }
+}
+
+/**
+ * Default implementation of [DatabaseProvider].
+ *
+ * @property database The JetBrains Exposed [Database] instance.
+ */
+internal class DatabaseProviderImpl(val database: Database) : DatabaseProvider {
+  /**
+   * Executes a transaction synchronously.
+   *
+   * @param T The return type of the statement.
+   * @param statement The code to execute within the transaction.
+   * @return The result of the transaction.
+   */
+  override fun <T> dbQuery(statement: Transaction.() -> T): T = transaction(database, statement = statement)
+
+  /**
+   * Executes a transaction asynchronously using a [CompletableFuture].
+   *
+   * @param T The return type of the statement.
+   * @param statement The code to execute within the transaction.
+   * @return A [CompletableFuture] that will contain the result of the transaction.
+   */
+  override fun <T> dbQueryAsync(statement: Transaction.() -> T): CompletableFuture<T> = CompletableFuture.supplyAsync {
+    dbQuery(statement)
+  }
+
+  /**
+   * Executes a transaction asynchronously using Kotlin coroutines.
+   * This implementation uses [Dispatchers.IO] for non-blocking I/O.
+   *
+   * @param T The return type of the statement.
+   * @param statement The code to execute within the transaction.
+   * @return The result of the transaction.
+   */
+  override suspend fun <T> dbQuerySuspend(statement: Transaction.() -> T): T = withContext(Dispatchers.IO) {
+    dbQuery(statement)
+  }
+}