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 : : #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_xindexes.hxx"
67 : : #include "pq_xindex.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::container::XEnumerationAccess;
90 : : using com::sun::star::container::XEnumeration;
91 : :
92 : : using com::sun::star::lang::WrappedTargetException;
93 : :
94 : : using com::sun::star::sdbcx::XColumnsSupplier;
95 : :
96 : : using com::sun::star::sdbc::XRow;
97 : : using com::sun::star::sdbc::XCloseable;
98 : : using com::sun::star::sdbc::XStatement;
99 : : using com::sun::star::sdbc::XResultSet;
100 : : using com::sun::star::sdbc::XParameters;
101 : : using com::sun::star::sdbc::XPreparedStatement;
102 : : using com::sun::star::sdbc::XDatabaseMetaData;
103 : :
104 : : namespace pq_sdbc_driver
105 : : {
106 : : #define ASCII_STR(x) OUString( RTL_CONSTASCII_USTRINGPARAM( x ) )
107 : :
108 : 0 : Indexes::Indexes(
109 : : const ::rtl::Reference< RefCountedMutex > & refMutex,
110 : : const ::com::sun::star::uno::Reference< com::sun::star::sdbc::XConnection > & origin,
111 : : ConnectionSettings *pSettings,
112 : : const rtl::OUString &schemaName,
113 : : const rtl::OUString &tableName)
114 : 0 : : Container( refMutex, origin, pSettings, getStatics().KEY ),
115 : : m_schemaName( schemaName ),
116 : 0 : m_tableName( tableName )
117 : : {
118 : 0 : }
119 : :
120 : 0 : Indexes::~Indexes()
121 : 0 : {}
122 : :
123 : 0 : void Indexes::refresh()
124 : : throw (::com::sun::star::uno::RuntimeException)
125 : : {
126 : : try
127 : : {
128 : 0 : if( isLog( m_pSettings, LogLevel::INFO ) )
129 : : {
130 : 0 : rtl::OStringBuffer buf;
131 : 0 : buf.append( "sdbcx.Indexes get refreshed for table " );
132 : 0 : buf.append( OUStringToOString( m_schemaName, m_pSettings->encoding ) );
133 : 0 : buf.append( "." );
134 : 0 : buf.append( OUStringToOString( m_tableName,m_pSettings->encoding ) );
135 : 0 : log( m_pSettings, LogLevel::INFO, buf.makeStringAndClear().getStr() );
136 : : }
137 : :
138 : 0 : osl::MutexGuard guard( m_refMutex->mutex );
139 : 0 : Statics & st = getStatics();
140 : :
141 : 0 : Int2StringMap column2NameMap;
142 : 0 : fillAttnum2attnameMap( column2NameMap, m_origin, m_schemaName, m_tableName );
143 : :
144 : : // see XDatabaseMetaData::getIndexInfo()
145 : 0 : Reference< XPreparedStatement > stmt = m_origin->prepareStatement(
146 : : ASCII_STR(
147 : : "SELECT nspname, " // 1
148 : : "pg_class.relname, " // 2
149 : : "class2.relname, " // 3
150 : : "indisclustered, " // 4
151 : : "indisunique, " // 5
152 : : "indisprimary, " // 6
153 : : "indkey " // 7
154 : : "FROM pg_index INNER JOIN pg_class ON indrelid = pg_class.oid "
155 : : "INNER JOIN pg_namespace ON pg_class.relnamespace = pg_namespace.oid "
156 : : "INNER JOIN pg_class as class2 ON pg_index.indexrelid = class2.oid "
157 : 0 : "WHERE nspname = ? AND pg_class.relname = ?" ) );
158 : :
159 : 0 : Reference< XParameters > params( stmt, UNO_QUERY);
160 : 0 : params->setString( 1, m_schemaName );
161 : 0 : params->setString( 2, m_tableName );
162 : 0 : Reference< XResultSet > rs = stmt->executeQuery();
163 : :
164 : 0 : Reference< XRow > row( rs, UNO_QUERY );
165 : 0 : String2IntMap map;
166 : 0 : m_values = Sequence< com::sun::star::uno::Any > ();
167 : 0 : sal_Int32 index = 0;
168 : 0 : while( rs->next() )
169 : : {
170 : : static const sal_Int32 C_SCHEMA = 1;
171 : : static const sal_Int32 C_TABLENAME = 2;
172 : : static const sal_Int32 C_INDEXNAME = 3;
173 : : static const sal_Int32 C_IS_CLUSTERED = 4;
174 : : static const sal_Int32 C_IS_UNIQUE = 5;
175 : : static const sal_Int32 C_IS_PRIMARY = 6;
176 : : static const sal_Int32 C_COLUMNS = 7;
177 : 0 : OUString currentIndexName = row->getString( C_INDEXNAME );
178 : : Index *pIndex =
179 : : new Index( m_refMutex, m_origin, m_pSettings,
180 : 0 : m_schemaName, m_tableName );
181 : :
182 : : (void) C_SCHEMA; (void) C_TABLENAME;
183 : 0 : sal_Bool isUnique = row->getBoolean( C_IS_UNIQUE );
184 : 0 : sal_Bool isPrimary = row->getBoolean( C_IS_PRIMARY );
185 : 0 : sal_Bool isClusterd = row->getBoolean( C_IS_CLUSTERED );
186 : 0 : Reference< com::sun::star::beans::XPropertySet > prop = pIndex;
187 : : pIndex->setPropertyValue_NoBroadcast_public(
188 : 0 : st.IS_UNIQUE, Any( &isUnique, getBooleanCppuType() ) );
189 : : pIndex->setPropertyValue_NoBroadcast_public(
190 : 0 : st.IS_PRIMARY_KEY_INDEX, Any( &isPrimary, getBooleanCppuType() ) );
191 : : pIndex->setPropertyValue_NoBroadcast_public(
192 : 0 : st.IS_CLUSTERED, Any( &isClusterd, getBooleanCppuType() ) );
193 : : pIndex->setPropertyValue_NoBroadcast_public(
194 : 0 : st.NAME, makeAny( currentIndexName ) );
195 : :
196 : 0 : Sequence< sal_Int32 > seq = parseIntArray( row->getString( C_COLUMNS ) );
197 : 0 : Sequence< OUString > columnNames(seq.getLength());
198 : 0 : for( int columns = 0 ; columns < seq.getLength() ; columns ++ )
199 : : {
200 : 0 : columnNames[columns] = column2NameMap[ seq[columns] ];
201 : : }
202 : :
203 : : pIndex->setPropertyValue_NoBroadcast_public(
204 : 0 : st.PRIVATE_COLUMN_INDEXES, makeAny( columnNames ));
205 : :
206 : : {
207 : 0 : const int currentIndex = index++;
208 : : assert(currentIndex == m_values.getLength());
209 : 0 : m_values.realloc( index );
210 : 0 : m_values[currentIndex] = makeAny( prop );
211 : 0 : map[ currentIndexName ] = currentIndex;
212 : : }
213 : 0 : }
214 : 0 : m_name2index.swap( map );
215 : : }
216 : 0 : catch ( com::sun::star::sdbc::SQLException & e )
217 : : {
218 : 0 : throw RuntimeException( e.Message , e.Context );
219 : : }
220 : :
221 : 0 : fire( RefreshedBroadcaster( *this ) );
222 : 0 : }
223 : :
224 : :
225 : 0 : void Indexes::appendByDescriptor(
226 : : const ::com::sun::star::uno::Reference< ::com::sun::star::beans::XPropertySet >& descriptor )
227 : : throw (::com::sun::star::sdbc::SQLException,
228 : : ::com::sun::star::container::ElementExistException,
229 : : ::com::sun::star::uno::RuntimeException)
230 : : {
231 : 0 : Statics & st = getStatics();
232 : 0 : OUString name = extractStringProperty( descriptor, st.NAME );
233 : :
234 : 0 : sal_Bool isUnique = extractBoolProperty( descriptor, st.IS_UNIQUE );
235 : :
236 : 0 : OUStringBuffer buf( 128 );
237 : :
238 : 0 : buf.appendAscii( RTL_CONSTASCII_STRINGPARAM( "CREATE " ) );
239 : 0 : if( isUnique )
240 : 0 : buf.appendAscii( RTL_CONSTASCII_STRINGPARAM( "UNIQUE " ) );
241 : 0 : buf.appendAscii( RTL_CONSTASCII_STRINGPARAM( "INDEX " ) );
242 : 0 : bufferQuoteIdentifier( buf, name, m_pSettings );
243 : 0 : buf.appendAscii( RTL_CONSTASCII_STRINGPARAM( " ON " ) );
244 : 0 : bufferQuoteQualifiedIdentifier( buf, m_schemaName, m_tableName, m_pSettings );
245 : :
246 : 0 : buf.appendAscii( RTL_CONSTASCII_STRINGPARAM( " ( " ) );
247 : :
248 : 0 : Reference< XColumnsSupplier > columns( descriptor, UNO_QUERY );
249 : 0 : if( columns.is() )
250 : : {
251 : 0 : Reference< XEnumerationAccess > access( columns->getColumns(), UNO_QUERY );
252 : 0 : if( access.is() )
253 : : {
254 : 0 : Reference< XEnumeration > xEnum( access->createEnumeration() );
255 : 0 : bool first = true;
256 : 0 : while( xEnum.is() && xEnum->hasMoreElements() )
257 : : {
258 : 0 : Reference< XPropertySet > column( xEnum->nextElement(), UNO_QUERY );
259 : 0 : if( first )
260 : : {
261 : 0 : first = false;
262 : : }
263 : : else
264 : : {
265 : 0 : buf.appendAscii( RTL_CONSTASCII_STRINGPARAM( ", " ) );
266 : : }
267 : 0 : buf.append( extractStringProperty( column, st.NAME ) );
268 : 0 : }
269 : 0 : }
270 : : }
271 : 0 : buf.appendAscii( RTL_CONSTASCII_STRINGPARAM( " ) " ) );
272 : :
273 : 0 : m_origin->createStatement()->executeUpdate( buf.makeStringAndClear() );
274 : 0 : refresh();
275 : 0 : }
276 : :
277 : 0 : void Indexes::dropByIndex( sal_Int32 index )
278 : : throw (::com::sun::star::sdbc::SQLException,
279 : : ::com::sun::star::lang::IndexOutOfBoundsException,
280 : : ::com::sun::star::uno::RuntimeException)
281 : : {
282 : :
283 : :
284 : 0 : osl::MutexGuard guard( m_refMutex->mutex );
285 : 0 : if( index < 0 || index >= m_values.getLength() )
286 : : {
287 : 0 : OUStringBuffer buf( 128 );
288 : 0 : buf.appendAscii( "Indexes: Index out of range (allowed 0 to " );
289 : 0 : buf.append( (sal_Int32) (m_values.getLength() -1) );
290 : 0 : buf.appendAscii( ", got " );
291 : 0 : buf.append( index );
292 : 0 : buf.appendAscii( ")" );
293 : : throw com::sun::star::lang::IndexOutOfBoundsException(
294 : 0 : buf.makeStringAndClear(), *this );
295 : : }
296 : :
297 : 0 : Reference< XPropertySet > set;
298 : 0 : m_values[index] >>= set;
299 : 0 : Statics &st = getStatics();
300 : :
301 : 0 : OUStringBuffer buf( 128 );
302 : 0 : buf.appendAscii( RTL_CONSTASCII_STRINGPARAM( "DROP INDEX " ) );
303 : 0 : bufferQuoteIdentifier( buf, extractStringProperty( set, st.NAME ), m_pSettings );
304 : 0 : m_origin->createStatement()->executeUpdate( buf.makeStringAndClear() );
305 : :
306 : 0 : Container::dropByIndex( index );
307 : 0 : }
308 : :
309 : :
310 : 0 : ::com::sun::star::uno::Reference< ::com::sun::star::beans::XPropertySet > Indexes::createDataDescriptor()
311 : : throw (::com::sun::star::uno::RuntimeException)
312 : : {
313 : 0 : return new IndexDescriptor( m_refMutex, m_origin, m_pSettings );
314 : : }
315 : :
316 : 0 : Reference< com::sun::star::container::XNameAccess > Indexes::create(
317 : : const ::rtl::Reference< RefCountedMutex > & refMutex,
318 : : const ::com::sun::star::uno::Reference< com::sun::star::sdbc::XConnection > & origin,
319 : : ConnectionSettings *pSettings,
320 : : const rtl::OUString & schemaName,
321 : : const rtl::OUString & tableName)
322 : : {
323 : 0 : Indexes *pIndexes = new Indexes( refMutex, origin, pSettings, schemaName, tableName );
324 : 0 : Reference< com::sun::star::container::XNameAccess > ret = pIndexes;
325 : 0 : pIndexes->refresh();
326 : 0 : return ret;
327 : : }
328 : :
329 : :
330 : : //_________________________________________________________________________________________
331 : 0 : IndexDescriptors::IndexDescriptors(
332 : : const ::rtl::Reference< RefCountedMutex > & refMutex,
333 : : const ::com::sun::star::uno::Reference< com::sun::star::sdbc::XConnection > & origin,
334 : : ConnectionSettings *pSettings)
335 : 0 : : Container( refMutex, origin, pSettings, getStatics().INDEX )
336 : 0 : {}
337 : :
338 : 0 : Reference< com::sun::star::container::XNameAccess > IndexDescriptors::create(
339 : : const ::rtl::Reference< RefCountedMutex > & refMutex,
340 : : const ::com::sun::star::uno::Reference< com::sun::star::sdbc::XConnection > & origin,
341 : : ConnectionSettings *pSettings)
342 : : {
343 : 0 : return new IndexDescriptors( refMutex, origin, pSettings );
344 : : }
345 : :
346 : 0 : ::com::sun::star::uno::Reference< ::com::sun::star::beans::XPropertySet > IndexDescriptors::createDataDescriptor()
347 : : throw (::com::sun::star::uno::RuntimeException)
348 : : {
349 : 0 : return new IndexDescriptor( m_refMutex, m_origin, m_pSettings );
350 : : }
351 : :
352 : : };
|
