0

我试图使用 ReadOnlyTransaction.getReadTimestamp() 函数，但我一直遇到异常：“方法只能在读取返回数据或完成后调用”我从数据库返回一两条记录，但我无法读取时间戳。下面是示例代码如何以及我在做什么。

IO {
  val db    = spannerClientInstance
  val rotxn = db.singleUseReadOnlyTransaction()

  val sql = "SELECT " +
    "Name " +
    "FROM Person " +
    "WHERE Name= @Name"

  val resultSet = db.singleUse.executeQuery(
    Statement.newBuilder(sql).bind("Name").to(name).build()
  )

  (resultSet, rotxn)
}.bracket {
  case (resultSet, rotxn) =>
    IO {
      val result =
        scala.collection.mutable.Map.empty[String, Person]

      while (resultSet.next()) {
        result += (resultSet.getString(0) -> new Person(resultSet.getString(0)))
      }

      (result.toMap, rotxn.getReadTimestamp)
    }
} {
  case (resultSet, _) =>
    IO(resultSet.close())
}

我尝试使用 resultSet.close() 和 rotxn.close() 关闭 resultSet 和/或 rotxn，然后调用 rotxn.getReadTimestamp()，但运气不佳。我得到了同样的错误信息。

我正在使用 Spanner Java 库：com.google.cloud:google-cloud-spanner:2.0.1 尝试用谷歌搜索该问题，但没有找到太多。欢迎任何帮助:)

谢谢。:)

4

1 回答 1

1

看来您实际上并没有对您启动的只读事务执行查询。执行查询的代码是：

  val resultSet = db.singleUse.executeQuery(
    Statement.newBuilder(sql).bind("Name").to(name).build()
  )

该查询使用的是一次性只读事务，而不是您以前的只读事务。尝试像这样执行它：

  val resultSet = rotxn.executeQuery(
    Statement.newBuilder(sql).bind("Name").to(name).build()
  )
于 2021-03-15T18:50:50.340 回答