为什么saveAll（）总是插入数据而不是更新数据？

Question

Spring Boot 2.4.0，DB是MySql 8。

使用REST每15秒从远程获取数据并使用saveAll（）将其存储到MySql DB。

它为所有给定的实体调用save（）方法。

所有数据都设置了ID。
我希望如果DB中没有这样的id-它将被插入。
如果这样的ID已经在DB中呈现-它将被更新。

这里是从控制台剪下的：

Hibernate: 
    insert 
    into
        iot_entity
        (controller_ref, description, device_id, device_ref, entity_type_ref, hw_address, hw_serial, image_ref, inventory_nr, ip6address1, ip6address2, ip_address1, ip_address2, latlng, location, mac_address, name, params, status, tenant, type, id) 
    values
        (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)
...
2020-12-05 23:18:28.269 ERROR 15752 --- [  restartedMain] o.h.e.jdbc.batch.internal.BatchingBatch  : HHH000315: Exception executing batch [java.sql.BatchUpdateException: Duplicate entry '1' for key 'iot_entity.PRIMARY'], SQL: insert into iot_entity (controller_ref, description, device_id, device_ref, entity_type_ref, hw_address, hw_serial, image_ref, inventory_nr, ip6address1, ip6address2, ip_address1, ip_address2, latlng, location, mac_address, name, params, status, tenant, type, id) values (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)
2020-12-05 23:18:28.269  WARN 15752 --- [  restartedMain] o.h.engine.jdbc.spi.SqlExceptionHelper   : SQL Error: 1062, SQLState: 23000
2020-12-05 23:18:28.269 ERROR 15752 --- [  restartedMain] o.h.engine.jdbc.spi.SqlExceptionHelper   : Duplicate entry '1' for key 'iot_entity.PRIMARY'
2020-12-05 23:18:28.269 DEBUG 15752 --- [  restartedMain] o.s.orm.jpa.JpaTransactionManager        : Initiating transaction rollback after commit exception

org.springframework.dao.DataIntegrityViolationException: could not execute batch; SQL [insert into iot_entity (controller_ref, description, device_id, device_ref, entity_type_ref, hw_address, hw_serial, image_ref, inventory_nr, ip6address1, ip6address2, ip_address1, ip_address2, latlng, location, mac_address, name, params, status, tenant, type, id) values (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)]; constraint [iot_entity.PRIMARY]; nested exception is org.hibernate.exception.ConstraintViolationException: could not execute batch

下面是获取和保存的方法，如下所示：

@Override
@SneakyThrows
@Scheduled(fixedDelay = 15_000)
@Transactional(propagation = Propagation.REQUIRES_NEW)
public void fetchAndStoreData() {
    IotEntity[] entities = restTemplate.getForObject(properties.getIotEntitiesUrl(), IotEntity[].class);

    log.debug("ENTITIES:\n{}", mapper.writerWithDefaultPrettyPrinter().writeValueAsString(entities));

    if (entities != null && entities.length > 0) {
        entityRepository.saveAll(List.of(entities));
    } else {
        log.warn("NO entities data FETCHED !!!");
    }
}

此方法每15秒运行一次。

实体：

@Data
@Entity
@NoArgsConstructor
@EqualsAndHashCode(of = {"id"})
@ToString(of = {"id", "deviceId", "entityTypeRef", "ipAddress1"})
public class IotEntity implements Serializable {

    private static final long serialVersionUID = 1L;

    @Id
    private Integer id;
    // other fields

和存储库：

public interface EntityRepository extends JpaRepository<IotEntity, Integer> {
}

这是以JSON格式截取的iot实体：

2020-12-05 23:18:44.261 DEBUG 15752 --- [pool-3-thread-1] EntityService : ENTITIES:
[ {
  "id" : 1,
  "controllerRef" : null,
  "name" : "Local Controller Unterföhring",
  "description" : "",
  "deviceId" : "",
  ...

所以ID是确定的。

此外，为项目启用了批处理。它不应该对保存有任何影响。

我不明白为什么它试图插入新实体而不是更新现有实体<为什么它不能区分新旧实体之间的区别？

更新：

实体实现的持久化：

@Data
@Entity
@NoArgsConstructor
@EqualsAndHashCode(of = {"id"})
@ToString(of = {"id", "deviceId", "entityTypeRef", "ipAddress1"})
public class IotEntity implements Serializable, Persistable<Integer> {
    private static final long serialVersionUID = 1L;

    @Id
    private Integer id;

    @Override
    public boolean isNew() {
        return false;
    }

    @Override
    public Integer getId() {
        return this.id;
    }

但是，它失败了，有同样的例外-key'iot_entity的重复条目'1'。PRIMARY'

如果我将添加GeneratedValue，如下所示：

@Id
@GeneratedValue(strategy = GenerationType.IDENTITY)
private Integer id;

它不会失败。但是，它会自行更新ID值。

例如，它使用id=15获取：

[ {
  "id" : 15,
  "carParkRef" : 15,
  "name" : "UF Haus 1/2",

并且应该像下面这样保存：

实际上，它的id为2：

这是不正确的。

试图添加到存储服务：

private final EntityManager entityManager;
...
List.of(carParks).forEach(entityManager::merge);

失败并出现相同的异常（无论是否实现Persistable）。它尝试将值插入到。。。键“”的重复条目“15”。主要'

来自application.yml的片段：

spring:
  # ===============================
  # = DATA SOURCE
  # ===============================
  datasource:
    url: jdbc:mysql://localhost:3306/demo_db
    username: root
    password: root
    initialization-mode: always

  # ===============================
  # = JPA / HIBERNATE
  # ===============================
  jpa:
    show-sql: true
    generate-ddl: true
    hibernate:
      ddl-auto: update
    properties:
      hibernate:
        format_sql: true
        generate_statistics: true

在这里您可以看到pom文件内容。

如何解决此问题？

Answer 1

Spring数据JPA使用@version@Id字段的组合来决定是合并还是插入。

• 空@id和空@版本意味着新记录，因此插入

因为你有@id和@version丢失，它试图插入，因为underlysing系统决定这是新的记录，当运行sql u得到错误。

Answer 2

看来我找到了这种行为的根源。

主应用程序启动器如下所示：

@AllArgsConstructor
@SpringBootApplication
public class Application implements CommandLineRunner {

    private final DataService dataService;
    private final QrReaderServer qrReaderServer;
    private final MonitoringService monitoringService;

    @Override
    public void run(String... args) {
        dataService.fetchAndStoreData();
        monitoringService.launchMonitoring();
        qrReaderServer.launchServer();
    }

所有3个步骤都有严格的执行顺序。如果需要，必须重复第一个步骤以在本地更新数据。另外两个仅用于存储数据的服务器。

其中第一种方法如下所示：

@Scheduled(fixedDelay = 15_000)
public void fetchAndStoreData() {
    log.debug("START_DATA_FETCH");

    carParkService.fetchAndStoreData();
    entityService.fetchAndStoreData();
    assignmentService.fetchAndStoreData();
    permissionService.fetchAndStoreData();
    capacityService.fetchAndStoreData();

    log.debug("END_DATA_FETCH");
}

此外，还计划了此执行。

当应用程序启动时，它尝试执行此提取两次：

2020-12-14 14:00:46.208 DEBUG 16656 --- [pool-3-thread-1] c.s.s.s.data.impl.DataServiceImpl        : START_DATA_FETCH
2020-12-14 14:00:46.208 DEBUG 16656 --- [  restartedMain] c.s.s.s.data.impl.DataServiceImpl        : START_DATA_FETCH

两个线程以相同的捕获和存储并行运行-尝试插入数据。（每次启动时都会重新创建表）。

所有后续的回迁都很好，它们只由指定的线程执行。

如果注释已被调度，它将正常工作，没有任何异常。

解决方案：

向服务类添加了其他布尔属性：

@Getter
private static final AtomicBoolean ifDataNotFetched = new AtomicBoolean(true);

@Override
@Scheduled(fixedDelay = 15_000)
@Order(value = Ordered.HIGHEST_PRECEDENCE)
public void fetchAndStoreData() {
    ifDataNotFetched.set(true);
    log.debug("START_DATA_FETCH");

    // fetch and store data with `saveAll()`

    log.debug("END_DATA_FETCH");
    ifDataNotFetched.set(false);
}

并在应用程序启动后控制值：

@Value("${sharepark.remote-data-fetch-timeout}")
private int dataFetchTimeout;
private static int fetchCounter;

@Override
public void run(String... args) {
    waitRemoteDataStoring();
    monitoringService.launchMonitoring();
    qrReaderServer.launchServer();
}

private void waitRemoteDataStoring() {
    do {
        try {
            if (fetchCounter == dataFetchTimeout) {
                log.warn("Data fetch timeout reached: {}", dataFetchTimeout);
            }

            Thread.sleep(1_000);

            ++fetchCounter;
            log.debug("{} Wait for data fetch one more second...", fetchCounter);
        } catch (InterruptedException e) {
            Thread.currentThread().interrupt();
        }
    } while (DataServiceImpl.getIfDataNotFetched().get() && fetchCounter <= dataFetchTimeout);
}

Answer 3

问题很可能是，由于Id没有标记为GeneratedValue，Spring数据假定传递给save（）/saveAll（）的所有分离（瞬态）实体都应该具有EntityManager。对其调用persist（）。

尝试使IotEntity实现持久并从isNew（）返回false。这将告诉Spring Data始终使用EntityManager.merge（），这应该具有预期的效果（即插入不存在的实体并更新现有实体）。