1

我必须使用 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)返回的“过期”属性值始终为 0 的文档（是 SDK 的错误，还是只是预期的行为？），所以当我我正在尝试 upsert 检索到的文档，“过期”为 0：

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

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

4

1 回答 1

0

您必须在您的基类中设置 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);
    }
}
}
于 2019-08-28T06:47:31.177 回答