Branch data Line data Source code
1 : : /* -*- Mode: C++; tab-width: 4; indent-tabs-mode: nil; c-basic-offset: 4 -*- */
2 : : /*************************************************************************
3 : : *
4 : : * Effective License of whole file:
5 : : *
6 : : * This library is free software; you can redistribute it and/or
7 : : * modify it under the terms of the GNU Lesser General Public
8 : : * License version 2.1, as published by the Free Software Foundation.
9 : : *
10 : : * This library is distributed in the hope that it will be useful,
11 : : * but WITHOUT ANY WARRANTY; without even the implied warranty of
12 : : * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
13 : : * Lesser General Public License for more details.
14 : : *
15 : : * You should have received a copy of the GNU Lesser General Public
16 : : * License along with this library; if not, write to the Free Software
17 : : * Foundation, Inc., 59 Temple Place, Suite 330, Boston,
18 : : * MA 02111-1307 USA
19 : : *
20 : : * Parts "Copyright by Sun Microsystems, Inc" prior to August 2011:
21 : : *
22 : : * The Contents of this file are made available subject to the terms of
23 : : * the GNU Lesser General Public License Version 2.1
24 : : *
25 : : * Copyright: 2000 by Sun Microsystems, Inc.
26 : : *
27 : : * Contributor(s): Joerg Budischewski
28 : : *
29 : : * All parts contributed on or after August 2011:
30 : : *
31 : : * Version: MPL 1.1 / GPLv3+ / LGPLv2.1+
32 : : *
33 : : * The contents of this file are subject to the Mozilla Public License Version
34 : : * 1.1 (the "License"); you may not use this file except in compliance with
35 : : * the License or as specified alternatively below. You may obtain a copy of
36 : : * the License at http://www.mozilla.org/MPL/
37 : : *
38 : : * Software distributed under the License is distributed on an "AS IS" basis,
39 : : * WITHOUT WARRANTY OF ANY KIND, either express or implied. See the License
40 : : * for the specific language governing rights and limitations under the
41 : : * License.
42 : : *
43 : : * Major Contributor(s):
44 : : * [ Copyright (C) 2011 Lionel Elie Mamane <lionel@mamane.lu> ]
45 : : *
46 : : * All Rights Reserved.
47 : : *
48 : : * For minor contributions see the git repository.
49 : : *
50 : : * Alternatively, the contents of this file may be used under the terms of
51 : : * either the GNU General Public License Version 3 or later (the "GPLv3+"), or
52 : : * the GNU Lesser General Public License Version 2.1 or later (the "LGPLv2.1+"),
53 : : * in which case the provisions of the GPLv3+ or the LGPLv2.1+ are applicable
54 : : * instead of those above.
55 : : *
56 : : ************************************************************************/
57 : :
58 : : #ifndef _PQ_CONNECTION_HXX_
59 : : #define _PQ_CONNECTION_HXX_
60 : : #include <boost/unordered_map.hpp>
61 : : #include <com/sun/star/uno/XComponentContext.hpp>
62 : : #include <com/sun/star/lang/XInitialization.hpp>
63 : : #include <com/sun/star/script/XTypeConverter.hpp>
64 : : #include <com/sun/star/sdbc/XWarningsSupplier.hpp>
65 : : #include <com/sun/star/sdbcx/XTablesSupplier.hpp>
66 : : #include <com/sun/star/sdbcx/XUsersSupplier.hpp>
67 : : #include <com/sun/star/sdbcx/XViewsSupplier.hpp>
68 : : #include <com/sun/star/sdbc/XConnection.hpp>
69 : :
70 : : #include <com/sun/star/container/XNameAccess.hpp>
71 : :
72 : : #include <rtl/ref.hxx>
73 : : #include <rtl/byteseq.hxx>
74 : :
75 : : #include <salhelper/simplereferenceobject.hxx>
76 : :
77 : : #include <cppuhelper/weakref.hxx>
78 : : #include <cppuhelper/compbase6.hxx>
79 : :
80 : : #include <libpq-fe.h>
81 : : #include "pq_allocator.hxx"
82 : :
83 : : namespace pq_sdbc_driver
84 : : {
85 : : #ifdef POSTGRE_TRACE
86 : : #define POSTGRE_TRACE( x ) printf( "%s\n" , x )
87 : : #else
88 : : #define POSTGRE_TRACE(x) ((void)0)
89 : : #endif
90 : :
91 : 0 : class RefCountedMutex : public salhelper::SimpleReferenceObject
92 : : {
93 : : public:
94 : : osl::Mutex mutex;
95 : : };
96 : :
97 : : struct ConnectionSettings;
98 : :
99 : :
100 : :
101 : : //--------------------------------------------------
102 : : // Logging API
103 : : //--------------------------------------------------
104 : : namespace LogLevel
105 : : {
106 : : // when you add a loglevel, extend the log function !
107 : : static const sal_Int32 NONE = 0;
108 : : static const sal_Int32 ERROR = 1;
109 : : static const sal_Int32 SQL = 2;
110 : : static const sal_Int32 INFO = 3;
111 : : static const sal_Int32 DATA = 4;
112 : : }
113 : : bool isLog( ConnectionSettings *settings, int loglevel );
114 : : void log( ConnectionSettings *settings, sal_Int32 level, const rtl::OUString &logString );
115 : : void log( ConnectionSettings *settings, sal_Int32 level, const char *str );
116 : : //--------------------------------------------------
117 : :
118 : : class Tables;
119 : : class Views;
120 : 0 : struct ConnectionSettings
121 : : {
122 : 0 : ConnectionSettings() :
123 : : encoding( RTL_TEXTENCODING_UTF8),
124 : : pConnection(0),
125 : : maxNameLen(0),
126 : : maxIndexKeys(0),
127 : : showSystemColumns( sal_False ),
128 : : logFile( 0 ),
129 : 0 : loglevel( LogLevel::INFO )
130 : 0 : {}
131 : : rtl_TextEncoding encoding;
132 : : PGconn *pConnection;
133 : : sal_Int32 maxNameLen;
134 : : sal_Int32 maxIndexKeys;
135 : : ::com::sun::star::uno::Reference< com::sun::star::script::XTypeConverter > tc;
136 : : ::com::sun::star::uno::Reference< com::sun::star::container::XNameAccess > tables;
137 : : ::com::sun::star::uno::Reference< com::sun::star::container::XNameAccess > users;
138 : : ::com::sun::star::uno::Reference< com::sun::star::container::XNameAccess > views;
139 : : Tables *pTablesImpl; // needed to implement renaming of tables / views
140 : : Views *pViewsImpl; // needed to implement renaming of tables / views
141 : : ::rtl::OUString user;
142 : : ::rtl::OUString catalog;
143 : : sal_Bool showSystemColumns;
144 : : FILE *logFile;
145 : : sal_Int32 loglevel;
146 : : };
147 : :
148 : : //--------------------------------------------------
149 : : typedef cppu::WeakComponentImplHelper6<
150 : : com::sun::star::sdbc::XConnection,
151 : : com::sun::star::sdbc::XWarningsSupplier,
152 : : com::sun::star::lang::XInitialization,
153 : : com::sun::star::sdbcx::XTablesSupplier,
154 : : com::sun::star::sdbcx::XViewsSupplier,
155 : : com::sun::star::sdbcx::XUsersSupplier > ConnectionBase;
156 : :
157 : : // some types
158 : : struct HashByteSequence
159 : : {
160 : 0 : sal_Int32 operator () ( const ::rtl::ByteSequence & seq ) const
161 : : {
162 : 0 : return *(sal_Int32*) seq.getConstArray();
163 : : }
164 : : };
165 : :
166 : : typedef ::boost::unordered_map<
167 : : ::rtl::ByteSequence,
168 : : ::com::sun::star::uno::WeakReference< com::sun::star::sdbc::XCloseable >,
169 : : HashByteSequence,
170 : : ::std::equal_to< ::rtl::ByteSequence >,
171 : : Allocator< std::pair< const ::rtl::ByteSequence,::com::sun::star::uno::WeakReference< com::sun::star::sdbc::XCloseable > > >
172 : : > WeakHashMap;
173 : : typedef ::std::vector< rtl::OString, Allocator< ::rtl::OString > > OStringVector;
174 : :
175 : :
176 : :
177 : : typedef ::boost::unordered_map
178 : : <
179 : : const sal_Int32,
180 : : rtl::OUString,
181 : : ::boost::hash< sal_Int32 >,
182 : : ::std::equal_to< sal_Int32 >,
183 : : Allocator< ::std::pair< sal_Int32, ::rtl::OUString > >
184 : : > Int2StringMap;
185 : :
186 : : class Connection : public ConnectionBase
187 : : {
188 : : ::com::sun::star::uno::Reference< com::sun::star::uno::XComponentContext > m_ctx;
189 : : ::com::sun::star::uno::Reference< com::sun::star::container::XNameAccess > m_typeMap;
190 : : ConnectionSettings m_settings;
191 : : ::rtl::Reference< RefCountedMutex > m_refMutex;
192 : : ::com::sun::star::uno::Reference< com::sun::star::sdbc::XDatabaseMetaData > m_meta;
193 : : WeakHashMap m_myStatements;
194 : :
195 : : private:
196 : : void checkClosed()
197 : : throw ( com::sun::star::sdbc::SQLException, com::sun::star::uno::RuntimeException );
198 : :
199 : : public:
200 : : Connection(
201 : : const rtl::Reference< RefCountedMutex > &refMutex,
202 : : const ::com::sun::star::uno::Reference< ::com::sun::star::uno::XComponentContext > & ctx );
203 : :
204 : : ~Connection( );
205 : :
206 : : public: // XCloseable
207 : : virtual void SAL_CALL close()
208 : : throw ( ::com::sun::star::sdbc::SQLException, ::com::sun::star::uno::RuntimeException );
209 : :
210 : : public: // XConnection
211 : :
212 : : virtual ::com::sun::star::uno::Reference< ::com::sun::star::sdbc::XStatement > SAL_CALL createStatement( )
213 : : throw (::com::sun::star::sdbc::SQLException, ::com::sun::star::uno::RuntimeException) ;
214 : : virtual ::com::sun::star::uno::Reference< ::com::sun::star::sdbc::XPreparedStatement > SAL_CALL prepareStatement(
215 : : const ::rtl::OUString& sql )
216 : : throw (::com::sun::star::sdbc::SQLException, ::com::sun::star::uno::RuntimeException);
217 : : virtual ::com::sun::star::uno::Reference< ::com::sun::star::sdbc::XPreparedStatement > SAL_CALL prepareCall(
218 : : const ::rtl::OUString& sql )
219 : : throw (::com::sun::star::sdbc::SQLException, ::com::sun::star::uno::RuntimeException);
220 : : virtual ::rtl::OUString SAL_CALL nativeSQL( const ::rtl::OUString& sql )
221 : : throw (::com::sun::star::sdbc::SQLException, ::com::sun::star::uno::RuntimeException);
222 : : virtual void SAL_CALL setAutoCommit( sal_Bool autoCommit )
223 : : throw (::com::sun::star::sdbc::SQLException, ::com::sun::star::uno::RuntimeException);
224 : : virtual sal_Bool SAL_CALL getAutoCommit( )
225 : : throw (::com::sun::star::sdbc::SQLException, ::com::sun::star::uno::RuntimeException);
226 : : virtual void SAL_CALL commit( )
227 : : throw (::com::sun::star::sdbc::SQLException, ::com::sun::star::uno::RuntimeException);
228 : : virtual void SAL_CALL rollback( )
229 : : throw (::com::sun::star::sdbc::SQLException, ::com::sun::star::uno::RuntimeException);
230 : : virtual sal_Bool SAL_CALL isClosed( )
231 : : throw (::com::sun::star::sdbc::SQLException, ::com::sun::star::uno::RuntimeException);
232 : : virtual ::com::sun::star::uno::Reference< com::sun::star::sdbc::XDatabaseMetaData > SAL_CALL getMetaData( )
233 : : throw (::com::sun::star::sdbc::SQLException, ::com::sun::star::uno::RuntimeException);
234 : : virtual void SAL_CALL setReadOnly( sal_Bool readOnly )
235 : : throw (::com::sun::star::sdbc::SQLException, ::com::sun::star::uno::RuntimeException);
236 : : virtual sal_Bool SAL_CALL isReadOnly( )
237 : : throw (::com::sun::star::sdbc::SQLException, ::com::sun::star::uno::RuntimeException);
238 : : virtual void SAL_CALL setCatalog( const ::rtl::OUString& catalog )
239 : : throw (::com::sun::star::sdbc::SQLException, ::com::sun::star::uno::RuntimeException);
240 : : virtual ::rtl::OUString SAL_CALL getCatalog( )
241 : : throw (::com::sun::star::sdbc::SQLException, ::com::sun::star::uno::RuntimeException);
242 : : virtual void SAL_CALL setTransactionIsolation( sal_Int32 level )
243 : : throw (::com::sun::star::sdbc::SQLException, ::com::sun::star::uno::RuntimeException);
244 : : virtual sal_Int32 SAL_CALL getTransactionIsolation( )
245 : : throw (::com::sun::star::sdbc::SQLException, ::com::sun::star::uno::RuntimeException);
246 : : virtual ::com::sun::star::uno::Reference< com::sun::star::container::XNameAccess > SAL_CALL getTypeMap( )
247 : : throw (::com::sun::star::sdbc::SQLException, ::com::sun::star::uno::RuntimeException);
248 : : virtual void SAL_CALL setTypeMap(
249 : : const ::com::sun::star::uno::Reference< com::sun::star::container::XNameAccess >& typeMap )
250 : : throw (::com::sun::star::sdbc::SQLException, ::com::sun::star::uno::RuntimeException);
251 : :
252 : : public: // XWarningsSupplier
253 : : virtual ::com::sun::star::uno::Any SAL_CALL getWarnings( )
254 : : throw (::com::sun::star::sdbc::SQLException, ::com::sun::star::uno::RuntimeException);
255 : : virtual void SAL_CALL clearWarnings( )
256 : : throw (::com::sun::star::sdbc::SQLException, ::com::sun::star::uno::RuntimeException);
257 : :
258 : : public: // XInitialization
259 : : virtual void SAL_CALL initialize(
260 : : const ::com::sun::star::uno::Sequence< ::com::sun::star::uno::Any >& aArguments )
261 : : throw (com::sun::star::uno::Exception, ::com::sun::star::uno::RuntimeException);
262 : :
263 : : public: // XTablesSupplier
264 : : virtual ::com::sun::star::uno::Reference< ::com::sun::star::container::XNameAccess > SAL_CALL getTables( ) throw (::com::sun::star::uno::RuntimeException);
265 : :
266 : : public: // XUsersSupplier
267 : : virtual ::com::sun::star::uno::Reference< ::com::sun::star::container::XNameAccess > SAL_CALL getUsers( ) throw (::com::sun::star::uno::RuntimeException);
268 : :
269 : : public: // XViewsSupplier
270 : : virtual ::com::sun::star::uno::Reference< ::com::sun::star::container::XNameAccess > SAL_CALL getViews( ) throw (::com::sun::star::uno::RuntimeException);
271 : :
272 : : public:
273 : : virtual void SAL_CALL disposing();
274 : :
275 : : public: // helper function
276 : : void removeFromWeakMap( const ::rtl::ByteSequence & seq );
277 : : };
278 : :
279 : : }
280 : : #endif
|