Spring Data JPA保存不插入数据库

Question

我正在使用带有 postgres 数据库的 spring data jpa，我有这个例子： 包 fr.enedis.peepsa.kepler.onescreen.domain;

@Entity
@Table(indexes = { @Index(name = "hashcode", columnList = "code") })
@FieldDefaults(level= AccessLevel.PRIVATE)
@Getter
@Setter
@ToString
@EqualsAndHashCode
@NoArgsConstructor
@AllArgsConstructor
public class Alert {

    @Id
    @GeneratedValue(strategy = GenerationType.SEQUENCE, generator = "alert_generator")
    @SequenceGenerator(name="alert_generator", sequenceName = "alert_seq")
    Long id;
    String code;
    @Enumerated(EnumType.STRING)
    Environment environment;
    @Enumerated(EnumType.STRING)
    Application nna;
    String alertName;
    String host;
    String cluster;
    String agentInfo;
    @Enumerated(EnumType.STRING)
    Publisher publisher;
    @Enumerated(EnumType.STRING)
    Criticality criticality;
    String alertInfo;
    @Transient
    long timestamp;
    Timestamp startDate;
    Timestamp endDate;

}

以及保存该实体的服务：

public void savingTest(AlertVM a) {
    Alert receivedAlert = new Alert(a);
    receivedAlert.setCode(receivedAlert.generateCode());
    //get DB alert if exist
    Alert alert = alertRepository.findByCodeAndEndDateIsNull(receivedAlert.getCode()).orElse(receivedAlert);
    switch (receivedAlert.getCriticality()) {
        case CRITICAL: {
            if(alert.getId() != null){
                break;
            }

            alert.setStartDate(new Timestamp(alert.getTimestamp()*1000));
            Alert as = alertRepository.save(alert);
            System.out.println("--------------------------------------> " + as.toString());

            break;
    }
}

当我从休息控制器调用 savingTest 服务时，保存完成，但是当我来自 kafka 消费者时，保存没有完成，我有这个输出登录休眠。

来自卡夫卡消费者：

Hibernate: select alert0_.id as id1_0_, alert0_.agent_info as agent_in2_0_, alert0_.alert_info as alert_in3_0_, alert0_.alert_name as alert_na4_0_, alert0_.cluster as cluster5_0_, alert0_.code as code6_0_, alert0_.criticality as critical7_0_, alert0_.end_date as end_date8_0_, alert0_.environment as environm9_0_, alert0_.host as host10_0_, alert0_.nna as nna11_0_, alert0_.publisher as publish12_0_, alert0_.start_date as start_d13_0_ from alert alert0_ where alert0_.code=? and (alert0_.end_date is null)
Hibernate: select nextval ('alert_seq')
Hibernate: select nextval ('alert_seq')

来自其余控制器：

Hibernate: select alert0_.id as id1_0_, alert0_.agent_info as agent_in2_0_, alert0_.alert_info as alert_in3_0_, alert0_.alert_name as alert_na4_0_, alert0_.cluster as cluster5_0_, alert0_.code as code6_0_, alert0_.criticality as critical7_0_, alert0_.end_date as end_date8_0_, alert0_.environment as environm9_0_, alert0_.host as host10_0_, alert0_.nna as nna11_0_, alert0_.publisher as publish12_0_, alert0_.start_date as start_d13_0_ from alert alert0_ where alert0_.code=? and (alert0_.end_date is null)

Hibernate: insert into alert (agent_info, alert_info, alert_name, cluster, code, criticality, end_date, environment, host, nna, publisher, start_date, id) values (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)

请提供任何帮助或建议

谢谢

Answer 1

您缺少事务注释，因此您的更改不会提交到数据库： https://docs.spring.io/spring-framework/docs/current/javadoc-api/org/springframework/transaction/annotation/Transactional.html

@Transactional
public void savingTest(AlertVM a) {
Alert receivedAlert = new Alert(a);
receivedAlert.setCode(receivedAlert.generateCode());
//get DB alert if exist
Alert alert = alertRepository.findByCodeAndEndDateIsNull(receivedAlert.getCode()).orElse(receivedAlert);
switch (receivedAlert.getCriticality()) {
    case CRITICAL: {
        if(alert.getId() != null){
            break;
        }

        alert.setStartDate(new Timestamp(alert.getTimestamp()*1000));
        Alert as = alertRepository.save(alert);
        System.out.println("--------------------------------------> " + as.toString());

        break;
 }
}