public String escapeDoubleQuotes()

in flink-vvp-connector-adbpg/src/main/java/org/apache/flink/connector/jdbc/table/sink/AdbpgOutputFormat.java [608:624]

• 16 lines of code
• 5 McCabe index (conditional complexity)

    public String escapeDoubleQuotes(String input) {
        if (null == input) {
            return input;
        }

        StringBuilder sb = new StringBuilder(input.length());
        for (int i = 0; i < input.length(); i++) {
            char c = input.charAt(i);
            if (c == quoteChar) { // 对源数据中的封闭符进行转义，避免源数据被错误分隔
                sb.append('\\');
            } else if (c == '\u0000') {
                continue;
            }
            sb.append(c);
        }
        return sb.toString();
    }