private String loadStatement()

in cassandra/src/main/java/org/apache/ignite/activestore/impl/cassandra/persistence/PersistenceController.java [194:241]

• 47 lines of code
• 11 McCabe index (conditional complexity)

    private String loadStatement(String keyspace, String table, boolean includeKeyFields, boolean includeValueFields,
        boolean includeFilter) {
        StringBuilder result = new StringBuilder("select ");
        boolean first = true;
        List<String> keyColumns = getKeyColumns();
        if (includeKeyFields) {
            for (String keyColumn : keyColumns) {
                if (first) {
                    first = false;
                }
                else {
                    result.append(", ");
                }
                result.append(keyColumn);
            }
        }
        if (includeValueFields) {
            List<String> valueColumns = getValueColumns();
            for (String valueColumn : valueColumns) {
                if (first) {
                    first = false;
                }
                else {
                    result.append(", ");
                }
                result.append(valueColumn);
            }
        }

        result.append(" from ");
        result.append(keyspace);
        result.append(".").append(table);
        if (includeFilter && !keyColumns.isEmpty()) {
            result.append(" where ");
            first = true;
            for (String keyColumn : keyColumns) {
                if (first) {
                    first = false;
                }
                else {
                    result.append(", ");
                }
                result.append(keyColumn).append("=?");
            }
        }
        result.append(";");
        return result.toString();
    }