Kotlin中JDBC操作MySQL的代码冗余问题优化咨询

你的写法不是完全错误，但存在大量重复逻辑（资源管理、查询模板），还有几个小问题需要修正：

• 重复执行SQL：executeQuery之后又调用stmt.execute，会重复执行同一条查询
• 每次查询后关闭连接：如果conn是全局复用的连接，每次查询后关闭会导致后续操作无法使用，应该改用连接池或合理控制连接生命周期

下面是几种高效的优化方案：

1. 用Kotlin的use简化资源管理 #

Kotlin的use函数会自动实现AutoCloseable接口对象的资源释放，替代繁琐的finally代码块，彻底消除重复的资源关闭逻辑。

2. 提取泛型通用查询方法 #

将重复的查询逻辑抽成通用方法，只把表名和ResultSet到实体的映射函数作为参数传入，实现代码复用。

示例代码 #

首先封装通用工具方法：

import java.sql.Connection
import java.sql.ResultSet

fun <T> Connection.queryAll(tableName: String, mapper: (ResultSet) -> T): List<T> {
    val sql = "SELECT * FROM $tableName;"
    return this.createStatement().use { stmt ->
        stmt.executeQuery(sql).use { rs ->
            val result = mutableListOf<T>()
            while (rs.next()) {
                result.add(mapper(rs))
            }
            result
        }
    }
}

然后你原来的两个方法可以简化成：

fun loadAllPatients(conn: Connection): List<Patient> {
    return conn.queryAll("patient") { rs ->
        Patient(
            rs.getInt("patientID"),
            rs.getString("first_name"),
            rs.getString("last_name"),
            rs.getDate("birthday")
        )
    }
}

fun loadAllEntries(conn: Connection): List<Entry> {
    return conn.queryAll("entry") { rs ->
        Entry(
            rs.getInt("entryID"),
            rs.getInt("patientID"),
            rs.getInt("therapyID"),
            rs.getInt("status"),
            rs.getString("comment"),
            rs.getInt("creator"),
            rs.getInt("employee"),
            rs.getDate("creation_date"),
            rs.getDate("start_date"),
            rs.getDate("end_date")
        )
    }
}

这样所有表的查询都只需要编写映射逻辑，重复的资源管理、查询执行逻辑都被统一封装。

3. 进阶：使用ORM框架 #

如果想彻底摆脱手动映射和JDBC模板代码，可以用Kotlin专属的ORM框架：

• Exposed：JetBrains官方推出的轻量级ORM，完全用Kotlin语法编写，无需XML或注解，支持DSL风格的查询
• Spring Data JPA：如果项目使用Spring生态，JPA可以自动生成CRUD方法，只需定义实体类和Repository接口

Exposed示例（简化版） #

1. 引入依赖后，定义实体：

object Patients : Table() {
    val patientID = integer("patientID").autoIncrement()
    val firstName = varchar("first_name", 50)
    val lastName = varchar("last_name", 50)
    val birthday = date("birthday")
}

2. 查询所有数据：

fun loadAllPatients(): List<Patient> {
    return transaction {
        Patients.selectAll().map {
            Patient(it[Patients.patientID], it[Patients.firstName], it[Patients.lastName], it[Patients.birthday])
        }
    }
}

ORM框架会自动处理连接管理、SQL生成和结果映射，大幅减少重复代码。

内容的提问来源于stack exchange，提问作者Sc4rocko