@@ -0,0 +1,1557 @@
+package org.javalite.db_migrator.maven;%0A%0Aimport org.apache.maven.plugin.MojoExecutionException;%0Aimport org.javalite.db_migrator.DbUtils;%0Aimport org.javalite.db_migrator.MigrationManager;%0A%0Aimport static java.lang.String.format;%0Aimport static org.javalite.db_migrator.DbUtils.*;%0A%0A%0A/**%0A * @goal create%0A */%0Apublic class CreateMojo extends AbstractDbMigrationMojo %7B%0A%0A    public void executeMojo() throws MojoExecutionException %7B%0A%0A        try %7B%0A%0A            String createSql = blank(getCreateSql()) ? %22create database %25s%22 : getCreateSql();%0A            String databaseName = DbUtils.extractDatabaseName(getUrl());%0A            switch (DbUtils.databaseType(getUrl())) %7B%0A                case MYSQL:%0A                    break;%0A                case SQL_SERVER:%0A                    break;%0A                case POSTGRESQL:%0A                    databaseName = %22%5C%22%22 + databaseName + %22%5C%22%22;%0A                    break;%0A            %7D%0A%0A            openConnection(true);%0A            exec(format(createSql, databaseName));%0A            getLog().info(%22Created database %22 + getUrl());%0A        %7D catch (Exception e) %7B%0A            throw new MojoExecutionException(%22Failed to create database: %22 + getUrl(), e);%0A        %7D finally %7B%0A            closeConnection();%0A        %7D%0A%0A        try%7B%0A            openConnection();%0A            new MigrationManager(getMigrationsPath()).createSchemaVersionTable();%0A%0A        %7Dcatch(Exception e)%7B%0A            throw  new MojoExecutionException(%22failed to create SCHEMA_VERSION table%22, e);%0A        %7Dfinally %7B%0A            closeConnection();%0A        %7D%0A    %7D%0A%7D%0A

Revert changes to CreateMojo class