so-etsi-nfvo/so-etsi-nfvo-ns-lcm/so-etsi-nfvo-ns-lcm-database-service/src/main/java/org/onap/so/etsi/nfvo/ns/lcm/database/service/DatabaseServiceProvider.java

   1 /*-
   2  * ============LICENSE_START=======================================================
   3  *  Copyright (C) 2020 Nordix Foundation.
   4  * ================================================================================
   5  * Licensed under the Apache License, Version 2.0 (the "License");
   6  * you may not use this file except in compliance with the License.
   7  * You may obtain a copy of the License at
   8  *
   9  *      http://www.apache.org/licenses/LICENSE-2.0
  10  *
  11  * Unless required by applicable law or agreed to in writing, software
  12  * distributed under the License is distributed on an "AS IS" BASIS,
  13  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  14  * See the License for the specific language governing permissions and
  15  * limitations under the License.
  16  *
  17  * SPDX-License-Identifier: Apache-2.0
  18  * ============LICENSE_END=========================================================
  19  */
  20 package org.onap.so.etsi.nfvo.ns.lcm.database.service;
  21
  22 import java.util.List;
  23 import java.util.Optional;
  24 import org.onap.so.etsi.nfvo.ns.lcm.database.beans.NfvoJob;
  25 import org.onap.so.etsi.nfvo.ns.lcm.database.beans.NfvoNfInst;
  26 import org.onap.so.etsi.nfvo.ns.lcm.database.beans.NfvoNsInst;
  27 import org.onap.so.etsi.nfvo.ns.lcm.database.beans.NsLcmOpOcc;
  28 import org.onap.so.etsi.nfvo.ns.lcm.database.beans.OperationStateEnum;
  29 import org.onap.so.etsi.nfvo.ns.lcm.database.beans.State;
  30 import org.onap.so.etsi.nfvo.ns.lcm.database.repository.NSLcmOpOccRepository;
  31 import org.onap.so.etsi.nfvo.ns.lcm.database.repository.NfvoJobRepository;
  32 import org.onap.so.etsi.nfvo.ns.lcm.database.repository.NfvoNfInstRepository;
  33 import org.onap.so.etsi.nfvo.ns.lcm.database.repository.NfvoNsInstRepository;
  34 import org.slf4j.Logger;
  35 import org.slf4j.LoggerFactory;
  36 import org.springframework.beans.factory.annotation.Autowired;
  37 import org.springframework.stereotype.Service;
  38 import org.springframework.transaction.annotation.Isolation;
  39 import org.springframework.transaction.annotation.Propagation;
  40 import org.springframework.transaction.annotation.Transactional;
  41
  42 /**
  43  * @author Waqas Ikram (waqas.ikram@est.tech)
  44  *
  45  */
  46
  47 @Service
  48 public class DatabaseServiceProvider {
  49     private static final Logger logger = LoggerFactory.getLogger(DatabaseServiceProvider.class);
  50
  51     private final NfvoJobRepository nfvoJobRepository;
  52
  53     private final NfvoNsInstRepository nfvoNsInstRepository;
  54
  55     private final NfvoNfInstRepository nfvoNfInstRepository;
  56
  57     private final NSLcmOpOccRepository nsLcmOpOccRepository;
  58
  59     @Autowired
  60     public DatabaseServiceProvider(final NfvoJobRepository nfvoJobRepository,
  61             final NfvoNsInstRepository nfvoNsInstRepository, final NfvoNfInstRepository nfvoNfInstRepository,
  62             final NSLcmOpOccRepository nsLcmOpOccRepository) {
  63         this.nfvoJobRepository = nfvoJobRepository;
  64         this.nfvoNsInstRepository = nfvoNsInstRepository;
  65         this.nfvoNfInstRepository = nfvoNfInstRepository;
  66         this.nsLcmOpOccRepository = nsLcmOpOccRepository;
  67     }
  68
  69     public boolean addJob(final NfvoJob job) {
  70         logger.info("Adding NfvoJob: {} to database", job);
  71         return nfvoJobRepository.saveAndFlush(job) != null;
  72     }
  73
  74     public Optional<NfvoJob> getJob(final String jobId) {
  75         logger.info("Querying database for NfvoJob using jobId: {}", jobId);
  76         return nfvoJobRepository.findById(jobId);
  77     }
  78
  79     @Transactional(propagation = Propagation.REQUIRES_NEW, isolation = Isolation.REPEATABLE_READ, readOnly = true)
  80     public Optional<NfvoJob> getRefreshedJob(final String jobId) {
  81         logger.info("Querying database for NfvoJob using jobId: {}", jobId);
  82         final Optional<NfvoJob> optional = getJob(jobId);
  83         if (optional.isPresent()) {
  84             nfvoJobRepository.refreshEntity(optional.get());
  85         }
  86         return optional;
  87     }
  88
  89     public Optional<NfvoJob> getJobByResourceId(final String resourceId) {
  90         logger.info("Querying database for NfvoJob using resourceId: {}", resourceId);
  91         return nfvoJobRepository.findByResourceId(resourceId);
  92     }
  93
  94     public boolean isNsInstExists(final String name) {
  95         logger.info("Checking if NfvoNsInst entry exists in database using name: {}", name);
  96         return nfvoNsInstRepository.existsNfvoNsInstByName(name);
  97     }
  98
  99     public boolean isNsInstExists(final String nsInstId, final String nfName) {
 100         logger.info("Checking if NfvoNfInst entry exists in database using nsInstId: {} and nfName: {}", nsInstId,
 101                 nfName);
 102         return nfvoNfInstRepository.findByNsInstNsInstIdAndName(nsInstId, nfName).isEmpty();
 103     }
 104
 105     public boolean saveNfvoNsInst(final NfvoNsInst nfvoNsInst) {
 106         logger.info("Saving NfvoNsInst: {} to database", nfvoNsInst);
 107         return nfvoNsInstRepository.saveAndFlush(nfvoNsInst) != null;
 108     }
 109
 110     @Transactional(propagation = Propagation.REQUIRES_NEW)
 111     public boolean updateNsInstState(final String nsInstId, final State state) {
 112         logger.info("Updating NfvoNsInst: {} State to {}", nsInstId, state);
 113         return nfvoNsInstRepository.updateNsInstState(nsInstId, state) > 0;
 114     }
 115
 116     public Optional<NfvoNsInst> getNfvoNsInst(final String nsInstId) {
 117         logger.info("Querying database for NfvoNsInst using nsInstId: {}", nsInstId);
 118         return nfvoNsInstRepository.findById(nsInstId);
 119     }
 120
 121     public Optional<NfvoNsInst> getNfvoNsInstByName(final String name) {
 122         logger.info("Querying database for NfvoNsInst using name: {}", name);
 123         return nfvoNsInstRepository.findByName(name);
 124     }
 125
 126     public boolean saveNfvoNfInst(final NfvoNfInst nfvoNfInst) {
 127         logger.info("Saving NfvoNfInst: {} to database", nfvoNfInst);
 128         return nfvoNfInstRepository.saveAndFlush(nfvoNfInst) != null;
 129     }
 130
 131     @Transactional(propagation = Propagation.REQUIRES_NEW)
 132     public boolean updateNfInstState(final String nfInstId, final State state) {
 133         logger.info("Updating NfvoNfInst: {} State to {}", nfInstId, state);
 134         return nfvoNfInstRepository.updateNfInstState(nfInstId, state) > 0;
 135     }
 136
 137     public List<NfvoNfInst> getNfvoNfInstByNsInstId(final String nsInstId) {
 138         logger.info("Querying database for NfvoNfInst using nsInstId: {}", nsInstId);
 139         return nfvoNfInstRepository.findByNsInstNsInstId(nsInstId);
 140     }
 141
 142     public List<NfvoNfInst> getNfvoNfInstByNsInstIdAndNfName(final String nsInstId, final String name) {
 143         logger.info("Querying database for NfvoNfInst using nsInstId: {} and name : {} ", nsInstId, name);
 144         return nfvoNfInstRepository.findByNsInstNsInstIdAndName(nsInstId, name);
 145     }
 146
 147     public Optional<NfvoNfInst> getNfvoNfInst(final String nfInstId) {
 148         logger.info("Querying database for NfvoNfInst using nfInstId: {}", nfInstId);
 149         return nfvoNfInstRepository.findByNfInstId(nfInstId);
 150     }
 151
 152     public boolean isNfInstExists(final String nfInstId) {
 153         logger.info("Checking if NfvoNfInst entry exists in database using nfInstId: {}", nfInstId);
 154         return nfvoNfInstRepository.findByNfInstId(nfInstId).isPresent();
 155     }
 156
 157     @Transactional(propagation = Propagation.REQUIRES_NEW)
 158     public void deleteNfvoNfInst(final String nfInstId) {
 159         logger.info("Deleting NfvoNfInst with nfInstId: {} from database", nfInstId);
 160         nfvoNfInstRepository.deleteNfvoNfInstUsingNfInstId(nfInstId);
 161     }
 162
 163     public boolean addNSLcmOpOcc(final NsLcmOpOcc nsLcmOpOcc) {
 164         logger.info("Adding NSLcmOpOcc: {} to database", nsLcmOpOcc);
 165         return nsLcmOpOccRepository.saveAndFlush(nsLcmOpOcc) != null;
 166     }
 167
 168     @Transactional(propagation = Propagation.REQUIRES_NEW)
 169     public boolean updateNsLcmOpOccOperationState(final String id, final OperationStateEnum operationState) {
 170         logger.info("Updating NsLcmOpOcc: {} operationState to {}", id, operationState);
 171         return nsLcmOpOccRepository.updateNsLcmOpOccOperationState(id, operationState) > 0;
 172     }
 173
 174     public Optional<NsLcmOpOcc> getNsLcmOpOcc(final String id) {
 175         logger.info("Querying database for NsLcmOpOcc using id: {}", id);
 176         return nsLcmOpOccRepository.findById(id);
 177     }
 178
 179     public void deleteNfvoNsInst(final String nsInstId) {
 180         logger.info("Deleting NfvoNsInst with nsInstId: {}", nsInstId);
 181         nfvoNsInstRepository.deleteById(nsInstId);
 182     }
 183 }