You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by jb...@apache.org on 2019/11/19 10:10:49 UTC
[activemq] branch master updated: [AMQ-7008] Add index on messages
table to speed up browsing
This is an automated email from the ASF dual-hosted git repository.
jbonofre pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/activemq.git
The following commit(s) were added to refs/heads/master by this push:
new 3c10f6e [AMQ-7008] Add index on messages table to speed up browsing
new 70fba72 Merge pull request #417 from jbonofre/AMQ-7008
3c10f6e is described below
commit 3c10f6ef863f0eac713de0869c753cee5b607dae
Author: Jean-Baptiste Onofré <jb...@apache.org>
AuthorDate: Tue Nov 19 05:45:30 2019 +0100
[AMQ-7008] Add index on messages table to speed up browsing
---
.../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();