当前位置：首页 > 文章列表 > 数据库 > MySQL > 聊聊SpinalTap的BinlogEvent

聊聊SpinalTap的BinlogEvent

来源：SegmentFault 2023-02-24 18:53:01 0浏览收藏

你在学习数据库相关的知识吗？本文《聊聊SpinalTap的BinlogEvent》，主要介绍的内容就涉及到MySQL，如果你想提升自己的开发能力，就不要错过这篇文章，大家要知道编程理论基础和实战操作都是不可或缺的哦！

序

本文主要研究一下SpinalTap的BinlogEvent

BinlogEvent

SpinalTap/spinaltap-mysql/src/main/java/com/airbnb/spinaltap/mysql/event/BinlogEvent.java

@Getter
@ToString
public abstract class BinlogEvent extends SourceEvent {
  private final long tableId;
  private final long serverId;
  private final BinlogFilePos binlogFilePos;

  public BinlogEvent(long tableId, long serverId, long timestamp, BinlogFilePos binlogFilePos) {
    super(timestamp);

    this.tableId = tableId;
    this.serverId = serverId;
    this.binlogFilePos = binlogFilePos;
  }

  public long getOffset() {
    return (binlogFilePos.getFileNumber()

BinlogEvent继承了SourceEvent，它定义了tableId、serverId、binlogFilePos属性

StartEvent

SpinalTap/spinaltap-mysql/src/main/java/com/airbnb/spinaltap/mysql/event/StartEvent.java

public class StartEvent extends BinlogEvent {
  public StartEvent(long serverId, long timestamp, BinlogFilePos filePos) {
    super(0L, serverId, timestamp, filePos);
  }
}

StartEvent继承了BinlogEvent，其构造器需要serverId、timestamp、filePos参数

TableMapEvent

SpinalTap/spinaltap-mysql/src/main/java/com/airbnb/spinaltap/mysql/event/TableMapEvent.java

@Getter
public final class TableMapEvent extends BinlogEvent {
  private final String database;
  private final String table;
  private final List<columndatatype> columnTypes;

  public TableMapEvent(
      long tableId,
      long serverId,
      long timestamp,
      BinlogFilePos filePos,
      String database,
      String table,
      byte[] columnTypeCodes) {
    super(tableId, serverId, timestamp, filePos);

    this.database = database;
    this.table = table;
    this.columnTypes = new ArrayList();

    for (byte code : columnTypeCodes) {
      columnTypes.add(ColumnDataType.byCode(code));
    }
  }
}</columndatatype>

TableMapEvent继承了BinlogEvent，它定义了database、table、columnTypes属性

WriteEvent

SpinalTap/spinaltap-mysql/src/main/java/com/airbnb/spinaltap/mysql/event/WriteEvent.java

@Getter
public final class WriteEvent extends BinlogEvent {
  private final List<serializable> rows;

  public WriteEvent(
      long tableId,
      long serverId,
      long timestamp,
      BinlogFilePos filePos,
      List<serializable> rows) {
    super(tableId, serverId, timestamp, filePos);

    this.rows = rows;
  }

  @Override
  public int size() {
    return rows.size();
  }
}</serializable></serializable>

WriteEvent继承了BinlogEvent，它定义了类型为
```
List<serializable></serializable>
```
的rows属性

DeleteEvent

SpinalTap/spinaltap-mysql/src/main/java/com/airbnb/spinaltap/mysql/event/DeleteEvent.java

@Getter
public final class DeleteEvent extends BinlogEvent {
  private final List<serializable> rows;

  public DeleteEvent(
      long tableId,
      long serverId,
      long timestamp,
      BinlogFilePos filePos,
      List<serializable> rows) {
    super(tableId, serverId, timestamp, filePos);

    this.rows = rows;
  }

  @Override
  public int size() {
    return rows.size();
  }
}</serializable></serializable>

DeleteEvent继承了BinlogEvent，它定义了类型为
```
List<serializable></serializable>
```
的rows属性

UpdateEvent

SpinalTap/spinaltap-mysql/src/main/java/com/airbnb/spinaltap/mysql/event/UpdateEvent.java

@Getter
public class UpdateEvent extends BinlogEvent {
  private final List<map.entry serializable>> rows;

  public UpdateEvent(
      long tableId,
      long serverId,
      long timestamp,
      BinlogFilePos filePos,
      List<map.entry serializable>> rows) {
    super(tableId, serverId, timestamp, filePos);

    this.rows = rows;
  }

  @Override
  public int size() {
    return rows.size();
  }
}</map.entry></map.entry>

UpdateEvent继承了BinlogEvent，它定义了类型为
```
List<map.entry serializable>></map.entry>
```
的rows属性

QueryEvent

SpinalTap/spinaltap-mysql/src/main/java/com/airbnb/spinaltap/mysql/event/QueryEvent.java

@Getter
public class QueryEvent extends BinlogEvent {
  private final String database;
  private final String sql;

  public QueryEvent(
      long serverId, long timestamp, BinlogFilePos filePos, String database, String sql) {
    super(0l, serverId, timestamp, filePos);

    this.database = database;
    this.sql = sql;
  }
}

QueryEvent继承了BinlogEvent，它定义了database、sql属性

XidEvent

SpinalTap/spinaltap-mysql/src/main/java/com/airbnb/spinaltap/mysql/event/XidEvent.java

@Getter
public class XidEvent extends BinlogEvent {
  private final long xid;

  public XidEvent(long serverId, long timestamp, BinlogFilePos filePos, long xid) {
    super(0l, serverId, timestamp, filePos);

    this.xid = xid;
  }
}

XidEvent继承了BinlogEvent，它定义了xid属性

GTIDEvent

SpinalTap/spinaltap-mysql/src/main/java/com/airbnb/spinaltap/mysql/event/GTIDEvent.java

@Getter
public class GTIDEvent extends BinlogEvent {
  private final String gtid;

  public GTIDEvent(long serverId, long timestamp, BinlogFilePos filePos, String gtid) {
    super(0, serverId, timestamp, filePos);
    this.gtid = gtid;
  }
}

GTIDEvent继承了BinlogEvent，它定义了gtid属性

小结

BinlogEvent继承了SourceEvent，它定义了tableId、serverId、binlogFilePos属性；其子类主要有StartEvent、TableMapEvent、WriteEvent、DeleteEvent、UpdateEvent、QueryEvent、XidEvent、GTIDEvent