| | |
| | | |
| | | maybeUpdate.getData().sort((o1, o2) -> DateUtil.compare(o1.getDate(extractUpdateTimeField), o2.getDate(extractUpdateTimeField))); |
| | | |
| | | batchResultEntity = targetNewDao.updateBatch(maybeUpdate, updateFilterEntity, false); |
| | | batchResultEntity = targetNewDao.updateBatch(maybeUpdate, updateFilterEntity, true); |
| | | |
| | | WriteExtractUtil.append("更新提取过滤后数据:" + extractTargetTable + ",需要更新的条数:" + maybeUpdate.getRows() + ",耗时:" + tempTestTimer2.intervalMs()); |
| | | targetNewDao.closeConnection(); |
| | | } |
| | | |
| | | if (!DataTableEntity.isEmpty(data)) { |