2

我有spring boot + hibernate应用程序，现在我想使用 debezium 来捕获日期变化。假设这个类是我的 POJO 实体类之一：

@Entity
@Table(name = "app_user")
public class User {
    @Id @GeneratedValue
    @Column(name = "id")
    private long id;

    @Column(name = "first_name")
    private String firstName;

    @Column(name = "last_name")
    private String firstName;

    // getters and setters are omitted for brevity
}

@Entity
@Table(name = "app_article")
public class Article {
    @Id @GeneratedValue
    @Column(name = "id")
    private long id;

    @Column(name = "title")
    private String title;

    @Column(name = "category")
    private String category;

    @ManyToOne
    @JoinColumn(name = "created_by")
    private User createdBy;

    @ManyToOne
    @JoinColumn(name = "updated_by")
    private User updatedBy;

    @Column(name = "created_date")
    private Date createdDate;

    @Column(name = "updated_date")
    private Date updatedDate;

    // getters and setters are omitted for brevity
}

现在，如果我创建新Article对象并使用如下代码将其持久化：

Article article = new Article();

article.setId(1);
article.setTitle("Introduction to Debezium");
article.setCategory("auditing");
article.setCreatedBy(Utils.getCurrentUser());
article.setUpdatedBy(Utils.getCurrentUser());
article.setCreatedDate(new Date());
article.setUpdatedDate(new Date());

entityManager.persist(article);

然后再次加载并更改一些字段并将其持久化：

Article art = entityManager.load(Article.class, 1);

art.setTitle("Introduction to Debezium for beginners");
art.setCategory("auditing and cdc");
art.setCreatedBy(Utils.getCurrentUser());
art.setUpdatedBy(Utils.getCurrentUser());
art.setCreatedDate(new Date());
art.setUpdatedDate(new Date());

entityManager.persist(art);

然后删除它：

entityManager.delete(Article.class, 1);

我可能会在每个步骤中看到这样的日志：

// create
{
    "payload" : {
        "before" : null,
        "after" : {
            "id" : 1,
            "title" : "Introduction to Debezium",
            "category" : "auditing",
            "created_by" : 1,
            "updated_by" : 1,
            "created_date" : "11/29/2017",
            "updated_date" : "11/29/2017"
        },
        "source" : {
            "name" : "dbserver1",
            "server_id" : 223344,
            "ts_sec" : 1500369632,
            "gtid" : null,
            "file" : "mysql-bin.000003",
            "pos" : 364,
            "row" : 0,
            "snapshot" : null,
            "thread" : 13,
            "db" : "app",
            "table" : "app_article"
        },
        "op" : "c",
        "ts_ms" : 1500369632095
    }
}

// update
{
    "payload" : {
        "before" : {
            "id" : 1,
            "title" : "Introduction to Debezium",
            "category" : "auditing",
            "created_by" : 1,
            "updated_by" : 1,
            "created_date" : "11/29/2017",
            "updated_date" : "11/29/2017"
        }
        "after" : {
            "id" : 1,
            "title" : "Introduction to Debezium for beginners",
            "category" : "auditing and cdc",
            "created_by" : 1,
            "updated_by" : 1,
            "created_date" : "11/29/2017",
            "updated_date" : "11/29/2017"
        },
        "source" : {
            "name" : "dbserver1",
            "server_id" : 223344,
            "ts_sec" : 1500369632,
            "gtid" : null,
            "file" : "mysql-bin.000003",
            "pos" : 364,
            "row" : 0,
            "snapshot" : null,
            "thread" : 13,
            "db" : "app",
            "table" : "app_article"
        },
        "op" : "u",
        "ts_ms" : 1500369632095
    }
}

// delete
{
    "payload" : {
        "before" : {
            "id" : 1,
            "title" : "Introduction to Debezium for beginners",
            "category" : "auditing and cdc",
            "created_by" : 1,
            "updated_by" : 1,
            "created_date" : "11/29/2017",
            "updated_date" : "11/29/2017"
        },
        "after": null,
        "source" : {
            "name" : "dbserver1",
            "server_id" : 223344,
            "ts_sec" : 1500369632,
            "gtid" : null,
            "file" : "mysql-bin.000003",
            "pos" : 364,
            "row" : 0,
            "snapshot" : null,
            "thread" : 13,
            "db" : "app",
            "table" : "app_article"
        },
        "op" : "d",
        "ts_ms" : 1500369632095
    }
}

正如您在上面看到的，我无法检测到如何从数据库中删除记录。我怎么解决这个问题？我应该使用像Hibernate Enver这样的东西 来补充这个吗？

4

1 回答 1

2

您可以使用逻辑删除，这实际上不会Article从表中删除记录，而只是设置一个deleted标志。这样，用户将成为传输更新事件的一部分。

然后，您可以实施某种（异步运行的）内务处理，以物理方式删除记录。执行此删除的（技术）用户不会对由此产生的删除事件感兴趣。

于 2017-11-30T13:29:07.460 回答