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

java.lang.Object
  extended by org.apache.activemq.store.jdbc.adapter.DefaultJDBCAdapter
      extended by org.apache.activemq.store.jdbc.adapter.BytesJDBCAdapter
All Implemented Interfaces:
JDBCAdapter
Direct Known Subclasses:
HsqldbJDBCAdapter, PostgresqlJDBCAdapter

public class BytesJDBCAdapter
extends DefaultJDBCAdapter

This JDBCAdapter inserts and extracts BLOB data using the setBytes()/getBytes() operations. The databases/JDBC drivers that use this adapter are:


Field Summary
 
Fields inherited from class org.apache.activemq.store.jdbc.adapter.DefaultJDBCAdapter
batchStatments, cleanupExclusiveLock, MAX_ROWS, maxRows, prioritizedMessages, statements
 
Constructor Summary
BytesJDBCAdapter()
           
 
Method Summary
protected  byte[] getBinaryData(ResultSet rs, int index)
           
protected  void setBinaryData(PreparedStatement s, int index, byte[] data)
           
 
Methods inherited from class org.apache.activemq.store.jdbc.adapter.DefaultJDBCAdapter
close, close, doAddMessage, doAddMessageReference, doClearLastAck, doCommitAddOp, doCreateTables, doDeleteOldMessages, doDeleteSubscription, doDropTables, doGetAllSubscriptions, doGetDestinations, doGetDurableSubscriberMessageCount, doGetLastAckedDurableSubscriberMessageId, doGetLastMessageStoreSequenceId, doGetLastProducerSequenceId, doGetMessage, doGetMessageById, doGetMessageCount, doGetMessageReference, doGetSubscriberEntry, doMessageIdScan, doRecordDestination, doRecover, doRecoverNextMessages, doRecoverNextMessages, doRecoverNextMessagesWithPriority, doRecoverPreparedOps, doRecoverSubscription, doRemoveAllMessages, doRemoveMessage, doSetLastAck, doSetLastAckWithPriority, doSetSubscriberEntry, dumpTables, dumpTables, getMaxRows, getStatements, getStoreSequenceId, isBatchStatments, printQuery, printQuery, setBatchStatments, setMaxRows, setStatements, setUseExternalMessageReferences
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

BytesJDBCAdapter

public BytesJDBCAdapter()
Method Detail

getBinaryData

protected byte[] getBinaryData(ResultSet rs,
                               int index)
                        throws SQLException
Overrides:
getBinaryData in class DefaultJDBCAdapter
Throws:
SQLException
See Also:
DefaultJDBCAdapter.getBinaryData(java.sql.ResultSet, int)

setBinaryData

protected void setBinaryData(PreparedStatement s,
                             int index,
                             byte[] data)
                      throws SQLException
Overrides:
setBinaryData in class DefaultJDBCAdapter
Throws:
SQLException
See Also:
DefaultJDBCAdapter.setBinaryData(java.sql.PreparedStatement, int, byte[])


Copyright © 2005-2013 The Apache Software Foundation. All Rights Reserved.