/*- * ============LICENSE_START======================================================= * ONAP : APPC * ================================================================================ * Copyright (C) 2017 AT&T Intellectual Property. All rights reserved. * ================================================================================ * Copyright (C) 2017 Amdocs * ============================================================================= * 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. * * ECOMP is a trademark and service mark of AT&T Intellectual Property. * ============LICENSE_END========================================================= */ package org.onap.sdnc.dg.loader; import java.io.File; import java.util.ArrayList; import java.util.List; import org.apache.commons.io.FileUtils; import org.apache.commons.lang.StringUtils; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.onap.ccsdk.sli.core.sli.SvcLogicException; import org.onap.ccsdk.sli.core.sli.SvcLogicParser; import org.onap.ccsdk.sli.core.sli.SvcLogicStore; import org.onap.ccsdk.sli.core.sli.SvcLogicStoreFactory; public class DGXMLLoad { private final static Logger logger = LoggerFactory.getLogger(DGXMLLoad.class); private final SvcLogicStore store; public static String STRING_ENCODING = "utf-8"; public DGXMLLoad(String propfile) throws Exception { if (StringUtils.isBlank(propfile)) { throw new Exception(propfile + " Profile file is not defined"); } this.store = SvcLogicStoreFactory.getSvcLogicStore(propfile); } protected DGXMLLoad(SvcLogicStore store) throws Exception { this.store = store; } public void loadDGXMLFile(String dgXMLpath) throws SvcLogicException { if (dgXMLpath != null) { SvcLogicParser.load(dgXMLpath, this.store); } } private void loadDGXMLDir(String xmlPath) throws Exception { try { logger.info( "******************** Loading DG into Database *****************************"); List errors = new ArrayList(); if (this.store != null) { File xmlDir = new File(xmlPath); if (xmlDir != null && xmlDir.isDirectory()) { String[] extensions = new String[] {"xml", "XML"}; List files = (List) FileUtils.listFiles(xmlDir, extensions, true); for (File file : files) { logger.info("Loading DG XML file :" + file.getCanonicalPath()); try { SvcLogicParser.load(file.getCanonicalPath(), this.store); } catch (Exception e) { errors.add("Failed to load XML " + file.getCanonicalPath() + ", Exception : " + e.getMessage()); } } } else { throw new Exception(xmlPath + " is not a valid XML Directory"); } } else { throw new Exception("Failed to initialise SvcLogicStore"); } if (errors.size() > 0) { throw new Exception(errors.toString()); } } catch (Exception e) { logger.error(e.getMessage()); } } public static void main(String[] args) { try { String xmlPath = null; String propertyPath = null; if (args != null && args.length >= 2) { xmlPath = args[0]; propertyPath = args[1]; } else { throw new Exception( "Sufficient inputs for DGXMLLoadNActivate are missing "); } DGXMLLoad dgXMLLoadDB = new DGXMLLoad(propertyPath); dgXMLLoadDB.loadDGXMLDir(xmlPath); } catch (Exception e) { e.printStackTrace(); } finally { System.exit(1); } } }