1.0.6

.gitignore

@@ -0,0 +1 @@
+/target

src/main/java/com/google/code/or/binlog/BinlogParserListener.java

@@ -0,0 +1,48 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License.  You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package com.google.code.or.binlog;
+
+/**
+ * 
+ * @author Jingqi Xu
+ */
+public interface BinlogParserListener {
+
+	/**
+	 * 
+	 */
+	void onStart(BinlogParser parser);
+
+	void onStop(BinlogParser parser);
+
+	void onException(BinlogParser parser, Exception eception);
+
+	/**
+	 * 
+	 */
+	class Adapter implements BinlogParserListener {
+
+		public void onStart(BinlogParser parser) {
+		}
+
+		public void onStop(BinlogParser parser) {
+		}
+
+		public void onException(BinlogParser parser, Exception exception) {
+		}
+	}
+}

src/main/java/com/google/code/or/binlog/impl/event/DeleteRowsEventV2.java

@@ -0,0 +1,112 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License.  You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package com.google.code.or.binlog.impl.event;
+
+import java.util.List;
+
+import com.google.code.or.binlog.BinlogEventV4Header;
+import com.google.code.or.common.glossary.Row;
+import com.google.code.or.common.glossary.UnsignedLong;
+import com.google.code.or.common.glossary.column.BitColumn;
+import com.google.code.or.common.util.MySQLConstants;
+import com.google.code.or.common.util.ToStringBuilder;
+
+/**
+ * Used for row-based binary logging. This event logs deletions of rows in a single table. 
+ * 
+ * @author Jingqi Xu
+ */
+public final class DeleteRowsEventV2 extends AbstractRowEvent {
+	//
+	public static final int EVENT_TYPE = MySQLConstants.DELETE_ROWS_EVENT_V2;
+
+	//
+	private int extraInfoLength;
+	private byte extraInfo[];
+	private UnsignedLong columnCount;
+	private BitColumn usedColumns;
+	private List<Row> rows;
+
+	/**
+	 * 
+	 */
+	public DeleteRowsEventV2() {
+	}
+
+	public DeleteRowsEventV2(BinlogEventV4Header header) {
+		this.header = header;
+	}
+
+	/**
+	 * 
+	 */
+	@Override
+	public String toString() {
+		return new ToStringBuilder(this)
+		.append("header", header)
+		.append("tableId", tableId)
+		.append("reserved", reserved)
+		.append("extraInfoLength", extraInfoLength)
+		.append("extraInfo", extraInfo)
+		.append("columnCount", columnCount)
+		.append("usedColumns", usedColumns)
+		.append("rows", rows).toString();
+	}
+
+	/**
+	 * 
+	 */
+	public int getExtraInfoLength() {
+		return extraInfoLength;
+	}
+
+	public void setExtraInfoLength(int extraInfoLength) {
+		this.extraInfoLength = extraInfoLength;
+	}
+
+	public byte[] getExtraInfo() {
+		return extraInfo;
+	}
+
+	public void setExtraInfo(byte[] extraInfo) {
+		this.extraInfo = extraInfo;
+	}
+
+	public UnsignedLong getColumnCount() {
+		return columnCount;
+	}
+
+	public void setColumnCount(UnsignedLong columnCount) {
+		this.columnCount = columnCount;
+	}
+
+	public BitColumn getUsedColumns() {
+		return usedColumns;
+	}
+
+	public void setUsedColumns(BitColumn usedColumns) {
+		this.usedColumns = usedColumns;
+	}
+
+	public List<Row> getRows() {
+		return rows;
+	}
+
+	public void setRows(List<Row> rows) {
+		this.rows = rows;
+	}
+}

src/main/java/com/google/code/or/binlog/impl/event/UpdateRowsEventV2.java

@@ -0,0 +1,123 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License.  You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package com.google.code.or.binlog.impl.event;
+
+import java.util.List;
+
+import com.google.code.or.binlog.BinlogEventV4Header;
+import com.google.code.or.common.glossary.Pair;
+import com.google.code.or.common.glossary.Row;
+import com.google.code.or.common.glossary.UnsignedLong;
+import com.google.code.or.common.glossary.column.BitColumn;
+import com.google.code.or.common.util.MySQLConstants;
+import com.google.code.or.common.util.ToStringBuilder;
+
+/**
+ * Used for row-based binary logging. This event logs updates of rows in a single table. 
+ * 
+ * @author Jingqi Xu
+ */
+public final class UpdateRowsEventV2 extends AbstractRowEvent {
+	//
+	public static final int EVENT_TYPE = MySQLConstants.UPDATE_ROWS_EVENT_V2;
+
+	//
+	private int extraInfoLength;
+	private byte extraInfo[];
+	private UnsignedLong columnCount;
+	private BitColumn usedColumnsBefore;
+	private BitColumn usedColumnsAfter;
+	private List<Pair<Row>> rows;
+
+	/**
+	 * 
+	 */
+	public UpdateRowsEventV2() {
+	}
+
+	public UpdateRowsEventV2(BinlogEventV4Header header) {
+		this.header = header;
+	}
+
+	/**
+	 * 
+	 */
+	@Override
+	public String toString() {
+		return new ToStringBuilder(this)
+		.append("header", header)
+		.append("tableId", tableId)
+		.append("reserved", reserved)
+		.append("extraInfoLength", extraInfoLength)
+		.append("extraInfo", extraInfo)
+		.append("columnCount", columnCount)
+		.append("usedColumnsBefore", usedColumnsBefore)
+		.append("usedColumnsAfter", usedColumnsAfter)
+		.append("rows", rows).toString();
+	}
+
+	/**
+	 * 
+	 */
+	public int getExtraInfoLength() {
+		return extraInfoLength;
+	}
+
+	public void setExtraInfoLength(int extraInfoLength) {
+		this.extraInfoLength = extraInfoLength;
+	}
+
+	public byte[] getExtraInfo() {
+		return extraInfo;
+	}
+
+	public void setExtraInfo(byte[] extraInfo) {
+		this.extraInfo = extraInfo;
+	}
+
+	public UnsignedLong getColumnCount() {
+		return columnCount;
+	}
+
+	public void setColumnCount(UnsignedLong columnCount) {
+		this.columnCount = columnCount;
+	}
+
+	public BitColumn getUsedColumnsBefore() {
+		return usedColumnsBefore;
+	}
+
+	public void setUsedColumnsBefore(BitColumn usedColumnsBefore) {
+		this.usedColumnsBefore = usedColumnsBefore;
+	}
+
+	public BitColumn getUsedColumnsAfter() {
+		return usedColumnsAfter;
+	}
+
+	public void setUsedColumnsAfter(BitColumn usedColumnsAfter) {
+		this.usedColumnsAfter = usedColumnsAfter;
+	}
+
+	public List<Pair<Row>> getRows() {
+		return rows;
+	}
+
+	public void setRows(List<Pair<Row>> rows) {
+		this.rows = rows;
+	}
+}