我如何确定更新查询是否在 Cassandra Datastax 中成功
how do I find out if the update query was successful or not in Cassandra Datastax
我想更新一个row
。我的代码成功更新了 row
,但我发现 ResultSet
没有给我有用的信息,我可以用这些信息来判断更新是否成功。
我正在创建如下查询:
QueryBuilder.update(tableName).`with`(QueryBuilder.set("confirmed",model.profile.internalProfileDetails.get.confirmed))/*(QueryBuilder.set("authprovider",model.profile.internalProfileDetails.get.loginInfo.providerID))
.and(QueryBuilder.set("id",model.id))
.and(QueryBuilder.set("password",model.profile.internalProfileDetails.get.passwordInfo.get.password))
.and(QueryBuilder.set("hasher",model.profile.internalProfileDetails.get.passwordInfo.get.hasher))
.and(QueryBuilder.set("salt",""/*model.profile.internalProfileDetails.get.passwordInfo.get.salt.get*/))
.where(QueryBuilder.eq("bucket", id.bucket))
.and(QueryBuilder.eq("email", id.email))
.and(QueryBuilder.eq("authprovider", id.authProvider))
.and(QueryBuilder.eq("firstname",id.firstName))
.and(QueryBuilder.eq("lastname",id.lastName))
然后我用session.execute
println("update Query: "+updateQuery)
val resultSet = session.execute(updateQuery)
println("resultSet from update: "+resultSet)
但是打印出来的 ResultSet
是 resultSet from update: ResultSet[ exhausted: true, Columns[]]
。它真的没有告诉我手术是否成功。如何查看操作是否成功?
它与 INSERT 相同 - 如果您没有返回异常,则执行操作,并使用给定的一致性级别(默认为 ONE)进行确认。
我想更新一个row
。我的代码成功更新了 row
,但我发现 ResultSet
没有给我有用的信息,我可以用这些信息来判断更新是否成功。
我正在创建如下查询:
QueryBuilder.update(tableName).`with`(QueryBuilder.set("confirmed",model.profile.internalProfileDetails.get.confirmed))/*(QueryBuilder.set("authprovider",model.profile.internalProfileDetails.get.loginInfo.providerID))
.and(QueryBuilder.set("id",model.id))
.and(QueryBuilder.set("password",model.profile.internalProfileDetails.get.passwordInfo.get.password))
.and(QueryBuilder.set("hasher",model.profile.internalProfileDetails.get.passwordInfo.get.hasher))
.and(QueryBuilder.set("salt",""/*model.profile.internalProfileDetails.get.passwordInfo.get.salt.get*/))
.where(QueryBuilder.eq("bucket", id.bucket))
.and(QueryBuilder.eq("email", id.email))
.and(QueryBuilder.eq("authprovider", id.authProvider))
.and(QueryBuilder.eq("firstname",id.firstName))
.and(QueryBuilder.eq("lastname",id.lastName))
然后我用session.execute
println("update Query: "+updateQuery)
val resultSet = session.execute(updateQuery)
println("resultSet from update: "+resultSet)
但是打印出来的 ResultSet
是 resultSet from update: ResultSet[ exhausted: true, Columns[]]
。它真的没有告诉我手术是否成功。如何查看操作是否成功?
它与 INSERT 相同 - 如果您没有返回异常,则执行操作,并使用给定的一致性级别(默认为 ONE)进行确认。