Method parseCopy

core/src/main/java/io/questdb/griffin/SqlParser.java:1031–1246

(GenericLexer lexer, SqlParserCallback sqlParserCallback)

    }

    private ExecutionModel parseCopy(GenericLexer lexer, SqlParserCallback sqlParserCallback) throws SqlException {
        @Nullable ExpressionNode target = null;
        @Nullable CharSequence selectText = null;
        CharSequence tok = tok(lexer, "copy source");
        int startOfSelect = 0;

        if (tok.length() == 1 && tok.charAt(0) == '(') {
            startOfSelect = lexer.getPosition();
            copyMode = true;
            try {
                parseDml(lexer, startOfSelect, sqlParserCallback);
                final int endOfSelect = lexer.getPosition() - 1;
                selectText = lexer.getContent().subSequence(startOfSelect, endOfSelect);
                expectTok(lexer, ')');
            } finally {
                copyMode = false;
            }
        } else {
            lexer.unparseLast();
            target = expectExpr(lexer, sqlParserCallback);
        }

        tok = tok(lexer, "'from' or 'to' or 'cancel'");

        ExportModel model = copyModelPool.next();
        if (isCancelKeyword(tok)) {
            model.setCancel(true);
            model.setTarget(target);

            tok = optTok(lexer);
            // no more tokens or ';' should indicate end of statement
            if (tok == null || Chars.equals(tok, ';')) {
                return model;
            }

            throw errUnexpected(lexer, tok);
        }

        if (isFromKeyword(tok) || isToKeyword(tok)) {
            tok = GenericLexer.immutableOf(tok);
            final ExpressionNode fileName = expectExpr(lexer, sqlParserCallback);
            if (fileName.token.length() < 3 && Chars.startsWith(fileName.token, '\'')) {
                throw SqlException.$(fileName.position, "file name expected");
            }

            model.setTarget(target);
            model.setSelectText(selectText, startOfSelect);
            model.setFileName(fileName);
        }

        if (isFromKeyword(tok)) {
            if (Chars.isBlank(configuration.getSqlCopyInputRoot())) {
                throw SqlException.$(lexer.lastTokenPosition(), "COPY is disabled ['cairo.sql.copy.root' is not set?]");
            }
            if (selectText != null) {
                throw SqlException.$(startOfSelect, "subqueries are not supported for `COPY-FROM`");
            }