aboutsummaryrefslogtreecommitdiffstats
path: root/resource-assignment/provider/src/main/java/org/onap/ccsdk/sli/adaptors/ra/rule/dao/RangeRuleDaoImpl.java
blob: b021620ba107480f3d9aa6c99a26f3a01435392c (plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
/*-
 * ============LICENSE_START=======================================================
 * openECOMP : SDN-C
 * ================================================================================
 * Copyright (C) 2017 AT&T Intellectual Property. All rights
 *                         reserved.
 * ================================================================================
 * Licensed under the Apache License, Version 2.0 (the "License");
 * you may not use this file except in compliance with the License.
 * You may obtain a copy of the License at
 *
 *      http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
 * limitations under the License.
 * ============LICENSE_END=========================================================
 */

package org.onap.ccsdk.sli.adaptors.ra.rule.dao;

import java.util.ArrayList;
import java.util.List;
import org.onap.ccsdk.sli.adaptors.ra.rule.data.RangeRule;
import org.onap.ccsdk.sli.adaptors.rm.data.Range;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.jdbc.core.RowMapper;

public class RangeRuleDaoImpl implements RangeRuleDao {

    private static final Logger log = LoggerFactory.getLogger(RangeRuleDaoImpl.class);

    private static final String GET_SQL = "SELECT * FROM RANGE_RULE WHERE service_model = ? AND equipment_level = ?";

    private JdbcTemplate jdbcTemplate;

    @Override
    public List<RangeRule> getRangeRules(String serviceModel, String equipLevel) {
        return jdbcTemplate.query(GET_SQL, new Object[] { serviceModel, equipLevel },
                (RowMapper<RangeRule>) (rs, rowNum) -> {
                    RangeRule rl = new RangeRule();
                    rl.id = rs.getLong("range_rule_id");
                    rl.rangeName = rs.getString("range_name");
                    rl.serviceModel = rs.getString("service_model");
                    rl.endPointPosition = rs.getString("end_point_position");
                    rl.equipmentLevel = rs.getString("equipment_level");
                    rl.equipmentExpression = rs.getString("equipment_expression");

                    String rangesStr = rs.getString("ranges");
                    String[] ranges = rangesStr.split(",");
                    rl.rangeList = new ArrayList<>();
                    for (String rangeStr : ranges) {
                        Range range = new Range();
                        String[] nn = rangeStr.split("-");
                        if (nn.length >= 1) {
                            try {
                                range.min = range.max = Integer.parseInt(nn[0]);
                            } catch (NumberFormatException e) {
                                log.warn("Invalid value found in DB for range: " + rangeStr, e);
                            }
                        }
                        if (nn.length >= 2) {
                            try {
                                range.max = Integer.parseInt(nn[1]);
                            } catch (NumberFormatException e) {
                                log.warn("Invalid value found in DB for range: " + rangeStr, e);
                            }
                        }
                        if (nn.length > 2) {
                            log.warn("Invalid value found in DB for range: {}", rangeStr);
                        }
                        rl.rangeList.add(range);
                    }

                    return rl;
                });

    }

    public void setJdbcTemplate(JdbcTemplate jdbcTemplate) {
        this.jdbcTemplate = jdbcTemplate;
    }
}