@Test
public void testQuery() throws Exception {

  QueryEvent queryEvent = new QueryEvent(SERVER_ID, 15l, BINLOG_FILE_POS, DATABASE_NAME, "BEGIN");
  List<? extends Mutation> mutations = eventMapper.map(queryEvent);
  assertTrue(mutations.isEmpty());
  assertEquals(15L, beginTransaction.get().getTimestamp());
  queryEvent = new QueryEvent(SERVER_ID, 30l, BINLOG_FILE_POS, DATABASE_NAME, "");
  mutations = eventMapper.map(queryEvent);
  assertTrue(mutations.isEmpty());
  assertEquals(15L, beginTransaction.get().getTimestamp());
  queryEvent = new QueryEvent(SERVER_ID, 30l, BINLOG_FILE_POS, DATABASE_NAME, "BEGIN");
  mutations = eventMapper.map(queryEvent);
  assertTrue(mutations.isEmpty());
  assertEquals(30L, beginTransaction.get().getTimestamp());
}