如何使用 spring-data-jpa 更新实体？

Question

这个问题几乎说明了一切。使用 JPARepository 如何更新实体？

JPARepository 只有一个 save 方法，它并没有告诉我它实际上是创建还是更新。比如我在数据库User中插入一个简单的Object，它有三个字段：firstname、lastname和age：

 @Entity
 public class User {

  private String firstname;
  private String lastname;
  //Setters and getters for age omitted, but they are the same as with firstname and lastname.
  private int age;

  @Column
  public String getFirstname() {
    return firstname;
  }
  public void setFirstname(String firstname) {
    this.firstname = firstname;
  }

  @Column
  public String getLastname() {
    return lastname;
  }
  public void setLastname(String lastname) {
    this.lastname = lastname;
  }

  private long userId;

  @Id
  @GeneratedValue(strategy=GenerationType.AUTO)
  public long getUserId(){
    return this.userId;
  }

  public void setUserId(long userId){
    this.userId = userId;
  }
}

然后我简单地调用save()，此时它实际上是插入数据库：

 User user1 = new User();
 user1.setFirstname("john"); user1.setLastname("dew");
 user1.setAge(16);

 userService.saveUser(user1);// This call is actually using the JPARepository: userRepository.save(user);

到目前为止一切顺利。现在我想更新这个用户，比如改变他的年龄。为此，我可以使用查询，无论是 QueryDSL 还是 NamedQuery。但是，考虑到我只想使用 spring-data-jpa 和 JPARepository，我该如何告诉它我想要更新而不是插入？

具体来说，我如何告诉 spring-data-jpa 具有相同用户名和名字的用户实际上是 EQUAL 并且应该更新现有实体？覆盖 equals 并没有解决这个问题。

Answer 1

实体的身份由它们的主键定义。由于firstname 和lastname 不是主键的一部分，因此您不能告诉JPA 将Users 与相同的firstnames 和lastnames 视为相同，如果它们具有不同的userIds。

因此，如果您要更新由其firstname 和lastname 标识的User，您需要通过查询找到User，然后更改您找到的对象的相应字段。这些更改将在事务结束时自动刷新到数据库，因此您无需执行任何操作来显式保存这些更改。

编辑：

也许我应该详细说明 JPA 的整体语义。设计持久性 API 有两种主要方法：

• 插入/更新方法。当您需要修改数据库时，您应该显式调用持久化 API 的方法：调用 insert 插入对象，或调用 update 将对象的新状态保存到数据库。

• 工作单元方法。在这种情况下，您有一组由持久性库管理的对象。您对这些对象所做的所有更改都将在工作单元结束时自动刷新到数据库中（即典型情况下在当前事务结束时）。当您需要向数据库中插入新记录时，您使相应的对象托管。 Managed 对象由它们的主键标识，因此如果您使用预定义的主键 managed 制作对象，它将与相同 id 的数据库记录相关联，并且此对象的状态将自动传播到该记录。

JPA 遵循后一种方法。 Spring Data JPA 中的 save() 由普通 JPA 中的 merge() 支持，因此它使您的实体托管如上所述。这意味着在具有预定义 id 的对象上调用 save() 将更新相应的数据库记录，而不是插入新记录，同时也解释了为什么 save() 不称为 create()。

Answer 2

由于@axtavt 的答案集中在JPA 而不是spring-data-jpa

通过查询更新实体然后保存效率不高，因为它需要两个查询，而且查询可能会非常昂贵，因为它可能会加入其他表并加载任何具有fetchType=FetchType.EAGER的集合

Spring-data-jpa支持更新操作。
您必须在 Repository 接口中定义方法。并使用@Query 和@Modifying 对其进行注释。

@Modifying
@Query("update User u set u.firstname = ?1, u.lastname = ?2 where u.id = ?3")
void setUserInfoById(String firstname, String lastname, Integer userId);

@Query 用于定义自定义查询，@Modifying 用于告诉spring-data-jpa 此查询是更新操作，它需要executeUpdate() 而不是executeQuery()。

您可以指定其他返回类型：
int - 正在更新的记录数。
boolean - 如果有正在更新的记录，则为 true。否则为假。

---

注意：在Transaction 中运行此代码。

Answer 3

你可以简单地使用这个函数和save() JPA函数，但是作为参数发送的对象必须包含数据库中现有的id，否则它将不起作用，因为save()当我们发送一个没有id的对象时，它直接添加数据库中的一行，但如果我们发送一个具有现有 id 的对象，它会更改数据库中已找到的列。

public void updateUser(Userinfos u) {
    User userFromDb = userRepository.findById(u.getid());
    // crush the variables of the object found
    userFromDb.setFirstname("john"); 
    userFromDb.setLastname("dew");
    userFromDb.setAge(16);
    userRepository.save(userFromDb);
}

Answer 4

正如其他人已经提到的，save() 本身包含创建和更新操作。

我只是想补充一下save() 方法背后的内容。

首先，让我们看看CrudRepository<T,ID> 的扩展/实现层次结构，

好的，让我们在SimpleJpaRepository<T, ID> 上检查save() 的实现，

@Transactional
public <S extends T> S save(S entity) {

    if (entityInformation.isNew(entity)) {
        em.persist(entity);
        return entity;
    } else {
        return em.merge(entity);
    }
}

如您所见，它首先会检查ID是否存在，如果实体已经存在，则仅通过merge(entity)方法进行更新，否则通过persist(entity)方法插入新记录.

Answer 5

spring data save() 方法将帮助您执行以下两项操作：添加新项目和更新现有项目。

只需拨打save() 即可享受生活:))

Answer 6

使用 spring-data-jpa save()，我遇到了与 @DtechNet 相同的问题。我的意思是每个save() 都在创建新对象而不是更新。为了解决这个问题，我必须将version 字段添加到实体和相关表中。

Answer 7

这就是我解决问题的方法：

User inbound = ...
User existing = userRepository.findByFirstname(inbound.getFirstname());
if(existing != null) inbound.setId(existing.getId());
userRepository.save(inbound);

Answer 8

public void updateLaserDataByHumanId(String replacement, String humanId) {
    List<LaserData> laserDataByHumanId = laserDataRepository.findByHumanId(humanId);
    laserDataByHumanId.stream()
            .map(en -> en.setHumanId(replacement))
            .collect(Collectors.toList())
            .forEach(en -> laserDataRepository.save(en));
}

Answer 9

具体来说，我如何告诉 spring-data-jpa 拥有 相同的用户名和名字实际上是 EQUAL 并且应该是 更新实体。覆盖等于无效。

为了这个特殊的目的，我们可以像这样引入一个复合键：

CREATE TABLE IF NOT EXISTS `test`.`user` (
  `username` VARCHAR(45) NOT NULL,
  `firstname` VARCHAR(45) NOT NULL,
  `description` VARCHAR(45) NOT NULL,
  PRIMARY KEY (`username`, `firstname`))

映射：

@Embeddable
public class UserKey implements Serializable {
    protected String username;
    protected String firstname;

    public UserKey() {}

    public UserKey(String username, String firstname) {
        this.username = username;
        this.firstname = firstname;
    }
    // equals, hashCode
}

这里是如何使用它：

@Entity
public class UserEntity implements Serializable {
    @EmbeddedId
    private UserKey primaryKey;

    private String description;

    //...
}

JpaRepository 看起来像这样：

public interface UserEntityRepository extends JpaRepository<UserEntity, UserKey>

然后，您可以使用以下 惯用语： 接受带有用户信息的 DTO，提取姓名和名字并创建 UserKey，然后使用此复合键创建一个 UserEntity，然后调用 Spring Data save()应该为您解决所有问题。

Answer 10

如果你的主键是自增的，那么你必须设置主键的值。 对于保存（）；方法作为 update() 工作。否则它将在 db 中创建一个新记录。

如果您使用的是jsp表单，则使用隐藏字段设置主键。

jsp:

Java：

@PostMapping("/update")
public String updateUser(@ModelAttribute User user) {
    repo.save(user);
    return "redirect:userlist";
}

也看看这个：

@Override
  @Transactional
  public Customer save(Customer customer) {

    // Is new?
    if (customer.getId() == null) {
      em.persist(customer);
      return customer;
    } else {
      return em.merge(customer);
    }
  }

Answer 11

你可以看下面的例子：

private void updateDeliveryStatusOfEvent(Integer eventId, int deliveryStatus) {
    try {
        LOGGER.info("NOTIFICATION_EVENT updating with event id:{}", eventId);
        Optional<Event> eventOptional = eventRepository.findById(eventId);
        if (!eventOptional.isPresent()) {
            LOGGER.info("Didn't find any updatable notification event with this eventId:{}", eventId);
        }
        Event event = eventOptional.get();
        event.setDeliveryStatus(deliveryStatus);
        event = eventRepository.save(event);
        if (!Objects.isNull(event)) {
            LOGGER.info("NOTIFICATION_EVENT Successfully Updated with this id:{}", eventId);
        }
    } catch (Exception e) {
        LOGGER.error("Error :{} while updating NOTIFICATION_EVENT of event Id:{}", e, eventId);
    }
}

或使用本机查询更新：

public interface yourRepositoryName extend extends JpaRepository<Event,Integer>{
@Transactional
    @Modifying
    @Query(value="update Event u set u.deliveryStatus = :deliveryStatus where u.eventId = :eventId", nativeQuery = true)
    void setUserInfoById(@Param("deliveryStatus")String deliveryStatus, @Param("eventId")Integer eventId);
}

Answer 12

使用@DynamicUpdate注解。它更干净，您不必为了获取保存的值而查询数据库。