如何在Spring批处理应用程序启动时将数据插入表

Question

我是Spring批处理编程的新手，我加入了下面的场景。

我有一个Spring批处理应用程序，我希望每次应用程序启动时都运行一个SQL插入脚本。

设想情况：

我的Spring应用程序有两个数据库- (1) HSQL和(2) MySQL --所有与spring批处理相关的表都是在HSQL中创建的，而应用程序所需的所有表都存在于MySQL中。每次应用程序启动时，我都希望在MySQL中运行一个INSERT SQL脚本。

我浏览了许多文章，并按照大多数文章中的建议创建了data.sql和data-mysql.sql并运行了我的应用程序。但是它尝试在HSQL中搜索表，并抛出对象，而不是找到异常。

我是否可以执行一个SQL脚本，以便它能够尝试连接到MySQL，然后执行插入。

我们非常感谢你的帮助。

提前谢谢Saurabh

Answer 1

您可以使用JobExecutionListener.beforeJob Listener和Spring ScriptUtils

示例代码：

public class MyobListener implements JobExecutionListener {
@Autowired
Private DataSource yourMySQLDataSource 

   //This method will be called before job get started 
    @Override
    public void beforeJob(JobExecution jobExecution) {
    ScriptUtils.executeSqlScript(yourMySQLDataSource.getConnection(), new ClassPathResource("your.sql"));

    }

    @Override
    public void afterJob(JobExecution jobExecution) {   

    }
}

参考：ScriptUtil