protected JobRepository createJobRepository() throws Exception { JobRepositoryFactoryBean factory = new JobRepositoryFactoryBean(); factory.setDataSource(this.dataSource); if (this.entityManagerFactory != null) { logger.warn( "JPA does not support custom isolation levels, so locks may not be taken when launching Jobs"); factory.setIsolationLevelForCreate("ISOLATION_DEFAULT"); } String tablePrefix = this.properties.getTablePrefix(); if (StringUtils.hasText(tablePrefix)) { factory.setTablePrefix(tablePrefix); } factory.setTransactionManager(getTransactionManager()); factory.afterPropertiesSet(); return factory.getObject(); }
@Bean public JobRepository batchSimpleJobRepository(DataSource dataSource) throws Exception { JobRepositoryFactoryBean factory = new JobRepositoryFactoryBean(); factory.setDataSource(dataSource); factory.setTransactionManager(transactionManager); factory.afterPropertiesSet(); return factory.getObject(); }
@Bean @ConditionalOnMissingBean(JobRepository.class) public JobRepository getJobRepository() throws Exception { BatchConfigurer batchConfigurer = getBatchConfigurer(); if (batchConfigurer != null) { return batchConfigurer.getJobRepository(); } JobRepositoryFactoryBean factory = new JobRepositoryFactoryBean(); factory.setDataSource(dataSource); factory.setTransactionManager(transactionManager); factory.afterPropertiesSet(); // factory.setIsolationLevelForCreate("ISOLATION_DEFAULT"); return factory.getObject(); }
@Bean public JobRepository jobRepository() throws Exception { JobRepositoryFactoryBean factory = new JobRepositoryFactoryBean(); factory.setDataSource(dataSource); factory.setTransactionManager(transactionManager); factory.afterPropertiesSet(); return (JobRepository) factory.getObject(); }
/** * This method is creating jobrepository * * @return JobRepositoryFactoryBean */ @Bean(name = "jobRepository") public JobRepositoryFactoryBean jobRepository() { this.jobRepository = new JobRepositoryFactoryBean(); this.jobRepository.setDataSource(this.dataSource); this.jobRepository.setTransactionManager(this.transactionManager); this.jobRepository.setIsolationLevelForCreate(this.isolationLevelForCreate); return this.jobRepository; }
private static JobRepository createJobRepository(DataSource dataSource, PlatformTransactionManager transactionManager) throws Exception { JobRepositoryFactoryBean factory = new JobRepositoryFactoryBean(); factory.setDataSource(dataSource); factory.setTransactionManager(transactionManager); factory.afterPropertiesSet(); return factory.getObject(); }
@BeforeClass public static void setUp() throws Exception { dataSource = applicationContext.getBean(DataSource.class); taskBatchDao = new JdbcTaskBatchDao(dataSource); JobRepositoryFactoryBean repositoryFactoryBean = new JobRepositoryFactoryBean(); repositoryFactoryBean.setDataSource(dataSource); repositoryFactoryBean.setTransactionManager(new DataSourceTransactionManager(dataSource)); jobRepository = repositoryFactoryBean.getObject(); TaskExecutionDaoFactoryBean taskExecutionDaoFactoryBean = new TaskExecutionDaoFactoryBean(dataSource); dao = taskExecutionDaoFactoryBean.getObject(); createSampleJob(JOB_NAME_ORIG, 1); createSampleJob(JOB_NAME_FOO, 1); createSampleJob(JOB_NAME_FOOBAR, 2); }
private void initialize() throws Exception { JobRepositoryFactoryBean repositoryFactoryBean = new JobRepositoryFactoryBean(); repositoryFactoryBean.setDataSource(this.dataSource); repositoryFactoryBean.setTransactionManager(new DataSourceTransactionManager(this.dataSource)); this.jobRepository = repositoryFactoryBean.getObject(); this.dao = (new TaskExecutionDaoFactoryBean(this.dataSource)).getObject(); this.taskBatchDao = new JdbcTaskBatchDao(this.dataSource); }
@Bean public SimpleJobServiceFactoryBean simpleJobServiceFactoryBean(DataSource dataSource, JobRepositoryFactoryBean repositoryFactoryBean) throws Exception { SimpleJobServiceFactoryBean factoryBean = new SimpleJobServiceFactoryBean(); factoryBean.setDataSource(dataSource); factoryBean.setJobRepository(repositoryFactoryBean.getObject()); factoryBean.setJobLocator(new MapJobRegistry()); factoryBean.setJobLauncher(new SimpleJobLauncher()); factoryBean.setDataSource(dataSource); return factoryBean; }
@Bean public JobRepositoryFactoryBean jobRepositoryFactoryBeanForServer(DataSource dataSource, DataSourceTransactionManager dataSourceTransactionManager) { JobRepositoryFactoryBean repositoryFactoryBean = new JobRepositoryFactoryBean(); repositoryFactoryBean.setDataSource(dataSource); repositoryFactoryBean.setTransactionManager(dataSourceTransactionManager); return repositoryFactoryBean; }
@Bean public JobRepositoryFactoryBean jobRepositoryFactoryBean(DataSource dataSource, DataSourceTransactionManager dataSourceTransactionManager) { JobRepositoryFactoryBean repositoryFactoryBean = new JobRepositoryFactoryBean(); repositoryFactoryBean.setDataSource(dataSource); repositoryFactoryBean.setTransactionManager(dataSourceTransactionManager); return repositoryFactoryBean; }
@Bean public SimpleJobServiceFactoryBean simpleJobServiceFactoryBean(DataSource dataSource, JobRepositoryFactoryBean repositoryFactoryBean) { SimpleJobServiceFactoryBean factoryBean = new SimpleJobServiceFactoryBean(); factoryBean.setDataSource(dataSource); try { factoryBean.setJobRepository(repositoryFactoryBean.getObject()); factoryBean.setJobLocator(new MapJobRegistry()); factoryBean.setJobLauncher(new SimpleJobLauncher()); } catch (Exception e) { throw new IllegalStateException(e); } return factoryBean; }
protected JobRepository createJobRepository() throws Exception { final JobRepositoryFactoryBean factory = new JobRepositoryFactoryBean(); factory.setDataSource(this.dataSource); //prevent ISOLATION_DEFAULT setting for oracle (i.e. SERIALIZABLE) //ISOLATION_REPEATABLE_READ throws READ_COMMITTED and SERIALIZABLE are the only valid transaction levels factory.setIsolationLevelForCreate(JobConfig.this.isolationLevelForCreate); factory.setTablePrefix(JobConfig.this.tablePrefix); factory.setTransactionManager(getTransactionManager()); factory.afterPropertiesSet(); return factory.getObject(); }
@Bean public JobRepository jobRepository() throws Exception { JobRepositoryFactoryBean factory = new JobRepositoryFactoryBean(); factory.setDataSource(dataSource); factory.setTransactionManager(transactionManager); factory.afterPropertiesSet(); factory.setIsolationLevelForCreate("ISOLATION_DEFAULT"); return factory.getObject(); }
protected JobRepository createJobRepository() throws Exception { JobRepositoryFactoryBean factory = new JobRepositoryFactoryBean(); factory.setDataSource(dataSource); factory.setTransactionManager(transactionManager); String isolationLevelForCreate = env.getProperty("batch.repository.isolationlevelforcreate"); if (isolationLevelForCreate != null) { factory.setIsolationLevelForCreate(isolationLevelForCreate); } String tablePrefix = env.getProperty("batch.repository.tableprefix"); if (tablePrefix != null) { factory.setTablePrefix(tablePrefix); } factory.afterPropertiesSet(); return factory.getObject(); }
protected JobRepository createJobRepository() throws Exception { JobRepositoryFactoryBean factory = new JobRepositoryFactoryBean(); factory.setIsolationLevelForCreate("ISOLATION_SERIALIZABLE"); factory.setDataSource(dataSource); factory.setTransactionManager(transactionManager); factory.setValidateTransactionState(false); factory.afterPropertiesSet(); return factory.getObject(); }
@Bean public JobRepository jobRepository() throws Exception { log.info("create JobRepository..."); JobRepositoryFactoryBean factory = new JobRepositoryFactoryBean(); factory.setDataSource(dataSource()); factory.setTransactionManager(transactionManager()); factory.afterPropertiesSet(); return factory.getJobRepository(); }
@Bean public JobRepository jobRepository(@Qualifier("jobDataSource") DataSource dataSource, @Qualifier("jobTransactionManager") PlatformTransactionManager transactionManager) throws Exception { log.info("create JobRepository... dataSource=[{}], transactionManager=[{}]", dataSource, transactionManager); JobRepositoryFactoryBean factory = new JobRepositoryFactoryBean(); factory.setDataSource(dataSource); factory.setTransactionManager(transactionManager); // HINT: 에러메시지 Standard JPA does not support custom isolation levels - use a special JpaDialect for your JPA implementation 가 나올 때 // HINT: http://forum.springsource.org/showthread.php?59779-Spring-Batch-1-1-2-Standard-JPA-does-not-support-custom-isolation-levels-use-a-sp factory.setIsolationLevelForCreate("ISOLATION_DEFAULT"); factory.afterPropertiesSet(); return factory.getJobRepository(); }
@Bean public JobRepository jobRepository(DataSource dataSource, PlatformTransactionManager transactionManager) throws Exception { LaunchConfiguration.log.info("create JobRepository..."); JobRepositoryFactoryBean factory = new JobRepositoryFactoryBean(); factory.setDataSource(dataSource); factory.setTransactionManager(transactionManager); factory.afterPropertiesSet(); return factory.getJobRepository(); }
@Bean public JobRepository jobRepository() throws Exception { LaunchConfiguration.log.info("create JobRepository..."); JobRepositoryFactoryBean factory = new JobRepositoryFactoryBean(); factory.setDataSource(dataSource()); factory.setDatabaseType(DatabaseType.HSQL.name()); factory.setTransactionManager(transactionManager()); factory.afterPropertiesSet(); return factory.getJobRepository(); }