2013-12-04 4 views
2

При попытке чтения из базы данных в Spring Batch Application произошло следующее исключение. Любое понимание было бы полезно. Это вызвано при использовании JdbcCursorItemReader. Приложение отлично работает с помощью JdbcPagingItemReader.InvalidDataAccessResourceUsageException: Неожиданное изменение позиции курсора

Также необходимо явно закрыть любые ресурсы (курсоры и т. Д.) При использовании JdbcCursorItemReader? Если да, то как мы это сделаем?

SEVERE: Encountered an error executing the step 
    org.springframework.dao.InvalidDataAccessResourceUsageException: Unexpected cursor position change. 
     at org.springframework.batch.item.database.AbstractCursorItemReader.verifyCursorPosition(AbstractCursorItemReader.java:365) 
     at org.springframework.batch.item.database.AbstractCursorItemReader.doRead(AbstractCursorItemReader.java:449) 
     at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) 
     at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57) 
     at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) 
     at java.lang.reflect.Method.invoke(Method.java:601) 
     at org.springframework.aop.support.AopUtils.invokeJoinpointUsingReflection(AopUtils.java:317) 
     at org.springframework.aop.framework.ReflectiveMethodInvocation.invokeJoinpoint(ReflectiveMethodInvocation.java:183) 
     at org.springframework.aop.framework.CglibAopProxy$CglibMethodInvocation.invokeJoinpoint(CglibAopProxy.java:695) 
     at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:150) 
     at org.springframework.aop.support.DelegatingIntroductionInterceptor.doProceed(DelegatingIntroductionInterceptor.java:132) 
     at org.springframework.aop.support.DelegatingIntroductionInterceptor.invoke(DelegatingIntroductionInterceptor.java:120) 
     at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:172) 
     at org.springframework.aop.framework.CglibAopProxy$DynamicAdvisedInterceptor.intercept(CglibAopProxy.java:631) 
     at com.testapp.springbatchtest.io.DataExtractCursorItemReader$$EnhancerByCGLIB$$748012e7.doRead(<generated>) 
     at org.springframework.batch.item.support.AbstractItemCountingItemStreamItemReader.read(AbstractItemCountingItemStreamItemReader.java:83) 
     at org.springframework.batch.core.step.item.SimpleChunkProvider.doRead(SimpleChunkProvider.java:91) 
     at org.springframework.batch.core.step.item.SimpleChunkProvider.read(SimpleChunkProvider.java:155) 
     at org.springframework.batch.core.step.item.SimpleChunkProvider$1.doInIteration(SimpleChunkProvider.java:114) 
     at org.springframework.batch.repeat.support.RepeatTemplate.getNextResult(RepeatTemplate.java:368) 
     at org.springframework.batch.repeat.support.RepeatTemplate.executeInternal(RepeatTemplate.java:215) 
     at org.springframework.batch.repeat.support.RepeatTemplate.iterate(RepeatTemplate.java:144) 
     at org.springframework.batch.core.step.item.SimpleChunkProvider.provide(SimpleChunkProvider.java:108) 
     at org.springframework.batch.core.step.item.ChunkOrientedTasklet.execute(ChunkOrientedTasklet.java:69) 
     at org.springframework.batch.core.step.tasklet.TaskletStep$ChunkTransactionCallback.doInTransaction(TaskletStep.java:395) 
     at org.springframework.transaction.support.TransactionTemplate.execute(TransactionTemplate.java:131) 
     at org.springframework.batch.core.step.tasklet.TaskletStep$2.doInChunkContext(TaskletStep.java:267) 
     at org.springframework.batch.core.scope.context.StepContextRepeatCallback.doInIteration(StepContextRepeatCallback.java:77) 
     at org.springframework.batch.repeat.support.RepeatTemplate.getNextResult(RepeatTemplate.java:368) 
     at org.springframework.batch.repeat.support.RepeatTemplate.executeInternal(RepeatTemplate.java:215) 
     at org.springframework.batch.repeat.support.RepeatTemplate.iterate(RepeatTemplate.java:144) 
     at org.springframework.batch.core.step.tasklet.TaskletStep.doExecute(TaskletStep.java:253) 
     at org.springframework.batch.core.step.AbstractStep.execute(AbstractStep.java:195) 
     at org.springframework.batch.core.job.SimpleStepHandler.handleStep(SimpleStepHandler.java:137) 
     at org.springframework.batch.core.job.AbstractJob.handleStep(AbstractJob.java:380) 
     at org.springframework.batch.core.job.SimpleJob.doExecute(SimpleJob.java:124) 
     at org.springframework.batch.core.job.AbstractJob.execute(AbstractJob.java:301) 
     at org.springframework.batch.core.launch.support.SimpleJobLauncher$1.run(SimpleJobLauncher.java:134) 
     at org.springframework.core.task.SyncTaskExecutor.execute(SyncTaskExecutor.java:49) 
     at org.springframework.batch.core.launch.support.SimpleJobLauncher.run(SimpleJobLauncher.java:127) 

Ниже приведен пример кода для объявления бобов. DataExtractCursorItemReader расширяет JdbcCursorItemReader.

@Bean 
@StepScope 
public DataExtractCursorItemReader cursorReaderBean() throws Exception { 
    DataExtractCursorItemReader dataExtractReader = new DataExtractCursorItemReader(); 
    dataExtractReader.setDataSource(dataSource); 
    dataExtractReader.setSql("SELECT * FROM SAMPLETABLE"); 
    dataExtractReader.setFetchSize(500); 
    dataExtractReader.setRowMapper(new DataExtractRowMapper()); 

    return dataExtractReader; 
} 

ответ

2

verifyCursorPosition свойства (кажется) просто проверка, чтобы предотвратить индекс menipulating пользователя, когда подклассы читателя; возможно, это ваш случай или, возможно, некоторые свойства платформы DB не работают.

Вы можете отключить его, и все должно работать нормально - это всего лишь тест для предотвращения подкласса.
Проверьте свой код, если вы измените позицию курсора или проверьте, не завершился ли тест из-за драйвера базы данных.

+0

Вы имеете в виду подклассификацию AbstractCursorItemReader? Как упоминалось в вопросе, DataExtractCursorItemReader расширяет JdbcCursorItemReader. Любая идея, почему по умолчанию установлено значение ИСТИНА? – gsndev

+0

IMO для предотвращения (нежелательных) результатов манипулирования курсором пользователем при чтении подкласса. но также может не работать из-за неподдерживаемой функции драйвером базы данных (попробуйте установить значение «false» и проверить результат). Вам нужен читатель подкласса? –

+0

Это разрешено установкой свойства в false. Мысль проверять, если его ОК, чтобы установить его на false, если манипуляция курсором не выполняется [в коде]. – gsndev

1

Я видел эту ошибку в случае, когда имеется несколько потоков, действующих на читателе базы данных и читатель не поточно- обычно JDBCCursorItemReader против JDBCPagingItemReader

1

verifyCursorPosition проверки зависит от java.sql.ResultSet :: GetRow(). «Поддержка метода GetRow не является обязательным для ResultSets с результатом заданного типа TYPE_FORWARD_ONLY» в соответствии с JavaDoc

Вы могли бы попытаться изменить драйвер, тип ResultSet (чтения), или следовать выше предложением отключить verifyCursorPosition

Смежные вопросы