diff options
Diffstat (limited to 'connectivity/source/inc/ado/ACollection.hxx')
| -rw-r--r-- | connectivity/source/inc/ado/ACollection.hxx | 274 |
1 files changed, 274 insertions, 0 deletions
diff --git a/connectivity/source/inc/ado/ACollection.hxx b/connectivity/source/inc/ado/ACollection.hxx new file mode 100644 index 000000000000..13d5c91de160 --- /dev/null +++ b/connectivity/source/inc/ado/ACollection.hxx @@ -0,0 +1,274 @@ +/************************************************************************* + * + * $RCSfile: ACollection.hxx,v $ + * + * $Revision: 1.1.1.1 $ + * + * last change: $Author: hr $ $Date: 2000-09-18 16:14:24 $ + * + * The Contents of this file are made available subject to the terms of + * either of the following licenses + * + * - GNU Lesser General Public License Version 2.1 + * - Sun Industry Standards Source License Version 1.1 + * + * Sun Microsystems Inc., October, 2000 + * + * GNU Lesser General Public License Version 2.1 + * ============================================= + * Copyright 2000 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 + * + * + * Sun Industry Standards Source License Version 1.1 + * ================================================= + * The contents of this file are subject to the Sun Industry Standards + * Source License Version 1.1 (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.openoffice.org/license.html. + * + * Software provided under this License is provided on an "AS IS" basis, + * WITHOUT WARRANTY OF ANY KIND, EITHER EXPRESSED OR IMPLIED, INCLUDING, + * WITHOUT LIMITATION, WARRANTIES THAT THE SOFTWARE IS FREE OF DEFECTS, + * MERCHANTABLE, FIT FOR A PARTICULAR PURPOSE, OR NON-INFRINGING. + * See the License for the specific provisions governing your rights and + * obligations concerning the Software. + * + * The Initial Developer of the Original Code is: Sun Microsystems, Inc. + * + * Copyright: 2000 by Sun Microsystems, Inc. + * + * All Rights Reserved. + * + * Contributor(s): _______________________________________ + * + * + ************************************************************************/ + +#ifndef _CONNECTIVITY_ADO_COLLECTION_HXX_ +#define _CONNECTIVITY_ADO_COLLECTION_HXX_ + +#ifndef _CPPUHELPER_IMPLBASE3_HXX_ +#include <cppuhelper/implbase3.hxx> +#endif +#ifndef _COM_SUN_STAR_CONTAINER_XNAMEACCESS_HPP_ +#include <com/sun/star/container/XNameAccess.hpp> +#endif +#ifndef _COM_SUN_STAR_CONTAINER_XINDEXACCESS_HPP_ +#include <com/sun/star/container/XIndexAccess.hpp> +#endif +#ifndef _CONNECTIVITY_ADO_AWRAPADOX_HXX_ +#include "ado/Awrapadox.hxx" +#endif +#ifndef _CONNECTIVITY_ADO_AOLEVARIANT_HXX_ +#include "ado/Aolevariant.hxx" +#endif +#ifndef _COM_SUN_STAR_LANG_XSERVICEINFO_HPP_ +#include <com/sun/star/lang/XServiceInfo.hpp> +#endif + +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 + { + 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(staruno::RuntimeException) + { + m_rParent.acquire(); + } + virtual void SAL_CALL release() throw(staruno::RuntimeException) + { + 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 aBSTR; + pIdx->get_Name(&aBSTR); + (*pStringArray) = (sal_Unicode*)aBSTR; + SysFreeString(aBSTR); + 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_ + + + |