Spring JpaRepository未返回更新的数据[重复]

Question

@Controller
public class ClientController {
    @Autowired
    NodeRepository nodeRepository;
    ...
}

@Controller
public class NodeController {
    @Autowired
    NodeRepository nodeRepository;
    ...
}

public interface NodeRepository extends JpaRepository<Node, Long>{
    Node findByNodeId(long nodeId);
    List<Node> findByStatusIn(Set<String> status);
    List<Node> findByNodeIdIn(Set<Long> ids);
    Node findByPhoneNumber(String phoneNumber);
    Node findByCloudId(String cloudId);
    Node findByDeviceDescription(String deviceDescription);
}

行为如下：

当ClientController接收到新请求时，将对其进行处理，控制器将请求发送到外部设备并等待其应答。
此应答由NodeController接收。因此，当答案到达时，接收到的信息将保存在数据库中，并向ClientController发送一个信号以唤醒它。

当这个控制器被唤醒并试图从数据库中检索更新的信息时，我的问题就来了。这些信息不是刚刚存储的信息，而是以前存储的信息。

// Retrieves the list of nodes that are going to be requested
requestedNodes = (List<Node>) nodeRepository.findAll();

System.out.println("BEFORE");
for (Node node : nodes)
    System.out.println(node.getNodeId() + ": " + node.getStatus());

// Sends a request to the nodes
// The Controller is blocked here until all answers have been received
fetchNodes(requestedNodes, DevicePing[0], null);

// Retrieves the list of nodes again
nodes = nodeRepository.findAll();

System.out.println("AFTER");
for (Node node : nodes)
    System.out.println(node.getNodeId() + ": " + node.getStatus());

BEFORE:
321: dead
1: dead
4: dead

AFTER:
321: dead
4: dead
1: dead

我已经检查了数据是否被正确地存储，它是正确的。在解锁ClientController之前，新数据在数据库中可用。

我还尝试使用存储库的JDBC intead检索新数据。在这种情况下，将正确检索新信息。因此，我认为它一定是与存储库相关的东西，但我找不到它是什么。可能存在一些缓存或刷新问题。我试图在保存新数据之后和检索新数据之前执行noderepository.flush()，但没有成功。

我希望有人能帮我。提前致谢

Answer 1

我终于找到了答案。这个问题确实与一些缓存问题有关。

Hibernate缓存使用函数nodeRepository.findAll()检索的实体，因此当我调用函数nodeRepository.findAll()时，它返回缓存的信息，而不是对数据库执行查询。

解决方案是在检索更新的数据之前，从EntityManager调用函数clear():

// Sends a request to the nodes
// The Controller is blocked here until all answers have been received
fetchNodes(requestedNodes, DevicePing[0], null);

// Clears the cache to avoid inconsistency
entityManager.clear();

// Retrieves the list of nodes again
nodes = nodeRepository.findAll();