public String buildCopySQL()

in src/main/java/org/apache/doris/kafka/connector/writer/CopySQLBuilder.java [45:71]

• 24 lines of code
• 2 McCabe index (conditional complexity)

    public String buildCopySQL() {
        StringBuilder sb = new StringBuilder();
        sb.append("COPY INTO ")
                .append(database)
                .append(".")
                .append(table)
                .append(" FROM @~('{")
                .append(String.join(",", fileList))
                .append("}') ")
                .append("PROPERTIES (");

        // copy into must be sync
        properties.put(COPY_SYNC, false);
        // default json
        properties.put("file.type", "json");
        properties.put("file.strip_outer_array", "false");
        properties.put("copy.use_delete_sign", enableDelete);
        StringJoiner props = new StringJoiner(",");
        for (Map.Entry<Object, Object> entry : properties.entrySet()) {
            String key = String.valueOf(entry.getKey());
            String value = String.valueOf(entry.getValue());
            String prop = String.format("'%s'='%s'", key, value);
            props.add(prop);
        }
        sb.append(props).append(")");
        return sb.toString();
    }