1 /************************************************************** 2 * 3 * Licensed to the Apache Software Foundation (ASF) under one 4 * or more contributor license agreements. See the NOTICE file 5 * distributed with this work for additional information 6 * regarding copyright ownership. The ASF licenses this file 7 * to you under the Apache License, Version 2.0 (the 8 * "License"); you may not use this file except in compliance 9 * with the License. You may obtain a copy of the License at 10 * 11 * http://www.apache.org/licenses/LICENSE-2.0 12 * 13 * Unless required by applicable law or agreed to in writing, 14 * software distributed under the License is distributed on an 15 * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY 16 * KIND, either express or implied. See the License for the 17 * specific language governing permissions and limitations 18 * under the License. 19 * 20 *************************************************************/ 21 22 23 24 // MARKER(update_precomp.py): autogen include statement, do not remove 25 #include "precompiled_connectivity.hxx" 26 27 #include "MacabConnection.hxx" 28 #include "MacabAddressBook.hxx" 29 #include "MacabDatabaseMetaData.hxx" 30 #include "MacabStatement.hxx" 31 #include "MacabPreparedStatement.hxx" 32 #include "MacabDriver.hxx" 33 #include "MacabCatalog.hxx" 34 #include <com/sun/star/sdbc/ColumnValue.hpp> 35 #include <com/sun/star/sdbc/TransactionIsolation.hpp> 36 37 using namespace connectivity::macab; 38 using namespace com::sun::star::uno; 39 using namespace com::sun::star::lang; 40 using namespace com::sun::star::beans; 41 using namespace com::sun::star::sdbc; 42 using namespace com::sun::star::sdbcx; 43 44 IMPLEMENT_SERVICE_INFO(MacabConnection, "com.sun.star.sdbc.drivers.MacabConnection", "com.sun.star.sdbc.Connection") 45 //----------------------------------------------------------------------------- 46 MacabConnection::MacabConnection(MacabDriver* _pDriver) 47 : OSubComponent<MacabConnection, MacabConnection_BASE>((::cppu::OWeakObject*)_pDriver, this), 48 m_pAddressBook(NULL), 49 m_pDriver(_pDriver) 50 { 51 m_pDriver->acquire(); 52 } 53 //----------------------------------------------------------------------------- 54 MacabConnection::~MacabConnection() 55 { 56 if (!isClosed()) 57 close(); 58 59 m_pDriver->release(); 60 m_pDriver = NULL; 61 } 62 //----------------------------------------------------------------------------- 63 void SAL_CALL MacabConnection::release() throw() 64 { 65 relase_ChildImpl(); 66 } 67 // ----------------------------------------------------------------------------- 68 void MacabConnection::construct(const ::rtl::OUString&, const Sequence< PropertyValue >&) throw(SQLException) 69 { 70 osl_incrementInterlockedCount( &m_refCount ); 71 72 // get the Mac OS X shared address book 73 m_pAddressBook = new MacabAddressBook(); 74 75 osl_decrementInterlockedCount( &m_refCount ); 76 } 77 // XServiceInfo 78 // -------------------------------------------------------------------------------- 79 Reference< XStatement > SAL_CALL MacabConnection::createStatement( ) throw(SQLException, RuntimeException) 80 { 81 ::osl::MutexGuard aGuard( m_aMutex ); 82 checkDisposed(MacabConnection_BASE::rBHelper.bDisposed); 83 84 // create a statement 85 // the statement can only be executed once 86 Reference< XStatement > xReturn = new MacabStatement(this); 87 m_aStatements.push_back(WeakReferenceHelper(xReturn)); 88 return xReturn; 89 } 90 // -------------------------------------------------------------------------------- 91 Reference< XPreparedStatement > SAL_CALL MacabConnection::prepareStatement( const ::rtl::OUString& _sSql ) throw(SQLException, RuntimeException) 92 { 93 ::osl::MutexGuard aGuard( m_aMutex ); 94 checkDisposed(MacabConnection_BASE::rBHelper.bDisposed); 95 96 // create a statement 97 // the statement can only be executed more than once 98 Reference< XPreparedStatement > xReturn = new MacabPreparedStatement(this, _sSql); 99 m_aStatements.push_back(WeakReferenceHelper(xReturn)); 100 return xReturn; 101 } 102 // -------------------------------------------------------------------------------- 103 Reference< XPreparedStatement > SAL_CALL MacabConnection::prepareCall( const ::rtl::OUString& ) throw(SQLException, RuntimeException) 104 { 105 ::osl::MutexGuard aGuard( m_aMutex ); 106 checkDisposed(MacabConnection_BASE::rBHelper.bDisposed); 107 108 // not implemented yet :-) a task to do 109 return NULL; 110 } 111 // -------------------------------------------------------------------------------- 112 ::rtl::OUString SAL_CALL MacabConnection::nativeSQL( const ::rtl::OUString& _sSql ) throw(SQLException, RuntimeException) 113 { 114 ::osl::MutexGuard aGuard( m_aMutex ); 115 // when you need to transform SQL92 to you driver specific you can do it here 116 117 return _sSql; 118 } 119 // -------------------------------------------------------------------------------- 120 void SAL_CALL MacabConnection::setAutoCommit( sal_Bool ) throw(SQLException, RuntimeException) 121 { 122 ::osl::MutexGuard aGuard( m_aMutex ); 123 checkDisposed(MacabConnection_BASE::rBHelper.bDisposed); 124 // here you have to set your commit mode please have a look at the jdbc documentation to get a clear explanation 125 } 126 // -------------------------------------------------------------------------------- 127 sal_Bool SAL_CALL MacabConnection::getAutoCommit( ) throw(SQLException, RuntimeException) 128 { 129 ::osl::MutexGuard aGuard( m_aMutex ); 130 checkDisposed(MacabConnection_BASE::rBHelper.bDisposed); 131 // you have to distinguish which if you are in autocommit mode or not 132 // at normal case true should be fine here 133 134 return sal_True; 135 } 136 // -------------------------------------------------------------------------------- 137 void SAL_CALL MacabConnection::commit( ) throw(SQLException, RuntimeException) 138 { 139 ::osl::MutexGuard aGuard( m_aMutex ); 140 checkDisposed(MacabConnection_BASE::rBHelper.bDisposed); 141 142 // when you database does support transactions you should commit here 143 } 144 // -------------------------------------------------------------------------------- 145 void SAL_CALL MacabConnection::rollback( ) throw(SQLException, RuntimeException) 146 { 147 ::osl::MutexGuard aGuard( m_aMutex ); 148 checkDisposed(MacabConnection_BASE::rBHelper.bDisposed); 149 150 // same as commit but for the other case 151 } 152 // -------------------------------------------------------------------------------- 153 sal_Bool SAL_CALL MacabConnection::isClosed( ) throw(SQLException, RuntimeException) 154 { 155 ::osl::MutexGuard aGuard( m_aMutex ); 156 157 // just simple -> we are closed when we are disposed, that means someone called dispose(); (XComponent) 158 return MacabConnection_BASE::rBHelper.bDisposed; 159 } 160 // -------------------------------------------------------------------------------- 161 Reference< XDatabaseMetaData > SAL_CALL MacabConnection::getMetaData( ) throw(SQLException, RuntimeException) 162 { 163 ::osl::MutexGuard aGuard( m_aMutex ); 164 checkDisposed(MacabConnection_BASE::rBHelper.bDisposed); 165 166 // here we have to create the class with biggest interface 167 // The answer is 42 :-) 168 Reference< XDatabaseMetaData > xMetaData = m_xMetaData; 169 if (!xMetaData.is()) 170 { 171 xMetaData = new MacabDatabaseMetaData(this); // need the connection because it can return it 172 m_xMetaData = xMetaData; 173 } 174 175 return xMetaData; 176 } 177 // -------------------------------------------------------------------------------- 178 void SAL_CALL MacabConnection::setReadOnly( sal_Bool ) throw(SQLException, RuntimeException) 179 { 180 ::osl::MutexGuard aGuard( m_aMutex ); 181 checkDisposed(MacabConnection_BASE::rBHelper.bDisposed); 182 183 // set you connection to readonly 184 } 185 // -------------------------------------------------------------------------------- 186 sal_Bool SAL_CALL MacabConnection::isReadOnly( ) throw(SQLException, RuntimeException) 187 { 188 ::osl::MutexGuard aGuard( m_aMutex ); 189 checkDisposed(MacabConnection_BASE::rBHelper.bDisposed); 190 191 // return if your connection to readonly 192 return sal_False; 193 } 194 // -------------------------------------------------------------------------------- 195 void SAL_CALL MacabConnection::setCatalog( const ::rtl::OUString& ) throw(SQLException, RuntimeException) 196 { 197 ::osl::MutexGuard aGuard( m_aMutex ); 198 checkDisposed(MacabConnection_BASE::rBHelper.bDisposed); 199 200 // if your database doesn't work with catalogs you go to next method otherwise you kjnow what to do 201 } 202 // -------------------------------------------------------------------------------- 203 ::rtl::OUString SAL_CALL MacabConnection::getCatalog( ) throw(SQLException, RuntimeException) 204 { 205 ::osl::MutexGuard aGuard( m_aMutex ); 206 checkDisposed(MacabConnection_BASE::rBHelper.bDisposed); 207 208 209 // return your current catalog 210 return ::rtl::OUString(); 211 } 212 // -------------------------------------------------------------------------------- 213 void SAL_CALL MacabConnection::setTransactionIsolation( sal_Int32 ) throw(SQLException, RuntimeException) 214 { 215 ::osl::MutexGuard aGuard( m_aMutex ); 216 checkDisposed(MacabConnection_BASE::rBHelper.bDisposed); 217 218 // set your isolation level 219 // please have a look at @see com.sun.star.sdbc.TransactionIsolation 220 } 221 // -------------------------------------------------------------------------------- 222 sal_Int32 SAL_CALL MacabConnection::getTransactionIsolation( ) throw(SQLException, RuntimeException) 223 { 224 ::osl::MutexGuard aGuard( m_aMutex ); 225 checkDisposed(MacabConnection_BASE::rBHelper.bDisposed); 226 227 228 // please have a look at @see com.sun.star.sdbc.TransactionIsolation 229 return TransactionIsolation::NONE; 230 } 231 // -------------------------------------------------------------------------------- 232 Reference< ::com::sun::star::container::XNameAccess > SAL_CALL MacabConnection::getTypeMap( ) throw(SQLException, RuntimeException) 233 { 234 ::osl::MutexGuard aGuard( m_aMutex ); 235 checkDisposed(MacabConnection_BASE::rBHelper.bDisposed); 236 237 // if your driver has special database types you can return it here 238 239 return NULL; 240 } 241 // -------------------------------------------------------------------------------- 242 void SAL_CALL MacabConnection::setTypeMap( const Reference< ::com::sun::star::container::XNameAccess >& ) throw(SQLException, RuntimeException) 243 { 244 // the other way around 245 } 246 // -------------------------------------------------------------------------------- 247 // XCloseable 248 void SAL_CALL MacabConnection::close( ) throw(SQLException, RuntimeException) 249 { 250 { 251 ::osl::MutexGuard aGuard( m_aMutex ); 252 checkDisposed(MacabConnection_BASE::rBHelper.bDisposed); 253 } 254 dispose(); 255 } 256 // -------------------------------------------------------------------------------- 257 // XWarningsSupplier 258 Any SAL_CALL MacabConnection::getWarnings( ) throw(SQLException, RuntimeException) 259 { 260 // when you collected some warnings -> return it 261 return Any(); 262 } 263 // -------------------------------------------------------------------------------- 264 void SAL_CALL MacabConnection::clearWarnings( ) throw(SQLException, RuntimeException) 265 { 266 // you should clear your collected warnings here 267 } 268 //------------------------------------------------------------------------------ 269 void MacabConnection::disposing() 270 { 271 // we noticed that we should be destroied in near future so we have to dispose our statements 272 ::osl::MutexGuard aGuard(m_aMutex); 273 274 for (OWeakRefArray::iterator i = m_aStatements.begin(); m_aStatements.end() != i; ++i) 275 { 276 Reference< XComponent > xComp(i->get(), UNO_QUERY); 277 if (xComp.is()) 278 xComp->dispose(); 279 } 280 m_aStatements.clear(); 281 282 if (m_pAddressBook != NULL) 283 { 284 delete m_pAddressBook; 285 m_pAddressBook = NULL; 286 } 287 288 m_xMetaData = ::com::sun::star::uno::WeakReference< ::com::sun::star::sdbc::XDatabaseMetaData>(); 289 290 dispose_ChildImpl(); 291 MacabConnection_BASE::disposing(); 292 } 293 // ----------------------------------------------------------------------------- 294 Reference< XTablesSupplier > SAL_CALL MacabConnection::createCatalog() 295 { 296 ::osl::MutexGuard aGuard( m_aMutex ); 297 298 Reference< XTablesSupplier > xTab = m_xCatalog; 299 if (!m_xCatalog.is()) 300 { 301 MacabCatalog *pCat = new MacabCatalog(this); 302 xTab = pCat; 303 m_xCatalog = xTab; 304 } 305 return xTab; 306 } 307 // ----------------------------------------------------------------------------- 308 MacabAddressBook* MacabConnection::getAddressBook() const 309 { 310 return m_pAddressBook; 311 } 312 // ----------------------------------------------------------------------------- 313 extern "C" SAL_DLLPUBLIC_EXPORT void* SAL_CALL createMacabConnection( void* _pDriver ) 314 { 315 MacabConnection* pConnection = new MacabConnection( static_cast< MacabDriver* >( _pDriver ) ); 316 // by definition, the pointer crossing library boundaries as void ptr is acquired once 317 pConnection->acquire(); 318 return pConnection; 319 } 320 321