Spring Boot：使用EntityListeners监听JPA实体持久化_springboot 监听数据库表插入 jpa @postpersist

之前的文章<<Spring Boot：Spring Data JPA开启审计功能，自动保存操作人操作时间>>介绍过JPA自动存储操作人、操作时间等信息，在开发过程中我们可能遇到需要对实体的其他属性信息在增删改前后进行监听的情况，从原理上来说之前的文章只是一种特例，SpringBoot框架已经帮我们实现。这里记录一下通过Spring Data JPA的EntityListeners注解实现自定义监听的过程。下面案例对之前的代码进行改造，未涉及到的源码具体可参照<<Spring Boot：Idea从零开始初始化后台项目>>。

1 创建自定义监听组件

创建组件类CompanyListener实现对HCompany实体的持久化监听（这里监听方法中仅仅打印日志信息，具体监听业务操作视情况而定）。监听操作主要通过以下几个注解实现，通过将方法添加指定注解完成在实体持久化不同阶段的监听：

• @PrePersist 在实体保存到数据库之前执行的操作
• @PostPersist 在实体保存到数据库之后执行的操作
• @PreUpdate 在实体更新到数据库之前执行的操作
• @PostUpdate 在实体更新到数据库之后执行的操作
• @PreRemove 在实体从数据库删除之前执行的操作
• @PostRemove 在实体从数据库删除之后执行的操作

CompanyListener类完整代码如下：

@Component
public class CompanyListener {
    private final String LOG_PREFIX = "CompanyListener 实体持久化监听>>>>>> HCompany实体执行";
    private final String LOG_POSTFIX = "<<<<<<";
    private Logger logger = LoggerFactory.getLogger(this.getClass());

    /**
     * @param company
     */
    @PrePersist
    public void PrePersist(final HCompany company) {
        this.logger.info("{} [{}] {}", this.LOG_PREFIX, "新增操作之前", LOG_POSTFIX);
    }

    /**
     * @param company
     */
    @PostPersist
    public void PostPersist(final HCompany company) {
        this.logger.info("{} [{}] {}", this.LOG_PREFIX, "新增操作之后", LOG_POSTFIX);
    }

    /**
     * @param company
     */
    @PreUpdate
    public void PreUpdate(final HCompany company) {
        this.logger.info("{} [{}] {}", this.LOG_PREFIX, "更新操作之前", LOG_POSTFIX);
    }

    /**
     * @param company
     */
    @PostUpdate
    public void PostUpdate(final HCompany company) {
        this.logger.info("{} [{}] {}", this.LOG_PREFIX, "更新操作之后", LOG_POSTFIX);
    }

    /**
     * @param company
     */
    @PreRemove
    public void PreRemove(final HCompany company) {
        this.logger.info("{} [{}] {}", this.LOG_PREFIX, "删除操作之前", LOG_POSTFIX);
    }

    /**
     * @param company
     */
    @PostRemove
    public void PostRemove(final HCompany company) {
        this.logger.info("{} [{}] {}", this.LOG_PREFIX, "删除操作之后", LOG_POSTFIX);
    }
}

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56

2 实体类关联监听

在需要监听的实体类上添加EntityListeners注解，这里我们添加到HCompany类上，完整代码如下：

@Entity
@Table(name = "h_company")
@Where(clause = "id > 0")
@EntityListeners({CompanyListener.class}) //实体类关联监听类CompanyListener
public class HCompany {
    @Id
    @GeneratedValue(strategy = GenerationType.IDENTITY)
    private Integer id;
    private String name;
    private String shortName;
    private String address;
    private String tel;
    private String remark;

    public Integer getId() {
        return id;
    }

    public void setId(Integer id) {
        this.id = id;
    }

    public String getName() {
        return name;
    }

    public void setName(String name) {
        this.name = name;
    }

    public String getShortName() {
        return shortName;
    }

    public void setShortName(String shortName) {
        this.shortName = shortName;
    }

    public String getAddress() {
        return address;
    }

    public void setAddress(String address) {
        this.address = address;
    }


    public String getTel() {
        return tel;
    }

    public void setTel(String tel) {
        this.tel = tel;
    }


    public String getRemark() {
        return remark;
    }

    public void setRemark(String remark) {
        this.remark = remark;
    }

}

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66

3 控制器添加实体类操作

在控制器DemoController类中添加对HCompany类的增、改请求操作，如下：

 	@PostMapping("/demo/addCompany")
    public HResponse addCompany(String name) {
        HCompany company = new HCompany();
        company.setName(name);
        company.setShortName(name);
        company.setAddress(name + " address");
        company.setTel("18988888888");
        this.companyRepository.save(company);
        return HResponse.success();
    }

    @PostMapping("/demo/updateCompany")
    public HResponse updateCompany(int id) {
        HCompany company = this.companyRepository.findById(id).orElseThrow(() -> new HException("数据不存在或已被删除！"));
        company.setRemark("update at " + new Date().toString());
        this.companyRepository.save(company);
        return HResponse.success();
    }
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18

4 监听效果

使用Postman工具发送请求，对实体类进行增、改操作，请求过程及响应日志如下图：