From aa72fface4bac3cb799c57eba74e2f6c5aae0fb1 Mon Sep 17 00:00:00 2001 From: cpandey Date: Tue, 3 Oct 2017 18:11:27 +0530 Subject: [PATCH 1/3] AMQ-6826: PostgresqlJDBCAdapter with table prefix errors when executing createSchemaStatements for creating Indexes. --- .../activemq/store/jdbc/adapter/PostgresqlJDBCAdapter.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/activemq-jdbc-store/src/main/java/org/apache/activemq/store/jdbc/adapter/PostgresqlJDBCAdapter.java b/activemq-jdbc-store/src/main/java/org/apache/activemq/store/jdbc/adapter/PostgresqlJDBCAdapter.java index 733405998df..11424313921 100644 --- a/activemq-jdbc-store/src/main/java/org/apache/activemq/store/jdbc/adapter/PostgresqlJDBCAdapter.java +++ b/activemq-jdbc-store/src/main/java/org/apache/activemq/store/jdbc/adapter/PostgresqlJDBCAdapter.java @@ -43,7 +43,7 @@ public class PostgresqlJDBCAdapter extends BytesJDBCAdapter { @Override public void setStatements(Statements statements) { statements.setBinaryDataType("BYTEA"); - statements.setDropAckPKAlterStatementEnd("DROP CONSTRAINT \"" + getAcksPkName() + "\""); + statements.setDropAckPKAlterStatementEnd("DROP CONSTRAINT \"" +statements.getTablePrefix().toLowerCase()+getAcksPkName() + "\""); super.setStatements(statements); } From 783062dab79c89cfdd042e0313742510174a6e6b Mon Sep 17 00:00:00 2001 From: cpandey Date: Tue, 3 Oct 2017 18:13:27 +0530 Subject: [PATCH 2/3] AMQ-6826 : PostgresqlJDBCAdapter with table prefix errors when executing createSchemaStatements for creating Indexes. --- .../activemq/store/jdbc/adapter/PostgresqlJDBCAdapter.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/activemq-jdbc-store/src/main/java/org/apache/activemq/store/jdbc/adapter/PostgresqlJDBCAdapter.java b/activemq-jdbc-store/src/main/java/org/apache/activemq/store/jdbc/adapter/PostgresqlJDBCAdapter.java index 11424313921..7b8a3723a8f 100644 --- a/activemq-jdbc-store/src/main/java/org/apache/activemq/store/jdbc/adapter/PostgresqlJDBCAdapter.java +++ b/activemq-jdbc-store/src/main/java/org/apache/activemq/store/jdbc/adapter/PostgresqlJDBCAdapter.java @@ -43,7 +43,7 @@ public class PostgresqlJDBCAdapter extends BytesJDBCAdapter { @Override public void setStatements(Statements statements) { statements.setBinaryDataType("BYTEA"); - statements.setDropAckPKAlterStatementEnd("DROP CONSTRAINT \"" +statements.getTablePrefix().toLowerCase()+getAcksPkName() + "\""); + statements.setDropAckPKAlterStatementEnd("DROP CONSTRAINT \"" + statements.getTablePrefix().toLowerCase()+getAcksPkName() + "\""); super.setStatements(statements); } From 869c0226d8530ff09a9851662f16330078149daa Mon Sep 17 00:00:00 2001 From: cpandey Date: Wed, 4 Oct 2017 10:10:54 +0530 Subject: [PATCH 3/3] PostgresqlJDBCAdapter with table prefix throw exception when executing createSchemaStatements for creating Indexes. --- .../activemq/store/jdbc/adapter/PostgresqlJDBCAdapter.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/activemq-jdbc-store/src/main/java/org/apache/activemq/store/jdbc/adapter/PostgresqlJDBCAdapter.java b/activemq-jdbc-store/src/main/java/org/apache/activemq/store/jdbc/adapter/PostgresqlJDBCAdapter.java index 7b8a3723a8f..86931f10937 100644 --- a/activemq-jdbc-store/src/main/java/org/apache/activemq/store/jdbc/adapter/PostgresqlJDBCAdapter.java +++ b/activemq-jdbc-store/src/main/java/org/apache/activemq/store/jdbc/adapter/PostgresqlJDBCAdapter.java @@ -43,7 +43,7 @@ public class PostgresqlJDBCAdapter extends BytesJDBCAdapter { @Override public void setStatements(Statements statements) { statements.setBinaryDataType("BYTEA"); - statements.setDropAckPKAlterStatementEnd("DROP CONSTRAINT \"" + statements.getTablePrefix().toLowerCase()+getAcksPkName() + "\""); + statements.setDropAckPKAlterStatementEnd("DROP CONSTRAINT \"" + statements.getTablePrefix().toLowerCase() + getAcksPkName() + "\""); super.setStatements(statements); }