About binlogFileName

[welyss]

In rotate event, i can obtain a correct value with "((RotateEvent)event).getBinlogFileName".
But after that, in the other event(include rotate event), i get a incorrect value with "event.getHeader().getBinlogFileName", i think when rotate event, only the value of RotateEvent instance has been changed, not the others?

[joungjo]

You can do this to solve the problem.

first change class RotateEventParser.

Add contribute private ReplicationBasedBinlogParser r , and add constructor like below

-private ReplicationBasedBinlogParser r;
public RotateEventParser(ReplicationBasedBinlogParser r) {
super(RotateEvent.EVENT_TYPE);
this.r = r;
}

Second change method parse in this class like below

public void parse(XInputStream is, BinlogEventV4Header header, BinlogParserContext context)
throws IOException {
final RotateEvent event = new RotateEvent(header);
event.setBinlogPosition(is.readLong(8));
event.setBinlogFileName(is.readFixedLengthString(is.available()));
/*
* change this line like this
*/
r.setBinlogFileName(event.getBinlogFileName().toString());
context.getEventListener().onEvents(event);
}

Third change method getDefaultBinlogParser in class OpenParser like below

• protected ReplicationBasedBinlogParser getDefaultBinlogParser() throws Exception {
  //
  final ReplicationBasedBinlogParser r = new ReplicationBasedBinlogParser();
  r.registerEventParser(new StopEventParser());
  /*
  * change this line like this
  */
  r.registerEventParser(new RotateEventParser(r));
  r.registerEventParser(new IntvarEventParser());
  r.registerEventParser(new XidEventParser());
  r.registerEventParser(new RandEventParser());
  r.registerEventParser(new QueryEventParser());
  r.registerEventParser(new UserVarEventParser());
  r.registerEventParser(new IncidentEventParser());
  r.registerEventParser(new TableMapEventParser());
  r.registerEventParser(new WriteRowsEventParser());
  r.registerEventParser(new UpdateRowsEventParser());
  r.registerEventParser(new DeleteRowsEventParser());
  r.registerEventParser(new WriteRowsEventV2Parser());
  r.registerEventParser(new UpdateRowsEventV2Parser());
  r.registerEventParser(new DeleteRowsEventV2Parser());
  r.registerEventParser(new FormatDescriptionEventParser());
  r.registerEventParser(new GtidEventParser());

  //
  r.setTransport(this.transport);
  r.setBinlogFileName(this.binlogFileName);
  return r;
  

  }