Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- @Bean
- public JobLauncher jobLauncher(JobRepository jobRepository){
- SimpleJobLauncher jobLauncher = new SimpleJobLauncher();
- jobLauncher.setJobRepository(jobRepository);
- return jobLauncher;
- }
- @Bean
- public JobRepository jobRepository(DataSource dataSource, PlatformTransactionManager transactionManager) throws Exception{
- JobRepositoryFactoryBean factoryBean = new JobRepositoryFactoryBean();
- factoryBean.setDataSource(dataSource);
- factoryBean.setTransactionManager(transactionManager);
- factoryBean.setDatabaseType("mysql");
- return factoryBean.getObject();
- }
- @Bean
- public PlatformTransactionManager transactionManager() {
- return new ResourcelessTransactionManager();
- }
- @Bean
- public DataSource dataSource(){
- DriverManagerDataSource datasource = new DriverManagerDataSource();
- datasource.setDriverClassName("com.mysql.jdbc.Driver");
- datasource.setUrl("jdbc:mysql://localhost:3306/mysqltest?useSSL=false");
- datasource.setUsername("user");
- datasource.setPassword("pwd");
- return datasource;
- }
- @Bean
- @Autowired
- public Job projectMasterJob(JobBuilderFactory jobs, Step projectMasterDump) {
- return jobs.get("projectMasterJob").incrementer(new RunIdIncrementer())
- .flow(projectMasterDump).end().build();
- }
- @Bean
- @Autowired
- public Step projectMasterDump(StepBuilderFactory stepBuilderFactory,
- FlatFileItemReader projectMasterReader, ItemWriter projectMasterDbWriter) {
- return stepBuilderFactory.get("projectMasterDump")
- .chunk(10).reader(projectMasterReader).writer(projectMasterDbWriter).build();
- }
- @Bean
- @Autowired
- public ItemWriter projectMasterDbWriter(DataSource dataSource){
- JdbcBatchItemWriter<ProjectMasterDTO> writer = new JdbcBatchItemWriter<ProjectMasterDTO>();
- writer.setSql(sql);
- writer.setDataSource(dataSource);
- writer.setItemSqlParameterSourceProvider(new BeanPropertyItemSqlParameterSourceProvider<>());
- return writer;
- }
- @Bean
- @Autowired
- public FlatFileItemReader projectMasterReader(ProjectMasterDTO projectMasterDTO, DataFormatter dataFormatter){
- ExcelItemReader<ProjectMasterDTO> reader = new ExcelItemReader<>();
- reader.setDataFormatter(dataFormatter);
- reader.setBean(projectMasterDTO);
- reader.setMapperFile(new File("../instance-config/projectMapper.json"));
- return reader;
- }
- @Bean
- @Scope("prototype")
- public ProjectMasterDTO projectMasterDTO(){
- return new ProjectMasterDTO();
- }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement