/************************************************************** * * Licensed to the Apache Software Foundation (ASF) under one * or more contributor license agreements. See the NOTICE file * distributed with this work for additional information * regarding copyright ownership. The ASF licenses this file * to you under the Apache License, Version 2.0 (the * "License"); you may not use this file except in compliance * with the License. You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, * software distributed under the License is distributed on an * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY * KIND, either express or implied. See the License for the * specific language governing permissions and limitations * under the License. * *************************************************************/ // MARKER(update_precomp.py): autogen include statement, do not remove #include "precompiled_connectivity.hxx" #include "KConnection.hxx" #include "KDatabaseMetaData.hxx" #include "KStatement.hxx" #include "KPreparedStatement.hxx" #include "KDriver.hxx" #include "KCatalog.hxx" #include #include #include using namespace connectivity::kab; 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 com::sun::star::sdbcx; IMPLEMENT_SERVICE_INFO(KabConnection, "com.sun.star.sdbc.drivers.KabConnection", "com.sun.star.sdbc.Connection") //----------------------------------------------------------------------------- KabConnection::KabConnection(KabDriver* _pDriver) : OMetaConnection_BASE(m_aMutex), OSubComponent((::cppu::OWeakObject*)_pDriver, this), m_xMetaData(NULL), m_pAddressBook(NULL), m_pDriver(_pDriver) { m_pDriver->acquire(); } //----------------------------------------------------------------------------- KabConnection::~KabConnection() { if (!isClosed()) close(); m_pDriver->release(); m_pDriver = NULL; } //----------------------------------------------------------------------------- void SAL_CALL KabConnection::release() throw() { relase_ChildImpl(); } // ----------------------------------------------------------------------------- void KabConnection::construct(const ::rtl::OUString&, const Sequence< PropertyValue >&) throw(SQLException) { osl_incrementInterlockedCount( &m_refCount ); // create a KDE address book object m_pAddressBook = KABC::StdAddressBook::self(); m_pAddressBook->setAutomaticSave(false); // perharps we should analyze the URL to know whether the addressbook is local, over LDAP, etc... // perharps we should get some user and password information from "info" properties osl_decrementInterlockedCount( &m_refCount ); } // XServiceInfo // -------------------------------------------------------------------------------- Reference< XStatement > SAL_CALL KabConnection::createStatement( ) throw(SQLException, RuntimeException) { ::osl::MutexGuard aGuard( m_aMutex ); checkDisposed(KabConnection_BASE::rBHelper.bDisposed); // create a statement // the statement can only be executed once Reference< XStatement > xReturn = new KabStatement(this); m_aStatements.push_back(WeakReferenceHelper(xReturn)); return xReturn; } // -------------------------------------------------------------------------------- Reference< XPreparedStatement > SAL_CALL KabConnection::prepareStatement( const ::rtl::OUString& _sSql ) throw(SQLException, RuntimeException) { ::osl::MutexGuard aGuard( m_aMutex ); checkDisposed(KabConnection_BASE::rBHelper.bDisposed); // create a statement // the statement can only be executed more than once Reference< XPreparedStatement > xReturn = new KabPreparedStatement(this, _sSql); m_aStatements.push_back(WeakReferenceHelper(xReturn)); return xReturn; } // -------------------------------------------------------------------------------- Reference< XPreparedStatement > SAL_CALL KabConnection::prepareCall( const ::rtl::OUString& ) throw(SQLException, RuntimeException) { ::osl::MutexGuard aGuard( m_aMutex ); checkDisposed(KabConnection_BASE::rBHelper.bDisposed); // not implemented yet :-) a task to do return NULL; } // -------------------------------------------------------------------------------- ::rtl::OUString SAL_CALL KabConnection::nativeSQL( const ::rtl::OUString& _sSql ) throw(SQLException, RuntimeException) { ::osl::MutexGuard aGuard( m_aMutex ); // when you need to transform SQL92 to you driver specific you can do it here return _sSql; } // -------------------------------------------------------------------------------- void SAL_CALL KabConnection::setAutoCommit( sal_Bool ) throw(SQLException, RuntimeException) { ::osl::MutexGuard aGuard( m_aMutex ); checkDisposed(KabConnection_BASE::rBHelper.bDisposed); // here you have to set your commit mode please have a look at the jdbc documentation to get a clear explanation } // -------------------------------------------------------------------------------- sal_Bool SAL_CALL KabConnection::getAutoCommit( ) throw(SQLException, RuntimeException) { ::osl::MutexGuard aGuard( m_aMutex ); checkDisposed(KabConnection_BASE::rBHelper.bDisposed); // you have to distinguish which if you are in autocommit mode or not // at normal case true should be fine here return sal_True; } // -------------------------------------------------------------------------------- void SAL_CALL KabConnection::commit( ) throw(SQLException, RuntimeException) { ::osl::MutexGuard aGuard( m_aMutex ); checkDisposed(KabConnection_BASE::rBHelper.bDisposed); // when you database does support transactions you should commit here } // -------------------------------------------------------------------------------- void SAL_CALL KabConnection::rollback( ) throw(SQLException, RuntimeException) { ::osl::MutexGuard aGuard( m_aMutex ); checkDisposed(KabConnection_BASE::rBHelper.bDisposed); // same as commit but for the other case } // -------------------------------------------------------------------------------- sal_Bool SAL_CALL KabConnection::isClosed( ) throw(SQLException, RuntimeException) { ::osl::MutexGuard aGuard( m_aMutex ); // just simple -> we are closed when we are disposed, that means someone called dispose(); (XComponent) return KabConnection_BASE::rBHelper.bDisposed; } // -------------------------------------------------------------------------------- Reference< XDatabaseMetaData > SAL_CALL KabConnection::getMetaData( ) throw(SQLException, RuntimeException) { ::osl::MutexGuard aGuard( m_aMutex ); checkDisposed(KabConnection_BASE::rBHelper.bDisposed); // here we have to create the class with biggest interface // The answer is 42 :-) Reference< XDatabaseMetaData > xMetaData = m_xMetaData; if (!xMetaData.is()) { xMetaData = new KabDatabaseMetaData(this); // need the connection because it can return it m_xMetaData = xMetaData; } return xMetaData; } // -------------------------------------------------------------------------------- void SAL_CALL KabConnection::setReadOnly( sal_Bool ) throw(SQLException, RuntimeException) { ::osl::MutexGuard aGuard( m_aMutex ); checkDisposed(KabConnection_BASE::rBHelper.bDisposed); // set you connection to readonly } // -------------------------------------------------------------------------------- sal_Bool SAL_CALL KabConnection::isReadOnly( ) throw(SQLException, RuntimeException) { ::osl::MutexGuard aGuard( m_aMutex ); checkDisposed(KabConnection_BASE::rBHelper.bDisposed); // return if your connection to readonly return sal_False; } // -------------------------------------------------------------------------------- void SAL_CALL KabConnection::setCatalog( const ::rtl::OUString& ) throw(SQLException, RuntimeException) { ::osl::MutexGuard aGuard( m_aMutex ); checkDisposed(KabConnection_BASE::rBHelper.bDisposed); // if your database doesn't work with catalogs you go to next method otherwise you kjnow what to do } // -------------------------------------------------------------------------------- ::rtl::OUString SAL_CALL KabConnection::getCatalog( ) throw(SQLException, RuntimeException) { ::osl::MutexGuard aGuard( m_aMutex ); checkDisposed(KabConnection_BASE::rBHelper.bDisposed); // return your current catalog return ::rtl::OUString(); } // -------------------------------------------------------------------------------- void SAL_CALL KabConnection::setTransactionIsolation( sal_Int32 ) throw(SQLException, RuntimeException) { ::osl::MutexGuard aGuard( m_aMutex ); checkDisposed(KabConnection_BASE::rBHelper.bDisposed); // set your isolation level // please have a look at @see com.sun.star.sdbc.TransactionIsolation } // -------------------------------------------------------------------------------- sal_Int32 SAL_CALL KabConnection::getTransactionIsolation( ) throw(SQLException, RuntimeException) { ::osl::MutexGuard aGuard( m_aMutex ); checkDisposed(KabConnection_BASE::rBHelper.bDisposed); // please have a look at @see com.sun.star.sdbc.TransactionIsolation return TransactionIsolation::NONE; } // -------------------------------------------------------------------------------- Reference< ::com::sun::star::container::XNameAccess > SAL_CALL KabConnection::getTypeMap( ) throw(SQLException, RuntimeException) { ::osl::MutexGuard aGuard( m_aMutex ); checkDisposed(KabConnection_BASE::rBHelper.bDisposed); // if your driver has special database types you can return it here return NULL; } // -------------------------------------------------------------------------------- void SAL_CALL KabConnection::setTypeMap( const Reference< ::com::sun::star::container::XNameAccess >& ) throw(SQLException, RuntimeException) { // the other way around } // -------------------------------------------------------------------------------- // XCloseable void SAL_CALL KabConnection::close( ) throw(SQLException, RuntimeException) { { ::osl::MutexGuard aGuard( m_aMutex ); checkDisposed(KabConnection_BASE::rBHelper.bDisposed); } dispose(); } // -------------------------------------------------------------------------------- // XWarningsSupplier Any SAL_CALL KabConnection::getWarnings( ) throw(SQLException, RuntimeException) { // when you collected some warnings -> return it return Any(); } // -------------------------------------------------------------------------------- void SAL_CALL KabConnection::clearWarnings( ) throw(SQLException, RuntimeException) { // you should clear your collected warnings here } //------------------------------------------------------------------------------ void KabConnection::disposing() { // we noticed that we should be destroied in near future so we have to dispose our statements ::osl::MutexGuard aGuard(m_aMutex); for (OWeakRefArray::iterator i = m_aStatements.begin(); m_aStatements.end() != i; ++i) { Reference< XComponent > xComp(i->get(), UNO_QUERY); if (xComp.is()) xComp->dispose(); } m_aStatements.clear(); if (m_pAddressBook != NULL) { m_pAddressBook->close(); m_pAddressBook = NULL; } m_xMetaData = ::com::sun::star::uno::WeakReference< ::com::sun::star::sdbc::XDatabaseMetaData>(); dispose_ChildImpl(); KabConnection_BASE::disposing(); } // ----------------------------------------------------------------------------- Reference< XTablesSupplier > SAL_CALL KabConnection::createCatalog() { ::osl::MutexGuard aGuard( m_aMutex ); Reference< XTablesSupplier > xTab = m_xCatalog; if (!m_xCatalog.is()) { KabCatalog *pCat = new KabCatalog(this); xTab = pCat; m_xCatalog = xTab; } return xTab; } // ----------------------------------------------------------------------------- ::KABC::AddressBook* KabConnection::getAddressBook() const { return m_pAddressBook; } // ----------------------------------------------------------------------------- extern "C" SAL_DLLPUBLIC_EXPORT void* SAL_CALL createKabConnection( void* _pDriver ) { KabConnection* pConnection = new KabConnection( static_cast< KabDriver* >( _pDriver ) ); // by definition, the pointer crossing library boundaries as void ptr is acquired once pConnection->acquire(); return pConnection; }