You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by da...@apache.org on 2018/01/22 15:10:13 UTC
[camel] 02/02: Configurable sql props: decouple from private field
through accessor usage
This is an automated email from the ASF dual-hosted git repository.
davsclaus pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/camel.git
commit cffa96f92d964ef389c5471c1f3fd35fa96cecdb
Author: Davide Cavestro <da...@gmail.com>
AuthorDate: Sat Jan 20 11:13:06 2018 +0100
Configurable sql props: decouple from private field through accessor usage
---
.../idempotent/jdbc/JdbcMessageIdRepository.java | 16 ++++++++--------
1 file changed, 8 insertions(+), 8 deletions(-)
diff --git a/components/camel-sql/src/main/java/org/apache/camel/processor/idempotent/jdbc/JdbcMessageIdRepository.java b/components/camel-sql/src/main/java/org/apache/camel/processor/idempotent/jdbc/JdbcMessageIdRepository.java
index ccedaa0..e2a8a20 100644
--- a/components/camel-sql/src/main/java/org/apache/camel/processor/idempotent/jdbc/JdbcMessageIdRepository.java
+++ b/components/camel-sql/src/main/java/org/apache/camel/processor/idempotent/jdbc/JdbcMessageIdRepository.java
@@ -61,18 +61,18 @@ public class JdbcMessageIdRepository extends AbstractJdbcMessageIdRepository<Str
public Boolean doInTransaction(TransactionStatus status) {
try {
// we will receive an exception if the table doesn't exists or we cannot access it
- jdbcTemplate.execute(tableExistsString);
+ jdbcTemplate.execute(getTableExistsString());
log.debug("Expected table for JdbcMessageIdRepository exist");
} catch (DataAccessException e) {
if (createTableIfNotExists) {
try {
log.debug("creating table for JdbcMessageIdRepository because it doesn't exist...");
- jdbcTemplate.execute(createString);
- log.info("table created with query '{}'", createString);
+ jdbcTemplate.execute(getCreateString());
+ log.info("table created with query '{}'", getCreateString());
} catch (DataAccessException dae) {
// we will fail if we cannot create it
log.error("Can't create table for JdbcMessageIdRepository with query '{}' because of: {}. This may be a permissions problem. Please create this table and try again.",
- createString, e.getMessage());
+ getCreateString(), e.getMessage());
throw dae;
}
} else {
@@ -87,22 +87,22 @@ public class JdbcMessageIdRepository extends AbstractJdbcMessageIdRepository<Str
@Override
protected int queryForInt(String key) {
- return jdbcTemplate.queryForObject(queryString, Integer.class, processorName, key);
+ return jdbcTemplate.queryForObject(getQueryString(), Integer.class, processorName, key);
}
@Override
protected int insert(String key) {
- return jdbcTemplate.update(insertString, processorName, key, new Timestamp(System.currentTimeMillis()));
+ return jdbcTemplate.update(getInsertString(), processorName, key, new Timestamp(System.currentTimeMillis()));
}
@Override
protected int delete(String key) {
- return jdbcTemplate.update(deleteString, processorName, key);
+ return jdbcTemplate.update(getDeleteString(), processorName, key);
}
@Override
protected int delete() {
- return jdbcTemplate.update(clearString, processorName);
+ return jdbcTemplate.update(getClearString(), processorName);
}
public boolean isCreateTableIfNotExists() {
--
To stop receiving notification emails like this one, please contact
davsclaus@apache.org.