Apache
/
activemq
mirror of https://github.com/apache/activemq.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

AMQ-2414 fixes for MySQL cluster setup 

git-svn-id: https://svn.apache.org/repos/asf/activemq/branches/activemq-5.3@820032 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Hiram R. Chirino 2009-09-29 17:07:12 +00:00
parent 7e551e100e
commit ba842ad58f
1 changed files with 23 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

24
activemq-core/src/main/java/org/apache/activemq/store/jdbc/adapter/MySqlJDBCAdapter.java
View File

@ -16,6 +16,9 @@
*/ */
package org.apache.activemq.store.jdbc.adapter; package org.apache.activemq.store.jdbc.adapter;
import java.util.ArrayList;
import java.util.Arrays;
import org.apache.activemq.store.jdbc.Statements; import org.apache.activemq.store.jdbc.Statements;
/** /**
@ -47,13 +50,32 @@ public class MySqlJDBCAdapter extends DefaultJDBCAdapter {
statements.setBinaryDataType("LONGBLOB"); statements.setBinaryDataType("LONGBLOB");
String typeClause = " TYPE="+type;
if( type.equals(NDBCLUSTER) ) {
// in the NDBCLUSTER case we will create as INNODB and then alter to NDBCLUSTER
typeClause = " TYPE="+INNODB;
}
// Update the create statements so they use the right type of engine // Update the create statements so they use the right type of engine
String[] s = statements.getCreateSchemaStatements(); String[] s = statements.getCreateSchemaStatements();
for (int i = 0; i < s.length; i++) { for (int i = 0; i < s.length; i++) {
if( s[i].startsWith("CREATE TABLE")) { if( s[i].startsWith("CREATE TABLE")) {
s[i] = s[i]+" TYPE="+type; s[i] = s[i]+typeClause;
} }
} }
if( type.equals(NDBCLUSTER) ) {
// Add the alter statements.
ArrayList<String> l = new ArrayList<String>(Arrays.asList(s));
l.add("ALTER TABLE "+statements.getFullMessageTableName()+" ENGINE="+NDBCLUSTER);
l.add("ALTER TABLE "+statements.getFullAckTableName()+" ENGINE="+NDBCLUSTER);
l.add("ALTER TABLE "+statements.getFullLockTableName()+" ENGINE="+NDBCLUSTER);
l.add("FLUSH TABLES");
s = l.toArray(new String[l.size()]);
statements.setCreateSchemaStatements(s);
}
super.setStatements(statements); super.setStatements(statements);
} }