Method parseMerge

jOOQ/src/main/java/org/jooq/impl/ParserImpl.java:2692–2812

(WithImpl with)

    }

    private final Merge<?> parseMerge(WithImpl with) {
        parseKeyword("MERGE");
        parseKeywordIf("INTO");
        Table<?> target = parseTableName();

        if (parseKeywordIf("AS") || !peekKeyword("USING"))
            target = target.as(parseIdentifier());

        parseKeyword("USING");
        Table<?> table = null;
        Select<?> using = null;

        if (parseIf('(')) {
            using = parseSelect();
            parse(')');
        }
        else {
            table = parseTableName();
        }

        TableLike<?> usingTable = parseCorrelationNameIf(table != null ? table : using, () -> peekKeyword("ON"));
        parseKeyword("ON");
        Condition on = parseCondition();
        boolean update = false;
        boolean insert = false;
        MergeUsingStep<?> s1 = (with == null ? dsl.mergeInto(target) : with.mergeInto(target));
        MergeMatchedStep<?> s2 = s1.using(usingTable).on(on);

        for (;;) {
            Map<Field<?>, Object> updateSet;
            Condition updateAnd = null;
            Condition updateWhere = null;
            Condition deleteWhere = null;
            List<Field<?>> insertColumns = null;
            List<Field<?>> insertValues = null;
            Condition insertAnd = null;
            Condition insertWhere = null;

            boolean notMatchedBySource = false;

            if (parseKeywordIf("WHEN MATCHED") || (notMatchedBySource = parseKeywordIf("WHEN NOT MATCHED BY SOURCE"))) {
                update = true;

                if (parseKeywordIf("AND"))
                    updateAnd = parseCondition();

                if (parseKeywordIf("THEN DELETE")) {
                    s2 = notMatchedBySource
                        ? updateAnd != null
                            ? s2.whenNotMatchedBySourceAnd(updateAnd).thenDelete()
                            : s2.whenNotMatchedBySource().thenDelete()
                        : updateAnd != null
                            ? s2.whenMatchedAnd(updateAnd).thenDelete()
                            : s2.whenMatchedThenDelete();
                }
                else {
                    parseKeyword("THEN UPDATE SET");
                    updateSet = parseSetClauseList();