@Test
public void testAddSourcePrefixCreateIndex() throws Exception {

  String ddl = "CREATE INDEX id_index ON lookup (id) USING BTREE;";
  assertEquals(ddl, schemaDatabase.addSourcePrefix(ddl));
  ddl = "CREATE UNIQUE INDEX unique_index ON `my_db`.`my_table` (`col1`, `col2`)";
  String expectedDDL =
      "CREATE UNIQUE INDEX unique_index ON `source/my_db`.`my_table` (`col1`, `col2`)";
  assertEquals(expectedDDL, schemaDatabase.addSourcePrefix(ddl));
}