我有一个很奇怪的问题。我需要说的是,我的代码在本地运行得很好,但没有在我们的pod(k8环境)中保存一些数据。

在此批处理中,我有不同的数据源可供使用。一切正常。Job Repository基于地图,并使用ResourcelessTransactionManager

@Configuration
@EnableBatchProcessing
public class BatchConfigurer extends DefaultBatchConfigurer {

    @Override
    public void setDataSource(DataSource dataSource){


    }
}

我还使用不同的平台transactionmanager,然后使用springbatch(问题)。所以我在财产中将spring-allow-bean覆盖设置为true。我的配置器中的平台事务管理器是右绑定的,我调试了它。

我的一个步骤是定制作家。更新多个dbs中的多个表中的记录(简而言之,不同的数据源)

public class MyWriter implements ItemWriter<MyDTO> {

    @Autowired
    private MyFirstRepo myfirstRepo; //table in first datasource

    @Autowired
    private MySecondRepo mySecondRepo; //table in second datasource
    
    
        @Override
        public void write(List<? extends MyDTO> myDtoList) throws Exception {
         //some logic
         mySecondRepo.delete(deletableEntity)

         //some logic
         mySecondRepo.saveAll(updatableEntities)

         //some logic
         myfirstRepo.saveAll(updatableEntities)
        }
    
    }

由于我有多个数据源,所以我定义了多个事务管理器,为了将事务管理器赋予我的步骤,我定义了包含这些管理器的链式事务管理器。

    @Bean
    public Step myStep(@Qualifier("chainedTransactionManager") ChainedTransactionManager chainedTransactionManager) {
 
        return getCommonStepBuilder("myStep")
                .transactionManager(chainedTransactionManager)
                .<MyDTO,MyDTO>chunk(200)
                .reader(myPaginingReader())
                .writer(myWriter)
                .taskExecutor(myTaskExecutor())
                .throttleLimit(15)
                .build();

    }

链式事务管理器配置(这两个事务管理器都是JpaTransactionManager):

@Configuration
public class TransactionManagerConfig {

    @Primary
    @Bean(name = "chainedTransactionManager")
    public ChainedTransactionManager transactionManager(

            @Qualifier("firstTransactionManager") PlatformTransactionManager firstTransactionManager,

            @Qualifier("secondTransactionManager")PlatformTransactionManager secondTransactionManager) {

        return new ChainedTransactionManager(firstTransactionManager,secondTransactionManager);

    }

}

因此,我在writer中的前两个jpa操作工作正常(对MyFirstRepo进行的操作),但最后一个操作不是将数据持久化到db。它不会抛出任何错误,作业成功完成,但不会更新表中的记录。

我必须提到第二次,它确实在我的本地更新。只是没有在我们的k8环境(码头化微服务)应用程序中更新。这让它变得如此令人困惑。知道为什么会这样吗?

Spring Batch/Data JPA应用程序未将数据持久化到数据库的更多相关文章

  1. Spring Boot可以修剪请求数据中的所有字符串吗?

    给定以下SpringBoot控制器操作请求主体绑定到以下类的实例如果用户提交的名称为"mything",验证将通过,因为有10个字符。我希望在验证之前将字符串修剪为"mything"。我可以自己在ThingRequest的构造函数中实现这一点,但我怀疑有一种更具声明性的方法。理想情况下,我希望将此修剪应用于用@RequestBody注释的对象的所有字符串财产用@RequestPart注释的对象所有字符串财产用@PathVariable注释的所有字符串但目前我只需要。SpringBoot是否提供了自动执行此

  2. Spring Boot Bean:构造函数中传递的值在构造函数中不为null,但在CGLIB代理中为null

    我在Kotlin中实现了以下存储库:具有以下基类:运行集成测试时,我得到一个异常,因为dao为空。我注意到对象引用不一样,但我不知道构造函数调用和创建代理bean之间发生了什么。我尝试了在SapArticleRepository中实现的抽象函数getDaoImpl()和调用该方法,但这似乎过于复杂。必须有一种方法来传递构造函数参数/字段,使其在使用Bean时仍然存在。注意TrmSapArticleDao只是Jooq生成的类。

  3. 类文件的版本61.0错误,IntelliJ中应为52.0

    我尝试过在本地的“JAVA_HOME”下设置环境变量,尝试过配置“javac”,尝试过在JAVA版本和项目结构的设置中更改版本。仍然没有解决方案。我以为这是STS问题,但它也发生在intelliJ上。

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

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

  5. 即使设备在开放遥测sdk中关闭,过时数据仍在流式传输

    我正在使用OpenTelemetry手动检测发送设备数据。我在这里面临的问题是,即使在关闭了设备之后,我也可以看到仪表仍在为关闭的设备发送数据。如果我再次重新启动服务器,那么我就不会再看到关闭的设备。请在这里提供任何指示。

  6. 如何在没有基础调用的情况下从Flux中分离数据?

    我正在使用反应式弹簧引导框架,我的应用程序中有一个这样的流程:现在,我看到来自redis的数据被获取了4次,我想要的是我们以反应方式获取一次,并将其分离出来,而不进行阻塞。

  7. Spring boot-从两个模型文件中获取常见细节

    我有两个模型文件UserDetails.java2.自定义用户细节.java在UserDetailsDaoImpl.java中在获取用户详细信息时-在获取详细信息后,需要使用CustomUserDetails减少详细信息(意味着在该对象中,我只有id、电子邮件和密码)

  8. 请求用户注册时出错,我无法删除空错误?

    我在restapi中实现用户控制器spring-boot时遇到了一个问题:问题如下,它都被配置为接收json,但当我放置json时,我有一个返回403bindexception,指责请求正文中发送的5个点为空,它们不是!下面是代码、请求和响应。如果有人能告诉我为什么api不接受它,我将非常感激!

  9. PostgreSQL上的Spring JBDC错误sql语法

    所以我试图将数据库从MySQL切换到PostgreSQL。我已经使用SpringBoot构建了一个API,它可以在MySQL上完美地执行基本的CRUD操作。问题是,当我用新的PostgreSQL在Postman中测试我的API时,只有GET和DELETE请求可以完美工作。POST和PUT请求返回此错误的sql语法错误错误如下:以下是执行查询的回购代码:我不熟悉PostgreSQL,因为这是我第一次使用它。当我使用MySQL时,所有的请求都能完美地工作,所以当它不在PostgreSQL上工作时,我为什么如此

  10. 当电子邮件返回错误时,将错误传递给错误电子邮件代码,并将其包含在电子邮件正文中

    我正在开发一个springboot应用程序,以生成一封pdf格式的电子邮件。如果异常处理程序捕获到异常,文档服务将返回一条消息,当它返回错误时,将错误传递给错误电子邮件代码并将其包含在电子邮件正文中。最后我想测试一下。

随机推荐

  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. 如何在前端单击按钮时调用后端中的函数?

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

返回
顶部