/*************************************************************************
*
* OpenOffice.org - a multi-platform office productivity suite
*
* $RCSfile: connpoolconfig.cxx,v $
*
* $Revision: 1.4 $
*
* last change: $Author: rt $ $Date: 2005-09-08 20:44:51 $
*
* The Contents of this file are made available subject to
* the terms of GNU Lesser General Public License Version 2.1.
*
*
* GNU Lesser General Public License Version 2.1
* =============================================
* Copyright 2005 by Sun Microsystems, Inc.
* 901 San Antonio Road, Palo Alto, CA 94303, USA
*
* This library is free software; you can redistribute it and/or
* modify it under the terms of the GNU Lesser General Public
* License version 2.1, as published by the Free Software Foundation.
*
* This library is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
* Lesser General Public License for more details.
*
* You should have received a copy of the GNU Lesser General Public
* License along with this library; if not, write to the Free Software
* Foundation, Inc., 59 Temple Place, Suite 330, Boston,
* MA 02111-1307 USA
*
************************************************************************/
#ifdef SVX_DLLIMPLEMENTATION
#undef SVX_DLLIMPLEMENTATION
#endif
#ifndef _OFFAPP_CONNPOOLCONFIG_HXX_
#include "connpoolconfig.hxx"
#endif
#ifndef _OFFAPP_CONNPOOLSETTINGS_HXX_
#include "connpoolsettings.hxx"
#endif
#include "connpooloptions.hxx"
#ifndef _SFXITEMSET_HXX
#include <svtools/itemset.hxx>
#endif
#ifndef _UNOTOOLS_CONFIGNODE_HXX_
#include <unotools/confignode.hxx>
#endif
#ifndef _COMPHELPER_EXTRACT_HXX_
#include <comphelper/extract.hxx>
#endif
#ifndef _SFXENUMITEM_HXX
#include <svtools/eitem.hxx>
#endif
#ifndef _COMPHELPER_PROCESSFACTORY_HXX_
#include <comphelper/processfactory.hxx>
#endif
#ifndef _OFFMGR_SDBCDRIVERENUMERATION_HXX_
#include "sdbcdriverenum.hxx"
#endif
#include "svxids.hrc"
//........................................................................
namespace offapp
{
//........................................................................
using namespace ::utl;
using namespace ::com::sun::star::uno;
//--------------------------------------------------------------------
static const ::rtl::OUString& getConnectionPoolNodeName()
{
static ::rtl::OUString s_sNodeName = ::rtl::OUString::createFromAscii("org.openoffice.Office.DataAccess/ConnectionPool");
return s_sNodeName;
}
//--------------------------------------------------------------------
static const ::rtl::OUString& getEnablePoolingNodeName()
{
static ::rtl::OUString s_sNodeName = ::rtl::OUString::createFromAscii("EnablePooling");
return s_sNodeName;
}
//--------------------------------------------------------------------
static const ::rtl::OUString& getDriverSettingsNodeName()
{
static ::rtl::OUString s_sNodeName = ::rtl::OUString::createFromAscii("DriverSettings");
return s_sNodeName;
}
//--------------------------------------------------------------------
static const ::rtl::OUString& getDriverNameNodeName()
{
static ::rtl::OUString s_sNodeName = ::rtl::OUString::createFromAscii("DriverName");
return s_sNodeName;
}
//--------------------------------------------------------------------
static const ::rtl::OUString& getEnableNodeName()
{
static ::rtl::OUString s_sNodeName = ::rtl::OUString::createFromAscii("Enable");
return s_sNodeName;
}
//--------------------------------------------------------------------
static const ::rtl::OUString& getTimeoutNodeName()
{
static ::rtl::OUString s_sNodeName = ::rtl::OUString::createFromAscii("Timeout");
return s_sNodeName;
}
//====================================================================
//= ConnectionPoolConfig
//====================================================================
//--------------------------------------------------------------------
void ConnectionPoolConfig::GetOptions(SfxItemSet& _rFillItems)
{
// the config node where all pooling relevant info are stored under
OConfigurationTreeRoot aConnectionPoolRoot = OConfigurationTreeRoot::createWithServiceFactory(
::comphelper::getProcessServiceFactory(), getConnectionPoolNodeName(), -1, OConfigurationTreeRoot::CM_READONLY);
// the global "enabled" flag
Any aEnabled = aConnectionPoolRoot.getNodeValue(getEnablePoolingNodeName());
sal_Bool bEnabled = sal_True;
aEnabled >>= bEnabled;
_rFillItems.Put(SfxBoolItem(SID_SB_POOLING_ENABLED, bEnabled));
// the settings for the single drivers
DriverPoolingSettings aSettings;
// first get all the drivers register at the driver manager
ODriverEnumeration aEnumDrivers;
for ( ODriverEnumeration::const_iterator aLoopDrivers = aEnumDrivers.begin();
aLoopDrivers != aEnumDrivers.end();
++aLoopDrivers
)
{
aSettings.push_back(DriverPooling(*aLoopDrivers, sal_False, 120));
}
// then look for which of them settings are stored in the configuration
OConfigurationNode aDriverSettings = aConnectionPoolRoot.openNode(getDriverSettingsNodeName());
Sequence< ::rtl::OUString > aDriverKeys = aDriverSettings.getNodeNames();
const ::rtl::OUString* pDriverKeys = aDriverKeys.getConstArray();
const ::rtl::OUString* pDriverKeysEnd = pDriverKeys + aDriverKeys.getLength();
for (;pDriverKeys != pDriverKeysEnd; ++pDriverKeys)
{
// the name of the driver in this round
OConfigurationNode aThisDriverSettings = aDriverSettings.openNode(*pDriverKeys);
::rtl::OUString sThisDriverName;
aThisDriverSettings.getNodeValue(getDriverNameNodeName()) >>= sThisDriverName;
// look if we (resp. the driver manager) know this driver
// doing O(n) search here, which is expensive, but this doesn't matter in this small case ...
DriverPoolingSettings::iterator aLookup;
for ( aLookup = aSettings.begin();
aLookup != aSettings.end();
++aLookup
)
if (sThisDriverName.equals(aLookup->sName))
break;
if (aLookup == aSettings.end())
{ // do not know the driver - add it
aSettings.push_back(DriverPooling(sThisDriverName, sal_False, 120));
// and the position of the new entry
aLookup = aSettings.end();
--aLookup;
}
// now fill this entry with the settings from the configuration
aThisDriverSettings.getNodeValue(getEnableNodeName()) >>= aLookup->bEnabled;
aThisDriverSettings.getNodeValue(getTimeoutNodeName()) >>= aLookup->nTimeoutSeconds;
}
_rFillItems.Put(DriverPoolingSettingsItem(SID_SB_DRIVER_TIMEOUTS, aSettings));
}
//--------------------------------------------------------------------
void ConnectionPoolConfig::SetOptions(const SfxItemSet& _rSourceItems)
{
// the config node where all pooling relevant info are stored under
OConfigurationTreeRoot aConnectionPoolRoot = OConfigurationTreeRoot::createWithServiceFactory(
::comphelper::getProcessServiceFactory(), getConnectionPoolNodeName(), -1, OConfigurationTreeRoot::CM_UPDATABLE);
if (!aConnectionPoolRoot.isValid())
// already asserted by the OConfigurationTreeRoot
return;
sal_Bool bNeedCommit = sal_False;
// the global "enabled" flag
SFX_ITEMSET_GET( _rSourceItems, pEnabled, SfxBoolItem, SID_SB_POOLING_ENABLED, sal_True );
if (pEnabled)
{
sal_Bool bEnabled = pEnabled->GetValue();
aConnectionPoolRoot.setNodeValue(getEnablePoolingNodeName(), Any(&bEnabled, ::getBooleanCppuType()));
bNeedCommit = sal_True;
}
// the settings for the single drivers
SFX_ITEMSET_GET( _rSourceItems, pDriverSettings, DriverPoolingSettingsItem, SID_SB_DRIVER_TIMEOUTS, sal_True );
if (pDriverSettings)
{
OConfigurationNode aDriverSettings = aConnectionPoolRoot.openNode(getDriverSettingsNodeName());
if (!aDriverSettings.isValid())
return;
::rtl::OUString sThisDriverName;
OConfigurationNode aThisDriverSettings;
const DriverPoolingSettings& rNewSettings = pDriverSettings->getSettings();
for ( DriverPoolingSettings::const_iterator aLoop = rNewSettings.begin();
aLoop != rNewSettings.end();
++aLoop
)
{
// need the name as ::rtl::OUString
sThisDriverName = aLoop->sName;
// the sub-node for this driver
if (aDriverSettings.hasByName(aLoop->sName))
aThisDriverSettings = aDriverSettings.openNode(aLoop->sName);
else
aThisDriverSettings = aDriverSettings.createNode(aLoop->sName);
// set the values
aThisDriverSettings.setNodeValue(getDriverNameNodeName(), makeAny(sThisDriverName));
aThisDriverSettings.setNodeValue(getEnableNodeName(), Any(&aLoop->bEnabled, ::getBooleanCppuType()));
aThisDriverSettings.setNodeValue(getTimeoutNodeName(), makeAny(aLoop->nTimeoutSeconds));
}
bNeedCommit = sal_True;
}
if (bNeedCommit)
aConnectionPoolRoot.commit();
}
//........................................................................
} // namespace offapp
//........................................................................