Couchbase PagingAndSortingRepository .save() 奇怪的行为？

如何解决Couchbase PagingAndSortingRepository .save() 奇怪的行为？

大家好，提前感谢您看这个问题。我在 Java Spring Boot（Java JDK 1.8 版）上使用 Couchbase Server community-6.6.0。

问题描述：为了与 Couchbase 交互，我使用了 PagingAndSortingRepository 存储库。每次我调用 .save() 时，都会在 Couchbase 中创建一个代表我正在使用的对象的新实例的新文档。此外，当我从 Couchbase 检索对象时，更改某些字段的值，例如 .setPassword() 然后调用 .save() 使更改持久化，然后我会得到该对象的新文档（带有新的 Id）被创建在沙发基地。在我看来，当我调用 .save() 时，数据库中存在该对象的许多不同修订版，我想确保我始终在处理该对象/实体实例的最新版本。

我真的很困惑！我想要做的应该很简单，每次更新 Java 实体时，我都希望对 Couchbase 中的该文档（具有该文档 ID）进行持久更改。也许我在这里遗漏了一些东西。请指教。

pom 的部分视图如下所示：

    <parent>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-parent</artifactId>
        <version>2.4.0</version>
        <relativePath/> <!-- lookup parent from repository -->
    </parent>
...

        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-data-couchbase</artifactId>
        </dependency>

实体如下：

@Data
@Document
@CompositeQueryIndex(fields = {"id","userName"})
public class User implements Serializable {

    private static final long serialVersionUID = 1L;
    
    @IdPrefix
    private String prefix;
    
    @Id @NotNull @GeneratedValue( delimiter = "::",strategy = GenerationStrategy.UNIQUE)
    private String id;
    
    @Field
    @NotNull
    @Size(min=2,max=40)
    private String firstname;

    @Field
    @NotNull
    @QueryIndexed
    private String username;
    
    //Other attributes here ...
}


//ConfirmationToken Entity

@Data
@NoArgsConstructor
@CompositeQueryIndex(fields = {"id","confirmationToken"})
public class ConfirmationToken {
    
    
    @IdPrefix
    private String prefix = "token";
    
    @Id @NotNull @GeneratedValue(delimiter = "::",strategy = GenerationStrategy.UNIQUE)
    private String id;
    
    @Field
    @Reference
    private User user;
    
    @Field
    @QueryIndexed
    private String confirmationToken;
    
     //Other attributes here ...
    
}

UserRepository 看起来像：

@Repository
public interface UserRepository extends PagingAndSortingRepository<User,Long> {
    
    @ScanConsistency(query = QueryScanConsistency.REQUEST_PLUS)
    List<User> findByUsername(String username);

}

@Service
@AllArgsConstructor
public class ConfirmationTokenServiceImpl implements ConfirmationTokenService {

    @Autowired
    private final ConfirmationTokenRepository confirmationTokenRepository;  
    
    @Override
    public void saveConfirmationToken(ConfirmationToken confirmToken) {
        confirmationTokenRepository.save(confirmToken);
    }

    
}//end class

当我想从 Couchbase 检索用户对象时，我执行以下操作：

  //How do I ensure this Object is the latest version of that document?
  List<User> users = userRepository.findByUsername(username);

  //The following does not ensure that I get the latest version of that User document with that username
  User testUser = users.get(users.size()-1);  

在某些方法中，我更改了该 Java 对象的字段值，即用户，然后当我调用 .save(User Object) 时，在数据库中创建了该用户文档的新修订版。如何更新该用户对象的字段并使该文档在数据库中持久化而不创建该文档的新修订版？另外，我如何确保我始终获取并处理那个用户文档的最新版本？

public void someMethod(UserDTO regForm,final String contextPath) {
        
        User testUser = new User();
        
        testUser.setFirstname(regForm.getFname());
        testUser.setLastname(regForm.getSname());

        //Make User persistent
        userRepository.save(testUser);
        
        //Create the confirmation token for that User instance
        final ConfirmationToken confirmToken = new ConfirmationToken(testUser);

        confirmationTokenService.saveConfirmationToken(confirmToken);
}

在这个方法中，我有另一个名为 ConfirmationToken 的类，它引用了一个用户对象。这是为了将每个 ConfirmationToken 实例与特定的 User 实例相关联。当我调用以下方法来更改用户密码时，会为数据库中的用户创建一个具有新 ID 的新文档。我无法理解如何更新当前实例。请帮忙。

    public void changeUserPassword(ConfirmationToken confirmToken,ResetPassDTO resetPassForm) {
        
        //Retrieve the User instance that is associated with that Token 
        final User testUser = confirmToken.getUser();
        
        if (testUser.getEmail().equals(resetPassForm.getEmail())) {
        
            //Get the Hash of the User's password
            final String encryptedPassword = bCryptPasswordEncoder.encode(resetPassForm.getNewPassword());
            testUser.setPassword(encryptedPassword);
        
            //Enable the user account - since email ownership is also verified
            testUser.setIsEnabled(true);

            userRepository.save(testUser);
            
        }
        
        //Delete the Confirmation Token entity      
        confirmationTokenService.deleteConfirmationToken(confirmToken); 
        
    }

更新：

看来我不得不回去为实体进行域建模。更具体地说，考虑 couchbase 如何进行文档嵌入以及何时进行引用。在我的示例中， ConfirmationToken 实例包含对 User 实例的引用。实际上， ConfirmationToken 将 User 实例嵌入到同一个 JSON 文档中。我无法访问我想要的实际用户对象。换句话说，我似乎无法通过从 ConfirmationToken 实例中遵循 User 对象的 id 来取消引用和获取 User 实例。 我的解决方案：我在 User 对象中引入了一个 uuid 字段，然后我从 ConfirmationToken 中获取了一个 User 实例的引用，然后我才调用 userRepository.findByUuid(userFromToken.getUuid()); 之后我才能够获取我想要的实际 User 对象。我的问题是为什么 Couchbase spring SDK 不能自动取消引用？此外，似乎当我更改某些属性的值时，更改不会发生在实际对象上，而是发生在嵌入上，因此每次我都需要取消引用以手动获取真实对象时。这类似于 MongoDB @DBRefs??不确定是否有 N1QL 和 NEST 查询的解决方案？我可以使用 N1QL 实现这一目标吗？