使用 MongoTemplate 插入并使用 @CreatedDate/@LastModifiedDate

Question

我有一个 pojo，如下所示：

@Document
public class MyPojo {
    @Id
    private String        id;
    ...
    @CreatedDate
    private ZonedDateTime createdAt;
    @LastModifiedDate
    private ZonedDateTime modifiedAt;
}

我想用以下逻辑插入一个文档：

• 如果文档是新文档，createdAt 和 modifiedAt 都设置为 now。
• 如果文档已经存在，createdAt 不应更新，modifiedAt 应设置为 now。

我尝试了以下代码：

MongoTemplate template = ...; // wired
MyPojo obj = new MyPojo();

template.findAndReplace(
        new Query().addCriteria(...),
        obj,
        new FindAndReplaceOptions().upsert());

这里，成员id、createdAt 和modifiedAt 未设置（因此它们是null）。

这似乎不起作用。数据库中文档 BSON 中的相应字段从不设置。

如何结合@CreatedDate 和@LastModifiedDate 注释来插入文档？这是可能的，还是我需要推出自己的东西。如果是后者，如何实现上述的 upsert 逻辑？

我正在使用以下配置：

@Configuration
@EnableMongoAuditing(dateTimeProviderRef = "dateTimeConverter")

这里，dateTimeProviderRef 用于支持ZonedDateTime 对象。

另外，我注意到当调用template.save(obj) 或template.insert(obj) 而不是findAndReplace(...)（如在我的代码sn-p 中）时，设置了createdAt 和modifiedAt创造，正如预期的那样。也就是说，我相信我需要 findAndReplace()，因为我需要一个原子 upsert 发生。

Answer 1

您需要在您的@SpringBootApplication 中使用@EnableMongoAuditing 来启用审计

@SpringBootApplication
@EnableMongoAuditing(modifyOnCreate = false)
public class DemoApplication {

此外，不支持 ZonedDateTime。请改用 Instant。

参考：

• CodecConfigurationException when saving ZonedDateTime to MongoDB with Spring Boot >= 2.0.1.RELEASE
• https://github.com/spring-projects/spring-boot/issues/10743

查看这个工作示例：

import lombok.Data;
import lombok.NoArgsConstructor;
import lombok.ToString;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.data.annotation.CreatedDate;
import org.springframework.data.annotation.Id;
import org.springframework.data.annotation.LastModifiedDate;
import org.springframework.data.mongodb.config.EnableMongoAuditing;
import org.springframework.data.mongodb.core.FindAndReplaceOptions;
import org.springframework.data.mongodb.core.MongoTemplate;
import org.springframework.data.mongodb.core.mapping.Document;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;

import java.time.Instant;

import static org.springframework.data.mongodb.core.query.Criteria.where;
import static org.springframework.data.mongodb.core.query.Query.query;

@SpringBootApplication
@EnableMongoAuditing
public class DemoApplication {
    public static void main(String[] args) {
        SpringApplication.run(DemoApplication.class, args);
    }
}

@RestController
class Ctrl {
    @Autowired
    MongoTemplate template;

    @GetMapping("/templ")
    void templ() throws InterruptedException {
        template.insert(new MyPojo("TOM"));
        template.insert(new MyPojo("HARRY"));


        Thread.sleep(2000);

        //update BOB to Robert if exists or insert new
        //should inert new
        template.findAndReplace(
                query(where("name").is("BOB")),
                new MyPojo("Robert"),
                new FindAndReplaceOptions().upsert());


        Thread.sleep(2000);

        //update TOM to Tommy if exists or insert new
        template.findAndReplace(
                query(where("name").is("TOM")),
                new MyPojo("Tommy"),
                new FindAndReplaceOptions().upsert());


        template.findAll(MyPojo.class).forEach(System.out::println);
    }
}

@Document
@Data
@ToString
@NoArgsConstructor
class MyPojo {
    public MyPojo(String name) {
        this.name = name;
    }

    @Id
    private String id;
    String name = "";
    @CreatedDate
    private Instant createdAt;

    @LastModifiedDate
    private Instant modifiedAt;
}

输出：

MyPojo(id=5f736d33b72165754ea9fca1, name=Tommy, createdAt=2020-09-29T17:21:59.765Z, modifiedAt=null)
MyPojo(id=5f736d33b72165754ea9fca2, name=HARRY, createdAt=2020-09-29T17:21:55.732Z, modifiedAt=null)
MyPojo(id=5f736d352e78c143350ed0f8, name=Robert, createdAt=2020-09-29T17:21:57.748Z, modifiedAt=null)