connectivity/source/drivers/evoab2/NConnection.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: NConnection.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 "NConnection.hxx"
  34 #include "NDatabaseMetaData.hxx"
  35 #include "NCatalog.hxx"
  36 #include <com/sun/star/lang/DisposedException.hpp>
  37 #include <com/sun/star/sdbc/TransactionIsolation.hpp>
  38 #include <tools/urlobj.hxx>
  39 #include "NPreparedStatement.hxx"
  40 #include "NStatement.hxx"
  41 #include <comphelper/extract.hxx>
  42 #include <connectivity/dbexception.hxx>
  43 #include <comphelper/processfactory.hxx>
  44 #include <vos/process.hxx>
  45 #include <tools/debug.hxx>
  46 #include "NDebug.hxx"
  47 #include <comphelper/sequence.hxx>
  48
  49 using namespace connectivity::evoab;
  50 using namespace vos;
  51 using namespace dbtools;
  52
  53 //------------------------------------------------------------------------------
  54 using namespace ::com::sun::star::uno;
  55 using namespace ::com::sun::star::beans;
  56 using namespace ::com::sun::star::sdbcx;
  57 using namespace ::com::sun::star::sdbc;
  58 using namespace ::com::sun::star::lang;
  59
  60 ::rtl::OUString implGetExceptionMsg( Exception& e, const ::rtl::OUString& aExceptionType_ )
  61 {
  62      ::rtl::OUString aExceptionType = aExceptionType_;
  63      if( aExceptionType.getLength() == 0 )
  64          aExceptionType =  ::rtl::OUString::createFromAscii("Unknown" ) ;
  65
  66      ::rtl::OUString aTypeLine( RTL_CONSTASCII_USTRINGPARAM("\nType: " ) );
  67      aTypeLine += aExceptionType;
  68
  69      ::rtl::OUString aMessageLine( RTL_CONSTASCII_USTRINGPARAM("\nMessage: " ) );
  70          aMessageLine += ::rtl::OUString( e.Message );
  71
  72      ::rtl::OUString aMsg(aTypeLine);
  73      aMsg += aMessageLine;
  74          return aMsg;
  75 }
  76
  77  // Exception type unknown
  78 ::rtl::OUString implGetExceptionMsg( Exception& e )
  79 {
  80          ::rtl::OUString aMsg = implGetExceptionMsg( e, ::rtl::OUString() );
  81          return aMsg;
  82 }
  83
  84 // --------------------------------------------------------------------------------
  85 OEvoabConnection::OEvoabConnection( OEvoabDriver& _rDriver )
  86     :OSubComponent<OEvoabConnection, OConnection_BASE>( (::cppu::OWeakObject*)(&_rDriver), this )
  87     ,m_rDriver(_rDriver)
  88     ,m_xCatalog(NULL)
  89 {
  90 }
  91 //-----------------------------------------------------------------------------
  92 OEvoabConnection::~OEvoabConnection()
  93 {
  94         ::osl::MutexGuard aGuard( m_aMutex );
  95
  96     if(!isClosed()) {
  97         acquire();
  98         close();
  99     }
 100 }
 101
 102 //-----------------------------------------------------------------------------
 103 void SAL_CALL OEvoabConnection::release() throw()
 104 {
 105     relase_ChildImpl();
 106 }
 107
 108 // XServiceInfo
 109 // --------------------------------------------------------------------------------
 110 IMPLEMENT_SERVICE_INFO(OEvoabConnection, "com.sun.star.sdbc.drivers.evoab.Connection", "com.sun.star.sdbc.Connection")
 111
 112 //-----------------------------------------------------------------------------
 113 void OEvoabConnection::construct(const ::rtl::OUString& url, const Sequence< PropertyValue >& info)  throw(SQLException)
 114 {
 115     osl_incrementInterlockedCount( &m_refCount );
 116     EVO_TRACE_STRING("OEvoabConnection::construct()::url = %s\n", url );
 117
 118      ::rtl::OUString sPassword;
 119         const char* pPwd                = "password";
 120
 121         const PropertyValue *pIter      = info.getConstArray();
 122         const PropertyValue *pEnd       = pIter + info.getLength();
 123         for(;pIter != pEnd;++pIter)
 124         {
 125                 if(!pIter->Name.compareToAscii(pPwd))
 126                 {
 127                         pIter->Value >>= sPassword;
 128                         break;
 129                 }
 130         }
 131
 132     if (url.equalsAscii("sdbc:address:evolution:groupwise"))
 133         setSDBCAddressType(SDBCAddress::EVO_GWISE);
 134     else if (url.equalsAscii("sdbc:address:evolution:ldap"))
 135         setSDBCAddressType(SDBCAddress::EVO_LDAP);
 136     else
 137         setSDBCAddressType(SDBCAddress::EVO_LOCAL);
 138     setURL(url);
 139     setPassword(::rtl::OUStringToOString(sPassword,RTL_TEXTENCODING_UTF8));
 140     osl_decrementInterlockedCount( &m_refCount );
 141 }
 142
 143 // --------------------------------------------------------------------------------
 144 ::rtl::OUString SAL_CALL OEvoabConnection::nativeSQL( const ::rtl::OUString& _sSql ) throw(SQLException, RuntimeException)
 145 {
 146     // when you need to transform SQL92 to you driver specific you can do it here
 147     return _sSql;
 148 }
 149 // --------------------------------------------------------------------------------
 150 Reference< XDatabaseMetaData > SAL_CALL OEvoabConnection::getMetaData(  ) throw(SQLException, RuntimeException)
 151 {
 152     ::osl::MutexGuard aGuard( m_aMutex );
 153     checkDisposed(OConnection_BASE::rBHelper.bDisposed);
 154
 155     Reference< XDatabaseMetaData > xMetaData = m_xMetaData;
 156     if(!xMetaData.is())
 157     {
 158         xMetaData = new OEvoabDatabaseMetaData(this);
 159         m_xMetaData = xMetaData;
 160     }
 161
 162     return xMetaData;
 163 }
 164 //------------------------------------------------------------------------------
 165 ::com::sun::star::uno::Reference< XTablesSupplier > OEvoabConnection::createCatalog()
 166 {
 167     ::osl::MutexGuard aGuard( m_aMutex );
 168      Reference< XTablesSupplier > xTab = m_xCatalog;
 169      if(!xTab.is())
 170      {
 171          OEvoabCatalog *pCat = new OEvoabCatalog(this);
 172          xTab = pCat;
 173          m_xCatalog = xTab;
 174      }
 175      return xTab;
 176 }
 177 // --------------------------------------------------------------------------------
 178 Reference< XStatement > SAL_CALL OEvoabConnection::createStatement(  ) throw(SQLException, RuntimeException)
 179 {
 180     ::osl::MutexGuard aGuard( m_aMutex );
 181     checkDisposed(OConnection_BASE::rBHelper.bDisposed);
 182
 183     OStatement* pStmt = new OStatement(this);
 184
 185     Reference< XStatement > xStmt = pStmt;
 186     m_aStatements.push_back(WeakReferenceHelper(*pStmt));
 187     return xStmt;
 188 }
 189 // --------------------------------------------------------------------------------
 190 Reference< XPreparedStatement > SAL_CALL OEvoabConnection::prepareStatement( const ::rtl::OUString& sql ) throw(SQLException, RuntimeException)
 191 {
 192     ::osl::MutexGuard aGuard( m_aMutex );
 193     checkDisposed(OConnection_BASE::rBHelper.bDisposed);
 194
 195     OEvoabPreparedStatement* pStmt = new OEvoabPreparedStatement( this );
 196     Reference< XPreparedStatement > xStmt = pStmt;
 197     pStmt->construct( sql );
 198
 199     m_aStatements.push_back(WeakReferenceHelper(*pStmt));
 200     return xStmt;
 201 }
 202
 203 Reference< XPreparedStatement > SAL_CALL OEvoabConnection::prepareCall( const ::rtl::OUString& /*sql*/ ) throw( SQLException, RuntimeException)
 204 {
 205     ::dbtools::throwFeatureNotImplementedException( "XConnection::prepareCall", *this );
 206     return NULL;
 207 }
 208 sal_Bool SAL_CALL OEvoabConnection::isClosed(  ) throw(SQLException, RuntimeException)
 209 {
 210     ::osl::MutexGuard aGuard( m_aMutex );
 211     return OConnection_BASE::rBHelper.bDisposed;
 212 }
 213
 214 // --------------------------------------------------------------------------------
 215 // XCloseable
 216 void SAL_CALL OEvoabConnection::close(  ) throw(SQLException, RuntimeException)
 217 {
 218     {  // we just dispose us
 219         ::osl::MutexGuard aGuard( m_aMutex );
 220         checkDisposed(OConnection_BASE::rBHelper.bDisposed);
 221     }
 222     dispose();
 223 }
 224
 225 // --------------------------------------------------------------------------------
 226 // XWarningsSupplier
 227 Any SAL_CALL OEvoabConnection::getWarnings(  ) throw(SQLException, RuntimeException)
 228 {
 229     return m_aWarnings.getWarnings();
 230 }
 231 void SAL_CALL OEvoabConnection::clearWarnings(  ) throw(SQLException, RuntimeException)
 232 {
 233     m_aWarnings.clearWarnings();
 234 }
 235 //------------------------------------------------------------------------------
 236
 237 void OEvoabConnection::disposing()
 238 {
 239     // we noticed that we should be destroyed in near future so we have to dispose our statements
 240     ::osl::MutexGuard aGuard(m_aMutex);
 241     OConnection_BASE::disposing();
 242     dispose_ChildImpl();
 243 }
 244
 245 // -------------------------------- stubbed methods ------------------------------------------------
 246 void SAL_CALL OEvoabConnection::setAutoCommit( sal_Bool /*autoCommit*/ ) throw(SQLException, RuntimeException)
 247 {
 248     ::dbtools::throwFeatureNotImplementedException( "XConnection::setAutoCommit", *this );
 249 }
 250 sal_Bool SAL_CALL OEvoabConnection::getAutoCommit(  ) throw(SQLException, RuntimeException)
 251 {
 252     return sal_True;
 253 }
 254 void SAL_CALL OEvoabConnection::commit(  ) throw(SQLException, RuntimeException)
 255 {
 256 }
 257 void SAL_CALL OEvoabConnection::rollback(  ) throw(SQLException, RuntimeException)
 258 {
 259 }
 260 void SAL_CALL OEvoabConnection::setReadOnly( sal_Bool /*readOnly*/ ) throw(SQLException, RuntimeException)
 261 {
 262     ::dbtools::throwFeatureNotImplementedException( "XConnection::setReadOnly", *this );
 263 }
 264 sal_Bool SAL_CALL OEvoabConnection::isReadOnly(  ) throw(SQLException, RuntimeException)
 265 {
 266     return sal_False;
 267 }
 268 void SAL_CALL OEvoabConnection::setCatalog( const ::rtl::OUString& /*catalog*/ ) throw(SQLException, RuntimeException)
 269 {
 270     ::dbtools::throwFeatureNotImplementedException( "XConnection::setCatalog", *this );
 271 }
 272
 273 ::rtl::OUString SAL_CALL OEvoabConnection::getCatalog(  ) throw(SQLException, RuntimeException)
 274 {
 275     return ::rtl::OUString();
 276 }
 277 void SAL_CALL OEvoabConnection::setTransactionIsolation( sal_Int32 /*level*/ ) throw(SQLException, RuntimeException)
 278 {
 279     ::dbtools::throwFeatureNotImplementedException( "XConnection::setTransactionIsolation", *this );
 280 }
 281
 282 sal_Int32 SAL_CALL OEvoabConnection::getTransactionIsolation(  ) throw(SQLException, RuntimeException)
 283 {
 284     return TransactionIsolation::NONE;
 285 }
 286
 287 Reference< ::com::sun::star::container::XNameAccess > SAL_CALL OEvoabConnection::getTypeMap(  ) throw(SQLException, RuntimeException)
 288 {
 289     ::dbtools::throwFeatureNotImplementedException( "XConnection::getTypeMap", *this );
 290     return NULL;
 291 }
 292 void SAL_CALL OEvoabConnection::setTypeMap( const Reference< ::com::sun::star::container::XNameAccess >& /*typeMap*/ ) throw(SQLException, RuntimeException)
 293 {
 294     ::dbtools::throwFeatureNotImplementedException( "XConnection::setTypeMap", *this );
 295 }