@Test
public void testDropTable() {

  String sql = "DROP TABLE db1.table2";
  QueryEvent event = new QueryEvent(1L, TIMESTAMP, BINLOG_FILE_POS, "db1", sql);
  when(schemaDatabase.getColumnsForAllTables("db1"))
      .thenReturn(ImmutableMap.of("table1", TABLE1_COLUMNS));
  schemaManager.processDDL(event, GTID);
  verify(schemaDatabase).applyDDL(sql, "db1");
  verify(schemaStore)
      .put(
          new MysqlTableSchema(
              0,
              "db1",
              "table2",
              BINLOG_FILE_POS,
              GTID,
              sql,
              TIMESTAMP,
              Collections.emptyList(),
              Collections.emptyMap()));
}