Advertisement
Guest User

Untitled

a guest
Jan 14th, 2017
92
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 2.41 KB | None | 0 0
  1. @Bean
  2. public JobLauncher jobLauncher(JobRepository jobRepository){
  3. SimpleJobLauncher jobLauncher = new SimpleJobLauncher();
  4. jobLauncher.setJobRepository(jobRepository);
  5. return jobLauncher;
  6. }
  7.  
  8.  
  9. @Bean
  10. public JobRepository jobRepository(DataSource dataSource, PlatformTransactionManager transactionManager) throws Exception{
  11. JobRepositoryFactoryBean factoryBean = new JobRepositoryFactoryBean();
  12. factoryBean.setDataSource(dataSource);
  13. factoryBean.setTransactionManager(transactionManager);
  14. factoryBean.setDatabaseType("mysql");
  15. return factoryBean.getObject();
  16.  
  17. }
  18.  
  19.  
  20. @Bean
  21. public PlatformTransactionManager transactionManager() {
  22. return new ResourcelessTransactionManager();
  23. }
  24.  
  25. @Bean
  26. public DataSource dataSource(){
  27. DriverManagerDataSource datasource = new DriverManagerDataSource();
  28. datasource.setDriverClassName("com.mysql.jdbc.Driver");
  29. datasource.setUrl("jdbc:mysql://localhost:3306/mysqltest?useSSL=false");
  30. datasource.setUsername("user");
  31. datasource.setPassword("pwd");
  32. return datasource;
  33. }
  34.  
  35.  
  36. @Bean
  37. @Autowired
  38. public Job projectMasterJob(JobBuilderFactory jobs, Step projectMasterDump) {
  39. return jobs.get("projectMasterJob").incrementer(new RunIdIncrementer())
  40. .flow(projectMasterDump).end().build();
  41. }
  42.  
  43.  
  44. @Bean
  45. @Autowired
  46. public Step projectMasterDump(StepBuilderFactory stepBuilderFactory,
  47. FlatFileItemReader projectMasterReader, ItemWriter projectMasterDbWriter) {
  48. return stepBuilderFactory.get("projectMasterDump")
  49. .chunk(10).reader(projectMasterReader).writer(projectMasterDbWriter).build();
  50. }
  51.  
  52. @Bean
  53. @Autowired
  54. public ItemWriter projectMasterDbWriter(DataSource dataSource){
  55. JdbcBatchItemWriter<ProjectMasterDTO> writer = new JdbcBatchItemWriter<ProjectMasterDTO>();
  56. writer.setSql(sql);
  57. writer.setDataSource(dataSource);
  58. writer.setItemSqlParameterSourceProvider(new BeanPropertyItemSqlParameterSourceProvider<>());
  59. return writer;
  60. }
  61.  
  62. @Bean
  63. @Autowired
  64. public FlatFileItemReader projectMasterReader(ProjectMasterDTO projectMasterDTO, DataFormatter dataFormatter){
  65. ExcelItemReader<ProjectMasterDTO> reader = new ExcelItemReader<>();
  66. reader.setDataFormatter(dataFormatter);
  67. reader.setBean(projectMasterDTO);
  68. reader.setMapperFile(new File("../instance-config/projectMapper.json"));
  69. return reader;
  70. }
  71.  
  72.  
  73. @Bean
  74. @Scope("prototype")
  75. public ProjectMasterDTO projectMasterDTO(){
  76. return new ProjectMasterDTO();
  77. }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement