diff options
author | 2018-01-19 10:43:43 -0500 | |
---|---|---|
committer | 2018-01-19 10:55:44 -0500 | |
commit | f758bb0ae798a53eee005b3e6e4a115f84b4ae19 (patch) | |
tree | e3ddcb8de4959c85663f937caf14b4cfc73af76b /src/main/java/org/openecomp/dcae/inventory/daos | |
parent | 929c29a9c6a9a7e91fe01d18e353cdb6a29bc3d9 (diff) |
Change package from openecomp to onap
Change-Id: I2a79eb123e5fbb6a6c2f0e72030d6781fbbd7513
Issue-ID: DCAEGEN2-225
Signed-off-by: Michael Hwang <mhwang@research.att.com>
Diffstat (limited to 'src/main/java/org/openecomp/dcae/inventory/daos')
7 files changed, 0 insertions, 646 deletions
diff --git a/src/main/java/org/openecomp/dcae/inventory/daos/DCAEServiceComponentsDAO.java b/src/main/java/org/openecomp/dcae/inventory/daos/DCAEServiceComponentsDAO.java deleted file mode 100644 index 9a674c9..0000000 --- a/src/main/java/org/openecomp/dcae/inventory/daos/DCAEServiceComponentsDAO.java +++ /dev/null @@ -1,62 +0,0 @@ -/*- - * ============LICENSE_START======================================================= - * dcae-inventory - * ================================================================================ - * Copyright (C) 2017 AT&T Intellectual Property. All rights reserved. - * ================================================================================ - * 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. - * ============LICENSE_END========================================================= - */ - -package org.openecomp.dcae.inventory.daos; - -import org.openecomp.dcae.inventory.dbthings.mappers.DCAEServiceComponentObjectMapper; -import org.openecomp.dcae.inventory.dbthings.models.DCAEServiceComponentObject; -import org.skife.jdbi.v2.sqlobject.Bind; -import org.skife.jdbi.v2.sqlobject.BindBean; -import org.skife.jdbi.v2.sqlobject.SqlQuery; -import org.skife.jdbi.v2.sqlobject.SqlUpdate; -import org.skife.jdbi.v2.sqlobject.customizers.Mapper; - -import java.util.List; - -/** - * Created by mhwang on 4/19/16. - */ -public interface DCAEServiceComponentsDAO extends InventoryDAO { - - @SqlQuery("select exists (select * from information_schema.tables where table_name = \'dcae_service_components\')") - Boolean checkIfTableExists(); - - @SqlUpdate("create table dcae_service_components (component_id varchar not null primary key, component_type varchar not null, " + - "component_source varchar not null, shareable integer default 0, created timestamp not null, modified timestamp not null)") - void createTable(); - - @SqlUpdate("insert into dcae_service_components (component_id, component_type, component_source, shareable, created, modified) " + - "values (:componentId, :componentType, :componentSource, :shareable, :created, :modified)") - void insert(@BindBean DCAEServiceComponentObject componentObject); - - @SqlUpdate("update dcae_service_components set component_type = :componentType, component_source = :componentSource, " + - "shareable = :shareable, modified = :modified where component_id = :componentId") - void update(@BindBean DCAEServiceComponentObject componentObject); - - @Mapper(DCAEServiceComponentObjectMapper.class) - @SqlQuery("select c.* from dcae_services_components_maps m join dcae_service_components c " + - "on m.component_id = c.component_id where m.service_id = :it") - List<DCAEServiceComponentObject> getByServiceId(@Bind String serviceId); - - @Mapper(DCAEServiceComponentObjectMapper.class) - @SqlQuery("select c.* from dcae_service_components c where c.component_id = :it") - DCAEServiceComponentObject getByComponentId(@Bind String componentId); - -} diff --git a/src/main/java/org/openecomp/dcae/inventory/daos/DCAEServiceTransactionDAO.java b/src/main/java/org/openecomp/dcae/inventory/daos/DCAEServiceTransactionDAO.java deleted file mode 100644 index c9d6dc8..0000000 --- a/src/main/java/org/openecomp/dcae/inventory/daos/DCAEServiceTransactionDAO.java +++ /dev/null @@ -1,158 +0,0 @@ -/*- - * ============LICENSE_START======================================================= - * dcae-inventory - * ================================================================================ - * Copyright (C) 2017 AT&T Intellectual Property. All rights reserved. - * ================================================================================ - * 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. - * ============LICENSE_END========================================================= - */ - -package org.openecomp.dcae.inventory.daos; - -import org.openecomp.dcae.inventory.dbthings.models.DCAEServiceComponentObject; -import org.openecomp.dcae.inventory.dbthings.models.DCAEServiceObject; -import org.joda.time.DateTime; -import org.skife.jdbi.v2.sqlobject.CreateSqlObject; -import org.skife.jdbi.v2.sqlobject.Transaction; - -import java.util.ArrayList; -import java.util.List; - -/** - * This is based-off of this blog post. - * http://manikandan-k.github.io/2015/05/10/Transactions_in_jdbi.html - * - * Created by mhwang on 4/21/16. - */ -public abstract class DCAEServiceTransactionDAO { - - public static class DCAEServiceTransactionContext { - - private final String serviceId; - private final DateTime modified; - private DCAEServiceObject serviceObjectToInsert; - private DCAEServiceObject serviceObjectToUpdate; - private List<DCAEServiceComponentObject> componentObjectsToInsert; - private List<DCAEServiceComponentObject> componentObjectsToUpdate; - private List<String> mappingsToInsert; - private List<String> mappingsToDelete; - - public String getServiceId() { - return serviceId; - } - - public DateTime getModified() { - return modified; - } - - public DCAEServiceObject getServiceObjectToInsert() { - return serviceObjectToInsert; - } - - public void setServiceObjectToInsert(DCAEServiceObject serviceObjectToInsert) { - this.serviceObjectToInsert = serviceObjectToInsert; - } - - public DCAEServiceObject getServiceObjectToUpdate() { - return serviceObjectToUpdate; - } - - public void setServiceObjectToUpdate(DCAEServiceObject serviceObjectToUpdate) { - this.serviceObjectToUpdate = serviceObjectToUpdate; - } - - public List<DCAEServiceComponentObject> getComponentObjectsToInsert() { - return componentObjectsToInsert; - } - - public List<DCAEServiceComponentObject> addComponentObjectToInsert(DCAEServiceComponentObject componentObject) { - this.componentObjectsToInsert.add(componentObject); - return this.componentObjectsToInsert; - } - - public List<DCAEServiceComponentObject> getComponentObjectsToUpdate() { - return componentObjectsToUpdate; - } - - public List<DCAEServiceComponentObject> addComponentObjectToUpdate(DCAEServiceComponentObject componentObject) { - this.componentObjectsToUpdate.add(componentObject); - return this.componentObjectsToUpdate; - } - - public List<String> getMappingsToInsert() { - return mappingsToInsert; - } - - public List<String> addMappingsToInsert(String componentId) { - this.mappingsToInsert.add(componentId); - return this.mappingsToInsert; - } - - public List<String> getMappingsToDelete() { - return mappingsToDelete; - } - - public List<String> addMappingsToDelete(String componentId) { - this.mappingsToDelete.add(componentId); - return this.mappingsToDelete; - } - - public DCAEServiceTransactionContext(String serviceId, DateTime modified) { - this.serviceId = serviceId; - this.modified = modified; - this.componentObjectsToInsert = new ArrayList<>(); - this.componentObjectsToUpdate = new ArrayList<>(); - this.mappingsToInsert = new ArrayList<>(); - this.mappingsToDelete = new ArrayList<>(); - } - - } - - @CreateSqlObject - abstract public DCAEServicesDAO getServicesDAO(); - - @CreateSqlObject - abstract public DCAEServicesComponentsMapsDAO getServicesComponentsMappingDAO(); - - @CreateSqlObject - abstract public DCAEServiceComponentsDAO getComponentsDAO(); - - @Transaction - public void insert(DCAEServiceTransactionContext context) { - if (context.getServiceObjectToInsert() != null) { - this.getServicesDAO().insert(context.getServiceObjectToInsert()); - } - - if (context.getServiceObjectToUpdate() != null) { - this.getServicesDAO().update(context.getServiceObjectToUpdate()); - } - - for (DCAEServiceComponentObject sco : context.getComponentObjectsToInsert()) { - this.getComponentsDAO().insert(sco); - } - - for (DCAEServiceComponentObject sco : context.getComponentObjectsToUpdate()) { - this.getComponentsDAO().update(sco); - } - - for (String componentId : context.getMappingsToInsert()) { - this.getServicesComponentsMappingDAO().insert(context.getServiceId(), componentId, context.getModified()); - } - - for (String componentId : context.getMappingsToDelete()) { - this.getServicesComponentsMappingDAO().delete(context.serviceId, componentId); - } - } - -} diff --git a/src/main/java/org/openecomp/dcae/inventory/daos/DCAEServiceTypesDAO.java b/src/main/java/org/openecomp/dcae/inventory/daos/DCAEServiceTypesDAO.java deleted file mode 100644 index 50b79b2..0000000 --- a/src/main/java/org/openecomp/dcae/inventory/daos/DCAEServiceTypesDAO.java +++ /dev/null @@ -1,90 +0,0 @@ -/*- - * ============LICENSE_START======================================================= - * dcae-inventory - * ================================================================================ - * Copyright (C) 2017 AT&T Intellectual Property. All rights reserved. - * ================================================================================ - * 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. - * ============LICENSE_END========================================================= - */ - -package org.openecomp.dcae.inventory.daos; - -import org.openecomp.dcae.inventory.dbthings.mappers.DCAEServiceTypeObjectMapper; - -import org.openecomp.dcae.inventory.dbthings.models.DCAEServiceTypeObject; -import io.swagger.model.DCAEServiceTypeRequest; -import org.skife.jdbi.v2.sqlobject.Bind; -import org.skife.jdbi.v2.sqlobject.BindBean; -import org.skife.jdbi.v2.sqlobject.SqlQuery; -import org.skife.jdbi.v2.sqlobject.SqlUpdate; -import org.skife.jdbi.v2.sqlobject.customizers.Mapper; - -/** - * DCAE service type records are no longer treated immutable because versioning is handled by clients - * to DCAE inventory i.e. ASDC. There is field "deactivated" that determines if a service type is active. - * Inserts and updates automatically activates a service type while deleting deactivates a service type. - * - * Created by mhwang on 4/19/16. - */ -public interface DCAEServiceTypesDAO extends InventoryDAO { - - @SqlQuery("select exists (select * from information_schema.tables where table_name = \'dcae_service_types\')") - Boolean checkIfTableExists(); - - /** - * Note that service_ids and service_locations are nullable fields. This might not be the right decision but because - * the resource model allows for nulls, thought it should consistent. - */ - @SqlUpdate("create table dcae_service_types (type_id varchar not null, type_version integer not null, " + - "type_name varchar not null, owner varchar not null, blueprint_template text not null, " + - "vnf_types varchar[] not null, service_ids varchar[], service_locations varchar[], " + - "asdc_service_id varchar, asdc_resource_id varchar, " + - "created timestamp not null, deactivated timestamp, constraint pk_type_created primary key (type_id))") - void createTable(); - - // REVIEW: asdcServiceId and asdcResourceId is implicitly part of the unique key and thus shouldn't be updated. - @SqlUpdate("insert into dcae_service_types(type_id, type_version, type_name, owner, blueprint_template, vnf_types, " + - "service_ids, service_locations, asdc_service_id, asdc_resource_id, created, deactivated) " + - "values (:typeId, :typeVersion, :typeName, :owner, :blueprintTemplate, :vnfTypes, :serviceIds, " + - ":serviceLocations, :asdcServiceId, :asdcResourceId, :created, null)") - void insert(@BindBean DCAEServiceTypeObject serviceObject); - - @SqlUpdate("update dcae_service_types set " + - "owner = :owner, blueprint_template = :blueprintTemplate, vnf_types = :vnfTypes, " + - "service_ids = :serviceIds, service_locations = :serviceLocations, created = :created, " + - "deactivated = null where type_id = :typeId") - void update(@BindBean DCAEServiceTypeObject serviceObject); - - @SqlUpdate("update dcae_service_types set deactivated = (now() at time zone 'utc') where type_id = :typeId") - void deactivateExisting(@Bind("typeId") String typeId); - - @Mapper(DCAEServiceTypeObjectMapper.class) - @SqlQuery("select * from dcae_service_types where type_id = :it") - DCAEServiceTypeObject getByTypeId(@Bind String typeId); - - @Mapper(DCAEServiceTypeObjectMapper.class) - @SqlQuery("select * from dcae_service_types where deactivated is null and type_id = :it") - DCAEServiceTypeObject getByTypeIdActiveOnly(@Bind String typeId); - - @Mapper(DCAEServiceTypeObjectMapper.class) - @SqlQuery("select * from dcae_service_types where type_name = :typeName and type_version = :typeVersion " + - "and asdc_service_id is null and asdc_resource_id is null") - DCAEServiceTypeObject getByRequestFromNotASDC(@BindBean DCAEServiceTypeRequest serviceTypeObject); - - @Mapper(DCAEServiceTypeObjectMapper.class) - @SqlQuery("select * from dcae_service_types where type_name = :typeName and type_version = :typeVersion " + - "and asdc_service_id = :asdcServiceId and asdc_resource_id = :asdcResourceId") - DCAEServiceTypeObject getByRequestFromASDC(@BindBean DCAEServiceTypeRequest serviceTypeObject); - -} diff --git a/src/main/java/org/openecomp/dcae/inventory/daos/DCAEServicesComponentsMapsDAO.java b/src/main/java/org/openecomp/dcae/inventory/daos/DCAEServicesComponentsMapsDAO.java deleted file mode 100644 index 5bfd3cd..0000000 --- a/src/main/java/org/openecomp/dcae/inventory/daos/DCAEServicesComponentsMapsDAO.java +++ /dev/null @@ -1,50 +0,0 @@ -/*- - * ============LICENSE_START======================================================= - * dcae-inventory - * ================================================================================ - * Copyright (C) 2017 AT&T Intellectual Property. All rights reserved. - * ================================================================================ - * 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. - * ============LICENSE_END========================================================= - */ - -package org.openecomp.dcae.inventory.daos; - -import org.joda.time.DateTime; -import org.skife.jdbi.v2.sqlobject.Bind; -import org.skife.jdbi.v2.sqlobject.SqlQuery; -import org.skife.jdbi.v2.sqlobject.SqlUpdate; - -/** - * This class manages the joining table called "dcae_services_components_maps" which maps the many-to-many relationship - * between DCAE services and DCAE service components. - * - * Created by mhwang on 4/19/16. - */ -public interface DCAEServicesComponentsMapsDAO extends InventoryDAO { - - @SqlQuery("select exists (select * from information_schema.tables where table_name = \'dcae_services_components_maps\')") - Boolean checkIfTableExists(); - - @SqlUpdate("create table dcae_services_components_maps (service_id varchar not null references dcae_services (service_id), " + - "component_id varchar not null references dcae_service_components (component_id), " + - "created timestamp not null, primary key (service_id, component_id))") - void createTable(); - - @SqlUpdate("insert into dcae_services_components_maps (service_id, component_id, created) values (:serviceId, :componentId, :created)") - void insert(@Bind("serviceId") String serviceId, @Bind("componentId") String componentId, @Bind("created") DateTime created); - - @SqlUpdate("delete from dcae_services_components_maps where service_id = :serviceId and component_id = :componentId") - void delete(@Bind("serviceId") String serviceId, @Bind("componentId") String componentId); - -} diff --git a/src/main/java/org/openecomp/dcae/inventory/daos/DCAEServicesDAO.java b/src/main/java/org/openecomp/dcae/inventory/daos/DCAEServicesDAO.java deleted file mode 100644 index 9200677..0000000 --- a/src/main/java/org/openecomp/dcae/inventory/daos/DCAEServicesDAO.java +++ /dev/null @@ -1,76 +0,0 @@ -/*- - * ============LICENSE_START======================================================= - * dcae-inventory - * ================================================================================ - * Copyright (C) 2017 AT&T Intellectual Property. All rights reserved. - * ================================================================================ - * 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. - * ============LICENSE_END========================================================= - */ - -package org.openecomp.dcae.inventory.daos; - -import org.openecomp.dcae.inventory.dbthings.mappers.DCAEServiceObjectMapper; -import org.openecomp.dcae.inventory.dbthings.models.DCAEServiceObject; -import org.joda.time.DateTime; -import org.skife.jdbi.v2.sqlobject.Bind; -import org.skife.jdbi.v2.sqlobject.BindBean; -import org.skife.jdbi.v2.sqlobject.SqlQuery; -import org.skife.jdbi.v2.sqlobject.SqlUpdate; -import org.skife.jdbi.v2.sqlobject.customizers.Mapper; -import org.skife.jdbi.v2.util.IntegerMapper; - - -/** - * Created by mhwang on 4/19/16. - */ -public interface DCAEServicesDAO extends InventoryDAO { - - @SqlQuery("select exists (select * from information_schema.tables where table_name = \'dcae_services\')") - Boolean checkIfTableExists(); - - @SqlUpdate("create table dcae_services (service_id varchar not null primary key, type_id varchar not null, " + - "vnf_id varchar not null, vnf_type varchar not null, vnf_location varchar not null, deployment_ref varchar, " + - "created timestamp not null, modified timestamp not null, status varchar not null)") - void createTable(); - - @SqlUpdate("insert into dcae_services(service_id, type_id, vnf_id, vnf_type, vnf_location, deployment_ref, " + - "created, modified, status) values (:serviceId, :typeId, :vnfId, :vnfType, :vnfLocation, :deploymentRef, " + - ":created, :modified, :status)") - void insert(@BindBean DCAEServiceObject serviceObject); - - @SqlUpdate("update dcae_services set type_id = :typeId, vnf_id = :vnfId, vnf_type = :vnfType, " + - "vnf_location = :vnfLocation, deployment_ref = :deploymentRef, modified = :modified, status = :status " + - "where service_id = :serviceId") - void update(@BindBean DCAEServiceObject serviceObject); - - @Mapper(DCAEServiceObjectMapper.class) - @SqlQuery("select * from dcae_services where status = :status and service_id = :serviceId") - DCAEServiceObject getByServiceId(@Bind("status") DCAEServiceObject.DCAEServiceStatus status, @Bind("serviceId") String serviceId); - - @Mapper(DCAEServiceObjectMapper.class) - @SqlQuery("select * from dcae_services where service_id = :serviceId") - DCAEServiceObject getByServiceId(@Bind("serviceId") String serviceId); - - @SqlUpdate("update dcae_services set modified = :modified, status = :status where service_id = :serviceId") - void updateStatusByServiceId(@Bind("modified") DateTime modified, - @Bind("status") DCAEServiceObject.DCAEServiceStatus status, - @Bind("serviceId") String serviceId); - - @Mapper(IntegerMapper.class) - @SqlQuery("select count(1) from dcae_services where status = :status and type_id = :typeId") - Integer countByType(@Bind("status") DCAEServiceObject.DCAEServiceStatus status, @Bind("typeId") String typeId); - -} - - diff --git a/src/main/java/org/openecomp/dcae/inventory/daos/InventoryDAO.java b/src/main/java/org/openecomp/dcae/inventory/daos/InventoryDAO.java deleted file mode 100644 index ef2fb8d..0000000 --- a/src/main/java/org/openecomp/dcae/inventory/daos/InventoryDAO.java +++ /dev/null @@ -1,29 +0,0 @@ -/*- - * ============LICENSE_START======================================================= - * dcae-inventory - * ================================================================================ - * Copyright (C) 2017 AT&T Intellectual Property. All rights reserved. - * ================================================================================ - * 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. - * ============LICENSE_END========================================================= - */ - -package org.openecomp.dcae.inventory.daos; - -/** - * Created by mhwang on 4/19/16. - */ -public interface InventoryDAO { - Boolean checkIfTableExists(); - void createTable(); -} diff --git a/src/main/java/org/openecomp/dcae/inventory/daos/InventoryDAOManager.java b/src/main/java/org/openecomp/dcae/inventory/daos/InventoryDAOManager.java deleted file mode 100644 index 77611b5..0000000 --- a/src/main/java/org/openecomp/dcae/inventory/daos/InventoryDAOManager.java +++ /dev/null @@ -1,181 +0,0 @@ -/*- - * ============LICENSE_START======================================================= - * dcae-inventory - * ================================================================================ - * Copyright (C) 2017 AT&T Intellectual Property. All rights reserved. - * ================================================================================ - * 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. - * ============LICENSE_END========================================================= - */ - -package org.openecomp.dcae.inventory.daos; - -import org.openecomp.dcae.inventory.InventoryConfiguration; -import org.openecomp.dcae.inventory.dbthings.StringListArgument; -import io.dropwizard.jdbi.DBIFactory; -import io.dropwizard.setup.Environment; -import org.skife.jdbi.v2.DBI; -import org.skife.jdbi.v2.Handle; -import org.skife.jdbi.v2.util.BooleanMapper; -import org.slf4j.Logger; -import org.slf4j.LoggerFactory; - -import java.util.Arrays; -import java.util.List; - -/** - * Reluctantly made this into a singleton in order to have access to the DAOs in the request handling code. Didn't - * want to change the interface on the handlers because they are generated by Swagger and I wanted to flexibility - * to swap in changes easily. This meant sacrificing dependency injection which is preferred. - * - * Created by mhwang on 4/19/16. - */ -public final class InventoryDAOManager { - - private static InventoryDAOManager instance; - - public static InventoryDAOManager getInstance() { - if (instance == null) { - instance = new InventoryDAOManager(); - } - - return instance; - } - - public static class InventoryDAOManagerSetupException extends RuntimeException { - - public InventoryDAOManagerSetupException(String message) { - super(message); - } - - } - - private final static Logger LOG = LoggerFactory.getLogger(InventoryDAOManager.class); - // WATCH! Table creation order matters where mapping tables refer to other tables for foreign keys. - private final static List<Class> DAO_CLASSES = Arrays.asList(DCAEServiceTypesDAO.class, DCAEServicesDAO.class, - DCAEServiceComponentsDAO.class, DCAEServicesComponentsMapsDAO.class); - - private DBI jdbi; - private Environment environment; - private InventoryConfiguration configuration; - - private InventoryDAOManager() { - } - - /** - * Setup the manager - * - * Saving the Dropwizard environment and configuration which are used to construct the DBI object in a later - * initialize call. This method can only be called once to be safe and to avoid runtime problems that could be - * caused if the global instance of this class gets into a weird state (Couldn't use Java's `final` qualifier). - * - * @param environment - * @param inventoryConfiguration - */ - public void setup(Environment environment, InventoryConfiguration inventoryConfiguration) { - if (this.environment == null && this.configuration == null) { - this.environment = environment; - this.configuration = inventoryConfiguration; - } else { - throw new InventoryDAOManagerSetupException("InventoryDAOManager setup can only be called once."); - } - } - - /** - * Initialize the manager - * - * Create the underlying validated DBI object that is used to manage database connections - */ - public void initialize() { - final DBIFactory factory = new DBIFactory(); - final DBI jdbi = factory.build(this.environment, this.configuration.getDataSourceFactory(), "dcae-database"); - jdbi.registerArgumentFactory(new StringListArgument()); - - for (Class<? extends InventoryDAO> daoClass : DAO_CLASSES) { - final InventoryDAO dao = jdbi.onDemand(daoClass); - - if (dao.checkIfTableExists()) { - LOG.info(String.format("Sql table exists: %s", daoClass.getSimpleName())); - } else { - dao.createTable(); - LOG.info(String.format("Sql table created: %s", daoClass.getSimpleName())); - } - } - - // CREATE VIEWS - // TODO: This doesn't belong here and is not consistent with the above approach. Make it better. - try (Handle jdbiHandle = jdbi.open()) { - String viewName = "dcae_service_types_latest"; - String checkQuery = String.format("select exists (select * from information_schema.tables where table_name = '%s')", - viewName); - - if (jdbiHandle.createQuery(checkQuery).map(BooleanMapper.FIRST).first()) { - LOG.info(String.format("Sql view exists: %s", viewName)); - } else { - StringBuilder sb = new StringBuilder(String.format("create view %s as ", viewName)); - sb.append("select s.* from dcae_service_types s "); - sb.append("join (select type_name, max(type_version) as max_version from dcae_service_types group by type_name) as f "); - sb.append("on s.type_name = f.type_name and s.type_version = f.max_version"); - - jdbiHandle.execute(sb.toString()); - LOG.info(String.format("Sql view created: %s", viewName)); - } - } catch (Exception e) { - throw new RuntimeException("", e); - } - - // Do this assignment at the end after performing table checks to ensure that connection is good - this.jdbi = jdbi; - } - - private InventoryDAO getDAO(Class<? extends InventoryDAO> klass) { - if (jdbi == null) { - throw new RuntimeException("InventoryDAOManager has not been initialized!"); - } - - // Using this approach to constructing the DAO, the client is not responsible for closing the handle. - // http://jdbi.org/sql_object_overview/ - // > In this case we do not need to (and in fact shouldn’t) ever take action to close the handle the sql object uses. - return jdbi.onDemand(klass); - } - - public DCAEServicesDAO getDCAEServicesDAO() { - return (DCAEServicesDAO) this.getDAO(DCAEServicesDAO.class); - } - - public DCAEServiceComponentsDAO getDCAEServiceComponentsDAO() { - return (DCAEServiceComponentsDAO) this.getDAO(DCAEServiceComponentsDAO.class); - } - - public DCAEServicesComponentsMapsDAO getDCAEServicesComponentsDAO() { - return (DCAEServicesComponentsMapsDAO) this.getDAO(DCAEServicesComponentsMapsDAO.class); - } - - public DCAEServiceTransactionDAO getDCAEServiceTransactionDAO() { - return jdbi.onDemand(DCAEServiceTransactionDAO.class); - } - - public DCAEServiceTypesDAO getDCAEServiceTypesDAO() { - return (DCAEServiceTypesDAO) this.getDAO(DCAEServiceTypesDAO.class); - } - - /** - * Must close the handle that is returned here. It is AutoCloseable so just use it as a try-with-resource. - * - * @return - */ - public Handle getHandle() { - return this.jdbi.open(); - } - -} |