Package org.apache.activemq.store.jdbc.adapter

Class BytesJDBCAdapter

java.lang.Object

org.apache.activemq.store.jdbc.adapter.DefaultJDBCAdapter

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, MAX_ROWS, maxRows, prioritizedMessages, statements

Constructor Summary

Constructors

Constructor	Description
BytesJDBCAdapter()

Method Summary

Modifier and Type	Method	Description
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, doUpdateMessage, dumpTables, dumpTables, getMaxRows, getStatements, getStoreSequenceId, isBatchStatements, isBatchStatments, limitQuery, printQuery, printQuery, setBatchStatements, 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[])