org.apache.activemq.store.jdbc.adapter
Class BlobJDBCAdapter

java.lang.Object
  extended by org.apache.activemq.store.jdbc.adapter.DefaultJDBCAdapter
      extended by org.apache.activemq.store.jdbc.adapter.BlobJDBCAdapter
All Implemented Interfaces:
JDBCAdapter
Direct Known Subclasses:
InformixJDBCAdapter

public class BlobJDBCAdapter
extends DefaultJDBCAdapter

This JDBCAdapter inserts and extracts BLOB data using the getBlob()/setBlob() operations. This is a little more involved since to insert a blob you have to: 1: insert empty blob. 2: select the blob 3: finally update the blob with data value. The databases/JDBC drivers that use this adapter are:

Version:
$Revision: 1.2 $

Field Summary
 
Fields inherited from class org.apache.activemq.store.jdbc.adapter.DefaultJDBCAdapter
batchStatments, statements
 
Constructor Summary
BlobJDBCAdapter()
           
 
Method Summary
 void doAddMessage(Connection c, long seq, String messageID, String destinationName, byte[] data)
           
 byte[] doGetMessage(TransactionContext c, long seq)
           
 
Methods inherited from class org.apache.activemq.store.jdbc.adapter.DefaultJDBCAdapter
doAddMessage, doAddMessageReference, doCreateTables, doDeleteOldMessages, doDeleteSubscription, doDropTables, doGetAllSubscriptions, doGetDestinations, doGetDurableSubscriberMessageCount, doGetLastMessageBrokerSequenceId, doGetMessageReference, doGetNextDurableSubscriberMessageIdStatement, doGetNextDurableSubscriberMessageStatement, doGetPrevDurableSubscriberMessageIdStatement, doGetSubscriberEntry, doRecover, doRecoverNextMessages, doRecoverSubscription, doRemoveAllMessages, doRemoveMessage, doSetLastAck, doSetSubscriberEntry, getBinaryData, getBrokerSequenceId, getStatements, isBatchStatments, setBatchStatments, setBinaryData, setStatements, setUseExternalMessageReferences
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

BlobJDBCAdapter

public BlobJDBCAdapter()
Method Detail

doAddMessage

public void doAddMessage(Connection c,
                         long seq,
                         String messageID,
                         String destinationName,
                         byte[] data)
                  throws SQLException,
                         javax.jms.JMSException
Throws:
SQLException
javax.jms.JMSException

doGetMessage

public byte[] doGetMessage(TransactionContext c,
                           long seq)
                    throws SQLException
Specified by:
doGetMessage in interface JDBCAdapter
Overrides:
doGetMessage in class DefaultJDBCAdapter
Throws:
SQLException


Copyright © 2011 Apache Software Foundation. All Rights Reserved.