mysql - Spring Batch JpaPagingItemReader(可能)在使用 SELECT native 查询时从数据库中删除行

Question

我正在尝试使用 JpaPagingItemReader 执行 native SELECT 查询。但是，当我运行它时，一些记录从我的数据库中删除(我使用 mysql 控制台在批处理作业执行之前和之后检查了它)。我与 MySQL 数据库通信的唯一的地方是当我读取数据时 - 像这样:

@Autowired
EntityManagerFactory entityManagerFactory

@Value('${integration.date.value}')
String date


@Bean
JpaPagingItemReader<Entry> entryJpaPagingItemReader() {
    JpaPagingItemReader jpaPagingItemReader = new JpaPagingItemReader<Entry>()
    jpaPagingItemReader.setEntityManagerFactory(entityManagerFactory)
    jpaPagingItemReader.setQueryProvider(createQueryProvider())
    jpaPagingItemReader.setPageSize(500)
    jpaPagingItemReader.afterPropertiesSet()
    jpaPagingItemReader
}

private JpaNativeQueryProvider<Entry> createQueryProvider() {
    String query = "SELECT distinct * FROM entry e WHERE e.entry_formal_category in ('FIL','SER') " +
            "and e.entry_categories not regexp 'DZI|INN|DOK' and e.entry_date = \'" + date + "\'" +
            " GROUP BY e.entry_title ORDER BY e.entry_id"

    JpaNativeQueryProvider<Entry> queryProvider = new JpaNativeQueryProvider<Entry>()
    queryProvider.setSqlQuery(query)
    queryProvider.setEntityClass(Entry)
    queryProvider.afterPropertiesSet()
    queryProvider
}

我对这种行为感到非常震惊 - 每次执行该作业时，我都会从数据库中丢失大约 10 到 50 条记录。是否有可能是原生查询结果分页导致的？

编辑:一点更新。当我将 pageSize 设置为 1500(这是一个大小，将在一页上保存所有行)时，问题不会发生。看起来这可能是一个 spring-batch bug。

Answer 1

好吧 - 我错过了一个修改 Entry 对象的地方，并且在获取另一页之前将更改传播到数据库。 Spring 批处理工作得很好 - 这是我的错。问题已解决 - 谢谢! :)