JDO 查询返回与过滤条件不匹配的实体

Question

我运行了以下 jdo 查询，它旨在获取具有空“流 id”的实体列表。但是，当我检查返回的列表时，它确实包含一个具有非空流 id 的实体。

PersistenceManager pm = pmf.getPersistenceManagerProxy();    
String flowId = "";
Map<String, Object> params = new HashMap<>();
params.put("flowId", flowId);
List<MyEntity> entities = pm.newQuery(MyEntity.class, " this.flowId == :flowId ").setNamedParameters(params).executeList();

它并不总是发生，但是当它发生时，我发现总是有来自另一个进程的对该实体的更新，以在类似的时间清除“流 id”。但是，我从上述查询中获得的结果具有该实体，但显示了一个非空的流 ID。我还检查了意外返回实体的 JDO 对象状态，它是持久干净的。查询在活动事务中运行。

这里是 JDOQLQuery 编译的 SQL。

SELECT 'com.example.MyEntity' AS "NUCLEUS_TYPE","A0"."CREATE_TIME","A0"."DATA_MAX_TIMESTAMP","A0"."DATA_MIN_TIMESTAMP","A0"."ID","A0"."OBSERVATION_ID","A0"."PARTITION_VALUE","A0"."PARTITION_CYCLE","A0"."PARTITION_TIMESTAMP","A0"."FLOW_ID","A0"."PROCESSING_STAGE","A0"."PROCESSING_STATUS","A0"."RECORD_COUNT","A0"."UPDATE_TIME" FROM "MY_ENTITIES" "A0" WHERE "A0"."FLOW_ID" = ?

虽然我认为这无关紧要，但隔离级别是读提交的，实体是可分离的，并且上面的查询是在事务中运行的。请帮忙，谢谢！

更新

在我将隔离级别更改为可重复读取后，它就再也不会发生了。因此很可能与隔离级别有关。我不确定是否存在错误。我的数据核版本是 4.1.6。任何想法都会有所帮助。

Answer 1

我关闭了一级和二级缓存。在一些罕见的情况下，数据核中的缓存似乎不起作用，多个进程使用已提交的隔离级别更新同一行。

当数据存储应用过滤条件时，它可以看到来自另一个进程的最新更新（在我的示例中将 flow_id 设置为空）。所以它返回该行。但是，当 datanucleus 使用行 ID 查找其字段时，它会首先检查缓存，但该实体的缓存中存在潜在的陈旧值，这似乎是此问题的根本原因。