[例外の解決]spring batchエラーORA-08177:このトランザクションに連続的にアクセスできません

4473 ワード

問題の説明:
Spring batch接続oracle操作を使用すると、常に次の異常が表示されます.
PreparedStatementCallback; SQL [INSERT into BATCH_JOB_INSTANCE(JOB_INSTANCE_ID, JOB_NAME, JOB_KEY, VERSION) values (?, ?, ?, ?)]; ORA-08177:            

理由:spring batchデフォルトはISO LATION_SERIALIZABLE
公式文書説明:The default is ISO LATION_SERIALIZABLE, which prevents accidental concurrent execution of the same job (ISOLATION_REPEATABLE_READ would work as well).
解決策:
1.資料を調べる:http://stackoverflow.com/questions/22364432/spring-batch-ora-08177-cant-serialize-access-for-this-transaction-when-runningOracleトランザクションレベルをSERIALIZABLEからISO LATIONに変更すると言われています.READ_COMMITTEDでいいです.確かにそうです.
2.自分で資料に基づいて実現する:
package cn.yong.zheng.config;

import javax.sql.DataSource;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.batch.core.configuration.annotation.EnableBatchProcessing;
import org.springframework.batch.core.launch.support.SimpleJobLauncher;
import org.springframework.batch.core.repository.JobRepository;
import org.springframework.batch.core.repository.support.JobRepositoryFactoryBean;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.transaction.PlatformTransactionManager;

/**
 * @author zhengyong
 *
 */
@Configuration
@EnableBatchProcessing
public class CommonBatchConfiguration{
	
	private static final Logger logger = LoggerFactory.getLogger(CommonBatchConfiguration.class);
    
    @Bean
    public JobRepositoryFactoryBean jobRepositoryFactoryBean(DataSource dataSource,PlatformTransactionManager transactionManager){
    	JobRepositoryFactoryBean jobRepositoryFactoryBean = new JobRepositoryFactoryBean();
    	jobRepositoryFactoryBean.setTransactionManager(transactionManager);
    	jobRepositoryFactoryBean.setDataSource(dataSource);
    	jobRepositoryFactoryBean.setIsolationLevelForCreate("ISOLATION_READ_COMMITTED");
    	try {
    		jobRepositoryFactoryBean.afterPropertiesSet();
		} catch (Exception e) {
			logger.error("  jobRepositoryFactoryBean  :{}",e.getMessage());
		}
    	return  jobRepositoryFactoryBean;
    }
 
    @Bean
    public JobRepository jobRepository(JobRepositoryFactoryBean jobRepositoryFactoryBean){
    	JobRepository jobRepository = null;
		try {
			jobRepository = jobRepositoryFactoryBean.getObject();
		} catch (Exception e) {
			logger.error("  jobRepository  {}",e.getMessage());
		}
    	return jobRepository;
    }
    
    @Bean
    public SimpleJobLauncher  simpleJobLauncher(JobRepository jobRepository){
    	SimpleJobLauncher  simpleJobLauncher = new SimpleJobLauncher();
    	simpleJobLauncher.setJobRepository(jobRepository);
    	try {
			simpleJobLauncher.afterPropertiesSet();
		} catch (Exception e) {
			logger.error("  simpleJobLauncher  :{}",e.getMessage());
		}
		return simpleJobLauncher;
    }

}
独自に作成したトランザクション・レベルは
ISOLATION_READ_COMMITTEDのlauncher実行batch
package cn.yong.zheng.task;

import java.text.SimpleDateFormat;
import java.util.Date;

import javax.annotation.Resource;

import org.quartz.JobExecutionContext;
import org.quartz.JobExecutionException;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.batch.core.Job;
import org.springframework.batch.core.JobExecution;
import org.springframework.batch.core.JobParametersBuilder;
import org.springframework.batch.core.launch.support.SimpleJobLauncher;
import org.springframework.beans.factory.annotation.Autowired;

/**
 * 
 * @author zhengyong
 */
public class BlackListMemcacgeScheduledTask implements org.quartz.Job {

    private static final Logger logger = LoggerFactory.getLogger(BlackListMemcacgeScheduledTask.class);

    @Autowired
    private SimpleJobLauncher simpleJobLauncher;

    @Resource(name = "springBatchJob")
    private Job springBatchJob;

    @Override
    public void execute(JobExecutionContext arg0) throws JobExecutionException {
        this.executeTask();
    }

    /**
     *         
     */
    private void executeTask() {
        try {
                JobExecution execution = simpleJobLauncher.run(springBatchJob,
                        new JobParametersBuilder().addLong("time", System.currentTimeMillis()).toJobParameters());
            } catch (Exception e) {
                logger.error("  :{}", e.getMessage());
            }
    }

}