@Test
public void testAddSourcePrefixCreateDatabase() throws Exception {

  String ddl = "CREATE DATABASE new_database";
  assertEquals("CREATE DATABASE `source/new_database`", schemaDatabase.addSourcePrefix(ddl));
  ddl = "CREATE DATABASE `another_new_database`";
  assertEquals(
      "CREATE DATABASE `source/another_new_database`", schemaDatabase.addSourcePrefix(ddl));
  ddl = "CREATE SCHEMA `new_database_123`";
  assertEquals("CREATE SCHEMA `source/new_database_123`", schemaDatabase.addSourcePrefix(ddl));
  ddl = "CREATE SCHEMA `new_``schema``+456.789`";
  assertEquals(
      "CREATE SCHEMA `source/new_``schema``+456.789`", schemaDatabase.addSourcePrefix(ddl));
  ddl = "CREATE DATABASE new_db DEFAULT CHARSET=utf8";
  assertEquals(
      "CREATE DATABASE `source/new_db` DEFAULT CHARSET=utf8",
      schemaDatabase.addSourcePrefix(ddl));
}