Spring Boot中高效检查记录是否存在并条件性创建或更新的策略

本文详细介绍了在spring boot应用中如何高效地检查数据库记录是否存在，并根据检查结果决定是创建新记录还是利用现有数据。通过优化查询方式，从传统的全量查询转变为使用`select exists`语句，结合spring data jpa的特性，提升了数据操作的性能和代码的可读性，并提供了实际的代码示例及注意事项。

数据库记录存在性检查与条件性操作

在开发企业级应用时，一个常见的业务场景是需要在向数据库插入新数据之前，先检查该数据是否已存在。如果存在，则可能需要更新现有数据或直接使用；如果不存在，则创建新的记录。这种模式对于避免数据重复、维护数据一致性至关重要。

传统检查方式及其局限性

最初，开发者可能倾向于执行一个查询来获取匹配的所有记录，然后通过判断查询结果是否为空来确定记录是否存在。例如，使用Spring Data JPA的自定义查询方法：

public interface ClassesCurriculumMapRepository extends JpaRepository {
    @Query(value ="select * from class_curriculummap where ClassId =?1 And CurriculumMapId='?2'", nativeQuery = true)
    List findByClassIdAndCurriculumMapId(Long classId, String curriculumMapId);
}

然后在业务逻辑中这样使用：

@EventHandler
@Override
public void on(ContentSaveUserEvent event) {
    var existingRecord = classesCurriculumMapRepository.findByClassIdAndCurriculumMapId(Long.valueOf(event.getClassId()), event.getCurriculumMapId());
    if (!existingRecord.isEmpty()) {
        // 记录已存在，在此处可以更新现有记录或执行其他逻辑
        // 例如：existingRecord.get(0).setDateLastModified(new Date());
        // classesCurriculumMapRepository.save(existingRecord.get(0));
    } else {
        // 记录不存在，创建新记录
        Class_CurriculumMap classCurriculumMap = new Class_CurriculumMap();
        classCurriculumMap.setId(new Class_CurriculumMapPK(Long.valueOf(event.getClassId()), event.getCurriculumMapId()));
        classCurriculumMap.setDateLastModified(new Date());
        classCurriculumMap.setUserLastModified(event.getUctx().getUserId());
        classCurriculumMap.setStatus(Status.Active.value);
        classesCurriculumMapRepository.save(classCurriculumMap);
    }
}

这种方法的局限性在于，即使我们只关心记录是否存在，select * 查询也会从数据库中检索所有匹配列的数据。对于包含大量列或大数据量的表，这会造成不必要的性能开销和网络传输负担。

优化方案：使用 SELECT EXISTS

为了更高效地检查记录是否存在，数据库提供了 EXISTS 关键字。SELECT EXISTS 子查询会立即返回一个布尔值（true或false），一旦找到匹配的记录，查询就会停止，而无需检索实际的数据。这显著提高了存在性检查的效率。

我们可以通过修改Spring Data JPA的Repository接口来利用这一特性：

public interface ClassesCurriculumMapRepository extends JpaRepository {
    // 使用原生SQL的EXISTS查询
    @Query(value ="select exists(select 1 from class_curriculummap where ClassId =?1 And CurriculumMapId='?2')", nativeQuery = true)
    boolean isExistsByClassIdAndCurriculumMapId(Long classId, String curriculumMapId);

    // Spring Data JPA 推荐的命名查询方式，无需手动编写@Query
    // Spring Data JPA 会自动解析方法名并生成对应的EXISTS查询
    boolean existsByClassIdAndCurriculumMapId(Long classId, String curriculumMapId);
}

说明：

Artbreeder

创建令人惊叹的插画和艺术

下载

• isExistsByClassIdAndCurriculumMapId 方法使用 @Query 注解显式定义了原生 SELECT EXISTS 查询。select 1 是一个常见的优化，因为它比 select * 更轻量，在 EXISTS 语境下效果相同。
• existsByClassIdAndCurriculumMapId 方法是Spring Data JPA的推荐做法。如果方法名遵循 existsBy 前缀，后跟实体属性名（通过 And、Or 等连接），Spring Data JPA 会自动生成一个高效的 EXISTS 查询，无需我们手动编写 @Query。这种方式更简洁、更符合框架惯例。

集成优化后的存在性检查

在业务逻辑中，我们可以将上述优化后的方法集成，使代码更清晰、更高效：

import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional; // 导入事务注解
import java.util.Date;
import java.util.Optional; // 导入Optional

@Service
public class ContentSaveUserService {

    private final ClassesCurriculumMapRepository classesCurriculumMapRepository;

    public ContentSaveUserService(ClassesCurriculumMapRepository classesCurriculumMapRepository) {
        this.classesCurriculumMapRepository = classesCurriculumMapRepository;
    }

    // 假设这是您的事件处理方法或服务方法
    @Transactional // 确保操作在事务中进行
    public void handleContentSaveUserEvent(ContentSaveUserEvent event) {
        Long classId = Long.valueOf(event.getClassId());
        String curriculumMapId = event.getCurriculumMapId();

        // 优先使用Spring Data JPA自动生成的existsBy方法，更简洁
        boolean recordExists = classesCurriculumMapRepository.existsByClassIdAndCurriculumMapId(classId, curriculumMapId);

        if (recordExists) {
            // 记录已存在，通常会在这里获取并更新现有记录
            // 注意：如果需要获取并更新，那么existsBy方法只能告诉你存在，
            // 还需要一个findById或findBy...方法来获取实际对象。
            // 更好的做法是尝试查找，如果不存在再创建。
            Optional existingOptional = classesCurriculumMapRepository.findById(new Class_CurriculumMapPK(classId, curriculumMapId));
            existingOptional.ifPresent(record -> {
                // 更新现有记录的逻辑
                record.setDateLastModified(new Date());
                record.setUserLastModified(event.getUctx().getUserId());
                // ... 其他需要更新的字段
                classesCurriculumMapRepository.save(record); // 保存更新
            });
            // 如果业务逻辑仅要求“使用现有记录”而不进行更新，则此处无需额外操作
            System.out.println("记录已存在，无需创建新记录。");
        } else {
            // 记录不存在，创建新记录
            Class_CurriculumMap classCurriculumMap = new Class_CurriculumMap();
            classCurriculumMap.setId(new Class_CurriculumMapPK(classId, curriculumMapId));
            classCurriculumMap.setDateLastModified(new Date());
            classCurriculumMap.setUserLastModified(event.getUctx().getUserId());
            classCurriculumMap.setStatus(Status.Active.value); // 假设Status是一个枚举或常量
            classesCurriculumMapRepository.save(classCurriculumMap);
            System.out.println("新记录已创建。");
        }
    }

    // 假设的ContentSaveUserEvent和Class_CurriculumMapPK定义
    // ...
}

进一步优化：使用 findBy... 返回 Optional 或 findById

在某些情况下，我们不仅需要知道记录是否存在，如果存在，还需要获取该记录进行更新。此时，直接使用 existsBy 可能会导致两次查询（一次 exists，一次 find）。更高效的模式是直接尝试查找记录，如果找到则使用，否则创建。

import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import java.util.Date;
import java.util.Optional;

@Service
public class ContentSaveUserService {

    private final ClassesCurriculumMapRepository classesCurriculumMapRepository;

    public ContentSaveUserService(ClassesCurriculumMapRepository classesCurriculumMapRepository) {
        this.classesCurriculumMapRepository = classesCurriculumMapRepository;
    }

    @Transactional
    public void handleContentSaveUserEvent(ContentSaveUserEvent event) {
        Long classId = Long.valueOf(event.getClassId());
        String curriculumMapId = event.getCurriculumMapId();
        Class_CurriculumMapPK pk = new Class_CurriculumMapPK(classId, curriculumMapId);

        // 尝试通过主键查找记录
        Optional existingOptional = classesCurriculumMapRepository.findById(pk);

        Class_CurriculumMap classCurriculumMap;
        if (existingOptional.isPresent()) {
            // 记录已存在，获取并更新
            classCurriculumMap = existingOptional.get();
            classCurriculumMap.setDateLastModified(new Date());
            classCurriculumMap.setUserLastModified(event.getUctx().getUserId());
            // ... 其他需要更新的字段
            System.out.println("记录已存在，已更新。");
        } else {
            // 记录不存在，创建新记录
            classCurriculumMap = new Class_CurriculumMap();
            classCurriculumMap.setId(pk);
            classCurriculumMap.setDateLastModified(new Date());
            classCurriculumMap.setUserLastModified(event.getUctx().getUserId());
            classCurriculumMap.setStatus(Status.Active.value);
            System.out.println("新记录已创建。");
        }
        classesCurriculumMapRepository.save(classCurriculumMap); // 保存（新创建或已更新）的记录
    }
}

这种 findById().orElseGet(() -> new Record()) 的模式在许多场景下更为实用和高效，因为它避免了两次数据库查询（一次检查是否存在，一次获取数据），而是通过一次查询尝试获取数据，根据结果决定是更新还是创建。

注意事项

1. 并发问题： 在高并发环境下，即使使用了 exists 检查，也可能出现“检查-然后-行动”（Check-then-Act）的竞态条件。例如，两个线程同时检查记录不存在，然后都尝试创建。这可能导致唯一性约束冲突。解决此问题通常需要：
   • 在数据库层面添加唯一性约束。
   • 利用数据库事务隔离级别和悲观/乐观锁。
   • 使用 INSERT ... ON CONFLICT UPDATE (PostgreSQL) 或 INSERT ... ON DUPLICATE KEY UPDATE (MySQL) 等数据库特定语法，Spring Data JPA 可以通过自定义查询或使用 JdbcTemplate 来实现。
2. 性能考量： SELECT EXISTS 在仅需判断存在性时性能优越。但如果后续操作（如更新）需要获取完整的记录数据，那么直接使用 findById 或 findBy... 返回 Optional 并根据其是否存在来决定操作，可以减少一次数据库往返。
3. 代码可读性： Spring Data JPA 的 existsBy... 方法命名惯例提高了代码的可读性和维护性，强烈推荐使用。

总结

在Spring Boot应用中处理“检查记录是否存在，然后条件性操作”的场景时，应优先考虑使用Spring Data JPA提供的 existsBy... 方法或直接通过 findById (或自定义 findBy... 返回 Optional) 来进行判断和操作。这不仅能有效提升查询效率，减少不必要的资源消耗，还能使代码更加符合Spring Data JPA的惯例，提高整体的可维护性和可读性。在设计这类功能时，务必结合业务需求和并发场景，选择最合适的实现策略。