connectivity/source/cpool/ZConnectionWrapper.cxx

   1 /* -*- Mode: C++; tab-width: 4; indent-tabs-mode: nil; c-basic-offset: 4 -*- */
   2 /*
   3  * This file is part of the LibreOffice project.
   4  *
   5  * This Source Code Form is subject to the terms of the Mozilla Public
   6  * License, v. 2.0. If a copy of the MPL was not distributed with this
   7  * file, You can obtain one at http://mozilla.org/MPL/2.0/.
   8  *
   9  * This file incorporates work covered by the following license notice:
  10  *
  11  *   Licensed to the Apache Software Foundation (ASF) under one or more
  12  *   contributor license agreements. See the NOTICE file distributed
  13  *   with this work for additional information regarding copyright
  14  *   ownership. The ASF licenses this file to you under the Apache
  15  *   License, Version 2.0 (the "License"); you may not use this file
  16  *   except in compliance with the License. You may obtain a copy of
  17  *   the License at http://www.apache.org/licenses/LICENSE-2.0 .
  18  */
  19
  20 #include "ZConnectionWrapper.hxx"
  21 #include <com/sun/star/sdbc/ColumnValue.hpp>
  22 #include <com/sun/star/sdbc/XRow.hpp>
  23 #include <com/sun/star/lang/DisposedException.hpp>
  24 #include <cppuhelper/typeprovider.hxx>
  25
  26 using namespace connectivity;
  27
  28 using namespace com::sun::star::uno;
  29 using namespace com::sun::star::lang;
  30 using namespace com::sun::star::beans;
  31 using namespace com::sun::star::sdbc;
  32
  33 OConnectionWeakWrapper::OConnectionWeakWrapper(Reference< XAggregation >& _xConnection)
  34     : OConnectionWeakWrapper_BASE(m_aMutex)
  35 {
  36     setDelegation(_xConnection,m_refCount);
  37     OSL_ENSURE(m_xConnection.is(),"OConnectionWeakWrapper: Connection must be valid!");
  38 }
  39
  40 OConnectionWeakWrapper::~OConnectionWeakWrapper()
  41 {
  42     if ( !OConnectionWeakWrapper_BASE::rBHelper.bDisposed )
  43     {
  44         osl_atomic_increment( &m_refCount );
  45         dispose();
  46     }
  47 }
  48 // XServiceInfo
  49
  50 IMPLEMENT_SERVICE_INFO(OConnectionWeakWrapper, "com.sun.star.sdbc.drivers.OConnectionWeakWrapper", "com.sun.star.sdbc.Connection")
  51
  52
  53 Reference< XStatement > SAL_CALL OConnectionWeakWrapper::createStatement(  )
  54 {
  55     ::osl::MutexGuard aGuard( m_aMutex );
  56     checkDisposed(OConnectionWeakWrapper_BASE::rBHelper.bDisposed);
  57
  58
  59     return m_xConnection->createStatement();
  60 }
  61
  62 Reference< XPreparedStatement > SAL_CALL OConnectionWeakWrapper::prepareStatement( const OUString& sql )
  63 {
  64     ::osl::MutexGuard aGuard( m_aMutex );
  65     checkDisposed(OConnectionWeakWrapper_BASE::rBHelper.bDisposed);
  66
  67
  68     return m_xConnection->prepareStatement(sql);
  69 }
  70
  71 Reference< XPreparedStatement > SAL_CALL OConnectionWeakWrapper::prepareCall( const OUString& sql )
  72 {
  73     ::osl::MutexGuard aGuard( m_aMutex );
  74     checkDisposed(OConnectionWeakWrapper_BASE::rBHelper.bDisposed);
  75
  76
  77     return m_xConnection->prepareCall(sql);
  78 }
  79
  80 OUString SAL_CALL OConnectionWeakWrapper::nativeSQL( const OUString& sql )
  81 {
  82     ::osl::MutexGuard aGuard( m_aMutex );
  83     checkDisposed(OConnectionWeakWrapper_BASE::rBHelper.bDisposed);
  84
  85
  86     return m_xConnection->nativeSQL(sql);
  87 }
  88
  89 void SAL_CALL OConnectionWeakWrapper::setAutoCommit( sal_Bool autoCommit )
  90 {
  91     ::osl::MutexGuard aGuard( m_aMutex );
  92     checkDisposed(OConnectionWeakWrapper_BASE::rBHelper.bDisposed);
  93
  94     m_xConnection->setAutoCommit(autoCommit);
  95 }
  96
  97 sal_Bool SAL_CALL OConnectionWeakWrapper::getAutoCommit(  )
  98 {
  99     ::osl::MutexGuard aGuard( m_aMutex );
 100     checkDisposed(OConnectionWeakWrapper_BASE::rBHelper.bDisposed);
 101
 102
 103     return m_xConnection->getAutoCommit();
 104 }
 105
 106 void SAL_CALL OConnectionWeakWrapper::commit(  )
 107 {
 108     ::osl::MutexGuard aGuard( m_aMutex );
 109     checkDisposed(OConnectionWeakWrapper_BASE::rBHelper.bDisposed);
 110
 111
 112     m_xConnection->commit();
 113 }
 114
 115 void SAL_CALL OConnectionWeakWrapper::rollback(  )
 116 {
 117     ::osl::MutexGuard aGuard( m_aMutex );
 118     checkDisposed(OConnectionWeakWrapper_BASE::rBHelper.bDisposed);
 119
 120
 121     m_xConnection->rollback();
 122 }
 123
 124 sal_Bool SAL_CALL OConnectionWeakWrapper::isClosed(  )
 125 {
 126     ::osl::MutexGuard aGuard( m_aMutex );
 127
 128     return m_xConnection->isClosed();
 129 }
 130
 131 Reference< XDatabaseMetaData > SAL_CALL OConnectionWeakWrapper::getMetaData(  )
 132 {
 133     ::osl::MutexGuard aGuard( m_aMutex );
 134     checkDisposed(OConnectionWeakWrapper_BASE::rBHelper.bDisposed);
 135
 136
 137     return m_xConnection->getMetaData();
 138 }
 139
 140 void SAL_CALL OConnectionWeakWrapper::setReadOnly( sal_Bool readOnly )
 141 {
 142     ::osl::MutexGuard aGuard( m_aMutex );
 143     checkDisposed(OConnectionWeakWrapper_BASE::rBHelper.bDisposed);
 144
 145
 146     m_xConnection->setReadOnly(readOnly);
 147 }
 148
 149 sal_Bool SAL_CALL OConnectionWeakWrapper::isReadOnly(  )
 150 {
 151     ::osl::MutexGuard aGuard( m_aMutex );
 152     checkDisposed(OConnectionWeakWrapper_BASE::rBHelper.bDisposed);
 153
 154
 155     return m_xConnection->isReadOnly();
 156 }
 157
 158 void SAL_CALL OConnectionWeakWrapper::setCatalog( const OUString& catalog )
 159 {
 160     ::osl::MutexGuard aGuard( m_aMutex );
 161     checkDisposed(OConnectionWeakWrapper_BASE::rBHelper.bDisposed);
 162
 163
 164     m_xConnection->setCatalog(catalog);
 165 }
 166
 167 OUString SAL_CALL OConnectionWeakWrapper::getCatalog(  )
 168 {
 169     ::osl::MutexGuard aGuard( m_aMutex );
 170     checkDisposed(OConnectionWeakWrapper_BASE::rBHelper.bDisposed);
 171
 172
 173     return m_xConnection->getCatalog();
 174 }
 175
 176 void SAL_CALL OConnectionWeakWrapper::setTransactionIsolation( sal_Int32 level )
 177 {
 178     ::osl::MutexGuard aGuard( m_aMutex );
 179     checkDisposed(OConnectionWeakWrapper_BASE::rBHelper.bDisposed);
 180
 181
 182     m_xConnection->setTransactionIsolation(level);
 183 }
 184
 185 sal_Int32 SAL_CALL OConnectionWeakWrapper::getTransactionIsolation(  )
 186 {
 187     ::osl::MutexGuard aGuard( m_aMutex );
 188     checkDisposed(OConnectionWeakWrapper_BASE::rBHelper.bDisposed);
 189
 190
 191     return m_xConnection->getTransactionIsolation();
 192 }
 193
 194 Reference< css::container::XNameAccess > SAL_CALL OConnectionWeakWrapper::getTypeMap(  )
 195 {
 196     ::osl::MutexGuard aGuard( m_aMutex );
 197     checkDisposed(OConnectionWeakWrapper_BASE::rBHelper.bDisposed);
 198
 199
 200     return m_xConnection->getTypeMap();
 201 }
 202
 203 void SAL_CALL OConnectionWeakWrapper::setTypeMap( const Reference< css::container::XNameAccess >& typeMap )
 204 {
 205     ::osl::MutexGuard aGuard( m_aMutex );
 206     checkDisposed(OConnectionWeakWrapper_BASE::rBHelper.bDisposed);
 207
 208
 209     m_xConnection->setTypeMap(typeMap);
 210 }
 211
 212 // XCloseable
 213 void SAL_CALL OConnectionWeakWrapper::close(  )
 214 {
 215     {
 216         ::osl::MutexGuard aGuard( m_aMutex );
 217         checkDisposed(OConnectionWeakWrapper_BASE::rBHelper.bDisposed);
 218
 219     }
 220     dispose();
 221 }
 222
 223 void OConnectionWeakWrapper::disposing()
 224 {
 225     ::osl::MutexGuard aGuard(m_aMutex);
 226
 227     OConnectionWeakWrapper_BASE::disposing();
 228     OConnectionWrapper::disposing();
 229 }
 230
 231 // css::lang::XUnoTunnel
 232 IMPLEMENT_FORWARD_REFCOUNT( OConnectionWeakWrapper, OConnectionWeakWrapper_BASE )
 233
 234 css::uno::Any SAL_CALL OConnectionWeakWrapper::queryInterface( const css::uno::Type& _rType )
 235 {
 236     css::uno::Any aReturn = OConnectionWeakWrapper_BASE::queryInterface( _rType );
 237     if ( !aReturn.hasValue() )
 238         aReturn = OConnectionWrapper::queryInterface( _rType );
 239     return aReturn;
 240 }
 241
 242 IMPLEMENT_FORWARD_XTYPEPROVIDER2(OConnectionWeakWrapper,OConnectionWeakWrapper_BASE,OConnectionWrapper)
 243
 244
 245 /* vim:set shiftwidth=4 softtabstop=4 expandtab: */