Java 类org.springframework.batch.core.repository.support.JobRepositoryFactoryBean 实例源码

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();
}

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();
}

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);
}

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);
}

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;
}

@Bean
public JobRepositoryFactoryBean jobRepositoryFactoryBeanForServer(DataSource dataSource,
        DataSourceTransactionManager dataSourceTransactionManager) {
    JobRepositoryFactoryBean repositoryFactoryBean = new JobRepositoryFactoryBean();
    repositoryFactoryBean.setDataSource(dataSource);
    repositoryFactoryBean.setTransactionManager(dataSourceTransactionManager);
    return repositoryFactoryBean;
}

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();
}