diff options
Diffstat (limited to 'src/main/java/org/onap/aai/migration/v12')
9 files changed, 73 insertions, 77 deletions
diff --git a/src/main/java/org/onap/aai/migration/v12/ALTSLicenseEntitlementMigration.java b/src/main/java/org/onap/aai/migration/v12/ALTSLicenseEntitlementMigration.java index ef45209..135685c 100644 --- a/src/main/java/org/onap/aai/migration/v12/ALTSLicenseEntitlementMigration.java +++ b/src/main/java/org/onap/aai/migration/v12/ALTSLicenseEntitlementMigration.java @@ -82,15 +82,15 @@ public class ALTSLicenseEntitlementMigration extends Migrator{ logger.info("\n"); if (!vnfLine.isEmpty()) { if (fileLineCounter != 0) { - String[] fields = vnfLine.split("\\s*,\\s*", -1); + String[] fields = vnfLine.split(",", -1); if (fields.length != this.headerLength) { logger.info("ERROR: Vnf line should contain " + this.headerLength + " columns, contains " + fields.length + " instead."); success = false; continue; } - String newResourceUuid = fields[0]; - String groupUuid = fields[1]; - String vnfId = fields[19]; + String newResourceUuid = fields[0].trim(); + String groupUuid = fields[1].trim(); + String vnfId = fields[19].trim(); logger.info("---------- Processing Line " + vnfLine + "----------"); logger.info("newResourceUuid = " + newResourceUuid + " vnfId = " + vnfId + " group uuid = " + groupUuid); if (history.containsKey(vnfId)){ @@ -104,7 +104,7 @@ public class ALTSLicenseEntitlementMigration extends Migrator{ } } else { - Set newSet = new HashSet(); + Set<String> newSet = new HashSet<>(); newSet.add(groupUuid); history.put(vnfId, newSet); } @@ -120,7 +120,7 @@ public class ALTSLicenseEntitlementMigration extends Migrator{ this.ChangeResourceUuid(licenses, newResourceUuid, "license", vnfId, groupUuid); } else { - this.headerLength = vnfLine.split("\\s*,\\s*", -1).length; + this.headerLength = vnfLine.split(",", -1).length; logger.info("headerLength: " + headerLength); if (this.headerLength < 22){ logger.info("ERROR: Input file should have 22 columns"); @@ -139,7 +139,6 @@ public class ALTSLicenseEntitlementMigration extends Migrator{ success = false; } catch (Exception e) { logger.info("encountered exception", e); - e.printStackTrace(); success = false; } } diff --git a/src/main/java/org/onap/aai/migration/v12/MigrateHUBEvcInventory.java b/src/main/java/org/onap/aai/migration/v12/MigrateHUBEvcInventory.java index 0b3103b..97936d7 100644 --- a/src/main/java/org/onap/aai/migration/v12/MigrateHUBEvcInventory.java +++ b/src/main/java/org/onap/aai/migration/v12/MigrateHUBEvcInventory.java @@ -120,16 +120,16 @@ public class MigrateHUBEvcInventory extends Migrator { logger.info("\n"); if (!line.isEmpty()) { if (fileLineCounter != 0) { - String[] colList = line.split("\\s*,\\s*", -1); + String[] colList = line.split(",", -1); // if (colList.length != headerLength) { // logger.info("ERROR: HUB line entry should contain " + headerLength + " columns, contains " + colList.length + " instead."); // success = false; // continue; // } Map<String, String> hubColValues = new HashMap<String, String>(); - hubColValues.put("ivlan", colList[1]); - hubColValues.put("nniSvlan", colList[3]); - hubColValues.put("evcName", colList[4]); + hubColValues.put("ivlan", colList[1].trim()); + hubColValues.put("nniSvlan", colList[3].trim()); + hubColValues.put("evcName", colList[4].trim()); String evcName = hubColValues.get("evcName"); String ivlan = hubColValues.get("ivlan"); @@ -169,7 +169,7 @@ public class MigrateHUBEvcInventory extends Migrator { } } } else { - this.headerLength = line.split("\\s*,\\s*", -1).length; + this.headerLength = line.split(",", -1).length; logger.info("headerLength: " + headerLength); if (this.headerLength < 5){ logger.info("ERROR: Input file should have 5 columns"); diff --git a/src/main/java/org/onap/aai/migration/v12/MigrateINVEvcInventory.java b/src/main/java/org/onap/aai/migration/v12/MigrateINVEvcInventory.java index a9fce6a..de97408 100644 --- a/src/main/java/org/onap/aai/migration/v12/MigrateINVEvcInventory.java +++ b/src/main/java/org/onap/aai/migration/v12/MigrateINVEvcInventory.java @@ -112,14 +112,14 @@ public class MigrateINVEvcInventory extends Migrator { logger.info("\n"); if (!line.isEmpty()) { if (fileLineCounter != 0) { - String[] colList = line.split("\\s*,\\s*", -1); + String[] colList = line.split(",", -1); if (colList.length != headerLength) { logger.info("ERROR: INV line should contain " + headerLength + " columns, contains " + colList.length + " instead."); continue; } Map<String, String> invColValues = new HashMap<String, String>(); - invColValues.put("evcName", colList[22]); - invColValues.put("collectorInterconnectType", colList[17]); + invColValues.put("evcName", colList[22].trim()); + invColValues.put("collectorInterconnectType", colList[17].trim()); String evcName = invColValues.get("evcName"); String interconnectType = invColValues.get("collectorInterconnectType"); @@ -152,7 +152,7 @@ public class MigrateINVEvcInventory extends Migrator { continue; } } else { - this.headerLength = line.split("\\s*,\\s*", -1).length; + this.headerLength = line.split(",", -1).length; logger.info("headerLength: " + headerLength); if (this.headerLength < 23){ logger.info("ERROR: Input file should have 23 columns"); @@ -183,7 +183,6 @@ public class MigrateINVEvcInventory extends Migrator { success = false; } catch (Exception e) { logger.info("encountered exception", e); - e.printStackTrace(); success = false; } } diff --git a/src/main/java/org/onap/aai/migration/v12/MigrateINVPhysicalInventory.java b/src/main/java/org/onap/aai/migration/v12/MigrateINVPhysicalInventory.java index 0c85481..ade7ec3 100644 --- a/src/main/java/org/onap/aai/migration/v12/MigrateINVPhysicalInventory.java +++ b/src/main/java/org/onap/aai/migration/v12/MigrateINVPhysicalInventory.java @@ -39,6 +39,7 @@ package org.onap.aai.migration.v12; */ +import java.util.stream.Collectors; import org.apache.tinkerpop.gremlin.process.traversal.dsl.graph.GraphTraversalSource; import org.apache.tinkerpop.gremlin.structure.Vertex; import org.javatuples.Pair; @@ -125,7 +126,6 @@ public class MigrateINVPhysicalInventory extends Migrator { success = false; } catch (Exception e) { logger.info("encountered exception", e); - e.printStackTrace(); success = false; } } @@ -231,7 +231,7 @@ public class MigrateINVPhysicalInventory extends Migrator { lines.stream() .filter(line -> !line.isEmpty()) - .map(line -> Arrays.asList(line.split("\\s*,\\s*", -1))) + .map(line -> Arrays.stream(line.split(",", -1)).map(String::trim).collect(Collectors.toList())) // .filter(this::verifyLine) .map(this::processLine) .filter(Optional::isPresent) @@ -316,7 +316,7 @@ public class MigrateINVPhysicalInventory extends Migrator { firstLine = lines.get(0); } - this.headerLength = firstLine.split("\\s*,\\s*", -1).length; + this.headerLength = firstLine.split(",", -1).length; logger.info("headerLength: " + headerLength); if (this.headerLength < 21){ String msg = "ERROR: Input file should have 21 columns"; diff --git a/src/main/java/org/onap/aai/migration/v12/MigratePATHEvcInventory.java b/src/main/java/org/onap/aai/migration/v12/MigratePATHEvcInventory.java index b0bacde..28b5b7b 100644 --- a/src/main/java/org/onap/aai/migration/v12/MigratePATHEvcInventory.java +++ b/src/main/java/org/onap/aai/migration/v12/MigratePATHEvcInventory.java @@ -136,25 +136,25 @@ public class MigratePATHEvcInventory extends Migrator { logger.info("\n"); if (!line.isEmpty()) { if (fileLineCounter != 0) { - String[] colList = line.split("\\s*,\\s*", -1); + String[] colList = line.split(",", -1); if (colList.length != headerLength) { logger.info("ERROR: PATH line should contain " + headerLength + " columns, contains " + colList.length + " instead."); // success = false; continue; } Map<String, String> pathColValues = new HashMap<String, String>(); - pathColValues.put("evcName", colList[1]); - pathColValues.put("bearerFacingCircuit", colList[4]); - pathColValues.put("bearerCvlan", colList[6]); - pathColValues.put("bearerSvlan", colList[7]); - pathColValues.put("bearerPtniiName", colList[8]); - String bearerPortAid = colList[12].replaceAll("^\"|\"$", "").replaceAll("\\s+",""); + pathColValues.put("evcName", colList[1].trim()); + pathColValues.put("bearerFacingCircuit", colList[4].trim()); + pathColValues.put("bearerCvlan", colList[6].trim()); + pathColValues.put("bearerSvlan", colList[7].trim()); + pathColValues.put("bearerPtniiName", colList[8].trim()); + String bearerPortAid = colList[12].trim().replaceAll("^\"|\"$", "").replaceAll("\\s+",""); pathColValues.put("bearerPortAid", bearerPortAid); - pathColValues.put("collectorFacingCircuit", colList[14]); - pathColValues.put("collectorCvlan", colList[16]); - pathColValues.put("collectorSvlan", colList[17]); - pathColValues.put("collectorPtniiName", colList[18]); - String collectorPortAid = colList[22].replaceAll("^\"|\"$", "").replaceAll("\\s+",""); + pathColValues.put("collectorFacingCircuit", colList[14].trim()); + pathColValues.put("collectorCvlan", colList[16].trim()); + pathColValues.put("collectorSvlan", colList[17].trim()); + pathColValues.put("collectorPtniiName", colList[18].trim()); + String collectorPortAid = colList[22].trim().replaceAll("^\"|\"$", "").replaceAll("\\s+",""); pathColValues.put("collectorPortAid", collectorPortAid); @@ -202,7 +202,7 @@ public class MigratePATHEvcInventory extends Migrator { } } } else { - this.headerLength = line.split("\\s*,\\s*", -1).length; + this.headerLength = line.split(",", -1).length; logger.info("headerLength: " + headerLength); if (this.headerLength < 24){ logger.info("ERROR: Input file should have 24 columns"); @@ -232,7 +232,6 @@ public class MigratePATHEvcInventory extends Migrator { success = false; } catch (Exception e) { logger.info("encountered exception", e); - e.printStackTrace(); success = false; } } diff --git a/src/main/java/org/onap/aai/migration/v12/MigrateSAREvcInventory.java b/src/main/java/org/onap/aai/migration/v12/MigrateSAREvcInventory.java index a24d21a..2894883 100644 --- a/src/main/java/org/onap/aai/migration/v12/MigrateSAREvcInventory.java +++ b/src/main/java/org/onap/aai/migration/v12/MigrateSAREvcInventory.java @@ -131,36 +131,36 @@ public class MigrateSAREvcInventory extends Migrator { logger.info("\n"); if (!line.isEmpty()) { if (fileLineCounter != 0) { - String[] colList = line.split("\\s*,\\s*", -1); + String[] colList = line.split(",", -1); // if (colList.length != headerLength) { // logger.info("ERROR: SAR line should contain " + headerLength + " columns, contains " + colList.length + " instead."); // success = false; // continue; // } Map<String, String> sarColValues = new HashMap<String, String>(); - sarColValues.put("evcName", colList[0]); - sarColValues.put("subscriberName", colList[1]); - sarColValues.put("espName", colList[2]); - sarColValues.put("bearerCircuitId", colList[3]); - sarColValues.put("bearerTagMode", colList[4]); - sarColValues.put("bearerCvlan", colList[5]); - sarColValues.put("bearerSvlan", colList[6]); - sarColValues.put("bearerPtniiName", colList[7]); - sarColValues.put("bearerSlotName", colList[8]); - String bearerPortAid = colList[9].replaceAll("^\"|\"$", "").replaceAll("\\s+",""); + sarColValues.put("evcName", colList[0].trim()); + sarColValues.put("subscriberName", colList[1].trim()); + sarColValues.put("espName", colList[2].trim()); + sarColValues.put("bearerCircuitId", colList[3].trim()); + sarColValues.put("bearerTagMode", colList[4].trim()); + sarColValues.put("bearerCvlan", colList[5].trim()); + sarColValues.put("bearerSvlan", colList[6].trim()); + sarColValues.put("bearerPtniiName", colList[7].trim()); + sarColValues.put("bearerSlotName", colList[8].trim()); + String bearerPortAid = colList[9].trim().replaceAll("^\"|\"$", "").replaceAll("\\s+",""); sarColValues.put("bearerPortAid", bearerPortAid); - sarColValues.put("bearerPortType", colList[10]); - sarColValues.put("collectorCircuitId", colList[11]); - sarColValues.put("collectorTagMode", colList[12]); - sarColValues.put("collectorCvlan", colList[13]); - sarColValues.put("collectorSvlan", colList[14]); - sarColValues.put("collectorPtniiName", colList[15]); - sarColValues.put("collectorSlotName", colList[16]); - String collectorPortAid = colList[17].replaceAll("^\"|\"$", "").replaceAll("\\s+",""); + sarColValues.put("bearerPortType", colList[10].trim()); + sarColValues.put("collectorCircuitId", colList[11].trim()); + sarColValues.put("collectorTagMode", colList[12].trim()); + sarColValues.put("collectorCvlan", colList[13].trim()); + sarColValues.put("collectorSvlan", colList[14].trim()); + sarColValues.put("collectorPtniiName", colList[15].trim()); + sarColValues.put("collectorSlotName", colList[16].trim()); + String collectorPortAid = colList[17].trim().replaceAll("^\"|\"$", "").replaceAll("\\s+",""); sarColValues.put("collectorPortAid", collectorPortAid); - sarColValues.put("collectorPortType", colList[18]); - sarColValues.put("espEvcCircuitId", colList[19]); - sarColValues.put("evcAccessCIR", colList[20]); + sarColValues.put("collectorPortType", colList[18].trim()); + sarColValues.put("espEvcCircuitId", colList[19].trim()); + sarColValues.put("evcAccessCIR", colList[20].trim()); String evcName = sarColValues.get("evcName"); if (!AAIConfig.isEmpty(evcName)) { @@ -181,7 +181,7 @@ public class MigrateSAREvcInventory extends Migrator { } } else { - this.headerLength = line.split("\\s*,\\s*", -1).length; + this.headerLength = line.split(",", -1).length; logger.info("headerLength: " + headerLength); if (this.headerLength < 21){ logger.info("ERROR: Input file should have 21 columns"); @@ -211,7 +211,6 @@ public class MigrateSAREvcInventory extends Migrator { success = false; } catch (Exception e) { logger.info("encountered exception", e); - e.printStackTrace(); success = false; } } diff --git a/src/main/java/org/onap/aai/migration/v12/SDWANSpeedChangeMigration.java b/src/main/java/org/onap/aai/migration/v12/SDWANSpeedChangeMigration.java index b420c57..d102f99 100644 --- a/src/main/java/org/onap/aai/migration/v12/SDWANSpeedChangeMigration.java +++ b/src/main/java/org/onap/aai/migration/v12/SDWANSpeedChangeMigration.java @@ -111,7 +111,6 @@ public class SDWANSpeedChangeMigration extends Migrator { } } catch (AAIException e) { - e.printStackTrace(); success = false; } diff --git a/src/main/java/org/onap/aai/migration/v12/UpdateAaiUriIndexMigration.java b/src/main/java/org/onap/aai/migration/v12/UpdateAaiUriIndexMigration.java index 6273f84..dbb892d 100644 --- a/src/main/java/org/onap/aai/migration/v12/UpdateAaiUriIndexMigration.java +++ b/src/main/java/org/onap/aai/migration/v12/UpdateAaiUriIndexMigration.java @@ -192,7 +192,7 @@ public class UpdateAaiUriIndexMigration extends Migrator { .status(SchemaStatus.DISABLED) .call(); } catch (Exception e) { - e.printStackTrace(); + logger.info("AwaitGraphIndexStatus error: " + e.getMessage()); } } @@ -260,7 +260,7 @@ public class UpdateAaiUriIndexMigration extends Migrator { .status(SchemaStatus.REGISTERED) .call(); } catch (Exception e) { - e.printStackTrace(); + logger.info("AwaitGraphIndexStatus error: " + e.getMessage()); } } @@ -279,7 +279,7 @@ public class UpdateAaiUriIndexMigration extends Migrator { .status(SchemaStatus.ENABLED) .call(); } catch (Exception e) { - e.printStackTrace(); + logger.info("AwaitGraphIndexStatus error: " + e.getMessage()); } } diff --git a/src/main/java/org/onap/aai/migration/v12/UriMigration.java b/src/main/java/org/onap/aai/migration/v12/UriMigration.java index ed3b84d..4a55f71 100644 --- a/src/main/java/org/onap/aai/migration/v12/UriMigration.java +++ b/src/main/java/org/onap/aai/migration/v12/UriMigration.java @@ -19,31 +19,36 @@ */ package org.onap.aai.migration.v12; +import java.io.UnsupportedEncodingException; import java.nio.charset.UnsupportedCharsetException; +import java.util.HashSet; +import java.util.Map; +import java.util.Optional; +import java.util.Set; +import java.util.UUID; +import java.util.stream.Collectors; +import javax.ws.rs.core.UriBuilder; import org.apache.tinkerpop.gremlin.process.traversal.dsl.graph.GraphTraversalSource; import org.apache.tinkerpop.gremlin.process.traversal.dsl.graph.__; import org.apache.tinkerpop.gremlin.structure.Vertex; import org.onap.aai.db.props.AAIProperties; import org.onap.aai.edges.EdgeIngestor; +import org.onap.aai.edges.enums.AAIDirection; import org.onap.aai.edges.enums.EdgeProperty; import org.onap.aai.exceptions.AAIException; import org.onap.aai.introspection.LoaderFactory; import org.onap.aai.introspection.ModelType; -import org.onap.aai.serialization.db.EdgeSerializer; -import org.onap.aai.introspection.exceptions.AAIUnknownObjectException; -import org.onap.aai.migration.*; -import org.onap.aai.edges.enums.AAIDirection; +import org.onap.aai.migration.MigrationDangerRating; +import org.onap.aai.migration.MigrationPriority; +import org.onap.aai.migration.Migrator; +import org.onap.aai.migration.Status; import org.onap.aai.serialization.db.DBSerializer; +import org.onap.aai.serialization.db.EdgeSerializer; import org.onap.aai.serialization.engines.TransactionalGraphEngine; import org.onap.aai.setup.SchemaVersion; import org.onap.aai.setup.SchemaVersions; import org.springframework.web.util.UriUtils; -import javax.ws.rs.core.UriBuilder; -import java.io.UnsupportedEncodingException; -import java.util.*; -import java.util.stream.Collectors; - //@Enabled @MigrationPriority(1000) @@ -99,12 +104,8 @@ public class UriMigration extends Migrator { logger.info(topLevelNodeType + " : " + parentSet.size()); try { this.verifyOrAddUri("", parentSet); - } catch (AAIUnknownObjectException e) { - e.printStackTrace(); - } catch (AAIException e) { - e.printStackTrace(); - } catch (UnsupportedEncodingException e) { - e.printStackTrace(); + } catch (UnsupportedEncodingException | AAIException e) { + logger.info("VerifyOrAddUri error: " + e.getMessage()); } }); logger.info("RUNTIME: " + (System.currentTimeMillis() - start)); |