mysqlc/source/mysqlc_driver.cxx

   1 /* -*- Mode: C++; tab-width: 4; indent-tabs-mode: nil; c-basic-offset: 4 -*- */
   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 * This file is part of OpenOffice.org.
  10 *
  11 * OpenOffice.org is free software: you can redistribute it and/or modify
  12 * it under the terms of the GNU Lesser General Public License version 3
  13 * only, as published by the Free Software Foundation.
  14 *
  15 * OpenOffice.org is distributed in the hope that it will be useful,
  16 * but WITHOUT ANY WARRANTY; without even the implied warranty of
  17 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  18 * GNU Lesser General Public License version 3 for more details
  19 * (a copy is included in the LICENSE file that accompanied this code).
  20 *
  21 * You should have received a copy of the GNU Lesser General Public License
  22 * version 3 along with OpenOffice.org.  If not, see
  23 * <http://www.openoffice.org/license.html>
  24 * for a copy of the LGPLv3 License.
  25 ************************************************************************/
  26 #include "mysqlc_driver.hxx"
  27 #include "mysqlc_connection.hxx"
  28 #include "mysqlc_general.hxx"
  29
  30 using namespace com::sun::star::uno;
  31 using namespace com::sun::star::lang;
  32 using namespace com::sun::star::beans;
  33 using namespace com::sun::star::sdbc;
  34 using namespace connectivity::mysqlc;
  35
  36 #include <cppuhelper/supportsservice.hxx>
  37 #include <stdio.h>
  38
  39 #include <cppconn/exception.h>
  40 #ifdef SYSTEM_MYSQL_CPPCONN
  41     #include <mysql_driver.h>
  42 #endif
  43
  44 MysqlCDriver::MysqlCDriver(const Reference< XMultiServiceFactory >& _rxFactory)
  45     : ODriver_BASE(m_aMutex)
  46     ,m_xFactory(_rxFactory)
  47 #ifndef SYSTEM_MYSQL_CPPCONN
  48     ,m_hCppConnModule( NULL )
  49     ,m_bAttemptedLoadCppConn( false )
  50 #endif
  51 {
  52     OSL_TRACE("MysqlCDriver::MysqlCDriver");
  53     cppDriver = NULL;
  54 }
  55
  56 void MysqlCDriver::disposing()
  57 {
  58     OSL_TRACE("MysqlCDriver::disposing");
  59     ::osl::MutexGuard aGuard(m_aMutex);
  60
  61     // when driver will be destroied so all our connections have to be destroied as well
  62     for (OWeakRefArray::iterator i = m_xConnections.begin(); m_xConnections.end() != i; ++i)
  63     {
  64         Reference< XComponent > xComp(i->get(), UNO_QUERY);
  65         if (xComp.is()) {
  66             xComp->dispose();
  67         }
  68     }
  69     m_xConnections.clear();
  70
  71     ODriver_BASE::disposing();
  72 }
  73
  74 // static ServiceInfo
  75 rtl::OUString MysqlCDriver::getImplementationName_Static()
  76     throw(RuntimeException)
  77 {
  78     OSL_TRACE("MysqlCDriver::getImplementationName_Static");
  79     return rtl::OUString( "com.sun.star.comp.sdbc.mysqlc.MysqlCDriver"  );
  80 }
  81
  82 Sequence< rtl::OUString > MysqlCDriver::getSupportedServiceNames_Static()
  83     throw(RuntimeException)
  84 {
  85     OSL_TRACE("MysqlCDriver::getSupportedServiceNames_Static");
  86     // which service is supported
  87     // for more information @see com.sun.star.sdbc.Driver
  88     Sequence< rtl::OUString > aSNS(1);
  89     aSNS[0] = "com.sun.star.sdbc.Driver";
  90     return aSNS;
  91 }
  92
  93 rtl::OUString SAL_CALL MysqlCDriver::getImplementationName()
  94     throw(RuntimeException, std::exception)
  95 {
  96     OSL_TRACE("MysqlCDriver::getImplementationName");
  97     return getImplementationName_Static();
  98 }
  99
 100 sal_Bool SAL_CALL MysqlCDriver::supportsService(const rtl::OUString& _rServiceName)
 101     throw(RuntimeException, std::exception)
 102 {
 103     return cppu::supportsService(this, _rServiceName);
 104 }
 105
 106 Sequence< rtl::OUString > SAL_CALL MysqlCDriver::getSupportedServiceNames()
 107     throw(RuntimeException, std::exception)
 108 {
 109     OSL_TRACE("MysqlCDriver::getSupportedServiceNames");
 110     return getSupportedServiceNames_Static();
 111 }
 112
 113 extern "C" { static void SAL_CALL thisModule() {} }
 114
 115 void MysqlCDriver::impl_initCppConn_lck_throw()
 116 {
 117 #ifdef SYSTEM_MYSQL_CPPCONN
 118     cppDriver = get_driver_instance();
 119 #else
 120 #ifdef BUNDLE_MARIADB
 121     if ( !m_bAttemptedLoadCConn )
 122     {
 123         const rtl::OUString sModuleName(BUNDLE_MARIADB);
 124         m_hCConnModule = osl_loadModuleRelative( &thisModule, sModuleName.pData, 0 );
 125         m_bAttemptedLoadCConn = true;
 126     }
 127
 128     // attempted to load - was it successful?
 129     if ( !m_hCConnModule )
 130     {
 131         OSL_FAIL( "MysqlCDriver::impl_initCppConn_lck_throw: could not load the " BUNDLE_MARIADB " library!");
 132         throw SQLException(
 133             "Unable to load the " BUNDLE_MARIADB " library.",
 134             *this,
 135             rtl::OUString( "08001"  ),  // "unable to connect"
 136             0,
 137             Any()
 138         );
 139     }
 140 #endif
 141     if ( !m_bAttemptedLoadCppConn )
 142     {
 143         const rtl::OUString sModuleName(CPPCONN_LIB);
 144         m_hCppConnModule = osl_loadModuleRelative( &thisModule, sModuleName.pData, 0 );
 145         m_bAttemptedLoadCppConn = true;
 146     }
 147
 148     // attempted to load - was it successful?
 149     if ( !m_hCppConnModule )
 150     {
 151         OSL_FAIL( "MysqlCDriver::impl_initCppConn_lck_throw: could not load the " CPPCONN_LIB " library!");
 152         throw SQLException(
 153             "Unable to load the " CPPCONN_LIB " library.",
 154             *this,
 155             rtl::OUString( "08001"  ),  // "unable to connect"
 156             0,
 157             Any()
 158         );
 159     }
 160
 161     // find the factory symbol
 162     const rtl::OUString sSymbolName = "sql_mysql_get_driver_instance";
 163     typedef void* (* FGetMySQLDriver)();
 164
 165     const FGetMySQLDriver pFactoryFunction = reinterpret_cast<FGetMySQLDriver>( osl_getFunctionSymbol( m_hCppConnModule, sSymbolName.pData ) );
 166     if ( !pFactoryFunction )
 167     {
 168         OSL_FAIL( "MysqlCDriver::impl_initCppConn_lck_throw: could not find the factory symbol in " CPPCONN_LIB "!");
 169         throw SQLException(
 170             CPPCONN_LIB " is invalid: missing the driver factory function.",
 171             *this,
 172             rtl::OUString( "08001"  ),  // "unable to connect"
 173             0,
 174             Any()
 175         );
 176     }
 177
 178     cppDriver = static_cast< sql::Driver* >( (*pFactoryFunction)() );
 179 #endif
 180     if ( !cppDriver )
 181     {
 182         throw SQLException(
 183             "Unable to obtain the MySQL_Driver instance from Connector/C++.",
 184             *this,
 185             rtl::OUString( "08001"  ),  // "unable to connect"
 186             0,
 187             Any()
 188         );
 189     }
 190 }
 191
 192 Reference< XConnection > SAL_CALL MysqlCDriver::connect(const rtl::OUString& url, const Sequence< PropertyValue >& info)
 193     throw(SQLException, RuntimeException, std::exception)
 194 {
 195     ::osl::MutexGuard aGuard( m_aMutex );
 196
 197     OSL_TRACE("MysqlCDriver::connect");
 198     if (!acceptsURL(url)) {
 199         return NULL;
 200     }
 201
 202     if ( !cppDriver )
 203     {
 204         impl_initCppConn_lck_throw();
 205         if ( !cppDriver )
 206             throw RuntimeException("MySQLCDriver::connect: internal error.", *this );
 207     }
 208
 209     Reference< XConnection > xConn;
 210     // create a new connection with the given properties and append it to our vector
 211     try {
 212         OConnection* pCon = new OConnection(*this, cppDriver);
 213         xConn = pCon;
 214
 215         pCon->construct(url,info);
 216         m_xConnections.push_back(WeakReferenceHelper(*pCon));
 217     }
 218     catch (const sql::SQLException &e)
 219     {
 220         mysqlc_sdbc_driver::translateAndThrow(e, *this, getDefaultEncoding());
 221     }
 222     return xConn;
 223 }
 224
 225 sal_Bool SAL_CALL MysqlCDriver::acceptsURL(const rtl::OUString& url)
 226         throw(SQLException, RuntimeException, std::exception)
 227 {
 228     OSL_TRACE("MysqlCDriver::acceptsURL");
 229     return url.startsWith("sdbc:mysqlc:");
 230 }
 231
 232 Sequence< DriverPropertyInfo > SAL_CALL MysqlCDriver::getPropertyInfo(const rtl::OUString& url, const Sequence< PropertyValue >& /* info */)
 233     throw(SQLException, RuntimeException, std::exception)
 234 {
 235     OSL_TRACE("MysqlCDriver::getPropertyInfo");
 236     if (acceptsURL(url)) {
 237         ::std::vector< DriverPropertyInfo > aDriverInfo;
 238
 239         aDriverInfo.push_back(DriverPropertyInfo(
 240                 rtl::OUString("Hostname")
 241                 ,rtl::OUString("Name of host")
 242                 ,sal_True
 243                 ,rtl::OUString("localhost")
 244                 ,Sequence< rtl::OUString >())
 245             );
 246         aDriverInfo.push_back(DriverPropertyInfo(
 247                 rtl::OUString("Port")
 248                 ,rtl::OUString("Port")
 249                 ,sal_True
 250                 ,rtl::OUString("3306")
 251                 ,Sequence< rtl::OUString >())
 252             );
 253         return Sequence< DriverPropertyInfo >(&(aDriverInfo[0]),aDriverInfo.size());
 254     }
 255
 256     return Sequence< DriverPropertyInfo >();
 257 }
 258
 259 sal_Int32 SAL_CALL MysqlCDriver::getMajorVersion()
 260     throw(RuntimeException, std::exception)
 261 {
 262     OSL_TRACE("MysqlCDriver::getMajorVersion");
 263     return MARIADBC_VERSION_MAJOR;
 264 }
 265
 266 sal_Int32 SAL_CALL MysqlCDriver::getMinorVersion()
 267     throw(RuntimeException, std::exception)
 268 {
 269     OSL_TRACE("MysqlCDriver::getMinorVersion");
 270     return MARIADBC_VERSION_MINOR;
 271 }
 272
 273 namespace connectivity
 274 {
 275 namespace mysqlc
 276 {
 277
 278 Reference< XInterface >  SAL_CALL MysqlCDriver_CreateInstance(const Reference< XMultiServiceFactory >& _rxFactory)
 279     throw(::com::sun::star::uno::Exception)
 280 {
 281     return(*(new MysqlCDriver(_rxFactory)));
 282 }
 283
 284 void release(oslInterlockedCount& _refCount,
 285              ::cppu::OBroadcastHelper& rBHelper,
 286              Reference< XInterface >& _xInterface,
 287              ::com::sun::star::lang::XComponent* _pObject)
 288 {
 289     if (osl_atomic_decrement(&_refCount) == 0) {
 290         osl_atomic_increment(&_refCount);
 291
 292         if (!rBHelper.bDisposed && !rBHelper.bInDispose) {
 293             // remember the parent
 294             Reference< XInterface > xParent;
 295             {
 296                 ::osl::MutexGuard aGuard(rBHelper.rMutex);
 297                 xParent = _xInterface;
 298                 _xInterface = NULL;
 299             }
 300
 301             // First dispose
 302             _pObject->dispose();
 303
 304             // only the alive ref holds the object
 305             OSL_ASSERT(_refCount == 1);
 306
 307             // release the parent in the destructor
 308             if (xParent.is()) {
 309                 ::osl::MutexGuard aGuard(rBHelper.rMutex);
 310                 _xInterface = xParent;
 311             }
 312         }
 313     } else {
 314         osl_atomic_increment(&_refCount);
 315     }
 316 }
 317
 318 void checkDisposed(bool _bThrow)
 319     throw (DisposedException)
 320 {
 321     if (_bThrow) {
 322         throw DisposedException();
 323     }
 324 }
 325
 326 } /* mysqlc */
 327 } /* connectivity */
 328
 329 /*
 330  * Local variables:
 331  * tab-width: 4
 332  * c-basic-offset: 4
 333  * End:
 334  * vim600: noet sw=4 ts=4 fdm=marker
 335  * vim<600: noet sw=4 ts=4
 336  */
 337
 338 /* vim:set shiftwidth=4 softtabstop=4 expandtab: */