我需要为这个案子制定一个解决方案。我有一个这样的表,我必须将共享产品+服务+原产地的寄存器数量减少到可能的最小范围:

ID PRODUCT SERVICE ORIGIN STARTDATE ENDDATE
1 100001 500 1 10/01/2023 15/01/2023
2 100001 500 1 12/01/2023 18/01/2023

我必须阅读所有记录,并在此过程中检查日期间隔,以统一它们:

  • 记录A(2023年1月10日-2023年01月15日)记录B(2023月1日-2022年1月18日)这将导致使用ID1日期更新寄存器,从而在两个日期和寄存器之间留下较大的范围:2023年10月1日-2023年01月18日(必要时扩展到其中一个范围的“右”或“左”)

其他情况:|ID|PRODUCT|SERVICE|ORIGIN|STARTDATE|ENDDATE||--------|--------|--------|---------|---------|--------|1|100001|500|1|2023/10/2023|15/01/2023||2|100001|500|1 |2023/12/01/2023|12/01/2023 |14/01/2023|

  • 在这种情况下,Record1的日期范围最大,我们应该删除Record2。
  • 当然,删除重复的日期范围

现在,我们已经实施了一个分块步骤,使之成为可能:

  • 读卡器:按公共字段读取数据排序(产品服务来源)
  • 处理器:保存在HashMap<;字符串,列表>;在工作上下文中,所有的寄存器,而“产品+服务+原产地”的组合是相同的。当检测到新的组合时,获取当前列表并进行大量比较,将记录辅助财产标记为“delete”或“update”,并将完整列表发送给编写器(之前在映射中使用新的公共字段组合开始创建其他列表)
  • 编写者:将要删除和更新的记录分组,并调用子编写者执行句子。

好吧,这是几年前的软件,但很快我们必须控制每个案例的大量记录,在JobContext中使用地图的“解决方案”必须改变。

我在想SpringBatch是否有一些我可以使用的特性来处理这类情况。

无论如何,我正在考虑更改插入所有这些记录的步骤,并在处理器中进行一对一的日期范围检查,但我认为这里的提交间隔必须为1,以允许每个寄存器检查所有先前处理的寄存器(当我们执行此作业时,表基本为空)。提交间隔中的其他值将在bbdd中进行检查,但不会在先前处理的项目中进行检查。

  • 所有这些案例都可以有0-n条记录共享产品+服务+原产地。

对不起,我的英语,很难用其他语言解释。

Spring批处理,将当前处理的记录与其余块记录进行比较的更多相关文章

  1. Spring批处理,将当前处理的记录与其余块记录进行比较

    我需要为这个案子制定一个解决方案。好吧,这是几年前的软件,但很快我们必须控制每个案例的大量记录,在JobContext中使用地图的“解决方案”必须改变。我在想SpringBatch是否有一些我可以使用的特性来处理这类情况。提交间隔中的其他值将在bbdd中进行检查,但不会在先前处理的项目中进行检查。

  2. Spring Batch/Data JPA应用程序未将数据持久化到数据库

    我需要说的是,我的代码在本地运行得很好,但没有在我们的pod中保存一些数据。在此批处理中,我有不同的数据源可供使用。JobRepository基于地图,并使用ResourcelessTransactionManager我还使用不同的平台transactionmanager,然后使用springbatch(问题)。所以我在财产中将spring-allow-bean覆盖设置为true。链式事务管理器配置:因此,我在writer中的前两个jpa操作工作正常,但最后一个操作不是将数据持久化到db。它不会抛出任何错

随机推荐

  1. 如何扩展ATmega324PB微控制器的以下宏寄存器?

    我目前正在学习嵌入式,我有以下练习:展开以下宏寄存器:如果有人解决了这个问题,我将不胜感激,以便将来参考

  2. Python将ONNX运行时设置为返回张量而不是numpy数组

    在python中,我正在加载预定义的模型:然后我加载一些数据并运行它:到目前为止,它仍在正常工作,但我希望它默认返回Tensor列表,而不是numpy数组。我对ONNX和PyTorch都是新手,我觉得这是我在这里缺少的基本内容。这将使转换中的一些开销相同。

  3. 在macOS上的终端中使用Shell查找文件中的单词

    我有一个文本文件,其中有一行:我需要找到ID并将其提取到变量中。我想出了一个RexEx模式:但它似乎对我尝试过的任何东西都不起作用:grep、sed——不管怎样。我的一个尝试是:我为这样一个看似愚蠢的问题感到抱歉,但我在互联网上找不到任何东西:我在SO和SE上读了几十个类似的问题,并在谷歌上搜索了几个教程,但仍然无法找到答案。欢迎提供任何指导!

  4. react-chartjs-2甜甜圈图中只有标题未更新

    我正在使用react-chartjs-2在我的网站中实现甜甜圈图。下面是我用来呈现图表的代码。我将甜甜圈图的详细信息从父组件传递到子组件,所有道具都正确传递。当我在beforeDraw函数外部记录props.title时,它会记录正确的值,但当我在beforeDraw函数内部记录props.title时,它将记录标题的前一个值,从而呈现标题的前值。我在这里做错了什么?

  5. 如何在tkinter中使用Python生成器函数?

    生成器函数承诺使某些代码更易于编写。但我并不总是知道如何使用它们。假设我有一个斐波那契生成器函数fib(),我想要一个显示第一个结果的tkinter应用程序。当我点击“下一步”按钮时,它会显示第二个数字,依此类推。我如何构建应用程序来实现这一点?我可能需要在线程中运行生成器。但如何将其连接回GUI?

  6. 如何为每次提交将存储库历史记录拆分为一行?

    我正在尝试获取存储库的历史记录,但结果仅以单行文本的形式返回给我。

  7. 尝试在颤振项目上初始化Firebase时出错

    当尝试在我的颤振项目上初始化firebase时,我收到了这个错误有人知道我能做什么吗?应用程序分级Gradle插件Gradle项目颤振相关性我已经将firebase设置为Google文档已经在另一个模拟器上尝试过,已经尝试过创建一个全新的模拟器,已经在不同的设备上尝试过了,已经尝试了特定版本的firebase,已经尝试添加但没有任何效果,已经在youtube上看到了关于它的每一个视频,该应用程序在android和iOS两个平台上都抛出了这个错误

  8. 在unix中基于当前日期添加新列

    我试图在unix中基于时间戳列在最后一个单元格中添加一个状态列。我不确定如何继续。

  9. 麦克斯·蒙特利。我一直得到UncaughtReferenceError:当我在终端中写入node-v时,节点未定义

    如果这是您应该知道的,请确认:我已将所有shell更改为默认为zsh。当我在终端中写入node-v时,我一直收到“UncaughtReferenceError:nodeisnotdefined”。但它显示节点已安装。我是个新手,在这方面经验不足。

  10. 如何在前端单击按钮时调用后端中的函数?

    那么如何在后端添加一个新的端点,点击按钮调用这个函数。

返回
顶部