connectivity/source/cpool/ZConnectionWrapper.cxx

   1 /*************************************************************************
   2  *
   3  * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER.
   4  *
   5  * Copyright 2008 by Sun Microsystems, Inc.
   6  *
   7  * OpenOffice.org - a multi-platform office productivity suite
   8  *
   9  * $RCSfile: ZConnectionWrapper.cxx,v $
  10  * $Revision: 1.10 $
  11  *
  12  * This file is part of OpenOffice.org.
  13  *
  14  * OpenOffice.org is free software: you can redistribute it and/or modify
  15  * it under the terms of the GNU Lesser General Public License version 3
  16  * only, as published by the Free Software Foundation.
  17  *
  18  * OpenOffice.org is distributed in the hope that it will be useful,
  19  * but WITHOUT ANY WARRANTY; without even the implied warranty of
  20  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  21  * GNU Lesser General Public License version 3 for more details
  22  * (a copy is included in the LICENSE file that accompanied this code).
  23  *
  24  * You should have received a copy of the GNU Lesser General Public License
  25  * version 3 along with OpenOffice.org.  If not, see
  26  * <http://www.openoffice.org/license.html>
  27  * for a copy of the LGPLv3 License.
  28  *
  29  ************************************************************************/
  30
  31 // MARKER(update_precomp.py): autogen include statement, do not remove
  32 #include "precompiled_connectivity.hxx"
  33 #include "ZConnectionWrapper.hxx"
  34 #include <com/sun/star/sdbc/ColumnValue.hpp>
  35 #include <com/sun/star/sdbc/XRow.hpp>
  36 #include <com/sun/star/lang/DisposedException.hpp>
  37 #include <comphelper/extract.hxx>
  38 #include <cppuhelper/typeprovider.hxx>
  39 #include <comphelper/sequence.hxx>
  40
  41 using namespace connectivity;
  42 //------------------------------------------------------------------------------
  43 using namespace com::sun::star::uno;
  44 using namespace com::sun::star::lang;
  45 using namespace com::sun::star::beans;
  46 using namespace com::sun::star::sdbc;
  47 // --------------------------------------------------------------------------------
  48 OConnectionWeakWrapper::OConnectionWeakWrapper(Reference< XAggregation >& _xConnection)
  49     : OConnectionWeakWrapper_BASE(m_aMutex)
  50 {
  51     setDelegation(_xConnection,m_refCount);
  52     OSL_ENSURE(m_xConnection.is(),"OConnectionWeakWrapper: Connection must be valid!");
  53 }
  54 //-----------------------------------------------------------------------------
  55 OConnectionWeakWrapper::~OConnectionWeakWrapper()
  56 {
  57     if ( !OConnectionWeakWrapper_BASE::rBHelper.bDisposed )
  58     {
  59         osl_incrementInterlockedCount( &m_refCount );
  60         dispose();
  61     }
  62 }
  63 // XServiceInfo
  64 // --------------------------------------------------------------------------------
  65 IMPLEMENT_SERVICE_INFO(OConnectionWeakWrapper, "com.sun.star.sdbc.drivers.OConnectionWeakWrapper", "com.sun.star.sdbc.Connection")
  66
  67 // --------------------------------------------------------------------------------
  68 Reference< XStatement > SAL_CALL OConnectionWeakWrapper::createStatement(  ) throw(SQLException, RuntimeException)
  69 {
  70     ::osl::MutexGuard aGuard( m_aMutex );
  71     checkDisposed(OConnectionWeakWrapper_BASE::rBHelper.bDisposed);
  72
  73
  74     return m_xConnection->createStatement();
  75 }
  76 // --------------------------------------------------------------------------------
  77 Reference< XPreparedStatement > SAL_CALL OConnectionWeakWrapper::prepareStatement( const ::rtl::OUString& sql ) throw(SQLException, RuntimeException)
  78 {
  79     ::osl::MutexGuard aGuard( m_aMutex );
  80     checkDisposed(OConnectionWeakWrapper_BASE::rBHelper.bDisposed);
  81
  82
  83     return m_xConnection->prepareStatement(sql);
  84 }
  85 // --------------------------------------------------------------------------------
  86 Reference< XPreparedStatement > SAL_CALL OConnectionWeakWrapper::prepareCall( const ::rtl::OUString& sql ) throw(SQLException, RuntimeException)
  87 {
  88     ::osl::MutexGuard aGuard( m_aMutex );
  89     checkDisposed(OConnectionWeakWrapper_BASE::rBHelper.bDisposed);
  90
  91
  92     return m_xConnection->prepareCall(sql);
  93 }
  94 // --------------------------------------------------------------------------------
  95 ::rtl::OUString SAL_CALL OConnectionWeakWrapper::nativeSQL( const ::rtl::OUString& sql ) throw(SQLException, RuntimeException)
  96 {
  97     ::osl::MutexGuard aGuard( m_aMutex );
  98     checkDisposed(OConnectionWeakWrapper_BASE::rBHelper.bDisposed);
  99
 100
 101     return m_xConnection->nativeSQL(sql);
 102 }
 103 // --------------------------------------------------------------------------------
 104 void SAL_CALL OConnectionWeakWrapper::setAutoCommit( sal_Bool autoCommit ) throw(SQLException, RuntimeException)
 105 {
 106     ::osl::MutexGuard aGuard( m_aMutex );
 107     checkDisposed(OConnectionWeakWrapper_BASE::rBHelper.bDisposed);
 108
 109     m_xConnection->setAutoCommit(autoCommit);
 110 }
 111 // --------------------------------------------------------------------------------
 112 sal_Bool SAL_CALL OConnectionWeakWrapper::getAutoCommit(  ) throw(SQLException, RuntimeException)
 113 {
 114     ::osl::MutexGuard aGuard( m_aMutex );
 115     checkDisposed(OConnectionWeakWrapper_BASE::rBHelper.bDisposed);
 116
 117
 118     return m_xConnection->getAutoCommit();
 119 }
 120 // --------------------------------------------------------------------------------
 121 void SAL_CALL OConnectionWeakWrapper::commit(  ) throw(SQLException, RuntimeException)
 122 {
 123     ::osl::MutexGuard aGuard( m_aMutex );
 124     checkDisposed(OConnectionWeakWrapper_BASE::rBHelper.bDisposed);
 125
 126
 127     m_xConnection->commit();
 128 }
 129 // --------------------------------------------------------------------------------
 130 void SAL_CALL OConnectionWeakWrapper::rollback(  ) throw(SQLException, RuntimeException)
 131 {
 132     ::osl::MutexGuard aGuard( m_aMutex );
 133     checkDisposed(OConnectionWeakWrapper_BASE::rBHelper.bDisposed);
 134
 135
 136     m_xConnection->rollback();
 137 }
 138 // --------------------------------------------------------------------------------
 139 sal_Bool SAL_CALL OConnectionWeakWrapper::isClosed(  ) throw(SQLException, RuntimeException)
 140 {
 141     ::osl::MutexGuard aGuard( m_aMutex );
 142
 143     return m_xConnection->isClosed();
 144 }
 145 // --------------------------------------------------------------------------------
 146 Reference< XDatabaseMetaData > SAL_CALL OConnectionWeakWrapper::getMetaData(  ) throw(SQLException, RuntimeException)
 147 {
 148     ::osl::MutexGuard aGuard( m_aMutex );
 149     checkDisposed(OConnectionWeakWrapper_BASE::rBHelper.bDisposed);
 150
 151
 152     return m_xConnection->getMetaData();
 153 }
 154 // --------------------------------------------------------------------------------
 155 void SAL_CALL OConnectionWeakWrapper::setReadOnly( sal_Bool readOnly ) throw(SQLException, RuntimeException)
 156 {
 157     ::osl::MutexGuard aGuard( m_aMutex );
 158     checkDisposed(OConnectionWeakWrapper_BASE::rBHelper.bDisposed);
 159
 160
 161     m_xConnection->setReadOnly(readOnly);
 162 }
 163 // --------------------------------------------------------------------------------
 164 sal_Bool SAL_CALL OConnectionWeakWrapper::isReadOnly(  ) throw(SQLException, RuntimeException)
 165 {
 166     ::osl::MutexGuard aGuard( m_aMutex );
 167     checkDisposed(OConnectionWeakWrapper_BASE::rBHelper.bDisposed);
 168
 169
 170     return m_xConnection->isReadOnly();
 171 }
 172 // --------------------------------------------------------------------------------
 173 void SAL_CALL OConnectionWeakWrapper::setCatalog( const ::rtl::OUString& catalog ) throw(SQLException, RuntimeException)
 174 {
 175     ::osl::MutexGuard aGuard( m_aMutex );
 176     checkDisposed(OConnectionWeakWrapper_BASE::rBHelper.bDisposed);
 177
 178
 179     m_xConnection->setCatalog(catalog);
 180 }
 181 // --------------------------------------------------------------------------------
 182 ::rtl::OUString SAL_CALL OConnectionWeakWrapper::getCatalog(  ) throw(SQLException, RuntimeException)
 183 {
 184     ::osl::MutexGuard aGuard( m_aMutex );
 185     checkDisposed(OConnectionWeakWrapper_BASE::rBHelper.bDisposed);
 186
 187
 188     return m_xConnection->getCatalog();
 189 }
 190 // --------------------------------------------------------------------------------
 191 void SAL_CALL OConnectionWeakWrapper::setTransactionIsolation( sal_Int32 level ) throw(SQLException, RuntimeException)
 192 {
 193     ::osl::MutexGuard aGuard( m_aMutex );
 194     checkDisposed(OConnectionWeakWrapper_BASE::rBHelper.bDisposed);
 195
 196
 197     m_xConnection->setTransactionIsolation(level);
 198 }
 199 // --------------------------------------------------------------------------------
 200 sal_Int32 SAL_CALL OConnectionWeakWrapper::getTransactionIsolation(  ) throw(SQLException, RuntimeException)
 201 {
 202     ::osl::MutexGuard aGuard( m_aMutex );
 203     checkDisposed(OConnectionWeakWrapper_BASE::rBHelper.bDisposed);
 204
 205
 206     return m_xConnection->getTransactionIsolation();
 207 }
 208 // --------------------------------------------------------------------------------
 209 Reference< ::com::sun::star::container::XNameAccess > SAL_CALL OConnectionWeakWrapper::getTypeMap(  ) throw(SQLException, RuntimeException)
 210 {
 211     ::osl::MutexGuard aGuard( m_aMutex );
 212     checkDisposed(OConnectionWeakWrapper_BASE::rBHelper.bDisposed);
 213
 214
 215     return m_xConnection->getTypeMap();
 216 }
 217 // --------------------------------------------------------------------------------
 218 void SAL_CALL OConnectionWeakWrapper::setTypeMap( const Reference< ::com::sun::star::container::XNameAccess >& typeMap ) throw(SQLException, RuntimeException)
 219 {
 220     ::osl::MutexGuard aGuard( m_aMutex );
 221     checkDisposed(OConnectionWeakWrapper_BASE::rBHelper.bDisposed);
 222
 223
 224     m_xConnection->setTypeMap(typeMap);
 225 }
 226 // --------------------------------------------------------------------------------
 227 // XCloseable
 228 void SAL_CALL OConnectionWeakWrapper::close(  ) throw(SQLException, RuntimeException)
 229 {
 230     {
 231         ::osl::MutexGuard aGuard( m_aMutex );
 232         checkDisposed(OConnectionWeakWrapper_BASE::rBHelper.bDisposed);
 233
 234     }
 235     dispose();
 236 }
 237 //------------------------------------------------------------------------------
 238 void OConnectionWeakWrapper::disposing()
 239 {
 240     ::osl::MutexGuard aGuard(m_aMutex);
 241
 242     OConnectionWeakWrapper_BASE::disposing();
 243     OConnectionWrapper::disposing();
 244 }
 245 // -----------------------------------------------------------------------------
 246 // com::sun::star::lang::XUnoTunnel
 247 #ifdef N_DEBUG
 248 IMPLEMENT_FORWARD_XINTERFACE2(OConnectionWeakWrapper,OConnectionWeakWrapper_BASE,OConnectionWrapper)
 249 #else
 250 IMPLEMENT_FORWARD_REFCOUNT( OConnectionWeakWrapper, OConnectionWeakWrapper_BASE ) \
 251 ::com::sun::star::uno::Any SAL_CALL OConnectionWeakWrapper::queryInterface( const ::com::sun::star::uno::Type& _rType ) throw (::com::sun::star::uno::RuntimeException) \
 252 { \
 253     ::com::sun::star::uno::Any aReturn = OConnectionWeakWrapper_BASE::queryInterface( _rType ); \
 254     if ( !aReturn.hasValue() ) \
 255         aReturn = OConnectionWrapper::queryInterface( _rType ); \
 256     return aReturn; \
 257 }
 258 #endif
 259 IMPLEMENT_FORWARD_XTYPEPROVIDER2(OConnectionWeakWrapper,OConnectionWeakWrapper_BASE,OConnectionWrapper)
 260
 261