diff --git a/activemq-core/src/main/java/org/apache/activemq/store/jdbc/adapter/DB2JDBCAdapter.java b/activemq-core/src/main/java/org/apache/activemq/store/jdbc/adapter/DB2JDBCAdapter.java new file mode 100644 index 0000000000..3b403a3768 --- /dev/null +++ b/activemq-core/src/main/java/org/apache/activemq/store/jdbc/adapter/DB2JDBCAdapter.java @@ -0,0 +1,40 @@ +/** + * + * Copyright 2005-2006 The Apache Software Foundation + * + * Licensed under the Apache License, Version 2.0 (the "License"); + * you may not use this file except in compliance with the License. + * You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ +package org.apache.activemq.store.jdbc.adapter; + +import java.sql.Blob; +import java.sql.ResultSet; +import java.sql.SQLException; + +/** + * + * @org.apache.xbean.XBean element="db2JDBCAdapter" + * + * @version $Revision: 1.2 $ + */ +public class DB2JDBCAdapter extends DefaultJDBCAdapter { + + public DB2JDBCAdapter() { + batchStatments=false; + } + + protected byte[] getBinaryData(ResultSet rs, int index) throws SQLException { + // Get as a BLOB + Blob aBlob = rs.getBlob(index); + return aBlob.getBytes(1, (int) aBlob.length()); + } +} diff --git a/activemq-core/src/main/resources/META-INF/services/org/apache/activemq/store/jdbc/ibm_db2_jdbc_universal_driver_architecture b/activemq-core/src/main/resources/META-INF/services/org/apache/activemq/store/jdbc/ibm_db2_jdbc_universal_driver_architecture index a2d8d40e92..48cde12e7d 100644 --- a/activemq-core/src/main/resources/META-INF/services/org/apache/activemq/store/jdbc/ibm_db2_jdbc_universal_driver_architecture +++ b/activemq-core/src/main/resources/META-INF/services/org/apache/activemq/store/jdbc/ibm_db2_jdbc_universal_driver_architecture @@ -1 +1 @@ -class=org.apache.activemq.store.jdbc.adapter.DefaultJDBCAdapter \ No newline at end of file +class=org.apache.activemq.store.jdbc.adapter.DB2JDBCAdapter \ No newline at end of file