This is an automated email from the ASF dual-hosted git repository. orpiske pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/camel.git
commit 5bceb53f505699a05a1a476f5d4898dfef587ef9 Author: Otavio Rodolfo Piske <[email protected]> AuthorDate: Mon Aug 26 14:12:15 2024 +0200 (chores) camel-sql: use more adequately sized buffers --- .../aggregate/jdbc/ClusteredJdbcAggregationRepository.java | 11 +++++++++-- .../jdbc/ClusteredPostgresAggregationRepository.java | 2 +- .../processor/aggregate/jdbc/JdbcAggregationRepository.java | 4 ++-- .../aggregate/jdbc/PostgresAggregationRepository.java | 2 +- 4 files changed, 13 insertions(+), 6 deletions(-) diff --git a/components/camel-sql/src/main/java/org/apache/camel/processor/aggregate/jdbc/ClusteredJdbcAggregationRepository.java b/components/camel-sql/src/main/java/org/apache/camel/processor/aggregate/jdbc/ClusteredJdbcAggregationRepository.java index 04f3d7a9571..5f0150e9af2 100644 --- a/components/camel-sql/src/main/java/org/apache/camel/processor/aggregate/jdbc/ClusteredJdbcAggregationRepository.java +++ b/components/camel-sql/src/main/java/org/apache/camel/processor/aggregate/jdbc/ClusteredJdbcAggregationRepository.java @@ -104,8 +104,15 @@ public class ClusteredJdbcAggregationRepository extends JdbcAggregationRepositor // The default totalParameterIndex is 3 for ID, Exchange and version. Depending // on logic this will be increased. int totalParameterIndex = 3; - StringBuilder queryBuilder = new StringBuilder().append("INSERT INTO ").append(repositoryName).append('(') - .append(EXCHANGE).append(", ").append(ID).append(", ").append(VERSION); + StringBuilder queryBuilder = new StringBuilder(256) + .append("INSERT INTO ") + .append(repositoryName) + .append('(') + .append(EXCHANGE) + .append(", ") + .append(ID) + .append(", ") + .append(VERSION); if (isStoreBodyAsText()) { queryBuilder.append(", ").append(BODY); diff --git a/components/camel-sql/src/main/java/org/apache/camel/processor/aggregate/jdbc/ClusteredPostgresAggregationRepository.java b/components/camel-sql/src/main/java/org/apache/camel/processor/aggregate/jdbc/ClusteredPostgresAggregationRepository.java index dd46bce0e62..1ee8289b420 100644 --- a/components/camel-sql/src/main/java/org/apache/camel/processor/aggregate/jdbc/ClusteredPostgresAggregationRepository.java +++ b/components/camel-sql/src/main/java/org/apache/camel/processor/aggregate/jdbc/ClusteredPostgresAggregationRepository.java @@ -58,7 +58,7 @@ public class ClusteredPostgresAggregationRepository extends ClusteredJdbcAggrega throws Exception { // The default totalParameterIndex is 2 for ID and Exchange. Depending on logic this will be increased int totalParameterIndex = 2; - StringBuilder queryBuilder = new StringBuilder() + StringBuilder queryBuilder = new StringBuilder(256) .append("INSERT INTO ").append(repositoryName) .append('(') .append(EXCHANGE).append(", ") diff --git a/components/camel-sql/src/main/java/org/apache/camel/processor/aggregate/jdbc/JdbcAggregationRepository.java b/components/camel-sql/src/main/java/org/apache/camel/processor/aggregate/jdbc/JdbcAggregationRepository.java index 9f0d51a00ec..fdf511f4b34 100644 --- a/components/camel-sql/src/main/java/org/apache/camel/processor/aggregate/jdbc/JdbcAggregationRepository.java +++ b/components/camel-sql/src/main/java/org/apache/camel/processor/aggregate/jdbc/JdbcAggregationRepository.java @@ -239,7 +239,7 @@ public class JdbcAggregationRepository extends ServiceSupport protected void update( final CamelContext camelContext, final String key, final Exchange exchange, String repositoryName, Long version) throws Exception { - StringBuilder queryBuilder = new StringBuilder() + StringBuilder queryBuilder = new StringBuilder(256) .append("UPDATE ").append(repositoryName) .append(" SET ") .append(EXCHANGE).append(" = ?") @@ -279,7 +279,7 @@ public class JdbcAggregationRepository extends ServiceSupport throws Exception { // The default totalParameterIndex is 3 for ID, Exchange and version. Depending on logic this will be increased. int totalParameterIndex = 3; - StringBuilder queryBuilder = new StringBuilder() + StringBuilder queryBuilder = new StringBuilder(256) .append("INSERT INTO ").append(repositoryName) .append('(').append(EXCHANGE) .append(", ").append(ID) diff --git a/components/camel-sql/src/main/java/org/apache/camel/processor/aggregate/jdbc/PostgresAggregationRepository.java b/components/camel-sql/src/main/java/org/apache/camel/processor/aggregate/jdbc/PostgresAggregationRepository.java index e906f6fc75c..4970877f084 100644 --- a/components/camel-sql/src/main/java/org/apache/camel/processor/aggregate/jdbc/PostgresAggregationRepository.java +++ b/components/camel-sql/src/main/java/org/apache/camel/processor/aggregate/jdbc/PostgresAggregationRepository.java @@ -58,7 +58,7 @@ public class PostgresAggregationRepository extends JdbcAggregationRepository { throws Exception { // The default totalParameterIndex is 2 for ID and Exchange. Depending on logic this will be increased int totalParameterIndex = 2; - StringBuilder queryBuilder = new StringBuilder() + StringBuilder queryBuilder = new StringBuilder(256) .append("INSERT INTO ").append(repositoryName) .append('(') .append(EXCHANGE).append(", ")
