Method execute0

jOOQ/src/main/java/org/jooq/impl/MigrationImpl.java:417–530

(boolean baseline)

    }

    void execute0(boolean baseline) {

        // TODO: Transactions don't really make sense in most dialects. In some, they do
        //       e.g. PostgreSQL supports transactional DDL. Check if we're getting this right.
        run(() -> {
            DefaultMigrationContext ctx = migrationContext(baseline);
            MigrationListener listener = new MigrationListeners(configuration);

            if (!FALSE.equals(dsl().settings().isMigrationAutoVerification()))
                verify0(ctx);

            init(baseline);

            try {
                listener.migrationStart(ctx);
                int untracked = ctx.revertUntrackedQueries.queries().length;

                if (baseline) {
                    if (history.available()
                        && history.current().version().id().equals(to().id())
                        && untracked == 0
                    ) {
                        if (log.isInfoEnabled())
                            log.info("Current version is already set to baseline version: " + to().id());

                        return;
                    }

                    if (log.isInfoEnabled())
                        log.info("Setting baseline to " + to().id());

                    if (untracked == 0) {
                        createRecord(ctx, SUCCESS, from(), to(), "New baseline");
                    }
                    else {
                        if (log.isInfoEnabled())
                            log.info("Reverting untracked changes (number of queries: " + untracked + ")");

                        StopWatch watch = new StopWatch();
                        HistoryRecord record = createRecord(ctx, STARTING, from(), to(), "New baseline");

                        try {
                            log(watch, record, REVERTING);
                            revertUntracked(ctx, listener, record);
                            log(watch, record, SUCCESS);
                        }
                        catch (Exception e) {
                            StringWriter s = new StringWriter();
                            e.printStackTrace(new PrintWriter(s));

                            if (log.isErrorEnabled())
                                log.error("Setting " + to().id() + " as baseline failed: " + e.getMessage());

                            log(watch, record, FAILURE, OPEN, s.toString());
                            throw new DataMigrationRedoLogException(record, e);
                        }
                    }