From 5321f74e401f4972edbf30b28594bfa48acd2d19 Mon Sep 17 00:00:00 2001 From: robokaso Date: Mon, 14 Jul 2008 07:35:50 +0000 Subject: [PATCH] RESOLVED - BATCH-723: tablePrefix property is not injected into JbdcExecutionContextDao --- .../core/repository/dao/AbstractJdbcBatchMetadataDao.java | 4 ++++ .../batch/core/repository/dao/JdbcJobExecutionDao.java | 1 + .../batch/core/repository/dao/JdbcStepExecutionDao.java | 1 + 3 files changed, 6 insertions(+) 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(); }