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 : #include <rtl/ustrbuf.hxx>
59 : #include <rtl/strbuf.hxx>
60 :
61 : #include <com/sun/star/sdbc/XRow.hpp>
62 : #include <com/sun/star/sdbc/XParameters.hpp>
63 : #include <com/sun/star/sdbc/KeyRule.hpp>
64 : #include <com/sun/star/sdbcx/KeyType.hpp>
65 :
66 : #include "pq_xkeys.hxx"
67 : #include "pq_xkey.hxx"
68 : #include "pq_statics.hxx"
69 : #include "pq_tools.hxx"
70 :
71 : using osl::MutexGuard;
72 :
73 : using rtl::OUString;
74 : using rtl::OUStringBuffer;
75 : using rtl::OUStringToOString;
76 :
77 : using com::sun::star::beans::XPropertySet;
78 :
79 : using com::sun::star::uno::Any;
80 : using com::sun::star::uno::makeAny;
81 : using com::sun::star::uno::UNO_QUERY;
82 : using com::sun::star::uno::Type;
83 : using com::sun::star::uno::XInterface;
84 : using com::sun::star::uno::Reference;
85 : using com::sun::star::uno::Sequence;
86 : using com::sun::star::uno::RuntimeException;
87 :
88 : using com::sun::star::container::NoSuchElementException;
89 : using com::sun::star::lang::WrappedTargetException;
90 :
91 : using com::sun::star::sdbc::XRow;
92 : using com::sun::star::sdbc::XCloseable;
93 : using com::sun::star::sdbc::XStatement;
94 : using com::sun::star::sdbc::XResultSet;
95 : using com::sun::star::sdbc::XParameters;
96 : using com::sun::star::sdbc::XPreparedStatement;
97 : using com::sun::star::sdbc::XDatabaseMetaData;
98 :
99 : namespace pq_sdbc_driver
100 : {
101 : #define ASCII_STR(x) OUString( RTL_CONSTASCII_USTRINGPARAM( x ) )
102 :
103 0 : Keys::Keys(
104 : const ::rtl::Reference< RefCountedMutex > & refMutex,
105 : const ::com::sun::star::uno::Reference< com::sun::star::sdbc::XConnection > & origin,
106 : ConnectionSettings *pSettings,
107 : const rtl::OUString &schemaName,
108 : const rtl::OUString &tableName)
109 0 : : Container( refMutex, origin, pSettings, getStatics().KEY ),
110 : m_schemaName( schemaName ),
111 0 : m_tableName( tableName )
112 0 : {}
113 :
114 0 : Keys::~Keys()
115 0 : {}
116 :
117 0 : static sal_Int32 string2keytype( const rtl::OUString &type )
118 : {
119 0 : sal_Int32 ret = com::sun::star::sdbcx::KeyType::UNIQUE;
120 0 : if ( type == "p" )
121 0 : ret = com::sun::star::sdbcx::KeyType::PRIMARY;
122 0 : else if ( type == "f" )
123 0 : ret = com::sun::star::sdbcx::KeyType::FOREIGN;
124 0 : return ret;
125 : }
126 :
127 0 : static sal_Int32 string2keyrule( const rtl::OUString & rule )
128 : {
129 0 : sal_Int32 ret = com::sun::star::sdbc::KeyRule::NO_ACTION;
130 0 : if( rule.compareToAscii( RTL_CONSTASCII_STRINGPARAM( "r" ) ) == 0 )
131 0 : ret = com::sun::star::sdbc::KeyRule::RESTRICT;
132 0 : else if( rule.compareToAscii( RTL_CONSTASCII_STRINGPARAM( "c" ) ) == 0 )
133 0 : ret = com::sun::star::sdbc::KeyRule::CASCADE;
134 0 : else if( rule.compareToAscii( RTL_CONSTASCII_STRINGPARAM( "n" ) ) == 0 )
135 0 : ret = com::sun::star::sdbc::KeyRule::SET_NULL;
136 0 : else if( rule.compareToAscii( RTL_CONSTASCII_STRINGPARAM( "d" ) ) == 0 )
137 0 : ret = com::sun::star::sdbc::KeyRule::SET_DEFAULT;
138 0 : return ret;
139 : }
140 :
141 :
142 :
143 : // static void fillAttnum2attnameMap(
144 : // Int2StringMap &map,
145 : // const Reference< com::sun::star::sdbc::XConnection > &conn,
146 : // const rtl::OUString &schema,
147 : // const rtl::OUString &table )
148 : // {
149 : // Reference< XPreparedStatement > prep = conn->prepareStatement(
150 : // ASCII_STR( "SELECT attname,attnum "
151 : // "FROM pg_attribute "
152 : // "INNER JOIN pg_class ON attrelid = pg_class.oid "
153 : // "INNER JOIN pg_namespace ON pg_class.relnamespace = pg_namespace.oid "
154 : // "WHERE relname=? AND nspname=?" ) );
155 :
156 : // Reference< XParameters > paras( prep, UNO_QUERY );
157 : // paras->setString( 1 , table );
158 : // paras->setString( 2 , schema );
159 : // Reference< XResultSet > rs = prep->executeQuery();
160 :
161 : // Reference< XRow > xRow( rs , UNO_QUERY );
162 : // while( rs->next() )
163 : // {
164 : // map[ xRow->getInt(2) ] = xRow->getString(1);
165 : // }
166 : // }
167 :
168 : // static Sequence< rtl::OUString > resolveColumnNames(
169 : // const Int2StringMap &map, const rtl::OUString &array )
170 : // {
171 : // Sequence< sal_Int32 > intArray = string2intarray( array );
172 : // Sequence< ::rtl::OUString > ret( intArray.getLength() );
173 : // for( int i = 0; i < intArray.getLength() ; i ++ )
174 : // {
175 : // Int2StringMap::const_iterator ii = map.find( intArray[i] );
176 : // if( ii != map.end() )
177 : // ret[i] = ii->second;
178 : // }
179 : // return ret;
180 : // }
181 :
182 0 : void Keys::refresh()
183 : throw (::com::sun::star::uno::RuntimeException)
184 : {
185 : try
186 : {
187 0 : if( isLog( m_pSettings, LogLevel::INFO ) )
188 : {
189 0 : rtl::OStringBuffer buf;
190 0 : buf.append( "sdbcx.Keys get refreshed for table " );
191 0 : buf.append( OUStringToOString( m_schemaName, m_pSettings->encoding ) );
192 0 : buf.append( "." );
193 0 : buf.append( OUStringToOString( m_tableName,m_pSettings->encoding ) );
194 0 : log( m_pSettings, LogLevel::INFO, buf.makeStringAndClear().getStr() );
195 : }
196 :
197 0 : osl::MutexGuard guard( m_refMutex->mutex );
198 0 : Statics & st = getStatics();
199 :
200 0 : Int2StringMap mainMap;
201 0 : fillAttnum2attnameMap( mainMap, m_origin, m_schemaName, m_tableName );
202 :
203 0 : Reference< XPreparedStatement > stmt = m_origin->prepareStatement(
204 : ASCII_STR(
205 : "SELECT conname, " // 1
206 : "contype, " // 2
207 : "confupdtype, " // 3
208 : "confdeltype, " // 4
209 : "class2.relname, " // 5
210 : "nmsp2.nspname, " // 6
211 : "conkey," // 7
212 : "confkey " // 8
213 : "FROM pg_constraint INNER JOIN pg_class ON conrelid = pg_class.oid "
214 : "INNER JOIN pg_namespace ON pg_class.relnamespace = pg_namespace.oid "
215 : "LEFT JOIN pg_class AS class2 ON confrelid = class2.oid "
216 : "LEFT JOIN pg_namespace AS nmsp2 ON class2.relnamespace=nmsp2.oid "
217 0 : "WHERE pg_class.relname = ? AND pg_namespace.nspname = ?" ) );
218 :
219 0 : Reference< XParameters > paras( stmt, UNO_QUERY );
220 0 : paras->setString( 1 , m_tableName );
221 0 : paras->setString( 2 , m_schemaName );
222 0 : Reference< XResultSet > rs = stmt->executeQuery();
223 :
224 0 : Reference< XRow > xRow( rs , UNO_QUERY );
225 :
226 0 : String2IntMap map;
227 0 : m_values = Sequence< com::sun::star::uno::Any > ();
228 0 : int keyIndex = 0;
229 0 : while( rs->next() )
230 : {
231 : Key * pKey =
232 0 : new Key( m_refMutex, m_origin, m_pSettings , m_schemaName, m_tableName );
233 0 : Reference< com::sun::star::beans::XPropertySet > prop = pKey;
234 :
235 : pKey->setPropertyValue_NoBroadcast_public(
236 0 : st.NAME, makeAny( xRow->getString( 1 ) ) );
237 0 : sal_Int32 keyType = string2keytype( xRow->getString(2) );
238 0 : pKey->setPropertyValue_NoBroadcast_public( st.TYPE, makeAny( keyType ) );
239 : pKey->setPropertyValue_NoBroadcast_public(
240 0 : st.UPDATE_RULE, makeAny( string2keyrule( xRow->getString(3) ) ) );
241 : pKey->setPropertyValue_NoBroadcast_public(
242 0 : st.DELETE_RULE, makeAny( string2keyrule( xRow->getString(4) ) ) );
243 : pKey->setPropertyValue_NoBroadcast_public(
244 : st.PRIVATE_COLUMNS,
245 : makeAny(
246 : convertMappedIntArray2StringArray(
247 : mainMap,
248 0 : string2intarray( xRow->getString( 7 ) ) ) ) );
249 :
250 0 : if( com::sun::star::sdbcx::KeyType::FOREIGN == keyType )
251 : {
252 0 : OUStringBuffer buf( 128 );
253 0 : buf.append( xRow->getString( 6 ) );
254 0 : buf.appendAscii( RTL_CONSTASCII_STRINGPARAM( "." ) );
255 0 : buf.append( xRow->getString( 5 ) );
256 : pKey->setPropertyValue_NoBroadcast_public(
257 0 : st.REFERENCED_TABLE, makeAny( buf.makeStringAndClear() ) );
258 :
259 0 : Int2StringMap foreignMap;
260 0 : fillAttnum2attnameMap( foreignMap, m_origin, xRow->getString(6), xRow->getString(5));
261 : pKey->setPropertyValue_NoBroadcast_public(
262 : st.PRIVATE_FOREIGN_COLUMNS,
263 : makeAny(
264 : convertMappedIntArray2StringArray(
265 : foreignMap,
266 0 : string2intarray( xRow->getString(8) ) ) ) );
267 : }
268 :
269 :
270 : {
271 0 : const int currentKeyIndex = keyIndex++;
272 0 : map[ xRow->getString( 1 ) ] = currentKeyIndex;
273 : assert(currentKeyIndex == m_values.getLength());
274 0 : m_values.realloc( keyIndex );
275 0 : m_values[currentKeyIndex] = makeAny( prop );
276 : }
277 0 : }
278 0 : m_name2index.swap( map );
279 : }
280 0 : catch ( com::sun::star::sdbc::SQLException & e )
281 : {
282 0 : throw RuntimeException( e.Message , e.Context );
283 : }
284 :
285 0 : fire( RefreshedBroadcaster( *this ) );
286 0 : }
287 :
288 :
289 0 : void Keys::appendByDescriptor(
290 : const ::com::sun::star::uno::Reference< ::com::sun::star::beans::XPropertySet >& descriptor )
291 : throw (::com::sun::star::sdbc::SQLException,
292 : ::com::sun::star::container::ElementExistException,
293 : ::com::sun::star::uno::RuntimeException)
294 : {
295 0 : osl::MutexGuard guard( m_refMutex->mutex );
296 :
297 0 : OUStringBuffer buf( 128 );
298 0 : buf.appendAscii( RTL_CONSTASCII_STRINGPARAM( "ALTER TABLE " ) );
299 0 : bufferQuoteQualifiedIdentifier( buf, m_schemaName, m_tableName, m_pSettings );
300 0 : buf.appendAscii( RTL_CONSTASCII_STRINGPARAM( " ADD " ) );
301 0 : bufferKey2TableConstraint( buf, descriptor, m_pSettings );
302 :
303 : Reference< XStatement > stmt =
304 0 : m_origin->createStatement();
305 0 : stmt->executeUpdate( buf.makeStringAndClear() );
306 0 : }
307 :
308 :
309 0 : void Keys::dropByIndex( sal_Int32 index )
310 : throw (::com::sun::star::sdbc::SQLException,
311 : ::com::sun::star::lang::IndexOutOfBoundsException,
312 : ::com::sun::star::uno::RuntimeException)
313 : {
314 0 : osl::MutexGuard guard( m_refMutex->mutex );
315 0 : if( index < 0 || index >= m_values.getLength() )
316 : {
317 0 : OUStringBuffer buf( 128 );
318 0 : buf.appendAscii( "TABLES: Index out of range (allowed 0 to " );
319 0 : buf.append( (sal_Int32)(m_values.getLength() -1) );
320 0 : buf.appendAscii( ", got " );
321 0 : buf.append( index );
322 0 : buf.appendAscii( ")" );
323 : throw com::sun::star::lang::IndexOutOfBoundsException(
324 0 : buf.makeStringAndClear(), *this );
325 : }
326 :
327 :
328 0 : Reference< XPropertySet > set;
329 0 : m_values[index] >>= set;
330 :
331 0 : OUStringBuffer buf( 128 );
332 0 : buf.appendAscii( RTL_CONSTASCII_STRINGPARAM( "ALTER TABLE " ) );
333 0 : bufferQuoteQualifiedIdentifier( buf, m_schemaName, m_tableName, m_pSettings );
334 0 : buf.appendAscii( RTL_CONSTASCII_STRINGPARAM( " DROP CONSTRAINT " ) );
335 0 : bufferQuoteIdentifier( buf, extractStringProperty( set , getStatics().NAME ), m_pSettings );
336 0 : m_origin->createStatement()->executeUpdate( buf.makeStringAndClear() );
337 :
338 :
339 0 : Container::dropByIndex( index );
340 0 : }
341 :
342 :
343 0 : ::com::sun::star::uno::Reference< ::com::sun::star::beans::XPropertySet > Keys::createDataDescriptor()
344 : throw (::com::sun::star::uno::RuntimeException)
345 : {
346 0 : return new KeyDescriptor( m_refMutex, m_origin, m_pSettings );
347 : }
348 :
349 0 : Reference< com::sun::star::container::XIndexAccess > Keys::create(
350 : const ::rtl::Reference< RefCountedMutex > & refMutex,
351 : const ::com::sun::star::uno::Reference< com::sun::star::sdbc::XConnection > & origin,
352 : ConnectionSettings *pSettings,
353 : const rtl::OUString & schemaName,
354 : const rtl::OUString & tableName)
355 : {
356 0 : Keys *pKeys = new Keys( refMutex, origin, pSettings, schemaName, tableName );
357 0 : Reference< com::sun::star::container::XIndexAccess > ret = pKeys;
358 0 : pKeys->refresh();
359 :
360 0 : return ret;
361 : }
362 : //_________________________________________________________________________________________
363 0 : KeyDescriptors::KeyDescriptors(
364 : const ::rtl::Reference< RefCountedMutex > & refMutex,
365 : const ::com::sun::star::uno::Reference< com::sun::star::sdbc::XConnection > & origin,
366 : ConnectionSettings *pSettings)
367 0 : : Container( refMutex, origin, pSettings, getStatics().KEY )
368 0 : {}
369 :
370 0 : Reference< com::sun::star::container::XIndexAccess > KeyDescriptors::create(
371 : const ::rtl::Reference< RefCountedMutex > & refMutex,
372 : const ::com::sun::star::uno::Reference< com::sun::star::sdbc::XConnection > & origin,
373 : ConnectionSettings *pSettings)
374 : {
375 0 : return new KeyDescriptors( refMutex, origin, pSettings );
376 : }
377 :
378 0 : ::com::sun::star::uno::Reference< ::com::sun::star::beans::XPropertySet > KeyDescriptors::createDataDescriptor()
379 : throw (::com::sun::star::uno::RuntimeException)
380 : {
381 0 : return new KeyDescriptor( m_refMutex, m_origin, m_pSettings );
382 : }
383 :
384 : };
|
