mirror of https://github.com/apache/activemq.git
fix for AMQ-1193
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@515963 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
parent
825447a615
commit
dccd381c8f
|
@ -17,20 +17,26 @@
|
||||||
*/
|
*/
|
||||||
package org.apache.activemq.store.jdbc.adapter;
|
package org.apache.activemq.store.jdbc.adapter;
|
||||||
|
|
||||||
|
import org.apache.activemq.store.jdbc.Statements;
|
||||||
|
|
||||||
import java.sql.Blob;
|
import java.sql.Blob;
|
||||||
import java.sql.ResultSet;
|
import java.sql.ResultSet;
|
||||||
import java.sql.SQLException;
|
import java.sql.SQLException;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
*
|
|
||||||
* @org.apache.xbean.XBean element="db2JDBCAdapter"
|
|
||||||
*
|
|
||||||
* @version $Revision: 1.2 $
|
* @version $Revision: 1.2 $
|
||||||
|
* @org.apache.xbean.XBean element="db2JDBCAdapter"
|
||||||
*/
|
*/
|
||||||
public class DB2JDBCAdapter extends DefaultJDBCAdapter {
|
public class DB2JDBCAdapter extends DefaultJDBCAdapter {
|
||||||
|
|
||||||
public DB2JDBCAdapter() {
|
public DB2JDBCAdapter() {
|
||||||
batchStatments=false;
|
batchStatments = false;
|
||||||
|
}
|
||||||
|
|
||||||
|
public void setStatements(Statements statements) {
|
||||||
|
String lockCreateStatement = "LOCK TABLE " + statements.getFullLockTableName() + " IN EXCLUSIVE MODE";
|
||||||
|
statements.setLockCreateStatement(lockCreateStatement);
|
||||||
|
|
||||||
|
super.setStatements(statements);
|
||||||
}
|
}
|
||||||
|
|
||||||
protected byte[] getBinaryData(ResultSet rs, int index) throws SQLException {
|
protected byte[] getBinaryData(ResultSet rs, int index) throws SQLException {
|
||||||
|
|
Loading…
Reference in New Issue