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

fix for https://issues.apache.org/activemq/browse/AMQ-2291 - jdbc sequence changed to long 

git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@784862 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Bosanac Dejan 2009-06-15 16:58:14 +00:00
parent 07822041b4
commit 78e7221d3e
6 changed files with 6 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
activemq-core/src/main/java/org/apache/activemq/store/jdbc/Statements.java
View File

@ -30,7 +30,7 @@ public class Statements {
protected String binaryDataType = "BLOB"; protected String binaryDataType = "BLOB";
protected String containerNameDataType = "VARCHAR(250)"; protected String containerNameDataType = "VARCHAR(250)";
protected String msgIdDataType = "VARCHAR(250)"; protected String msgIdDataType = "VARCHAR(250)";
protected String sequenceDataType = "INTEGER"; protected String sequenceDataType = "BIGINT";
protected String longDataType = "BIGINT"; protected String longDataType = "BIGINT";
protected String stringIdDataType = "VARCHAR(250)"; protected String stringIdDataType = "VARCHAR(250)";
protected boolean useExternalMessageReferences; protected boolean useExternalMessageReferences;

1
activemq-core/src/main/java/org/apache/activemq/store/jdbc/adapter/AxionJDBCAdapter.java
View File

@ -56,6 +56,7 @@ public class AxionJDBCAdapter extends StreamJDBCAdapter {
statements.setCreateSchemaStatements(createStatements); statements.setCreateSchemaStatements(createStatements);
statements.setDeleteOldMessagesStatement("DELETE FROM " + statements.getFullMessageTableName() + " WHERE ( EXPIRATION<>0 AND EXPIRATION<?)"); statements.setDeleteOldMessagesStatement("DELETE FROM " + statements.getFullMessageTableName() + " WHERE ( EXPIRATION<>0 AND EXPIRATION<?)");
statements.setLongDataType("LONG"); statements.setLongDataType("LONG");
statements.setSequenceDataType("LONG");
super.setStatements(statements); super.setStatements(statements);
} }

1
activemq-core/src/main/java/org/apache/activemq/store/jdbc/adapter/InformixJDBCAdapter.java
View File

@ -32,6 +32,7 @@ public class InformixJDBCAdapter extends BlobJDBCAdapter {
statements.setContainerNameDataType("VARCHAR(150)"); statements.setContainerNameDataType("VARCHAR(150)");
statements.setStringIdDataType("VARCHAR(150)"); statements.setStringIdDataType("VARCHAR(150)");
statements.setLongDataType("INT8"); statements.setLongDataType("INT8");
statements.setSequenceDataType("INT8");
statements.setBinaryDataType("BYTE"); statements.setBinaryDataType("BYTE");
super.setStatements(statements); super.setStatements(statements);
} }

1
activemq-core/src/main/java/org/apache/activemq/store/jdbc/adapter/MaxDBJDBCAdapter.java
View File

@ -28,6 +28,7 @@ public class MaxDBJDBCAdapter extends DefaultJDBCAdapter {
statements.setStringIdDataType("VARCHAR(250) ASCII"); statements.setStringIdDataType("VARCHAR(250) ASCII");
statements.setContainerNameDataType("VARCHAR(250) ASCII"); statements.setContainerNameDataType("VARCHAR(250) ASCII");
statements.setLongDataType("INTEGER"); statements.setLongDataType("INTEGER");
statements.setSequenceDataType("INTEGER");
super.setStatements(statements); super.setStatements(statements);
} }

1
activemq-core/src/main/java/org/apache/activemq/store/jdbc/adapter/OracleJDBCAdapter.java
View File

@ -46,6 +46,7 @@ public class OracleJDBCAdapter extends BlobJDBCAdapter {
public void setStatements(Statements statements) { public void setStatements(Statements statements) {
statements.setLongDataType("NUMBER"); statements.setLongDataType("NUMBER");
statements.setSequenceDataType("NUMBER");
super.setStatements(statements); super.setStatements(statements);
} }

1
activemq-core/src/main/java/org/apache/activemq/store/jdbc/adapter/SybaseJDBCAdapter.java
View File

@ -28,6 +28,7 @@ public class SybaseJDBCAdapter extends ImageBasedJDBCAdaptor {
statements.setLockCreateStatement("LOCK TABLE " + statements.getFullLockTableName() + " IN EXCLUSIVE MODE"); statements.setLockCreateStatement("LOCK TABLE " + statements.getFullLockTableName() + " IN EXCLUSIVE MODE");
statements.setLongDataType("DECIMAL"); statements.setLongDataType("DECIMAL");
statements.setSequenceDataType("DECIMAL");
super.setStatements(statements); super.setStatements(statements);
} }
} }