com.taobao.tddl.dbsync.binlog.event

类 RowsLogEvent

java.lang.Object

com.taobao.tddl.dbsync.binlog.LogEvent

com.taobao.tddl.dbsync.binlog.event.RowsLogEvent

直接已知子类:

DeleteRowsLogEvent, UpdateRowsLogEvent, WriteRowsLogEvent

public abstract class RowsLogEvent
extends LogEvent

Common base class for all row-containing log events.

版本:

1.0

作者:

Changyuan.lh

字段概要

字段

限定符和类型	字段和说明
protected java.util.BitSet	changeColumns Bitmap for columns available in the after image, if present.
protected int	columnLen Bitmap denoting columns available
protected java.util.BitSet	columns
static int	COMPLETE_ROWS_F Indicates that rows in this event are complete, that is contain values for all columns of the table.
protected int	jsonColumnCount
static int	NO_FOREIGN_KEY_CHECKS_F Value of the OPTION_NO_FOREIGN_KEY_CHECKS flag in thd->options
protected boolean	partial
static int	RELAXED_UNIQUE_CHECKS_F Value of the OPTION_RELAXED_UNIQUE_CHECKS flag in thd->options
static int	RW_FLAGS_OFFSET
static int	RW_MAPID_OFFSET
static int	RW_V_EXTRAINFO_TAG
static int	RW_V_TAG_LEN
static int	RW_VHLEN_OFFSET
static int	STMT_END_F Last event of a statement

从类继承的字段 com.taobao.tddl.dbsync.binlog.LogEvent

ANNOTATE_ROWS_EVENT, ANONYMOUS_GTID_LOG_EVENT, APPEND_BLOCK_EVENT, BEGIN_LOAD_QUERY_EVENT, BINLOG_CHECKPOINT_EVENT, BINLOG_CHECKSUM_ALG_CRC32, BINLOG_CHECKSUM_ALG_DESC_LEN, BINLOG_CHECKSUM_ALG_ENUM_END, BINLOG_CHECKSUM_ALG_OFF, BINLOG_CHECKSUM_ALG_UNDEF, BINLOG_CHECKSUM_LEN, BINLOG_VERSION, CHECKSUM_CRC32_SIGNATURE_LEN, CREATE_FILE_EVENT, DELETE_FILE_EVENT, DELETE_ROWS_EVENT, DELETE_ROWS_EVENT_V1, ENUM_END_EVENT, EVENT_LEN_OFFSET, EVENT_TYPE_OFFSET, EXEC_LOAD_EVENT, EXECUTE_LOAD_QUERY_EVENT, EXTRA_ROW_INFO_FORMAT_OFFSET, EXTRA_ROW_INFO_HDR_BYTES, EXTRA_ROW_INFO_LEN_OFFSET, EXTRA_ROW_INFO_MAX_PAYLOAD, FLAGS_OFFSET, FORMAT_DESCRIPTION_EVENT, GTID_EVENT, GTID_LIST_EVENT, GTID_LOG_EVENT, header, HEARTBEAT_LOG_EVENT, IGNORABLE_LOG_EVENT, INCIDENT_EVENT, INTVAR_EVENT, LOAD_EVENT, LOG_EVENT_IGNORABLE_F, LOG_POS_OFFSET, logger, MARIA_EVENTS_BEGIN, MARIA_SLAVE_CAPABILITY_ANNOTATE, MARIA_SLAVE_CAPABILITY_BINLOG_CHECKPOINT, MARIA_SLAVE_CAPABILITY_GTID, MARIA_SLAVE_CAPABILITY_MINE, MARIA_SLAVE_CAPABILITY_TOLERATE_HOLES, MARIA_SLAVE_CAPABILITY_UNKNOWN, MYSQL_EVENTS_END, MYSQL_TYPE_BIT, MYSQL_TYPE_BLOB, MYSQL_TYPE_DATE, MYSQL_TYPE_DATETIME, MYSQL_TYPE_DATETIME2, MYSQL_TYPE_DECIMAL, MYSQL_TYPE_DOUBLE, MYSQL_TYPE_ENUM, MYSQL_TYPE_FLOAT, MYSQL_TYPE_GEOMETRY, MYSQL_TYPE_INT24, MYSQL_TYPE_JSON, MYSQL_TYPE_LONG, MYSQL_TYPE_LONG_BLOB, MYSQL_TYPE_LONGLONG, MYSQL_TYPE_MEDIUM_BLOB, MYSQL_TYPE_NEWDATE, MYSQL_TYPE_NEWDECIMAL, MYSQL_TYPE_NULL, MYSQL_TYPE_SET, MYSQL_TYPE_SHORT, MYSQL_TYPE_STRING, MYSQL_TYPE_TIME, MYSQL_TYPE_TIME2, MYSQL_TYPE_TIMESTAMP, MYSQL_TYPE_TIMESTAMP2, MYSQL_TYPE_TINY, MYSQL_TYPE_TINY_BLOB, MYSQL_TYPE_VAR_STRING, MYSQL_TYPE_VARCHAR, MYSQL_TYPE_YEAR, NEW_LOAD_EVENT, PARTIAL_UPDATE_ROWS_EVENT, PRE_GA_DELETE_ROWS_EVENT, PRE_GA_UPDATE_ROWS_EVENT, PRE_GA_WRITE_ROWS_EVENT, PREVIOUS_GTIDS_LOG_EVENT, QUERY_EVENT, QUERY_HEADER_LEN, QUERY_HEADER_MINIMAL_LEN, RAND_EVENT, ROTATE_EVENT, ROWS_QUERY_LOG_EVENT, semival, SERVER_ID_OFFSET, SERVER_VERSION, SLAVE_EVENT, START_ENCRYPTION_EVENT, START_EVENT_V3, STOP_EVENT, TABLE_MAP_EVENT, TRANSACTION_CONTEXT_EVENT, UNKNOWN_EVENT, UPDATE_ROWS_EVENT, UPDATE_ROWS_EVENT_V1, USER_VAR_EVENT, VIEW_CHANGE_EVENT, WRITE_ROWS_EVENT, WRITE_ROWS_EVENT_V1, XA_PREPARE_LOG_EVENT, XID_EVENT

构造器概要

构造器

构造器和说明
RowsLogEvent(LogHeader header, LogBuffer buffer, FormatDescriptionLogEvent descriptionEvent)
RowsLogEvent(LogHeader header, LogBuffer buffer, FormatDescriptionLogEvent descriptionEvent, boolean partial)

方法概要

限定符和类型	方法和说明
void	fillTable(LogContext context)
java.util.BitSet	getChangeColumns()
java.util.BitSet	getColumns()
int	getFlags(int flags)
RowsLogBuffer	getRowsBuf(java.lang.String charsetName)
TableMapLogEvent	getTable()
long	getTableId()

从类继承的方法 com.taobao.tddl.dbsync.binlog.LogEvent

getEventLen, getHeader, getLogPos, getSemival, getServerId, getTypeName, getWhen, setSemival

从类继承的方法 java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

字段详细资料

columnLen

protected final int columnLen

Bitmap denoting columns available

partial

protected final boolean partial

columns

protected final java.util.BitSet columns

changeColumns

protected final java.util.BitSet changeColumns

Bitmap for columns available in the after image, if present. These fields are only available for Update_rows events. Observe that the width of both the before image COLS vector and the after image COLS vector is the same: the number of columns of the table on the master.

jsonColumnCount

protected int jsonColumnCount

STMT_END_F

public static final int STMT_END_F

Last event of a statement

另请参阅:

常量字段值

NO_FOREIGN_KEY_CHECKS_F

public static final int NO_FOREIGN_KEY_CHECKS_F

Value of the OPTION_NO_FOREIGN_KEY_CHECKS flag in thd->options

另请参阅:

常量字段值

RELAXED_UNIQUE_CHECKS_F

public static final int RELAXED_UNIQUE_CHECKS_F

Value of the OPTION_RELAXED_UNIQUE_CHECKS flag in thd->options

另请参阅:

常量字段值

COMPLETE_ROWS_F

public static final int COMPLETE_ROWS_F

Indicates that rows in this event are complete, that is contain values for all columns of the table.

另请参阅:

常量字段值

RW_MAPID_OFFSET

public static final int RW_MAPID_OFFSET

另请参阅:

常量字段值

RW_FLAGS_OFFSET

public static final int RW_FLAGS_OFFSET

另请参阅:

常量字段值

RW_VHLEN_OFFSET

public static final int RW_VHLEN_OFFSET

另请参阅:

常量字段值

RW_V_TAG_LEN

public static final int RW_V_TAG_LEN

另请参阅:

常量字段值

RW_V_EXTRAINFO_TAG

public static final int RW_V_EXTRAINFO_TAG

另请参阅:

常量字段值

构造器详细资料

RowsLogEvent

public RowsLogEvent(LogHeader header,
                    LogBuffer buffer,
                    FormatDescriptionLogEvent descriptionEvent)

RowsLogEvent

public RowsLogEvent(LogHeader header,
                    LogBuffer buffer,
                    FormatDescriptionLogEvent descriptionEvent,
                    boolean partial)

方法详细资料

fillTable

public final void fillTable(LogContext context)

getTableId

public final long getTableId()

getTable

public final TableMapLogEvent getTable()

getColumns

public final java.util.BitSet getColumns()

getChangeColumns

public final java.util.BitSet getChangeColumns()

getRowsBuf

public final RowsLogBuffer getRowsBuf(java.lang.String charsetName)

getFlags

public final int getFlags(int flags)