大佬教程收集整理的这篇文章主要介绍了Cloud Spanner DB - 无法从 ReadOnlyTransaction.getReadTimestamp() 读取时间戳,大佬教程大佬觉得挺不错的,现在分享给大家,也给大家做个参考。
我试图使用 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 尝试谷歌搜索这个问题,但没有找到太多。欢迎任何帮助:)
谢谢。 :)
看来您实际上并未对您启动的只读事务执行查询。执行查询的代码是:
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 - 无法从 ReadOnlyTransaction.getReadTimestamp() 读取时间戳所遇到的程序开发问题。
如果觉得大佬教程网站内容还不错,欢迎将大佬教程推荐给程序员好友。
本图文内容来源于网友网络收集整理提供,作为学习参考使用,版权属于原作者。
如您有任何意见或建议可联系处理。小编QQ:384754419,请注明来意。