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
9 * http://www.apache.org/licenses/LICENSE-2.0
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.
17 * SPDX-License-Identifier: Apache-2.0
18 * ============LICENSE_END=========================================================
20 package org.onap.so.etsi.nfvo.ns.lcm.database.service;
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;
43 * @author Waqas Ikram (waqas.ikram@est.tech)
48 public class DatabaseServiceProvider {
49 private static final Logger logger = LoggerFactory.getLogger(DatabaseServiceProvider.class);
51 private final NfvoJobRepository nfvoJobRepository;
53 private final NfvoNsInstRepository nfvoNsInstRepository;
55 private final NfvoNfInstRepository nfvoNfInstRepository;
57 private final NSLcmOpOccRepository nsLcmOpOccRepository;
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;
69 public boolean addJob(final NfvoJob job) {
70 logger.info("Adding NfvoJob: {} to database", job);
71 return nfvoJobRepository.saveAndFlush(job) != null;
74 public Optional<NfvoJob> getJob(final String jobId) {
75 logger.info("Querying database for NfvoJob using jobId: {}", jobId);
76 return nfvoJobRepository.findById(jobId);
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());
89 public Optional<NfvoJob> getJobByResourceId(final String resourceId) {
90 logger.info("Querying database for NfvoJob using resourceId: {}", resourceId);
91 return nfvoJobRepository.findByResourceId(resourceId);
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);
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,
102 return nfvoNfInstRepository.findByNsInstNsInstIdAndName(nsInstId, nfName).isEmpty();
105 public boolean saveNfvoNsInst(final NfvoNsInst nfvoNsInst) {
106 logger.info("Saving NfvoNsInst: {} to database", nfvoNsInst);
107 return nfvoNsInstRepository.saveAndFlush(nfvoNsInst) != null;
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;
116 public Optional<NfvoNsInst> getNfvoNsInst(final String nsInstId) {
117 logger.info("Querying database for NfvoNsInst using nsInstId: {}", nsInstId);
118 return nfvoNsInstRepository.findById(nsInstId);
121 public Optional<NfvoNsInst> getNfvoNsInstByName(final String name) {
122 logger.info("Querying database for NfvoNsInst using name: {}", name);
123 return nfvoNsInstRepository.findByName(name);
126 public boolean saveNfvoNfInst(final NfvoNfInst nfvoNfInst) {
127 logger.info("Saving NfvoNfInst: {} to database", nfvoNfInst);
128 return nfvoNfInstRepository.saveAndFlush(nfvoNfInst) != null;
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;
137 public List<NfvoNfInst> getNfvoNfInstByNsInstId(final String nsInstId) {
138 logger.info("Querying database for NfvoNfInst using nsInstId: {}", nsInstId);
139 return nfvoNfInstRepository.findByNsInstNsInstId(nsInstId);
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);
147 public Optional<NfvoNfInst> getNfvoNfInst(final String nfInstId) {
148 logger.info("Querying database for NfvoNfInst using nfInstId: {}", nfInstId);
149 return nfvoNfInstRepository.findByNfInstId(nfInstId);
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();
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);
163 public boolean addNSLcmOpOcc(final NsLcmOpOcc nsLcmOpOcc) {
164 logger.info("Adding NSLcmOpOcc: {} to database", nsLcmOpOcc);
165 return nsLcmOpOccRepository.saveAndFlush(nsLcmOpOcc) != null;
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;
174 public Optional<NsLcmOpOcc> getNsLcmOpOcc(final String id) {
175 logger.info("Querying database for NsLcmOpOcc using id: {}", id);
176 return nsLcmOpOccRepository.findById(id);
179 public void deleteNfvoNsInst(final String nsInstId) {
180 logger.info("Deleting NfvoNsInst with nsInstId: {}", nsInstId);
181 nfvoNsInstRepository.deleteById(nsInstId);