00001 /*************************************************************************** 00002 * Copyright (C) 2005-2007 Stefan Schwarzer, Jens Schneider, * 00003 * Matthias Hardt, Guido Madaus * 00004 * * 00005 * Copyright (C) 2007-2008 BerLinux Solutions GbR * 00006 * Stefan Schwarzer & Guido Madaus * 00007 * * 00008 * Copyright (C) 2009-2013 BerLinux Solutions GmbH * 00009 * * 00010 * Authors: * 00011 * Stefan Schwarzer <stefan.schwarzer@diskohq.org>, * 00012 * Matthias Hardt <matthias.hardt@diskohq.org>, * 00013 * Jens Schneider <jens.schneider@diskohq.org>, * 00014 * Guido Madaus <guido.madaus@diskohq.org>, * 00015 * Patrick Helterhoff <patrick.helterhoff@diskohq.org>, * 00016 * René Bählkow <rene.baehlkow@diskohq.org> * 00017 * * 00018 * This library is free software; you can redistribute it and/or * 00019 * modify it under the terms of the GNU Lesser General Public * 00020 * License version 2.1 as published by the Free Software Foundation. * 00021 * * 00022 * This library is distributed in the hope that it will be useful, * 00023 * but WITHOUT ANY WARRANTY; without even the implied warranty of * 00024 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU * 00025 * Lesser General Public License for more details. * 00026 * * 00027 * You should have received a copy of the GNU Lesser General Public * 00028 * License along with this library; if not, write to the * 00029 * Free Software Foundation, Inc., * 00030 * 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA * 00031 **************************************************************************/ 00032 00033 #include "mmsconfig/mmsimportsourceservice.h" 00034 #include "mmsconfig/mmsimportsourcedao.h" 00035 #include "mmstools/mmsdbconnmgr.h" 00036 #include "mmstools/tools.h" 00037 00038 MMSImportSourceService::MMSImportSourceService(DataSource *datasource) : 00039 dbconn(NULL) { 00040 MMSDBConnMgr connMgr(datasource); 00041 if((this->dbconn = connMgr.getConnection())) 00042 this->dbconn->connect(); 00043 } 00044 00045 MMSImportSourceService::~MMSImportSourceService() { 00046 if(this->dbconn) { 00047 this->dbconn->disconnect(); 00048 delete this->dbconn; 00049 } 00050 } 00051 00052 void MMSImportSourceService::setImportSource(vector<MMSImportSourceData *> dataList) { 00053 MMSImportSourceDAO myImportSourceDAO(this->dbconn); 00054 myImportSourceDAO.saveOrUpdate(dataList); 00055 } 00056 00057 vector<MMSImportSourceData *> MMSImportSourceService::getImportSourcesByPlugin(MMSPluginData *plugin) { 00058 MMSImportSourceDAO myImportSourceDAO(this->dbconn); 00059 vector<MMSImportSourceData *> importSources; 00060 importSources = myImportSourceDAO.findImportSourcesByPlugin(plugin); 00061 00062 /* substitute env vars in the sources */ 00063 for (unsigned i = 0; i < importSources.size(); i++) { 00064 importSources.at(i)->setSource(substituteEnvVars(importSources.at(i)->getSource())); 00065 } 00066 00067 return importSources; 00068 } 00069 00070 MMSImportSourceData * MMSImportSourceService::getImportSourcesByID(int id) { 00071 MMSImportSourceDAO myImportSourceDAO(this->dbconn); 00072 return myImportSourceDAO.findImportSourcesByID(id); 00073 } 00074 00075 MMSImportSourceData * MMSImportSourceService::getImportSourcesByName(string name) { 00076 MMSImportSourceDAO myImportSourceDAO(this->dbconn); 00077 return myImportSourceDAO.findImportSourcesByName(name); 00078 }