Hibernate更新MySQL数据遇唯一键重复错误求助

咱们先拆解下你遇到的问题：你明明是想更新已存在的London条目，却触发了唯一约束的重复键报错，核心原因是你用错了Hibernate的持久化方法，导致它把更新操作当成了插入新记录。

问题根源分析 #

看你的更新方法代码，当你确认数据库里已经存在London的记录后，调用了session.save(weatherToUpdate)——这个方法的作用是插入新实体，而不是更新现有实体。哪怕你修改的是已存在的城市数据，save()依然会尝试向数据库插入一条新记录，自然就触发了city列的唯一约束，报错Duplicate entry 'London'。

另外还有两个小问题：

• 没有判断retrievedWeatherData是否为空，直接get(0)会抛出索引越界异常
• 方法里调用factory.close()是错误的，SessionFactory是全局单例对象，不能每次操作都关闭，否则后续无法获取Session

正确的解决方案 #

我给你两种可行的更新方式，根据你的场景选择：

方案一：利用持久态实体自动更新（推荐）

当你从当前Session中查询出实体时，这个实体处于持久态，Hibernate会自动跟踪它的属性变化。你只需要修改属性，事务提交时Hibernate会自动生成更新语句，不需要手动调用任何持久化方法。

修改后的代码：

public void updateCityFromDatabase(Weather weatherToUpdate, String city){
    Session session = factory.getCurrentSession();
    session.getTransaction().begin();
    try{
        LOGGER.info("Reading the weather data...");
        Query query = session.createQuery("from Weather wt where wt.city = :city");
        query.setParameter("city", weatherToUpdate.getCity());
        List<Weather> retrievedWeatherData = query.list();
        
        if(!retrievedWeatherData.isEmpty()){
            // 获取持久态的现有实体
            Weather existingWeather = retrievedWeatherData.get(0);
            // 更新需要修改的字段（按需调整）
            existingWeather.setHeadline(weatherToUpdate.getHeadline());
            existingWeather.setDescription(weatherToUpdate.getDescription());
            existingWeather.setCurrentTemp(weatherToUpdate.getCurrentTemp());
            existingWeather.setMinTemp(weatherToUpdate.getMinTemp());
            existingWeather.setMaxTemp(weatherToUpdate.getMaxTemp());
            existingWeather.setSunrise(weatherToUpdate.getSunrise());
            existingWeather.setSunset(weatherToUpdate.getSunset());
            
            LOGGER.info("City parameters will be updated automatically on transaction commit");
        } else {
            // 如果数据库中没有该城市，才执行插入
            session.save(weatherToUpdate);
            LOGGER.info("New city added to database");
        }
        
        session.getTransaction().commit();
        LOGGER.info("Operation completed successfully!");
    } catch(Exception e){
        // 异常时回滚事务
        session.getTransaction().rollback();
        LOGGER.error("Error occurred during update: ", e);
    } finally {
        // 关闭当前Session，不要关闭SessionFactory
        if(session.isOpen()){
            session.close();
        }
    }
}

方案二：使用session.merge()处理离线实体

如果你的weatherToUpdate是离线状态（比如从前端传入、不是当前Session查询出来的实体），可以用merge()方法——它会先查询数据库中是否存在该实体（通过ID或唯一键识别），存在则更新，不存在则插入。

代码示例：

public void updateCityFromDatabase(Weather weatherToUpdate, String city){
    Session session = factory.getCurrentSession();
    session.getTransaction().begin();
    try{
        LOGGER.info("Merging weather data...");
        // merge自动处理更新/插入逻辑
        session.merge(weatherToUpdate);
        
        session.getTransaction().commit();
        LOGGER.info("Weather data merged successfully!");
    } catch(Exception e){
        session.getTransaction().rollback();
        LOGGER.error("Error occurred during merge: ", e);
    } finally {
        if(session.isOpen()){
            session.close();
        }
    }
}

额外注意事项 #

• 永远不要在业务方法里关闭SessionFactory，它应该在应用启动时初始化一次，应用关闭时再关闭
• 如果使用saveOrUpdate()，要确保实体携带正确的ID（因为Hibernate通过ID判断是更新还是插入），否则依然会触发插入操作导致唯一约束冲突

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