content: package com.taobao.tddl.dbsync.binlog.event.mariadb;
  
  import com.taobao.tddl.dbsync.binlog.LogBuffer;
  import com.taobao.tddl.dbsync.binlog.event.FormatDescriptionLogEvent;
  import com.taobao.tddl.dbsync.binlog.event.IgnorableLogEvent;
  import com.taobao.tddl.dbsync.binlog.event.LogHeader;
  
  import java.nio.charset.StandardCharsets;
  
  /**
   * mariadb的ANNOTATE_ROWS_EVENT类型
   * 
   * @author jianghang 2014-1-20 下午2:20:35
   * @since 1.0.17
   */
  public class AnnotateRowsEvent extends IgnorableLogEvent {
  
      private String rowsQuery;
  
      public AnnotateRowsEvent(LogHeader header, LogBuffer buffer, FormatDescriptionLogEvent descriptionEvent){
          super(header, buffer, descriptionEvent);
  
          final int commonHeaderLen = descriptionEvent.getCommonHeaderLen();
          final int postHeaderLen = descriptionEvent.getPostHeaderLen()[header.getType() - 1];
  
          int offset = commonHeaderLen + postHeaderLen;
          int len = buffer.limit() - offset;
          rowsQuery = buffer.getFullString(offset, len, StandardCharsets.ISO_8859_1);
      }
  
      public String getRowsQuery() {
          return rowsQuery;
      }
  
  }
  