From dc8837a1da84304ada98eea8107ef55a62ad0515 Mon Sep 17 00:00:00 2001 From: manoj Date: Fri, 5 Dec 2014 12:33:08 +0530 Subject: [PATCH] DAO Layer Implementation --- .../config/DeviceConfigurationManager.java | 104 ++++++++++++++++++ .../mgt/core/config/DeviceMgtConfig.java | 61 ++++++++++ 2 files changed, 165 insertions(+) create mode 100644 components/device-mgt/org.wso2.carbon.device.mgt.core/src/main/java/org/wso2/carbon/device/mgt/core/config/DeviceConfigurationManager.java create mode 100644 components/device-mgt/org.wso2.carbon.device.mgt.core/src/main/java/org/wso2/carbon/device/mgt/core/config/DeviceMgtConfig.java diff --git a/components/device-mgt/org.wso2.carbon.device.mgt.core/src/main/java/org/wso2/carbon/device/mgt/core/config/DeviceConfigurationManager.java b/components/device-mgt/org.wso2.carbon.device.mgt.core/src/main/java/org/wso2/carbon/device/mgt/core/config/DeviceConfigurationManager.java new file mode 100644 index 0000000000..25131d6b8c --- /dev/null +++ b/components/device-mgt/org.wso2.carbon.device.mgt.core/src/main/java/org/wso2/carbon/device/mgt/core/config/DeviceConfigurationManager.java @@ -0,0 +1,104 @@ +/* + * Copyright (c) 2014, WSO2 Inc. (http://www.wso2.org) All Rights Reserved. + * WSO2 Inc. licenses this file to you 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. + * 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. + */ + +package org.wso2.carbon.device.mgt.core.config; + +import org.apache.commons.logging.Log; +import org.apache.commons.logging.LogFactory; +import org.w3c.dom.Document; +import org.wso2.carbon.device.mgt.common.DeviceManagementConstants; +import org.wso2.carbon.device.mgt.common.DeviceManagementException; +import org.wso2.carbon.rssmanager.core.dao.RSSDAOFactory; +import org.wso2.carbon.rssmanager.core.environment.EnvironmentManager; +import org.wso2.carbon.rssmanager.core.environment.EnvironmentManagerFactory; +import org.wso2.carbon.rssmanager.core.exception.RSSManagerException; +import org.wso2.carbon.rssmanager.core.manager.adaptor.EnvironmentAdaptor; +import org.wso2.carbon.rssmanager.core.util.RSSDbCreator; +import org.wso2.carbon.rssmanager.core.util.RSSManagerUtil; +import org.wso2.carbon.utils.CarbonUtils; + +import javax.sql.DataSource; +import javax.xml.bind.JAXBContext; +import javax.xml.bind.Unmarshaller; +import java.io.File; + +/** + * Class responsible for the rss manager configuration initialization + */ +public class DeviceConfigurationManager { + + private RSSConfig currentRSSConfig; + private static DeviceConfigurationManager deviceConfigManager; + + private static final Log log = LogFactory.getLog(DeviceConfigurationManager.class); + private final String rssConfigXMLPath = CarbonUtils.getCarbonConfigDirPath() + File.separator + "conf" + File + .separator + + DeviceManagementConstants.DataSourceProperties.DEVICE_CONFIG_XML_NAME; + + private final String cdmSetupSql = CarbonUtils.getCarbonHome() + File.separator + "repository" + File.separator + + "conf" + File.separator + "dbscripts"; + + public static DeviceConfigurationManager getInstance() { + if (deviceConfigManager == null) { + synchronized (DeviceConfigurationManager.class) { + if (deviceConfigManager == null) { + deviceConfigManager = new DeviceConfigurationManager(); + } + } + } + return deviceConfigManager; + } + + + public synchronized void initConfig() throws DeviceManagementException { + try { + File rssConfig = new File(rssConfigXMLPath); + Document doc = RSSManagerUtil.convertToDocument(rssConfig); + //rss-config supports secure vault as it needs to be resolve when parsing + RSSManagerUtil.secureResolveDocument(doc); + /* Un-marshaling RSS configuration */ + JAXBContext rssContext = JAXBContext.newInstance(RSSConfig.class); + Unmarshaller unmarshaller = rssContext.createUnmarshaller(); + this.currentRSSConfig = (RSSConfig) unmarshaller.unmarshal(doc); + //set jndi data source name for future use + RSSManagerUtil.setJndiDataSourceName(currentRSSConfig.getRSSManagementRepository().getDataSourceConfig(). + getJndiLookupDefintion().getJndiName()); + DataSource dataSource = RSSDAOFactory.resolveDataSource(this.currentRSSConfig.getRSSManagementRepository() + .getDataSourceConfig()); + RSSManagerUtil.setDataSource(dataSource); + String setupOption = System.getProperty("setup"); + //if -Dsetup option specified then create rss manager tables + if (setupOption != null) { + log.info("Setup option specified"); + RSSDbCreator dbCreator = new RSSDbCreator(dataSource); + dbCreator.setRssDBScriptDirectory(cdmSetupSql); + log.info("Creating Meta Data tables"); + dbCreator.createRegistryDatabase(); + } + //Initialization of environment manager + EnvironmentManager environmentManager = EnvironmentManagerFactory.getEnvironmentManager(currentRSSConfig. + getRSSEnvironments()); + environmentManager + .initEnvironments(currentRSSConfig.getRSSProvider(), currentRSSConfig.getRSSManagementRepository()); + this.adaptor = new EnvironmentAdaptor(environmentManager); + } catch (Exception e) { + throw new RSSManagerException("Error occurred while initializing RSS config", e); + } + } + + public RSSConfig getCurrentRSSConfig() { + return currentRSSConfig; + } +} diff --git a/components/device-mgt/org.wso2.carbon.device.mgt.core/src/main/java/org/wso2/carbon/device/mgt/core/config/DeviceMgtConfig.java b/components/device-mgt/org.wso2.carbon.device.mgt.core/src/main/java/org/wso2/carbon/device/mgt/core/config/DeviceMgtConfig.java new file mode 100644 index 0000000000..1625749c40 --- /dev/null +++ b/components/device-mgt/org.wso2.carbon.device.mgt.core/src/main/java/org/wso2/carbon/device/mgt/core/config/DeviceMgtConfig.java @@ -0,0 +1,61 @@ +/* + * Copyright (c) 2014, WSO2 Inc. (http://www.wso2.org) All Rights Reserved. + * WSO2 Inc. licenses this file to you 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. + * 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. + */ +package org.wso2.carbon.device.mgt.core.config; + +import org.wso2.carbon.rssmanager.core.environment.Environment; + +import javax.xml.bind.annotation.XmlElement; +import javax.xml.bind.annotation.XmlElementWrapper; +import javax.xml.bind.annotation.XmlRootElement; + +/** + * Represents RSS configuration. + */ +@XmlRootElement(name = "RSSConfiguration") +public final class DeviceMgtConfig { + + private String rssProvider; + private Environment[] environments; + private RSSManagementRepository rssMgtRepository; + + @XmlElement(name = "ManagementRepository", nillable = false) + public RSSManagementRepository getRSSManagementRepository() { + return rssMgtRepository; + } + + public void setRSSManagementRepository(RSSManagementRepository rssMgtRepository) { + this.rssMgtRepository = rssMgtRepository; + } + + @XmlElementWrapper(name = "Environments", nillable = false) + @XmlElement(name = "Environment", nillable = false) + public Environment[] getRSSEnvironments() { + return environments; + } + + public void setRSSEnvironments(Environment[] environments) { + this.environments = environments; + } + + @XmlElement(name = "Provider", nillable = false) + public String getRSSProvider() { + return rssProvider; + } + + public void setRSSProvider(String rssProvider) { + this.rssProvider = rssProvider; + } + +}