Spring Boot JPA实现代理存在时更新佣金不新增记录方法

每次操作都新增行的核心原因是：Spring Data JPA的save()方法默认通过实体主键判断对象是否为新实体，你每次写入时都new一个全新的AgentDetails实体，主键id为null，JPA会判定这是新实体，永远执行insert逻辑，自然不会更新已有记录。

先提一个表结构前置优化点：你当前AgentDetails表用agentName关联代理存在重名风险，建议先给表新增agentId字段（关联agent表主键）并加唯一约束，作为判断代理是否存在的唯一依据，后续所有逻辑都基于agentId判断，避免数据错乱。另外你policy表的字段存在拼写错误：polictId应为policyId、commissionOnPolicyin建议修正为commissionOnPolicy，避免JPA字段映射出错。

以下方案按推荐优先级排序，可根据业务并发量、数据量级选择：

方案1：先查询后判断写入（最易实现，业务逻辑可控，适合低并发场景） #

逻辑非常直接：写入前先根据代理唯一标识（agentId）查询已有记录，存在则累加字段值更新，不存在则新建。

1. 定义AgentDetails的Repository接口

public interface AgentDetailsRepository extends JpaRepository<AgentDetails, Long> {
    // 若暂时没加agentId字段，可临时改成findByAgentName查询
    Optional<AgentDetails> findByAgentId(Long agentId);
}

2. 在业务层写统计写入逻辑，加事务保证查询和写入的原子性

@Service
public class AgentStatisticsService {

    private final AgentDetailsRepository agentDetailsRepository;
    // 注入Billing、Policy相关的Repository依赖
    private final BillingRepository billingRepository;
    private final PolicyRepository policyRepository;

    // 构造函数注入
    public AgentStatisticsService(AgentDetailsRepository agentDetailsRepository, BillingRepository billingRepository, PolicyRepository policyRepository) {
        this.agentDetailsRepository = agentDetailsRepository;
        this.billingRepository = billingRepository;
        this.policyRepository = policyRepository;
    }

    @Transactional(rollbackFor = Exception.class)
    public void syncAgentStatistics(Long agentId, String agentName, Integer policySoldIncrement, BigDecimal commissionIncrement) {
        // 查询当前代理是否已有统计记录
        AgentDetails agentDetails = agentDetailsRepository.findByAgentId(agentId)
                .orElseGet(() -> {
                    // 不存在则新建空对象，设置初始值
                    AgentDetails newEntity = new AgentDetails();
                    newEntity.setAgentId(agentId);
                    newEntity.setAgentName(agentName);
                    newEntity.setNumberOfPolicySoldByAgent(0);
                    newEntity.setTotalCommissionEarn(BigDecimal.ZERO);
                    return newEntity;
                });
        // 累加统计值，不要直接覆盖
        agentDetails.setNumberOfPolicySoldByAgent(agentDetails.getNumberOfPolicySoldByAgent() + policySoldIncrement);
        agentDetails.setTotalCommissionEarn(agentDetails.getTotalCommissionEarn().add(commissionIncrement));
        // 已有记录主键不为空，JPA会自动执行update逻辑
        agentDetailsRepository.save(agentDetails);
    }
}

从Billing、Policy表提取完对应代理的新增保单数、新增佣金数据后，直接调用syncAgentStatistics方法即可。

方案2：数据库层面Upsert（性能最高，适合高并发、批量统计场景） #

利用MySQL原生的INSERT ... ON DUPLICATE KEY UPDATE语法，不需要提前查询，数据库自动判断唯一键是否冲突，冲突则直接执行更新，性能远高于先查后存，还能避免并发下的重复插入问题。
前提要求：AgentDetails表的agent_id字段必须加唯一约束。

1. 在AgentDetails实体类上配置唯一约束

@Entity
@Table(name = "agent_details", uniqueConstraints = @UniqueConstraint(columnNames = "agent_id"))
public class AgentDetails {
    @Id
    @GeneratedValue(strategy = GenerationType.IDENTITY)
    private Long id;
    private Long agentId;
    private String agentName;
    private Integer numberOfPolicySoldByAgent;
    private BigDecimal totalCommissionEarn;
    // 省略getter、setter方法
}

2. 在Repository中写原生upsert SQL

public interface AgentDetailsRepository extends JpaRepository<AgentDetails, Long> {
    @Modifying
    @Transactional
    @Query(value = "INSERT INTO agent_details(agent_id, agent_name, number_of_policy_sold_by_agent, total_commission_earn) " +
            "VALUES (:agentId, :agentName, :soldIncrement, :commissionIncrement) " +
            "ON DUPLICATE KEY UPDATE " +
            "number_of_policy_sold_by_agent = number_of_policy_sold_by_agent + :soldIncrement, " +
            "total_commission_earn = total_commission_earn + :commissionIncrement", nativeQuery = true)
    void upsertAgentStatistics(@Param("agentId") Long agentId,
                               @Param("agentName") String agentName,
                               @Param("soldIncrement") Integer soldIncrement,
                               @Param("commissionIncrement") BigDecimal commissionIncrement);
}

业务层提取完增量数据后，直接调用upsertAgentStatistics方法即可，不需要额外判断逻辑。

方案3：Hibernate NaturalId方案（仅适合纯Hibernate场景，不推荐） #

如果深度使用Hibernate原生API，可以将agentId标注为@NaturalId自然主键，通过Hibernate Session的byNaturalId方法获取记录后更新，本质和先查后存逻辑一致，只是省了自定义Repository查询方法的步骤，通用性不如前两种方案。

• 无论用哪种方案，都必须在数据库层面给agentId加唯一约束做兜底，避免并发场景下出现重复的代理统计记录
• 更新字段时必须做累加计算，不要直接覆盖numberOfPolicySoldByAgent、totalCommissionEarn的值，否则会丢失历史统计数据
• 如果需要批量同步多个代理的统计数据，优先选方案2，批量执行upsert的性能比循环先查后存高1~2个数量级

内容的提问来源于stack exchange，提问作者Tushant Singh