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