Method loadSQL

jOOQ/src/main/java/org/jooq/impl/CommitsImpl.java:304–360

(FilePattern pattern, List<Source> files)

    }

    private final Commits loadSQL(FilePattern pattern, List<Source> files) throws IOException {

        // [#9506] TODO: Turning a directory into a MigrationsType (and various other conversion)
        //               could be made reusable. This is certainly very useful for testing and interop,
        //               e.g. also to support other formats (Flyway, Liquibase) as source
        TreeMap<String, CommitType> idToCommit = new TreeMap<>(comparing(
            java.io.File::new,
            pattern.fileComparator()
        ));

        List<FileData> list = files.stream().map(s -> new FileData(pattern, s)).collect(toList());

        if (log.isDebugEnabled())
            list.forEach(f -> log.debug("Reading file", f));

        for (FileData f : list)
            idToCommit.putIfAbsent(f.id, new CommitType()
                .withId(f.id)
                .withAuthor(f.author)
                .withMessage(f.message)
                .withTags(f.tags)
            );

        for (FileData f : list) {
            CommitType commit = idToCommit.get(f.id);

            // Parents are implicit
            // [#9506] TODO: What cases of implicit parents are possible. What edge cases aren't?
            if (f.parents.isEmpty()) {
                Entry<String, CommitType> e = idToCommit.lowerEntry(f.id);

                if (e != null)
                    commit.setParents(asList(new ParentType().withId(e.getKey())));
            }

            // Parents are explicit
            else {
                for (String parent : f.parents)
                    if (idToCommit.containsKey(parent))
                        commit.getParents().add(new ParentType().withId(parent));
                    else
                        throw new DataMigrationVerificationException("Parent " + parent + " is not defined");
            }

            commit.getFiles().add(new FileType()
                .withPath(f.path)
                .withContentType(f.contentType)
                .withContent(f.source.readString())
                .withChange(ChangeType.MODIFY)
            );
        }

        if (log.isDebugEnabled())
            log.debug("Loading files into: " + new MigrationsType().withCommits(idToCommit.values()));

        return load(new MigrationsType().withCommits(idToCommit.values()));
    }