Merge pull request #480 from jbonofre/AMQ-7368

[AMQ-7368] Add limitQuery in HSQL, MySQL and PostgreSQL JDBC adapters

activemq-jdbc-store/src/main/java/org/apache/activemq/store/jdbc/adapter/HsqldbJDBCAdapter.java

@@ -30,4 +30,9 @@ public class HsqldbJDBCAdapter extends BytesJDBCAdapter {
         super.setStatements(statements);
     }
 
+    @Override
+    public String limitQuery(String query) {
+        return query + " LIMIT " + getMaxRows();
+    }
+
 }

activemq-jdbc-store/src/main/java/org/apache/activemq/store/jdbc/adapter/MySqlJDBCAdapter.java

@@ -96,4 +96,10 @@ public class MySqlJDBCAdapter extends DefaultJDBCAdapter {
     public void setTypeStatement(String typeStatement) {
         this.typeStatement = typeStatement;
     }
+
+    @Override
+    public String limitQuery(String query) {
+        return query + " LIMIT " + getMaxRows();
+    }
+
 }

activemq-jdbc-store/src/main/java/org/apache/activemq/store/jdbc/adapter/OracleJDBCAdapter.java

@@ -48,4 +48,5 @@ public class OracleJDBCAdapter extends DefaultJDBCAdapter {
     public String limitQuery(String query) {
         return "SELECT * FROM (" + query + ") WHERE ROWNUM <= " + getMaxRows();
     }
+
 }

activemq-jdbc-store/src/main/java/org/apache/activemq/store/jdbc/adapter/PostgresqlJDBCAdapter.java

@@ -54,4 +54,10 @@ public class PostgresqlJDBCAdapter extends BytesJDBCAdapter {
     public void setAcksPkName(String acksPkName) {
         this.acksPkName = acksPkName;
     }
+
+    @Override
+    public String limitQuery(String query) {
+        return query + " LIMIT " + getMaxRows();
+    }
+
 }