updateBigDecimalでこの ResultSet はクローズされています（Kotlin×PostgreSQL）

Question

前提・実現したいこと

ResultSetでupdateBigDecimalしたい。

しかし、オープン状態のはずなのに下記のエラーが出てしまう。
"org.postgresql.util.PSQLException: この ResultSet はクローズされています。"

発生している問題・エラーメッセージ

org.postgresql.util.PSQLException: この ResultSet はクローズされています。
        at org.postgresql.jdbc.PgResultSet.checkClosed(PgResultSet.java:2741)
        at org.postgresql.jdbc.PgResultSet.findColumn(PgResultSet.java:2588)
        at org.postgresql.jdbc.PgResultSet.updateBigDecimal(PgResultSet.java:1467)
        秘匿

該当のソースコード

秘匿
try{
	秘匿
		rset = stmt!!.executeQuery(秘匿);
		println(rset!!.isClosed());//false
		while(rset!!.next()){
			秘匿
			println(rset!!.isClosed());//false
			rset!!.updateBigDecimal(秘匿));//PSQLExceptionの発生行
			rset!!.updateRow();
			println(rset!!.isClosed());
		}
		conn!!.commit();
		秘匿
	}
}catch(e: Exception){
	println(rset!!.isClosed());//false
	e.printStackTrace();
}finally{
	println(rset!!.isClosed());//false
}
秘匿

試したこと

各所でrset!!.isClosed()を出力してみましたが、すべてfalseで、オープンの状態でした。

私が思いつくのは下記のどちらかです。
isClosedではクローズ状態を判定できない。
または
（ないとは思いますが）表示されるエラーメッセージがおかしい。

補足情報（FW/ツールのバージョンなど）

・kotlincは1.3.60
・PostgreSQL12
・postgresql-42.2.5.jar

Comments

[shiketa]

参考まで。
[Kotlin入門までの助走読本](https://devlights.hatenablog.com/entry/2017/05/30/123344)の37-38ページ曰く。
> ...!!演算子は危険な操作であり、絶対に一生使わないくらいの気持ちでいるとよいでしょう。

[picohead]

頂いたリンクは残念ながら「Entry is not found」でした。

使い終わったらnullを代入するため、null許容型にしています。
Kotlinのガベージコレクションがよくわからず、これが正しいのかわかりません。

また、1つのSQL文ごとに各関数でDBの接続・切断を行っていたのですが、全体の処理時間の99%以上がDBの接続だったため、グローバル変数にして使いまわしたところ、処理時間は圧倒的に改善したのですが、!!演算子がないとコンパイルが通らなくなってしましました。
DBは占有可能な仕様のためOKとしましたが、この対応で良いのか、私自身、疑問に思っていました。

この場合、普通はどうするのが正解なのでしょうか。

[shiketa]

> 頂いたリンクは残念ながら「Entry is not found」でした。
あら。`Kotlin入門までの助走読本`でお探しください。

> 使い終わったらnullを代入するため、null許容型にしています。
Javaのtry-with-resouceぽいことができる use() 関数を使うのも手かと。
https://kotlinlang.org/api/latest/jvm/stdlib/kotlin.io/use.html
`conn.createStatement().use{stmt ->stmt.executeQuery(秘匿).use{rset -> ...}}`

> Kotlinのガベージコレクションがよくわからず、これが正しいのかわかりません。
結局はJVM上で動くので、べつにKotlinだからどうこうはないのではないかと。

> ...この場合、普通はどうするのが正解なのでしょうか。
接続プールを使う、かな。 https://www.postgresql.jp/document/7.4/html/jdbc-datasource.html

Answer 1

いちおてきとうな内容でデータを更新してみました。再現は、できませんでした。

import java.sql.DriverManager
import java.sql.ResultSet
import java.time.LocalDateTime

object xxHoge {
  @JvmStatic
  fun main(args: Array<String>) {
    DriverManager.getConnection("jdbc:postgresql://localhost:5432/test", "秘匿", "秘匿").use { conn ->
      println(conn::class.java)
      println(conn.metaData.driverName)
      println(conn.metaData.driverVersion)
      println(conn.metaData.jdbcMajorVersion)
      println(conn.metaData.jdbcMinorVersion)
      conn.createStatement().use { stmt ->
        stmt.execute("drop table if exists test")
        stmt.execute("create table test (id text primary key, name text, num bigint)")
        stmt.execute("insert into test (id, name, num) values('01', 'aa', 1)")
        stmt.execute("insert into test (id, name, num) values('02', 'bb', 2)")
        stmt.execute("insert into test (id, name, num) values('03', 'cc', 3)")

        println("--")
        stmt.executeQuery("select id, name, num from test").use { rs ->
          val meta = rs.metaData
          while (rs.next()) {
            val row =
                (1..meta.columnCount)
                    .map { index -> meta.getColumnName(index) to rs.getString(index) }
                    .toMap()
            println("row : ${row}")
          }
        }
      }

      conn.createStatement(ResultSet.TYPE_SCROLL_INSENSITIVE, ResultSet.CONCUR_UPDATABLE).use { stmt ->
        println("-- update")
        stmt.executeQuery("select id, name, num from test").use { rs ->
          val meta = rs.metaData
          while (rs.next()) {
            rs.updateString(2, LocalDateTime.now().toString())
            rs.updateBigDecimal(3, System.nanoTime().toBigDecimal())
            rs.updateRow()
          }
        }
      }

      conn.createStatement().use { stmt ->
        println("--")
        stmt.executeQuery("select id, name, num from test").use { rs ->
          val meta = rs.metaData
          while (rs.next()) {
            val row =
                (1..meta.columnCount)
                    .map { index ->
                      meta.getColumnName(index) to rs.getString(index)
                    }
                    .toMap()
            println("updated row : ${row}")
          }
        }
      }
    }
  }
}

//class org.postgresql.jdbc.PgConnection
//PostgreSQL JDBC Driver
//42.2.12
//4
//2
//--
//row : {id=01, name=aa, num=1}
//row : {id=02, name=bb, num=2}
//row : {id=03, name=cc, num=3}
//-- update
//--
//updated row : {id=01, name=2020-05-03T20:38:51.912669, num=24028744079186}
//updated row : {id=02, name=2020-05-03T20:38:51.949183, num=24028755991783}
//updated row : {id=03, name=2020-05-03T20:38:51.951468, num=24028758275722}

---

useを使用するにはどうしたら良いでしょうか。

追記。

IntelliJでGradleの新規プロジェクトをJavaとKotlin/JVMを選択して生成したときのbuild.gradleを添付しておきます。なお、JDBCドライバ(PostgreSQ)Lの依存だけは手動で追加しました。以外は生成したままです。おそらくkotlin-stdlibの追加が必要なのでしょう。

plugins {
    id 'java'
    id 'org.jetbrains.kotlin.jvm' version '1.3.72'
}

group 'org.example'
version '1.0-SNAPSHOT'

repositories {
    mavenCentral()
}

dependencies {
    implementation "org.jetbrains.kotlin:kotlin-stdlib-jdk8"
    testCompile group: 'junit', name: 'junit', version: '4.12'
    runtime group: 'org.postgresql', name: 'postgresql', version: '42.2.12'
}

compileKotlin {
    kotlinOptions.jvmTarget = "1.8"
}
compileTestKotlin {
    kotlinOptions.jvmTarget = "1.8"
}

Comments

[picohead]

ソースありがとうございます。
書き方は異なりますが、アドバイス通りResultSetの定数を渡しつつcreateStatementしてexecuteQueryしてupdate～するのは一緒なんですね。。。

use使ってないことなどに原因があるのかと思い、ソースを試してみたところ、コンパイルエラーが出て、
import java.sql.Connection;
import java.sql.Statement;
を追記して型を明示したところ、.useの全行で下記のコンパイルエラーとなりました。
============
UpdTest.kt:11:113: error: unresolved reference. None of the following candidates is applicable because of receiver type mismatch:
@InlineOnly public inline fun <T : Closeable?, R> ???.use(block: (???) -> ???): ??? defined in kotlin.io
DriverManager.getConnection(秘匿).use { conn: Connection ->
============
useを使用するにはどうしたら良いでしょうか。

[picohead]

申し訳ございません。
updateBigDecimal(秘匿)の秘匿部分で、別の自作関数を呼び出していました。
そちらで共有しているグローバル変数のconnをcommitしており、その際にクローズされていたようで、別で接続したら解決しました。

なお、kotlin-stdlibを追加しても同じエラーでした。
エラーメッセージにもdefined in kotlin.ioとありますし、下記と類似の現象なのかと思いました。
https://qiita.com/m-sugawara/items/f462136bc53dc709ee3a
こちらは本題ではありませんので、空いた時に調査を続けてみようかなと思います。

長い間、お付き合い頂きありがとうございました！！

Answer 2

肝心の部分が提示されていないので、あくまでも推測です。「スクロールまたは更新、あるいはその両方が可能なResultSetオブジェクトを生成」していないのでは？

see: https://docs.oracle.com/javase/jp/8/docs/api/java/sql/ResultSet.html

スクロールまたは更新、あるいはその両方が可能なResultSetオブジェクトを生成できます。conが有効なConnectionオブジェクトである次のコード・フラグメントは、スクロール可能でほかで行われた更新を反映しない結果セット、および更新可能な結果セットの作成方法を示しています。

       Statement stmt = con.createStatement(
                                      ResultSet.TYPE_SCROLL_INSENSITIVE,
                                      ResultSet.CONCUR_UPDATABLE);
       ResultSet rs = stmt.executeQuery("SELECT a, b FROM TABLE2");
       // rs will be scrollable, will not show changes made by others,
       // and will be updatable

Comments

[picohead]

ご回答ありがとうございます。
試してみましたが、エラーの内容は変わりませんでした。
しかし、オープンになった時、「更新可能でない」的なエラーが想定されるため、おかげさまで未来のエラーを先に潰せたのかなと思います。

[shiketa]

コメント取り下げます。