2 * ============LICENSE_START=======================================================
4 * ================================================================================
5 * Copyright (C) 2017 AT&T Intellectual Property. All rights
7 * ================================================================================
8 * Licensed under the Apache License, Version 2.0 (the "License");
9 * you may not use this file except in compliance with the License.
10 * You may obtain a copy of the License at
12 * http://www.apache.org/licenses/LICENSE-2.0
14 * Unless required by applicable law or agreed to in writing, software
15 * distributed under the License is distributed on an "AS IS" BASIS,
16 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
17 * See the License for the specific language governing permissions and
18 * limitations under the License.
19 * ============LICENSE_END=========================================================
22 package jtest.org.openecomp.sdnc.ra;
24 import java.util.Date;
26 import jtest.util.org.openecomp.sdnc.ra.TestDb;
27 import jtest.util.org.openecomp.sdnc.ra.TestTable;
29 public class DataSetup {
31 private TestDb testDb;
33 private TestTable vpePool = null;
34 private TestTable vplspePool = null;
35 private TestTable pserver = null;
36 private TestTable serviceResource = null;
37 private TestTable resource = null;
38 private TestTable allocationItem = null;
40 private static final String[] VPE_POOL_COLUMNS = {
41 "vpe_name", "ipv4_oam_address", "loopback0_ipv4_address", "provisioning_status", "aic_site_id",
42 "availability_zone", "vlan_id_outer", "vendor", "physical_intf_name", "physical_intf_speed",
43 "physical_intf_units", "vpe_uuid", "vpe_id", "image_filename" };
45 private static final String[] VPLSPE_POOL_COLUMNS = {
46 "vplspe_name", "aic_site_id", "availability_zone", "physical_intf_name", "physical_intf_speed",
47 "physical_intf_units", "loopback0_ipv4_address", "vlan_id_outer", "vplspe_uuid", "image_filename",
48 "provisioning_status", "vendor" };
50 private static final String[] PSERVER_COLUMNS = {
51 "hostname", "ptnii_equip_name", "number_of_cpus", "disk_in_gigabytes", "ram_in_megabytes", "equip_type",
52 "equip_vendor", "equip_model", "fqdn", "pserver_selflink", "ipv4_oam_address", "serial_number",
53 "pserver_id", "internet_topology", "aic_site_id", "in_maint", "pserver_name2", "purpose" };
55 private static final String[] SERVICE_RESOURCE_COLUMNS = {
56 "service_instance_id", "service_status", "service_change_number", "resource_set_id", "resource_union_id" };
58 private static final String[] RESOURCE_COLUMNS = { "asset_id", "resource_name", "resource_type", "lt_used" };
60 private static final String[] ALLOCATION_ITEM_COLUMNS = {
61 "resource_id", "application_id", "resource_set_id", "resource_union_id", "resource_share_group_list",
62 "lt_used", "allocation_time" };
64 private void initTables() {
66 vpePool = testDb.table("VPE_POOL", "vpe_name", VPE_POOL_COLUMNS);
67 if (vplspePool == null)
68 vplspePool = testDb.table("VPLSPE_POOL", "vplspe_name", VPLSPE_POOL_COLUMNS);
70 pserver = testDb.table("PSERVER", "hostname", PSERVER_COLUMNS);
71 if (serviceResource == null)
72 serviceResource = testDb.table("SERVICE_RESOURCE", "service_resource_id", SERVICE_RESOURCE_COLUMNS);
74 resource = testDb.table("RESOURCE", "resource_id", RESOURCE_COLUMNS);
75 if (allocationItem == null)
76 allocationItem = testDb.table("ALLOCATION_ITEM", "allocation_item_id", ALLOCATION_ITEM_COLUMNS);
79 public void cleanup() {
81 vpePool.delete("true");
82 vplspePool.delete("true");
83 pserver.delete("true");
84 serviceResource.delete("true");
85 allocationItem.delete("true");
86 resource.delete("true");
89 public void setupVpePort(
94 String imageFileName) {
96 vpePool.add(vpeId, "127.0.0.1", "107.134.152.139", provStatus, aicSiteId, "mtanj-esx-az01", "3501",
97 "JUNIPER", interfaceName, "1", "GBPS", "vpe002", "VPESAT-auttx200me6", imageFileName);
100 public void setupVplspePort(
103 String interfaceName,
105 String imageFileName) {
107 vplspePool.add(vplspeId, aicSiteId, "mtanj-esx-az01", interfaceName, "100", "GBPS", "192.168.119.32", "3501",
108 "vpls002", imageFileName, provStatus, "JUNIPER");
111 public void setupPserver(String hostname, String aicSiteId) {
113 pserver.add(hostname, hostname + "srv1", 4, 1000, 16000, "equip_type", "equip_vendor", "equip_model", "fqdn",
114 "pserver_selflink", "123.123.123.123", "serial_number", "pserver_id", "internet_topology", aicSiteId,
115 "N", hostname, "purpose");
118 public void setupService(
119 String serviceInstanceId,
128 String resourceSetId = serviceInstanceId + "/" + changeNumber;
129 String resourceUnionId = serviceInstanceId;
131 serviceResource.add(serviceInstanceId, status, changeNumber, resourceSetId, resourceUnionId);
133 Long rid = resource.getId("asset_id = '" + vpeId + "/ae0' AND resource_name = 'Bandwidth'");
135 resource.add(vpeId + "/ae0", "Bandwidth", "Limit", 1);
136 rid = resource.getLastId();
138 allocationItem.add(rid, "SDNC", resourceSetId, resourceUnionId, null, speedKbps, new Date());
140 rid = resource.getId("asset_id = '" + vplspeId + "' AND resource_name = 'Bandwidth'");
142 resource.add(vplspeId, "Bandwidth", "Limit", 1);
143 rid = resource.getLastId();
145 allocationItem.add(rid, "SDNC", resourceSetId, resourceUnionId, null, speedKbps, new Date());
147 rid = resource.getId("asset_id = '" + serverId + "' AND resource_name = 'Bandwidth'");
149 resource.add(serverId, "Bandwidth", "Limit", 1);
150 rid = resource.getLastId();
152 allocationItem.add(rid, "SDNC", resourceSetId, resourceUnionId, null, speedKbps, new Date());
154 rid = resource.getId("asset_id = '" + serverId + "' AND resource_name = 'Connection'");
156 resource.add(serverId, "Connection", "Limit", 1);
157 rid = resource.getLastId();
159 allocationItem.add(rid, "SDNC", resourceSetId, resourceUnionId, null, 1, new Date());
162 public boolean serviceNotInDb(String serviceInstanceId, String status, Integer changeNumber) {
163 String where = "service_instance_id = '" + serviceInstanceId + "'";
165 where += " AND service_status = '" + status + "'";
166 if (changeNumber != null)
167 where += " AND service_change_number = " + changeNumber;
169 if (serviceResource.exists(where))
172 where = "resource_union_id = '" + serviceInstanceId + "'";
173 if (changeNumber != null)
174 where += " AND resource_set_id = '" + serviceInstanceId + "/" + changeNumber + "'";
176 if (allocationItem.exists(where))
182 public boolean serviceCorrectInDb(String serviceInstanceId, String status, int changeNumber, long speedKbps) {
183 String where = "service_instance_id = '" + serviceInstanceId + "' AND service_status = '" + status +
184 "' AND service_change_number = " + changeNumber;
185 if (!serviceResource.exists(where))
188 where = "resource_union_id = '" + serviceInstanceId + "' AND resource_set_id = '" + serviceInstanceId + "/" +
189 changeNumber + "' AND lt_used = " + speedKbps;
190 if (!allocationItem.exists(where))
196 public boolean serviceCorrectInDb(
199 String serviceInstanceId,
204 String where = "service_instance_id = '" + serviceInstanceId + "' AND service_status = '" + status +
205 "' AND service_change_number = " + changeNumber;
206 if (!serviceResource.exists(where))
209 Long vpebwrid = resource.getId("asset_id = '" + vpeId + "/ae0' AND resource_name = 'Bandwidth'");
210 if (vpebwrid == null)
213 where = "resource_id = " + vpebwrid + " AND resource_union_id = '" + serviceInstanceId +
214 "' AND resource_set_id = '" + serviceInstanceId + "/" + changeNumber + "' AND lt_used = " + speedKbps;
215 if (!allocationItem.exists(where))
218 Long srvbwrid = resource.getId("asset_id = '" + aicSiteId + "/Server1' AND resource_name = 'Bandwidth'");
219 if (srvbwrid == null)
222 where = "resource_id = " + srvbwrid + " AND resource_union_id = '" + serviceInstanceId +
223 "' AND resource_set_id = '" + serviceInstanceId + "/" + changeNumber + "' AND lt_used = " + speedKbps;
224 if (!allocationItem.exists(where))
227 Long srvconrid = resource.getId("asset_id = '" + aicSiteId + "/Server1' AND resource_name = 'Connection'");
228 if (srvconrid == null)
231 where = "resource_id = " + srvconrid + " AND resource_union_id = '" + serviceInstanceId +
232 "' AND resource_set_id = '" + serviceInstanceId + "/" + changeNumber + "' AND lt_used = 1";
233 if (!allocationItem.exists(where))
239 public boolean serviceCorrectInDb(
240 String serviceInstanceId,
241 String endPointPosition,
245 String where = "service_instance_id = '" + serviceInstanceId + "' AND service_status = '" + status +
246 "' AND service_change_number = " + changeNumber;
247 if (!serviceResource.exists(where))
250 where = "resource_union_id = '" + serviceInstanceId + "/" + endPointPosition + "' AND resource_set_id = '" +
251 serviceInstanceId + "/" + endPointPosition + "/" + changeNumber + "' AND lt_used = " + speedKbps;
252 if (!allocationItem.exists(where))
258 public void setTestDb(TestDb testDb) {
259 this.testDb = testDb;