public class MySqlJDBCAdapter extends DefaultJDBCAdapter
Modifier and Type | Field and Description |
---|---|
static String |
BDB |
static String |
HEAP |
static String |
INNODB |
static String |
ISAM |
static String |
MERGE |
static String |
MYISAM |
static String |
NDBCLUSTER |
batchStatments, cleanupExclusiveLock, MAX_ROWS, maxRows, prioritizedMessages, statements
Constructor and Description |
---|
MySqlJDBCAdapter() |
Modifier and Type | Method and Description |
---|---|
String |
getEngineType() |
String |
getTypeStatement() |
void |
setEngineType(String engineType) |
void |
setStatements(Statements statements) |
void |
setTypeStatement(String typeStatement) |
close, close, doAddMessage, doAddMessageReference, doCreateTables, doDeleteOldMessages, doDeleteSubscription, doDropTables, doGetAllSubscriptions, doGetDestinations, doGetDurableSubscriberMessageCount, doGetLastAckedDurableSubscriberMessageId, doGetLastMessageStoreSequenceId, doGetLastProducerSequenceId, doGetMessage, doGetMessageById, doGetMessageCount, doGetMessageReference, doGetNextDurableSubscriberMessageStatement, doGetSubscriberEntry, doMessageIdScan, doRecordDestination, doRecover, doRecoverNextMessages, doRecoverNextMessages, doRecoverNextMessagesWithPriority, doRecoverSubscription, doRemoveAllMessages, doRemoveMessage, doSetLastAck, doSetLastAckWithPriority, doSetSubscriberEntry, getBinaryData, getMaxRows, getStatements, getStoreSequenceId, isBatchStatments, setBatchStatments, setBinaryData, setMaxRows, setUseExternalMessageReferences
public static final String INNODB
public static final String NDBCLUSTER
public static final String BDB
public static final String MYISAM
public static final String ISAM
public static final String MERGE
public static final String HEAP
public void setStatements(Statements statements)
setStatements
in interface JDBCAdapter
setStatements
in class DefaultJDBCAdapter
public String getEngineType()
public void setEngineType(String engineType)
public String getTypeStatement()
public void setTypeStatement(String typeStatement)
Copyright © 2005–2013 The Apache Software Foundation. All rights reserved.