@Test
public void testAlterTable() {

  String sql = "ALTER TABLE db1.table1 ADD account VARCHAR(255)";
  QueryEvent event = new QueryEvent(1L, TIMESTAMP, BINLOG_FILE_POS, "db1", sql);
  List<MysqlColumn> newTableColumns =
      Arrays.asList(
          new MysqlColumn("id", "int", "int", false),
          new MysqlColumn("account", "varchar", "varchar(255)", false));
  when(schemaDatabase.getColumnsForAllTables("db1"))
      .thenReturn(ImmutableMap.of("table1", newTableColumns, "table2", TABLE2_COLUMNS));
  schemaManager.processDDL(event, GTID);
  verify(schemaDatabase).applyDDL(sql, "db1");
  verify(schemaStore)
      .put(
          new MysqlTableSchema(
              0,
              "db1",
              "table1",
              BINLOG_FILE_POS,
              GTID,
              sql,
              TIMESTAMP,
              newTableColumns,
              Collections.emptyMap()));
}