public class JDBCJournalRecord extends Object
Modifier and Type | Field and Description |
---|---|
static byte |
ADD_RECORD |
static byte |
ADD_RECORD_TX |
static byte |
COMMIT_RECORD |
static byte |
DELETE_RECORD |
static byte |
DELETE_RECORD_TX |
static byte |
PREPARE_RECORD |
static byte |
ROLLBACK_RECORD |
static byte |
UPDATE_RECORD |
static byte |
UPDATE_RECORD_TX |
protected byte |
userRecordType |
Constructor and Description |
---|
JDBCJournalRecord(long id,
byte recordType,
long seq) |
public static final byte ADD_RECORD
public static final byte UPDATE_RECORD
public static final byte ADD_RECORD_TX
public static final byte UPDATE_RECORD_TX
public static final byte DELETE_RECORD_TX
public static final byte DELETE_RECORD
public static final byte PREPARE_RECORD
public static final byte COMMIT_RECORD
public static final byte ROLLBACK_RECORD
protected byte userRecordType
public void complete(boolean success)
public void storeLineUp()
protected void writeRecord(PreparedStatement statement) throws SQLException
SQLException
protected void writeDeleteRecord(PreparedStatement deleteStatement) throws SQLException
SQLException
public static JDBCJournalRecord readRecord(ResultSet rs) throws SQLException
SQLException
public IOCompletion getIoCompletion()
public void setIoCompletion(IOCompletion ioCompletion)
public boolean isStoreLineUp()
public void setStoreLineUp(boolean storeLineUp)
public boolean isSync()
public void setSync(boolean sync)
public Long getId()
public byte getRecordType()
public byte getCompactCount()
public void setCompactCount(byte compactCount)
public long getTxId()
public void setTxId(long txId)
public int getVariableSize()
public void setVariableSize(int variableSize)
public byte getUserRecordType()
public void setUserRecordType(byte userRecordType)
public void setRecord(byte[] record)
public void setRecord(InputStream record)
public void setRecord(EncodingSupport record)
public InputStream getRecord()
public int getTxCheckNoRecords()
public void setTxCheckNoRecords(int txCheckNoRecords)
public void setTxDataSize(int txDataSize)
public int getTxDataSize()
public InputStream getTxData()
public void setTxData(InputStream record)
public void setTxData(EncodingSupport txData)
public void setTxData(byte[] txData)
public boolean isUpdate()
public byte[] getRecordData() throws IOException
IOException
public byte[] getTxDataAsByteArray() throws IOException
IOException
public RecordInfo toRecordInfo() throws IOException
IOException
public boolean isTransactional()
public long getSeq()
Copyright © 2016 The Apache Software Foundation. All rights reserved.