/*************************************************************************
*
* DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER.
*
* Copyright 2000, 2010 Oracle and/or its affiliates.
*
* OpenOffice.org - a multi-platform office productivity suite
*
* This file is part of OpenOffice.org.
*
* OpenOffice.org is free software: you can redistribute it and/or modify
* it under the terms of the GNU Lesser General Public License version 3
* only, as published by the Free Software Foundation.
*
* OpenOffice.org 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 version 3 for more details
* (a copy is included in the LICENSE file that accompanied this code).
*
* You should have received a copy of the GNU Lesser General Public License
* version 3 along with OpenOffice.org. If not, see
* <http://www.openoffice.org/license.html>
* for a copy of the LGPLv3 License.
*
************************************************************************/
#ifndef _CONNECTIVITY_ADO_COLLECTION_HXX_
#define _CONNECTIVITY_ADO_COLLECTION_HXX_
#include <cppuhelper/implbase3.hxx>
#include <com/sun/star/container/XNameAccess.hpp>
#include <com/sun/star/container/XIndexAccess.hpp>
#include "ado/Awrapadox.hxx"
#include "ado/Aolevariant.hxx"
#include <com/sun/star/lang/XServiceInfo.hpp>
namespace connectivity
{
namespace ado
{
namespace starcontainer = ::com::sun::star::container;
namespace starlang = ::com::sun::star::lang;
namespace staruno = ::com::sun::star::uno;
namespace starbeans = ::com::sun::star::beans;
typedef ::cppu::WeakImplHelper3< starcontainer::XNameAccess,
starcontainer::XIndexAccess,
starlang::XServiceInfo> OCollectionBase;
//************************************************************
// OCollection
//************************************************************
template <class T,class SimT,class OCl> class OCollection : public OCollectionBase
{
private:
OCollection( const OCollection& ); // never implemented
OCollection& operator=( const OCollection& ); // never implemented
protected:
vector<OCl*> m_aElements;
::cppu::OWeakObject& m_rParent;
::osl::Mutex& m_rMutex; // mutex of the parent
T* m_pCollection;
public:
OCollection(::cppu::OWeakObject& _rParent, ::osl::Mutex& _rMutex,T* _pCollection)
: m_rParent(_rParent)
,m_rMutex(_rMutex)
,m_pCollection(_pCollection)
{
m_pCollection->AddRef();
}
~OCollection()
{
m_pCollection->Release();
}
virtual ::rtl::OUString SAL_CALL getImplementationName( ) throw (staruno::RuntimeException)
{
return ::rtl::OUString::createFromAscii("com.sun.star.sdbcx.ACollection");
}
virtual sal_Bool SAL_CALL supportsService( const ::rtl::OUString& _rServiceName ) throw(staruno::RuntimeException)
{
staruno::Sequence< ::rtl::OUString > aSupported(getSupportedServiceNames());
const ::rtl::OUString* pSupported = aSupported.getConstArray();
for (sal_Int32 i=0; i<aSupported.getLength(); ++i, ++pSupported)
if (pSupported->equals(_rServiceName))
return sal_True;
return sal_False;
}
virtual staruno::Sequence< ::rtl::OUString > SAL_CALL getSupportedServiceNames( ) throw(staruno::RuntimeException)
{
staruno::Sequence< ::rtl::OUString > aSupported(1);
aSupported[0] = ::rtl::OUString::createFromAscii("com.sun.star.sdbcx.Container");
return aSupported;
}
// dispatch the refcounting to the parent
virtual void SAL_CALL acquire() throw()
{
m_rParent.acquire();
}
virtual void SAL_CALL release() throw()
{
m_rParent.release();
}
// ::com::sun::star::container::XElementAccess
virtual staruno::Type SAL_CALL getElementType( ) throw(staruno::RuntimeException)
{
return::getCppuType(static_cast< staruno::Reference< starbeans::XPropertySet>*>(NULL));
}
virtual sal_Bool SAL_CALL hasElements( ) throw(staruno::RuntimeException)
{
::osl::MutexGuard aGuard(m_rMutex);
return getCount() > 0;
}
// starcontainer::XIndexAccess
virtual sal_Int32 SAL_CALL getCount( ) throw(staruno::RuntimeException)
{
::osl::MutexGuard aGuard(m_rMutex);
sal_Int32 nCnt = 0;
m_pCollection->get_Count(&nCnt);
return nCnt;
}
virtual staruno::Any SAL_CALL getByIndex( sal_Int32 Index ) throw(starlang::IndexOutOfBoundsException, starlang::WrappedTargetException, staruno::RuntimeException)
{
::osl::MutexGuard aGuard(m_rMutex);
if (Index < 0 || Index >= getCount())
throw starlang::IndexOutOfBoundsException();
SimT* pCol = NULL;
m_pCollection->get_Item(OLEVariant(Index),&pCol);
if(!pCol)
throw starlang::IndexOutOfBoundsException();
OCl* pIndex = new OCl(pCol);
m_aElements.push_back(pIndex);
return staruno::makeAny( staruno::Reference< starbeans::XPropertySet >(pIndex));
}
// starcontainer::XNameAccess
virtual staruno::Any SAL_CALL getByName( const ::rtl::OUString& aName ) throw(starcontainer::NoSuchElementException, starlang::WrappedTargetException, staruno::RuntimeException)
{
::osl::MutexGuard aGuard(m_rMutex);
SimT* pCol = NULL;
m_pCollection->get_Item(OLEVariant(aName),&pCol);
if(!pCol)
throw starlang::IndexOutOfBoundsException();
OCl* pIndex = new OCl(pCol);
m_aElements.push_back(pIndex);
return staruno::makeAny( staruno::Reference< starbeans::XPropertySet >(pIndex));
}
virtual staruno::Sequence< ::rtl::OUString > SAL_CALL getElementNames( ) throw(staruno::RuntimeException)
{
::osl::MutexGuard aGuard(m_rMutex);
sal_Int32 nLen = getCount();
staruno::Sequence< ::rtl::OUString > aNameList(nLen);
::rtl::OUString* pStringArray = aNameList.getArray();
OLEVariant aVar;
for (sal_Int32 i=0;i<nLen;++i)
{
aVar.setInt32(i);
SimT* pIdx = NULL;
m_pCollection->get_Item(aVar,&pIdx);
pIdx->AddRef();
_bstr_t sBSTR;
pIdx->get_Name(&sBSTR);
(*pStringArray) = (sal_Unicode*)sBSTR;
pIdx->Release();
++pStringArray;
}
return aNameList;
}
virtual sal_Bool SAL_CALL hasByName( const ::rtl::OUString& aName ) throw(staruno::RuntimeException)
{
::osl::MutexGuard aGuard(m_rMutex);
SimT* pCol = NULL;
m_pCollection->get_Item(OLEVariant(aName),&pCol);
return pCol != NULL;
}
void SAL_CALL disposing()
{
::osl::MutexGuard aGuard(m_rMutex);
for (::std::vector<OCl*>::const_iterator i = m_aElements.begin(); i != m_aElements.end(); ++i)
{
(*i)->disposing();
(*i)->release();
}
m_aElements.clear();
}
};
class OIndex;
class OKey;
class OColumn;
class OTable;
class OView;
class OGroup;
class OUser;
typedef OCollection< ADOIndexes,ADOIndex,OIndex> OIndexes;
typedef OCollection< ADOKeys,ADOKey,OKey> OKeys;
typedef OCollection< ADOColumns,ADOColumn,OColumn> OColumns;
typedef OCollection< ADOTables,ADOTable,OTable> OTables;
typedef OCollection< ADOViews,ADOView,OView> OViews;
typedef OCollection< ADOGroups,ADOGroup,OGroup> OGroups;
typedef OCollection< ADOUsers,ADOUser,OUser> OUsers;
}
}
#endif // _CONNECTIVITY_ADO_COLLECTION_HXX_