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

AMQ-2414: Support mysql cluster configurations 

git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@818905 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Hiram R. Chirino 2009-09-25 16:14:05 +00:00
parent 80ac49db97
commit 5d2f52f0d6
1 changed files with 30 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -25,18 +25,43 @@ import org.apache.activemq.store.jdbc.Statements;
*/
public class MySqlJDBCAdapter extends DefaultJDBCAdapter {
// The transactional types..
public static final String INNODB = "INNODB";
public static final String NDBCLUSTER = "NDBCLUSTER";
public static final String BDB = "BDB";
// The non transactional types..
public static final String MYISAM = "MYISAM";
public static final String ISAM = "ISAM";
public static final String MERGE = "MERGE";
public static final String HEAP = "HEAP";
String engineType = INNODB;
public void setStatements(Statements statements) {
statements.setLockCreateStatement("LOCK TABLE " + statements.getFullLockTableName() + " WRITE");
String type = engineType.toUpperCase();
if( !type.equals(INNODB) && !type.equals(NDBCLUSTER) ) {
// Don't use LOCK TABLE for the INNODB and NDBCLUSTER engine types...
statements.setLockCreateStatement("LOCK TABLE " + statements.getFullLockTableName() + " WRITE");
}
statements.setBinaryDataType("LONGBLOB");
// Use INNODB table since we need transaction support.
// Update the create statements so they use the right type of engine
String[] s = statements.getCreateSchemaStatements();
for (int i = 0; i < s.length; i++) {
if( s[i].startsWith("CREATE TABLE")) {
s[i] = s[i]+" TYPE=INNODB";
s[i] = s[i]+" TYPE="+type;
}
}
super.setStatements(statements);
}
}
public String getEngineType() {
return engineType;
}
public void setEngineType(String engineType) {
this.engineType = engineType;
}
}