private String createSQLQuery()

in custos-services/custos-core-services/custos-logging/src/main/java/org/apache/custos/logging/persistance/repository/LogEventRepoImpl.java [59:143]
44 lines of code
16 McCabe index (conditional complexity)

    private String createSQLQuery(LogEventRequest logEventRequest, Map<String, Object> valueMap) {

        String query = "SELECT * FROM log_events E WHERE ";


        if (logEventRequest.getTenantId() != 0) {

            query = query + "E.tenant_id = :" + "tenant_id" + " AND ";

            valueMap.put("tenant_id", logEventRequest.getTenantId());

        }

        if (logEventRequest.getClientId() != null && !logEventRequest.getClientId().equals("")) {

            query = query + "E.client_id = :" + "client_id" + " AND ";

            valueMap.put("client_id", logEventRequest.getClientId());

        }

        if (logEventRequest.getServiceName() != null && !logEventRequest.getServiceName().equals("")) {

            query = query + "E.service_name = :" + "service_name" + " AND ";

            valueMap.put("service_name", logEventRequest.getServiceName());

        }

        if (logEventRequest.getEventType() != null && !logEventRequest.getEventType().equals("")) {

            query = query + "E.event_type = :" + "event_type" + " AND ";

            valueMap.put("event_type", logEventRequest.getEventType());

        }

        if (logEventRequest.getRemoteIp() != null && !logEventRequest.getRemoteIp().equals("")) {

            query = query + "E.remote_ip = :" + "remote_ip" + " AND ";

            valueMap.put("remote_ip", logEventRequest.getEventType());

        }

        if (logEventRequest.getUsername() != null && !logEventRequest.getUsername().equals("")) {

            query = query + "E.username = :" + "username" + " AND ";

            valueMap.put("username", logEventRequest.getEventType());

        }

        if (logEventRequest.getStartTime() > 0) {

            query = query + "E.created_time >= :" + "created_time" + " AND ";

            valueMap.put("created_time", logEventRequest.getStartTime());

        }

        if (logEventRequest.getEndTime() > 0) {

            query = query + "E.created_time < :" + "created_time" + " AND ";

            valueMap.put("created_time", logEventRequest.getEndTime());

        }

        query = query.substring(0, query.length() - 5);

        query = query + " ORDER BY E.created_time DESC ";

        if (logEventRequest.getOffset() >= 0 && logEventRequest.getLimit() > 0) {
            query = query + " LIMIT " + ":limit" + " OFFSET " + ":offset";
            valueMap.put("limit", logEventRequest.getLimit());
            valueMap.put("offset", logEventRequest.getOffset());
        }

        LOGGER.debug("Query ####" + query);


        return query;

    }