java - 如何使用Couchbase Java SDK修改存储桶中的文档而不更改其 "expiration"值？

Question

我必须使用 Java SDK 修改 Couchbase 存储桶中的文档(目前它是版本 2.7.7 中的 Java 客户端，但是，如果需要，可以更改)，而不更改其“过期”值。存储桶中没有索引，并且无法使用 N1QL 查询，因此我必须坚持使用键/值操作。

以下是描述问题所在以及我迄今为止尝试过的最小示例:
我的存储桶中有一个 json 文档，它是使用 Java SDK 创建的:

JsonObject obj = JsonObject.create()
    //Setting some essential data ... 
    .put(“lessImportant”, “This shouldn’t influence on the expiration time”);
int expiry = ((int)Instant.now().getEpochSecond()) + someOffset;
JsonDocument doc = JsonDocument.create("msg::42", expiry, obj);
bucket.insert(doc);

我想获取这个对象并修改它的“lessImportant”属性，但我不想在执行此操作时更改对象元数据中的“过期”值。

当我尝试设置属性并重新发送对象时:

JsonDocument doc = bucket.get(“msg::42”)
doc.content.put(“otherData”, “I hope expiration remains the same”);
bucket.upsert(doc); 

或者创建新的而不指定过期值:

JsonObject obj = oldDoc.content();
obj.put(“otherData”, “I hope expiration remains the same”);
JsonDocument doc = JsonDocument.create(oldDoc.id(), obj);
bucket.upsert(doc);

或者与upsert()替换为replace()相同，然后我可以看到每次更新文档时，它的“过期”值都被删除(它设置为0，这对于Couchbase来说意味着插入后它应该将此文档视为没有设置过期日期 - 该文档应该永远保留)

正如我在创建 JsonDocument 时观察到的那样，没有显式设置“过期”:

JsonDocument.create(String id, int expiry, JsonObject data);  

那么默认情况下该值被设置为 0:

JsonDocument.create(String id, JsonObject data); //0 is the default`  

此外，事实证明，无论存储桶内的实际过期时间是多少，bucket.get(String id) 返回的文档始终具有相同的“expiration”属性值，即 0(这是 SDK 的错误，还是只是预期的行为？)，因此当我尝试更新插入检索到的文档时，“expiration”为 0:

bucket.upsert(JsonDocument.create(
    “msg::123”, SOME_EXPIRATION, obj));//sets expiration SOME_EXPIRATION
bucket.upsert(bucket.get(“msg::123”));//resets expiration to 0

是否可以以不修改此特定元数据的方式更新文档，或者获取旧的“过期”值，以便在插入之前将其设置为正确的值？

Answer 1

你必须在你的基类中设置Expiration时间，当SDK通过扩展AbstractCouchbaseConfiguration来读取文档时，并在写入此类文档时将其设置回来，下面给出了一个示例

import com.ishfaqhaider.MyCustomClass;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.data.couchbase.config.AbstractCouchbaseConfiguration;
import org.springframework.data.couchbase.core.convert.MappingCouchbaseConverter;
import org.springframework.data.couchbase.core.mapping.CouchbaseDocument;
import org.springframework.data.couchbase.repository.config.EnableCouchbaseRepositories;

@Configuration
@EnableCouchbaseRepositories(basePackages = {"com.ishfaqhaider"})
public class CouchbaseConfig extends AbstractCouchbaseConfiguration {

@Bean
@Override
public MappingCouchbaseConverter mappingCouchbaseConverter() throws Exception {
    final MappingCouchbaseConverter converter = new MyCouchbaseConverter(couchbaseMappingContext());
    return converter;
}

static class MyCouchbaseConverter extends MappingCouchbaseConverter {
    @Override
    public <R> R read(final Class<R> clazz, final CouchbaseDocument source) {
        R r= super.read(clazz, source);
        if(clazz==MyCustomClass.class){
        ((MyCustomClass)r).setExpiration(source.getExpiration());
        }
        return r;
    }
    @Override
    public void write(final Object source, final CouchbaseDocument target) {
        if(source instanceof MyCustomClass){
            target.setExpiration(((MyCustomClass)source).getExpiration());
        }
        super.write(source, target);
    }
}
}