/************************************************************************* * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER. * * Copyright 2008 by Sun Microsystems, Inc. * * OpenOffice.org - a multi-platform office productivity suite * * $RCSfile: mysqlc_driver.cxx,v $ * * $Revision: 1.1.2.5 $ * * This file is part of OpenOffice.org. * * OpenOffice.org is free software: you can redistribute it and/or modify * it under the terms of the GNU Lesser General Public License version 3 * only, as published by the Free Software Foundation. * * OpenOffice.org 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 version 3 for more details * (a copy is included in the LICENSE file that accompanied this code). * * You should have received a copy of the GNU Lesser General Public License * version 3 along with OpenOffice.org. If not, see * * for a copy of the LGPLv3 License. ************************************************************************/ #include "mysqlc_driver.hxx" #include "mysqlc_connection.hxx" #include "mysqlc_general.hxx" using namespace com::sun::star::uno; using namespace com::sun::star::lang; using namespace com::sun::star::beans; using namespace com::sun::star::sdbc; using namespace connectivity::mysqlc; using ::rtl::OUString; #include #include #include #include #include /* {{{ MysqlCDriver::MysqlCDriver() -I- */ MysqlCDriver::MysqlCDriver(const Reference< XMultiServiceFactory >& _rxFactory) : ODriver_BASE(m_aMutex) ,m_xFactory(_rxFactory) { OSL_TRACE("MysqlCDriver::MysqlCDriver"); cppDriver = NULL; } /* }}} */ /* {{{ MysqlCDriver::disposing() -I- */ void MysqlCDriver::disposing() { OSL_TRACE("MysqlCDriver::disposing"); ::osl::MutexGuard aGuard(m_aMutex); // when driver will be destroied so all our connections have to be destroied as well for (OWeakRefArray::iterator i = m_xConnections.begin(); m_xConnections.end() != i; ++i) { Reference< XComponent > xComp(i->get(), UNO_QUERY); if (xComp.is()) { xComp->dispose(); } } m_xConnections.clear(); ODriver_BASE::disposing(); } /* }}} */ // static ServiceInfo /* {{{ MysqlCDriver::getImplementationName_Static() -I- */ OUString MysqlCDriver::getImplementationName_Static() throw(RuntimeException) { OSL_TRACE("MysqlCDriver::getImplementationName_Static"); return ::rtl::OUString( RTL_CONSTASCII_USTRINGPARAM( "com.sun.star.comp.sdbc.mysqlc.MysqlCDriver" ) ); } /* }}} */ /* {{{ MysqlCDriver::getSupportedServiceNames_Static() -I- */ Sequence< OUString > MysqlCDriver::getSupportedServiceNames_Static() throw(RuntimeException) { OSL_TRACE("MysqlCDriver::getSupportedServiceNames_Static"); // which service is supported // for more information @see com.sun.star.sdbc.Driver Sequence< OUString > aSNS(1); aSNS[0] = OUString::createFromAscii("com.sun.star.sdbc.Driver"); return aSNS; } /* }}} */ /* {{{ MysqlCDriver::getImplementationName() -I- */ OUString SAL_CALL MysqlCDriver::getImplementationName() throw(RuntimeException) { OSL_TRACE("MysqlCDriver::getImplementationName"); return getImplementationName_Static(); } /* }}} */ /* {{{ MysqlCDriver::supportsService() -I- */ sal_Bool SAL_CALL MysqlCDriver::supportsService(const OUString& _rServiceName) throw(RuntimeException) { OSL_TRACE("MysqlCDriver::supportsService"); Sequence< OUString > aSupported(getSupportedServiceNames()); const OUString* pSupported = aSupported.getConstArray(); const OUString* pEnd = pSupported + aSupported.getLength(); for (;pSupported != pEnd && !pSupported->equals(_rServiceName); ++pSupported){} return (pSupported != pEnd); } /* }}} */ /* {{{ MysqlCDriver::getSupportedServiceNames() -I- */ Sequence< OUString > SAL_CALL MysqlCDriver::getSupportedServiceNames() throw(RuntimeException) { OSL_TRACE("MysqlCDriver::getSupportedServiceNames"); return getSupportedServiceNames_Static(); } /* }}} */ extern "C" { static void SAL_CALL thisModule() {} } void MysqlCDriver::impl_initCppConn_lck_throw() { cppDriver = get_driver_instance(); if ( !cppDriver ) { throw SQLException( ::rtl::OUString( RTL_CONSTASCII_USTRINGPARAM( "Unable to obtain the MySQL_Driver instance from Connector/C++." ) ), *this, ::rtl::OUString( RTL_CONSTASCII_USTRINGPARAM( "08001" ) ), // "unable to connect" 0, Any() ); } } /* {{{ MysqlCDriver::connect() -I- */ Reference< XConnection > SAL_CALL MysqlCDriver::connect(const OUString& url, const Sequence< PropertyValue >& info) throw(SQLException, RuntimeException) { ::osl::MutexGuard aGuard( m_aMutex ); OSL_TRACE("MysqlCDriver::connect"); if (!acceptsURL(url)) { return NULL; } if ( !cppDriver ) { impl_initCppConn_lck_throw(); OSL_POSTCOND( cppDriver, "MySQLCDriver::connect: internal error." ); if ( !cppDriver ) throw RuntimeException( ::rtl::OUString( RTL_CONSTASCII_USTRINGPARAM( "MySQLCDriver::connect: internal error." ) ), *this ); } Reference< XConnection > xConn; // create a new connection with the given properties and append it to our vector try { OConnection* pCon = new OConnection(*this, cppDriver); xConn = pCon; pCon->construct(url,info); m_xConnections.push_back(WeakReferenceHelper(*pCon)); } catch (sql::SQLException &e) { mysqlc_sdbc_driver::translateAndThrow(e, *this, getDefaultEncoding()); } return xConn; } /* }}} */ /* {{{ MysqlCDriver::acceptsURL() -I- */ sal_Bool SAL_CALL MysqlCDriver::acceptsURL(const OUString& url) throw(SQLException, RuntimeException) { OSL_TRACE("MysqlCDriver::acceptsURL"); return (!url.compareTo(OUString::createFromAscii("sdbc:mysqlc:"), sizeof("sdbc:mysqlc:")-1)); } /* }}} */ /* {{{ MysqlCDriver::getPropertyInfo() -I- */ Sequence< DriverPropertyInfo > SAL_CALL MysqlCDriver::getPropertyInfo(const OUString& url, const Sequence< PropertyValue >& /* info */) throw(SQLException, RuntimeException) { OSL_TRACE("MysqlCDriver::getPropertyInfo"); if (acceptsURL(url)) { ::std::vector< DriverPropertyInfo > aDriverInfo; aDriverInfo.push_back(DriverPropertyInfo( OUString(RTL_CONSTASCII_USTRINGPARAM("Hostname")) ,OUString(RTL_CONSTASCII_USTRINGPARAM("Name of host")) ,sal_True ,OUString::createFromAscii("localhost") ,Sequence< OUString >()) ); aDriverInfo.push_back(DriverPropertyInfo( OUString(RTL_CONSTASCII_USTRINGPARAM("Port")) ,OUString(RTL_CONSTASCII_USTRINGPARAM("Port")) ,sal_True ,OUString::createFromAscii("3306") ,Sequence< OUString >()) ); return Sequence< DriverPropertyInfo >(&(aDriverInfo[0]),aDriverInfo.size()); } return Sequence< DriverPropertyInfo >(); } /* }}} */ /* {{{ MysqlCDriver::getMajorVersion() -I- */ sal_Int32 SAL_CALL MysqlCDriver::getMajorVersion() throw(RuntimeException) { OSL_TRACE("MysqlCDriver::getMajorVersion"); return MYSQLC_VERSION_MAJOR; } /* }}} */ /* {{{ MysqlCDriver::getMinorVersion() -I- */ sal_Int32 SAL_CALL MysqlCDriver::getMinorVersion() throw(RuntimeException) { OSL_TRACE("MysqlCDriver::getMinorVersion"); return MYSQLC_VERSION_MINOR; } /* }}} */ namespace connectivity { namespace mysqlc { Reference< XInterface > SAL_CALL MysqlCDriver_CreateInstance(const Reference< XMultiServiceFactory >& _rxFactory) throw(::com::sun::star::uno::Exception) { return(*(new MysqlCDriver(_rxFactory))); } /* {{{ connectivity::mysqlc::release() -I- */ void release(oslInterlockedCount& _refCount, ::cppu::OBroadcastHelper& rBHelper, Reference< XInterface >& _xInterface, ::com::sun::star::lang::XComponent* _pObject) { if (osl_decrementInterlockedCount(&_refCount) == 0) { osl_incrementInterlockedCount(&_refCount); if (!rBHelper.bDisposed && !rBHelper.bInDispose) { // remember the parent Reference< XInterface > xParent; { ::osl::MutexGuard aGuard(rBHelper.rMutex); xParent = _xInterface; _xInterface = NULL; } // First dispose _pObject->dispose(); // only the alive ref holds the object OSL_ASSERT(_refCount == 1); // release the parent in the destructor if (xParent.is()) { ::osl::MutexGuard aGuard(rBHelper.rMutex); _xInterface = xParent; } } } else { osl_incrementInterlockedCount(&_refCount); } } /* }}} */ /* {{{ connectivity::mysqlc::checkDisposed() -I- */ void checkDisposed(sal_Bool _bThrow) throw (DisposedException) { if (_bThrow) { throw DisposedException(); } } /* }}} */ } /* mysqlc */ } /* connectivity */ /* * Local variables: * tab-width: 4 * c-basic-offset: 4 * End: * vim600: noet sw=4 ts=4 fdm=marker * vim<600: noet sw=4 ts=4 */