jOOQ fetch 与 fetchResultSet 以及 Kotlin 中的关闭连接

我使用 Kotlin 与 HikariCP 和 jOOQ 来查询我的数据库。我开始意识到这段代码按预期工作，获取行并随后关闭连接：

class CountriesService(private val datasource: DataSource) {

    private val countries = Countries()

    fun getCountries(): List<String> {
        DSL.using(datasource, SQLDialect.POSTGRES_10)
            .use { ctx ->
                ctx.select(countries.CO_NAME)
                    .from(countries)
                    .orderBy(countries.CO_NAME)
                    .fetch()
                return emptyList()
            }
    }
}

而如果我使用fetchResultSet()，连接永远不会关闭并且池会干涸：

class CountriesService(private val datasource: DataSource) {

    private val countries = Countries()

    fun getCountries(): List<String> {
        DSL.using(datasource, SQLDialect.POSTGRES_10)
            .use { ctx ->
                ctx.select(countries.CO_NAME)
                    .from(countries)
                    .orderBy(countries.CO_NAME)
                    .fetchResultSet()
                return emptyList()
            }
    }
}

我见过那个AbstractResultQuery#fetchResultSet()正在委托给fetchLazy()方法，所以不确定是否与此有关。

如果我自己获得连接而不是将其委托给DSLContext，然后它就起作用了：

class CountriesService(private val datasource: DataSource) {

    private val countries = Countries()

    fun getCountries(): List<String> {
        val conn = datasource.connection
        conn.use {
            DSL.using(it, SQLDialect.POSTGRES_10)
                .select(countries.CO_NAME)
                .from(countries)
                .orderBy(countries.CO_NAME)
                .fetchResultSet()
            return emptyList()
        }
    }
}

我应该使用最后一种方法吗？

它的工作原理与指定的完全一样Javadoc https://www.jooq.org/javadoc/latest/org/jooq/ResultQuery.html#fetchResultSet--:

这与调用相同fetchLazy().resultSet()并会返回一个ResultSet包装 JDBC 驱动程序ResultSet。关闭此 ResultSet 可能会关闭生产Statement or PreparedStatement，取决于您的设置keepStatement(boolean).

此方法的要点是您想要使用 JDBC 结果集，而不是让 jOOQ 为您使用它。因此，您负责资源管理。

鉴于您的示例代码，您绝对不应该调用此方法，而应该调用fetch()反而。例如：

class CountriesService(private val datasource: DataSource) {

    private val countries = Countries()

    fun getCountries(): List<String> {
        return
        DSL.using(datasource, SQLDialect.POSTGRES_10)
           .select(countries.CO_NAME)
           .from(countries)
           .orderBy(countries.CO_NAME)
           .fetch(countries.CO_NAME)
    }
}

请注意，您不需要调用它use()方法对你的DSLContext. While DSLContext延伸AutoCloseable，仅当您的DSLContext管理底层 JDBC 连接（即创建连接时）。在您的情况下，当您将数据源传递给DSL.using()，那么你不必关闭DSLContext.