com.github.shyiko.mysql.binlog.event.WriteRowsEventData类的使用及代码示例

x33g5p2x  于2022-02-03 转载在 其他  
字(7.4k)|赞(0)|评价(0)|浏览(191)

本文整理了Java中com.github.shyiko.mysql.binlog.event.WriteRowsEventData类的一些代码示例，展示了WriteRowsEventData类的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。WriteRowsEventData类的具体详情如下：
包路径：com.github.shyiko.mysql.binlog.event.WriteRowsEventData
类名称：WriteRowsEventData

WriteRowsEventData介绍

暂无

代码示例

代码示例来源：origin: debezium/debezium

long tableNumber = write.getTableId();
BitSet includedColumns = write.getIncludedColumns();
RecordsForTable recordMaker = recordMakers.forTable(tableNumber, includedColumns, super::enqueueRecord);
if (recordMaker != null) {
  List<Serializable[]> rows = write.getRows();
  Long ts = context.getClock().currentTimeInMillis();
  int count = 0;

代码示例来源：origin: shyiko/mysql-binlog-connector-java

@Override
public WriteRowsEventData deserialize(ByteArrayInputStream inputStream) throws IOException {
  WriteRowsEventData eventData = new WriteRowsEventData();
  eventData.setTableId(inputStream.readLong(6));
  inputStream.skip(2); // reserved
  if (mayContainExtraInformation) {
    int extraInfoLength = inputStream.readInteger(2);
    inputStream.skip(extraInfoLength - 2);
  }
  int numberOfColumns = inputStream.readPackedInteger();
  eventData.setIncludedColumns(inputStream.readBitSet(numberOfColumns, true));
  eventData.setRows(deserializeRows(eventData.getTableId(), eventData.getIncludedColumns(), inputStream));
  return eventData;
}

代码示例来源：origin: apache/nifi

public InsertRowsEventInfo(TableInfo tableInfo, Long timestamp, String binlogFilename, Long binlogPosition, WriteRowsEventData data) {
    super(tableInfo, INSERT_EVENT, timestamp, binlogFilename, binlogPosition, data.getIncludedColumns(), data.getRows());
    this.data = data;
  }
}

代码示例来源：origin: apache/rocketmq-externals

private void processWriteEvent(Event event) {
  WriteRowsEventData data = event.getData();
  Long tableId = data.getTableId();
  List<Serializable[]> list = data.getRows();
  for (Serializable[] row : list) {
    addRow("WRITE", tableId, row);
  }
}

代码示例来源：origin: debezium/debezium

protected void assertRows(WriteRowsEventData eventData, int numRowsInEvent, Serializable... expectedValuesInRows) {
  assertThat(eventData.getRows().size()).isEqualTo(numRowsInEvent);
  int valuePosition = 0;
  for (Serializable[] row : eventData.getRows()) {
    for (Serializable value : row) {
      assertThat(value).isEqualTo(expectedValuesInRows[valuePosition++]);
    }
  }
}

代码示例来源：origin: zendesk/maxwell

public Long getTableID() {
  EventData data = event.getData();
  switch ( event.getHeader().getEventType() ) {
    case EXT_WRITE_ROWS:
    case WRITE_ROWS:
      return ((WriteRowsEventData) data).getTableId();
    case EXT_UPDATE_ROWS:
    case UPDATE_ROWS:
      return ((UpdateRowsEventData) data).getTableId();
    case EXT_DELETE_ROWS:
    case DELETE_ROWS:
      return ((DeleteRowsEventData) data).getTableId();
    case TABLE_MAP:
      return ((TableMapEventData) data).getTableId();
  }
  return null;
}

代码示例来源：origin: debezium/debezium

protected void assertRows(WriteRowsEventData eventData, RowBuilder rows) {
  assertThat(eventData.getRows().size()).isEqualTo(rows.rows().size());
  for (Serializable[] removedRow : eventData.getRows()) {
    if (!rows.findInsertedRow(removedRow)) {
      fail("Failed to find inserted row: " + eventData);
    }
  }
}

代码示例来源：origin: zendesk/maxwell

case WRITE_ROWS:
case EXT_WRITE_ROWS:
  for ( Serializable[] data : writeRowsData().getRows() ) {
    list.add(buildRowMap("insert", position, nextPosition, data, table, writeRowsData().getIncludedColumns(), rowQuery));

代码示例来源：origin: perfectsense/dari

WriteRowsEventData d = (WriteRowsEventData) eventData;
if (d.getTableId() == recordTableId) {
  d.getRows().forEach(row -> {
    if (LOGGER.isInfoEnabled()) {
      LOGGER.debug("Pending write: {}", StringUtils.hex((byte[]) row[0]));

代码示例来源：origin: eventuate-local/eventuate-local

private void handleWriteRowsEvent(Event event, Consumer<M> eventConsumer) {
 logger.debug("Got binlog event {}", event);
 offset = ((EventHeaderV4) event.getHeader()).getPosition();
 WriteRowsEventData eventData = event.getData();
 if (tableMapEventByTableId.containsKey(eventData.getTableId())) {
  try {
   eventConsumer.accept(writeRowsEventDataParser.parseEventData(eventData,
       getCurrentBinlogFilename(), offset
       )
   );
  } catch (IOException e) {
   throw new RuntimeException("Event row parsing exception", e);
  }
 }
}

代码示例来源：origin: eventuate-local/eventuate-local

private Serializable getValue(WriteRowsEventData eventData, String columnName) {
 if(columnOrders.containsKey(columnName)) {
  return eventData.getRows().get(0)[columnOrders.get(columnName) - 1];
 }
 throw new RuntimeException("Column with name [" + columnName + "] not found");
}

代码示例来源：origin: perfectsense/dari

@Override
public WriteRowsEventData deserialize(ByteArrayInputStream inputStream) throws IOException {
  WriteRowsEventData eventData = new WriteRowsEventData();
  eventData.setTableId(inputStream.readLong(6));
  inputStream.skip(2); // reserved
  if (mayContainExtraInformation) {
    int extraInfoLength = inputStream.readInteger(2);
    inputStream.skip(extraInfoLength - 2);
  }
  int numberOfColumns = inputStream.readPackedInteger();
  eventData.setIncludedColumns(inputStream.readBitSet(numberOfColumns, true));
  eventData.setRows(deserializeRows(eventData.getTableId(), eventData.getIncludedColumns(), inputStream));
  return eventData;
}

代码示例来源：origin: org.apache.nifi/nifi-cdc-mysql-processors

public InsertRowsEventInfo(TableInfo tableInfo, Long timestamp, String binlogFilename, Long binlogPosition, WriteRowsEventData data) {
    super(tableInfo, INSERT_EVENT, timestamp, binlogFilename, binlogPosition, data.getIncludedColumns(), data.getRows());
    this.data = data;
  }
}

代码示例来源：origin: perfectsense/dari

tableId = ((WriteRowsEventData) eventData).getTableId();
} else if (EventType.isUpdate(eventType)) {
  tableId = ((UpdateRowsEventData) eventData).getTableId();

代码示例来源：origin: networknt/light-eventuate-4j

private Serializable getValue(WriteRowsEventData eventData, String columnName) {
 if(columnOrders.containsKey(columnName)) {
  return eventData.getRows().get(0)[columnOrders.get(columnName) - 1];
 }
 throw new RuntimeException("Column with name [" + columnName + "] not found");
}

代码示例来源：origin: networknt/light-eventuate-4j

offset = ((EventHeaderV4) event.getHeader()).getPosition();
WriteRowsEventData eventData = event.getData();
if (tableMapEventByTableId.containsKey(eventData.getTableId())) {
 try {
  eventConsumer.accept(writeRowsEventDataParser.parseEventData(eventData,

代码示例来源：origin: io.eventuate.tram.core/eventuate-tram-cdc-mysql-connector

private Serializable getValue(WriteRowsEventData eventData, String columnName) {
 if(columnOrders.containsKey(columnName)) {
  return eventData.getRows().get(0)[columnOrders.get(columnName) - 1];
 }
 throw new RuntimeException("Column with name [" + columnName + "] not found. Have " + columnOrders.keySet());
}

代码示例来源：origin: eventuate-tram/eventuate-tram-core

private Serializable getValue(WriteRowsEventData eventData, String columnName) {
 if(columnOrders.containsKey(columnName)) {
  return eventData.getRows().get(0)[columnOrders.get(columnName) - 1];
 }
 throw new RuntimeException("Column with name [" + columnName + "] not found. Have " + columnOrders.keySet());
}

代码示例来源：origin: io.debezium/debezium-connector-mysql

protected void assertRows(WriteRowsEventData eventData, int numRowsInEvent, Serializable... expectedValuesInRows) {
  assertThat(eventData.getRows().size()).isEqualTo(numRowsInEvent);
  int valuePosition = 0;
  for (Serializable[] row : eventData.getRows()) {
    for (Serializable value : row) {
      assertThat(value).isEqualTo(expectedValuesInRows[valuePosition++]);
    }
  }
}

代码示例来源：origin: io.debezium/debezium-connector-mysql

protected void assertRows(WriteRowsEventData eventData, RowBuilder rows) {
  assertThat(eventData.getRows().size()).isEqualTo(rows.rows().size());
  for (Serializable[] removedRow : eventData.getRows()) {
    if (!rows.findInsertedRow(removedRow)) {
      fail("Failed to find inserted row: " + eventData);
    }
  }
}

内容来源于网络，如有侵权，请联系作者删除！

WriteRowsEventData

相关文章

    查看更多
    微信公众号

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多
    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com