Cloud Spanner DB - 无法从 ReadOnlyTransaction.getReadTimestamp() 读取时间戳

Question

我试图使用 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 and/or rotxn，然后调用 rotxn.getReadTimestamp()，但运气不佳。我收到了同样的错误信息。

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

谢谢。 :)

Answer 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()
  )

Cloud Spanner DB - 无法从 ReadOnlyTransaction.getReadTimestamp() 读取时间戳

Cloud Spanner DB - Unable to read timestamp from ReadOnlyTransaction.getReadTimestamp()

google-cloud-platform

google-cloud-spanner

google-cloud-spanner-emulator