diff --git a/spring-batch-core/src/main/java/org/springframework/batch/core/repository/dao/AbstractJdbcBatchMetadataDao.java b/spring-batch-core/src/main/java/org/springframework/batch/core/repository/dao/AbstractJdbcBatchMetadataDao.java index 5f5fcfcc5..881c54492 100644 --- a/spring-batch-core/src/main/java/org/springframework/batch/core/repository/dao/AbstractJdbcBatchMetadataDao.java +++ b/spring-batch-core/src/main/java/org/springframework/batch/core/repository/dao/AbstractJdbcBatchMetadataDao.java @@ -25,6 +25,10 @@ public abstract class AbstractJdbcBatchMetadataDao implements InitializingBean { protected String getQuery(String base) { return StringUtils.replace(base, "%PREFIX%", tablePrefix); } + + protected String getTablePrefix() { + return tablePrefix; + } /** * Public setter for the table prefix property. This will be prefixed to all diff --git a/spring-batch-core/src/main/java/org/springframework/batch/core/repository/dao/JdbcJobExecutionDao.java b/spring-batch-core/src/main/java/org/springframework/batch/core/repository/dao/JdbcJobExecutionDao.java index edd639abd..afbf70378 100644 --- a/spring-batch-core/src/main/java/org/springframework/batch/core/repository/dao/JdbcJobExecutionDao.java +++ b/spring-batch-core/src/main/java/org/springframework/batch/core/repository/dao/JdbcJobExecutionDao.java @@ -196,6 +196,7 @@ public class JdbcJobExecutionDao extends AbstractJdbcBatchMetadataDao implements Assert.notNull(jobExecutionIncrementer); ecDao.setJdbcTemplate(getJdbcTemplate()); ecDao.setLobHandler(lobHandler); + ecDao.setTablePrefix(getTablePrefix()); ecDao.afterPropertiesSet(); } diff --git a/spring-batch-core/src/main/java/org/springframework/batch/core/repository/dao/JdbcStepExecutionDao.java b/spring-batch-core/src/main/java/org/springframework/batch/core/repository/dao/JdbcStepExecutionDao.java index e1c24dffa..c870a22a0 100644 --- a/spring-batch-core/src/main/java/org/springframework/batch/core/repository/dao/JdbcStepExecutionDao.java +++ b/spring-batch-core/src/main/java/org/springframework/batch/core/repository/dao/JdbcStepExecutionDao.java @@ -247,6 +247,7 @@ public class JdbcStepExecutionDao extends AbstractJdbcBatchMetadataDao implement Assert.notNull(stepExecutionIncrementer, "StepExecutionIncrementer cannot be null."); ecDao.setJdbcTemplate(getJdbcTemplate()); ecDao.setLobHandler(lobHandler); + ecDao.setTablePrefix(getTablePrefix()); ecDao.afterPropertiesSet(); }