DAO Layer Implementation

revert-dabc3590
manoj 10 years ago
parent a9bd0ea8c6
commit dc8837a1da

@ -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;
}
}

@ -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;
}
}
Loading…
Cancel
Save