在JPA中保存后刷新和获取实体

Kahen大约 7 分钟

在JPA中保存后刷新和获取实体

Java持久化API（JPA）充当Java对象和关系数据库之间的桥梁，允许我们无缝地持久化和检索数据。在本教程中，我们将探讨在JPA中保存操作后有效地刷新和获取实体的各种策略和技术。### 2. Spring Data JPA中的实体管理理解

在Spring Data JPA中，实体管理围绕JpaRepository接口展开，它是与数据库交互的主要机制。通过扩展CrudRepository的JpaRepository接口，Spring Data JPA提供了一套强大的方法用于实体的持久化、检索、更新和删除。

此外，Spring容器会自动将_entityManager_注入到这些仓库接口中。这个组件是Spring Data JPA中JPA基础设施的一个不可分割的部分，它促进了与底层持久化上下文的交互以及执行JPA查询。

2.1. 持久化上下文

JPA中的一个关键组件是持久化上下文。想象这个上下文作为一个临时的存储区域，JPA在这里管理检索或创建的实体的状态。

它确保：

实体是唯一的：在任何给定时间，具有特定主键的实体在上下文中只存在一个实例。
跟踪更改：_EntityManager_跟踪在上下文中对实体属性所做的任何修改。
维护数据一致性：_EntityManager_在事务期间将上下文中所做的更改与底层数据库同步。

2.2. JPA实体的生命周期

JPA实体有四个不同的生命周期阶段：新、托管、已删除和分离。

当我们使用实体的构造函数创建一个新的实体实例时，它处于“新”状态。我们可以通过检查实体的ID（主键）是否为空来验证这一点：

Order order = new Order();
if (order.getId() == null) {
    // 实体处于“新”状态
}

使用仓库的save()方法持久化实体后，它转变为“托管”状态。我们可以通过检查保存的实体是否存在于仓库中来验证这一点：

Order savedOrder = repository.save(order);
if (repository.findById(savedOrder.getId()).isPresent()) {
    // 实体处于“托管”状态
}

当我们在托管实体上调用仓库的delete()方法时，它转变为“已删除”状态。我们可以通过检查删除后实体是否不再存在于数据库中来验证这一点：

repository.delete(savedOrder);
if (!repository.findById(savedOrder.getId()).isPresent()) {
    // 实体处于“已删除”状态
}

最后，一旦使用仓库的detach()方法分离实体，实体就不再与持久化上下文关联。**对分离实体所做的更改将不会反映在数据库中，除非显式地合并回托管状态。**我们可以通过在分离后尝试修改实体来验证这一点：

repository.detach(savedOrder);
// 修改实体
savedOrder.setName("New Order Name");

如果我们对分离的实体调用save()，它将重新将实体附加到持久化上下文，并且在刷新持久化上下文时将更改持久化到数据库。

3. 使用Spring Data JPA保存实体

当我们调用save()时，Spring Data JPA在事务提交时计划将实体插入数据库。它将实体添加到持久化上下文中，并将其标记为托管。

这是一个简单的代码片段，演示了如何在Spring Data JPA中使用save()方法持久化实体：

Order order = new Order();
order.setName("New Order Name");

repository.save(order);

然而，需要注意的是，调用save()并不会立即触发数据库插入操作。相反，它只是将实体转变为持久化上下文中的托管状态。因此，如果其他事务在我们事务提交之前从数据库中读取数据，它们可能会检索到我们尚未提交的更改之前的过时数据。

为确保数据保持最新，我们可以采用两种方法：获取和刷新。

4. Spring Data JPA中获取实体

当我们获取实体时，我们不会丢弃在持久化上下文中对它所做的任何修改。相反，我们只是从数据库中检索实体的数据，并将其添加到持久化上下文中以进行进一步处理。

4.1. 使用`findById()`

Spring Data JPA仓库提供了如findById()这样方便的方法来检索实体。这些方法总是从数据库中获取最新的数据，不管实体在持久化上下文中的状态如何。这种方法简化了实体检索，并消除了直接管理持久化上下文的需要。

Order order = repository.findById(1L).get();

4.2. 急切与延迟获取

**在急切获取中，所有与主实体相关联的实体都会在检索主实体的同时从数据库中检索出来。**通过在orderItems集合上设置fetch = FetchType.EAGER，我们指示JPA在检索Order时急切地获取所有相关的OrderItem实体：

@Entity
public class Order {
    @Id
    private Long id;

    @OneToMany(mappedBy = "order", fetch = FetchType.EAGER)
    private List```<OrderItem>``` orderItems;
}

这意味着在findById()调用之后，我们可以直接在order对象内访问orderItems列表，并遍历相关的OrderItem实体，而不需要任何额外的数据库查询：

Order order = repository.findById(1L).get();

// 在获取Order后直接访问OrderItems
if (order != null) {
    for (OrderItem item : order.getOrderItems()) {
        System.out.println("Order Item: " + item.getName() + ", Quantity: " + item.getQuantity());
    }
}

另一方面，通过设置fetch = FetchType.LAZY，相关实体将不会被从数据库中检索，直到它们在代码中被显式访问：

@Entity
public class Order {
    @Id
    private Long id;

    @OneToMany(mappedBy = "order", fetch = FetchType.LAZY)
    private List```<OrderItem>``` orderItems;
}

**当我们调用order.getOrderItems()时，将执行一个单独的数据库查询来获取该订单的相关OrderItem实体。**这个额外的查询仅因为我们显式访问了orderItems列表而被触发：

Order order = repository.findById(1L).get();

if (order != null) {
    List```<OrderItem>``` items = order.getOrderItems(); // 这触发了一个单独的查询来获取OrderItems
    for (OrderItem item : items) {
        System.out.println("Order Item: " + item.getName() + ", Quantity: " + item.getQuantity());
    }
}

4.3. 使用JPQL获取

**Java持久化查询语言（JPQL）允许我们编写针对实体而不是表的类似SQL的查询。**它提供了根据各种标准检索特定数据或实体的灵活性。

让我们看一个根据客户名称和订单日期范围获取订单的示例：

@Query("SELECT o FROM Order o WHERE o.customerName = :customerName AND "
  + "o.orderDate BETWEEN :startDate AND :endDate")
List```<Order>``` findOrdersByCustomerAndDateRange(@Param("customerName") String customerName,
  @Param("startDate") LocalDate startDate, @Param("endDate") LocalDate endDate);

4.4. 使用Criteria API获取

Spring Data JPA中的Criteria API提供了一种可靠和灵活的方法来动态创建查询。它允许我们使用方法链和标准表达式安全地构建复杂查询，确保我们的查询在编译时无误。

让我们考虑一个使用Criteria API根据客户名称和订单日期范围的组合标准获取订单的示例：

CriteriaBuilder criteriaBuilder = entityManager.getCriteriaBuilder();
CriteriaQuery```<Order>``` criteriaQuery = criteriaBuilder.createQuery(Order.class);
Root```<Order>``` root = criteriaQuery.from(Order.class);

Predicate customerPredicate = criteriaBuilder.equal(root.get("customerName"), customerName);
Predicate dateRangePredicate = criteriaBuilder.between(root.get("orderDate"), startDate, endDate);

criteriaQuery.where(customerPredicate, dateRangePredicate);

return entityManager.createQuery(criteriaQuery).getResultList();

5. 使用Spring Data JPA刷新实体

在JPA中刷新实体确保应用程序中内存中的实体表示与数据库中存储的最新数据保持同步。**当其他事务修改或更新实体时，持久化上下文中的数据可能会变得过时。**刷新实体允许我们从数据库中检索最近的数据，防止不一致并保持数据准确性。

5.1. 使用`refresh()`方法

在JPA中，我们使用EntityManager提供的refresh()方法来刷新实体。**在托管实体上调用refresh()会丢弃在持久化上下文中对该实体所做的任何修改。**它从数据库重新加载实体的状态，有效地替换了自实体上次与数据库同步以来所做的任何修改。

但需要注意的是，Spring Data JPA仓库没有提供内置的refresh()方法。

以下是使用EntityManager刷新实体的方法：

@Autowired
private EntityManager entityManager;

entityManager.refresh(order);

5.2. 处理`OptimisticLockException`

**Spring Data JPA中的@Version注解用于实现乐观锁。**它有助于确保当多个事务可能同时尝试更新同一个实体时的数据一致性。当我们使用@Version时，JPA会自动在我们的实体类上创建一个特殊字段（通常命名为version）。

这个字段存储了一个整数值，表示数据库中实体的版本：

@Entity
public class Order {
    @Id
    @GeneratedValue
    private Long id;

    @Version
    private Long version;
}

当我们从数据库中检索实体时，JPA积极获取其版本。**在更新实体时