Merge pull request #88 from zendesk/ben/handle_commits

handle COMMIT QUERY_EVENTs

pom.xml

@@ -4,7 +4,7 @@
 
   <groupId>com.zendesk</groupId>
   <artifactId>maxwell</artifactId>
-  <version>0.10.0-RC4</version>
+  <version>0.11.0-PRE1</version>
   <packaging>jar</packaging>
 
   <name>maxwell</name>

src/main/java/com/zendesk/maxwell/MaxwellParser.java

@@ -187,10 +187,17 @@ private LinkedList<MaxwellAbstractRowsEvent> getTransactionEvents() throws Excep
 					break;
 				case MySQLConstants.QUERY_EVENT:
 					QueryEvent qe = (QueryEvent) v4Event;
-					// TODO: need to handle this case.
-					// The MySQL guys say some storage engines will output a "COMMIT" QUERY_EVENT at the
-					// end of the stream.
-					throw new RuntimeException("Unhandled QueryEvent: " + qe);
+
+					if ( qe.getSql().toString().equals("COMMIT") ) {
+						// some storage engines(?) will output a "COMMIT" QUERY_EVENT instead of a XID_EVENT.
+						// not sure exactly how to trigger this.
+						if ( !list.isEmpty() )
+							list.getLast().setTXCommit();
+
+						return list;
+					} else {
+						throw new RuntimeException("Unhandled QueryEvent: " + qe);
+					}
 				case MySQLConstants.XID_EVENT:
 					XidEvent xe = (XidEvent) v4Event;
 					for ( MaxwellAbstractRowsEvent e : list )