@Test
public void testCreateTable() {

  String sql = "CREATE TABLE table123 (uid INT)";
  QueryEvent event = new QueryEvent(1L, TIMESTAMP, BINLOG_FILE_POS, "db1", sql);
  List<MysqlColumn> newTableColumns =
      Collections.singletonList(new MysqlColumn("uid", "int", "int", false));
  when(schemaDatabase.getColumnsForAllTables("db1"))
      .thenReturn(
          ImmutableMap.of(
              "table1", TABLE1_COLUMNS, "table2", TABLE2_COLUMNS, "table123", newTableColumns));
  schemaManager.processDDL(event, GTID);
  verify(schemaDatabase).applyDDL(sql, "db1");
  verify(schemaStore)
      .put(
          new MysqlTableSchema(
              0,
              "db1",
              "table123",
              BINLOG_FILE_POS,
              GTID,
              sql,
              TIMESTAMP,
              newTableColumns,
              Collections.emptyMap()));
}