public static String getFlatBuffersSql()

in src/main/java/com/aliyun/ha3engine/jdbc/common/utils/Ha3ToolUtils.java [143:163]

• 20 lines of code
• 6 McCabe index (conditional complexity)

    public static String getFlatBuffersSql(String sql) {
        /** only support formatType:flatbuffers */
        if (sql.contains("&&kvpair=")) {
            if (!sql.contains("formatType")) {
                sql = sql.replace("&&kvpair=", "&&kvpair=formatType:flatbuffers;");
            } else {
                if (sql.contains("formatType:string")) {
                    sql = sql.replace("formatType:string", "formatType:flatbuffers");
                } else if (sql.contains("formatType:json")) {
                    sql = sql.replace("formatType:json", "formatType:flatbuffers");
                } else if (sql.contains("formatType:full_json")) {
                    sql = sql.replace("formatType:full_json", "formatType:flatbuffers");
                }
            }
        } else {
            StringBuilder stringBuilder = new StringBuilder(sql);
            stringBuilder.append("&&kvpair=formatType:flatbuffers;");
            sql = stringBuilder.toString();
        }
        return sql;
    }