[activemq] branch activemq-5.15.x updated: [AMQ-7008] Add index on messages table to speed up browsing

[jbonofre]

This is an automated email from the ASF dual-hosted git repository.

jbonofre pushed a commit to branch activemq-5.15.x
in repository https://gitbox.apache.org/repos/asf/activemq.git


The following commit(s) were added to refs/heads/activemq-5.15.x by this push:
     new abc3707  [AMQ-7008] Add index on messages table to speed up browsing
abc3707 is described below

commit abc37071d7671d849016237ca5bdb8df092e41a2
Author: Jean-Baptiste Onofré <jbono...@apache.org>
AuthorDate: Tue Nov 19 05:45:30 2019 +0100

    [AMQ-7008] Add index on messages table to speed up browsing
    
    (cherry picked from commit 3c10f6ef863f0eac713de0869c753cee5b607dae)
---
 .../src/main/java/org/apache/activemq/store/jdbc/Statements.java       | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git 
a/activemq-jdbc-store/src/main/java/org/apache/activemq/store/jdbc/Statements.java
 
b/activemq-jdbc-store/src/main/java/org/apache/activemq/store/jdbc/Statements.java
index 0fe6338..b679712 100644
--- 
a/activemq-jdbc-store/src/main/java/org/apache/activemq/store/jdbc/Statements.java
+++ 
b/activemq-jdbc-store/src/main/java/org/apache/activemq/store/jdbc/Statements.java
@@ -115,7 +115,8 @@ public class Statements {
                 "ALTER TABLE " + getFullAckTableName() + " " + 
getDropAckPKAlterStatementEnd(),
                 "ALTER TABLE " + getFullAckTableName() + " ADD PRIMARY KEY 
(CONTAINER, CLIENT_ID, SUB_NAME, PRIORITY)",
                 "CREATE INDEX " + getFullMessageTableName() + "_XIDX ON " + 
getFullMessageTableName() + " (XID)",
-                "CREATE INDEX " + getFullAckTableName() + "_XIDX ON " + 
getFullAckTableName() + " (XID)"
+                "CREATE INDEX " + getFullAckTableName() + "_XIDX ON " + 
getFullAckTableName() + " (XID)",
+                "CREATE INDEX " + getFullMessageTableName() + "_IIDX ON " + 
getFullMessageTableName() + " (ID ASC, XID, CONTAINER)"
             };
         }
         getCreateLockSchemaStatements();