0

问题是关于 Scalar DB ( https://github.com/scalar-labs/scalardb )。

以下代码给出了com.scalar.db.exception.storage.NoMutationException: no mutation was applied.导致此错误的原因以及如何修复它？

  def updateConfirmedStatusAndDeleteToken(user:User,token:UserToken) = Future {
    val transaction: DistributedTransaction = transactionService.start
    logger.trace("transaction started: " + transaction);
    //Perform the operations you want to group in the transaction

    val pUserKey = new Key(new IntValue("bucket", utilities.bucketIDFromEmail(user.profile.externalProfileDetails.email)),
      new TextValue("email", user.profile.externalProfileDetails.email)
    )
    val cUserKey = new Key(
      new TextValue("authprovider", "credentials"),
      new TextValue("firstname", user.profile.externalProfileDetails.firstName),
      new TextValue("lastname", user.profile.externalProfileDetails.lastName)
    )
    logger.trace("created keys. ")
    val putUser: Put = new Put(pUserKey, cUserKey)
      .forNamespace("cj")
      .forTable("users")
      .withValue(new BooleanValue("confirmed", true))

    logger.trace(s"putting user with confirmed status ${putUser}")
    transaction.put(putUser)
    logger.trace(s"reading token before deleting")
    val pGetToken = new Key(new TextValue("token_id",token.tokenId.toString))
    val getToken:Get = new Get(pGetToken)
      .forNamespace("cj")
      .forTable("user_authentication_token")

    transaction.get(getToken)

    logger.trace(s"deleting token. Preparing keys using ${token}, ${token.tokenId.toString}")
    val pDeleteTokenKey = new Key(new TextValue("token_id",token.tokenId.toString))
    logger.trace(s"delete key is ${pDeleteTokenKey}")
    val deleteToken:Delete = new Delete(pDeleteTokenKey)
      .forNamespace("cj")
      .forTable("user_authentication_token")

    transaction.delete(deleteToken)

    try{
      logger.trace(s"committing")
      transaction.commit()
    } catch {
      case e1:UnknownTransactionStatusException =>{
        logger.error("error in commiting. Unknowns status")
        throw e1;

      }
      case e2:CommitException =>{
        logger.error("error in commiting. Rolling back")
        transaction.abort();
        throw e2;
      }
    }
  }
4

1 回答 1

1

问题在于我对 DistributedTransaction 的使用。我正在创建 DistributedTransaction 的单独实例，而不是在不同的数据库操作中使用单个实例。我在其他操作中创建了一个，updateConfirmedStatusAndDeleteToken但同样在其他操作中创建了新的。现在我从顶层传递实例，以便所有操作都使用同一个实例。

于 2020-07-21T06:41:43.737 回答