[例外の解決]spring batchエラーORA-08177:このトランザクションに連続的にアクセスできません
4473 ワード
問題の説明:
Spring batch接続oracle操作を使用すると、常に次の異常が表示されます.
理由: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.自分で資料に基づいて実現する:
ISOLATION_READ_COMMITTEDのlauncher実行batch
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());
}
}
}