@Test
public void testCreateDatabase() {

  String sql = "CREATE DATABASE db3";
  QueryEvent event = new QueryEvent(1L, TIMESTAMP, BINLOG_FILE_POS, "db3", sql);
  when(schemaDatabase.listDatabases()).thenReturn(ImmutableList.of("db1", "db2", "db3"));
  when(schemaDatabase.getColumnsForAllTables("db3")).thenReturn(Collections.emptyMap());
  schemaManager.processDDL(event, GTID);
  verify(schemaDatabase).applyDDL(sql, null);
  verify(schemaStore)
      .put(
          new MysqlTableSchema(
              0,
              "db3",
              null,
              BINLOG_FILE_POS,
              GTID,
              sql,
              TIMESTAMP,
              Collections.emptyList(),
              Collections.emptyMap()));
}