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 <vector>
59 :
60 : #include <rtl/ustrbuf.hxx>
61 : #include <rtl/strbuf.hxx>
62 :
63 : #include <com/sun/star/sdbc/XRow.hpp>
64 : #include <com/sun/star/sdbc/XParameters.hpp>
65 : #include <com/sun/star/sdbc/DataType.hpp>
66 : #include <com/sun/star/sdbc/ColumnValue.hpp>
67 :
68 : #include "pq_xcolumns.hxx"
69 : #include "pq_xindexcolumns.hxx"
70 : #include "pq_xindexcolumn.hxx"
71 : #include "pq_statics.hxx"
72 : #include "pq_tools.hxx"
73 :
74 : using osl::MutexGuard;
75 :
76 : using rtl::OUString;
77 : using rtl::OUStringBuffer;
78 : using rtl::OUStringToOString;
79 :
80 : using com::sun::star::beans::XPropertySet;
81 :
82 : using com::sun::star::uno::Any;
83 : using com::sun::star::uno::makeAny;
84 : using com::sun::star::uno::UNO_QUERY;
85 : using com::sun::star::uno::Type;
86 : using com::sun::star::uno::XInterface;
87 : using com::sun::star::uno::Reference;
88 : using com::sun::star::uno::Sequence;
89 : using com::sun::star::uno::RuntimeException;
90 :
91 : using com::sun::star::container::NoSuchElementException;
92 : using com::sun::star::lang::WrappedTargetException;
93 :
94 : using com::sun::star::sdbc::XRow;
95 : using com::sun::star::sdbc::XCloseable;
96 : using com::sun::star::sdbc::XStatement;
97 : using com::sun::star::sdbc::XResultSet;
98 : using com::sun::star::sdbc::XParameters;
99 : using com::sun::star::sdbc::XPreparedStatement;
100 : using com::sun::star::sdbc::XDatabaseMetaData;
101 : using com::sun::star::sdbc::SQLException;
102 :
103 : namespace pq_sdbc_driver
104 : {
105 : #define ASCII_STR(x) OUString( RTL_CONSTASCII_USTRINGPARAM( x ) )
106 :
107 0 : IndexColumns::IndexColumns(
108 : const ::rtl::Reference< RefCountedMutex > & refMutex,
109 : const ::com::sun::star::uno::Reference< com::sun::star::sdbc::XConnection > & origin,
110 : ConnectionSettings *pSettings,
111 : const rtl::OUString &schemaName,
112 : const rtl::OUString &tableName,
113 : const rtl::OUString &indexName,
114 : const com::sun::star::uno::Sequence< rtl::OUString > &columns )
115 : : Container( refMutex, origin, pSettings, ASCII_STR( "INDEX_COLUMN" ) ),
116 : m_schemaName( schemaName ),
117 : m_tableName( tableName ),
118 : m_indexName( indexName ),
119 0 : m_columns( columns )
120 0 : {}
121 :
122 0 : IndexColumns::~IndexColumns()
123 0 : {}
124 :
125 0 : static sal_Int32 findInSequence( const Sequence< rtl::OUString > & seq , const rtl::OUString &str)
126 : {
127 : int index;
128 0 : for( index = 0 ; index < seq.getLength() ; index ++ )
129 : {
130 0 : if( str == seq[index] )
131 0 : break;
132 : }
133 0 : return index;
134 : }
135 :
136 0 : void IndexColumns::refresh()
137 : throw (::com::sun::star::uno::RuntimeException)
138 : {
139 : try
140 : {
141 0 : if( isLog( m_pSettings, LogLevel::INFO ) )
142 : {
143 0 : rtl::OStringBuffer buf;
144 0 : buf.append( "sdbcx.IndexColumns get refreshed for index " );
145 0 : buf.append( OUStringToOString( m_indexName, m_pSettings->encoding ) );
146 0 : log( m_pSettings, LogLevel::INFO, buf.makeStringAndClear().getStr() );
147 : }
148 :
149 0 : osl::MutexGuard guard( m_refMutex->mutex );
150 :
151 0 : Statics &st = getStatics();
152 0 : Reference< XDatabaseMetaData > meta = m_origin->getMetaData();
153 :
154 : Reference< XResultSet > rs =
155 0 : meta->getColumns( Any(), m_schemaName, m_tableName, st.cPERCENT );
156 :
157 0 : DisposeGuard disposeIt( rs );
158 0 : Reference< XRow > xRow( rs , UNO_QUERY );
159 0 : m_values = Sequence< Any >( m_columns.getLength() );
160 :
161 0 : while( rs->next() )
162 : {
163 0 : OUString columnName = xRow->getString( 4 );
164 :
165 0 : sal_Int32 index = findInSequence( m_columns, columnName );
166 0 : if( index >= m_columns.getLength() )
167 0 : continue;
168 :
169 : IndexColumn * pIndexColumn =
170 0 : new IndexColumn( m_refMutex, m_origin, m_pSettings );
171 0 : Reference< com::sun::star::beans::XPropertySet > prop = pIndexColumn;
172 :
173 0 : columnMetaData2SDBCX( pIndexColumn, xRow );
174 : pIndexColumn->setPropertyValue_NoBroadcast_public(
175 0 : st.IS_ASCENDING , makeAny( (sal_Bool ) sal_False ) );
176 :
177 0 : m_values[ index ] = makeAny( prop );
178 0 : m_name2index[ columnName ] = index;
179 0 : }
180 : }
181 0 : catch ( com::sun::star::sdbc::SQLException & e )
182 : {
183 0 : throw RuntimeException( e.Message , e.Context );
184 : }
185 :
186 0 : fire( RefreshedBroadcaster( *this ) );
187 0 : }
188 :
189 :
190 0 : void IndexColumns::appendByDescriptor(
191 : const ::com::sun::star::uno::Reference< ::com::sun::star::beans::XPropertySet >& future )
192 : throw (::com::sun::star::sdbc::SQLException,
193 : ::com::sun::star::container::ElementExistException,
194 : ::com::sun::star::uno::RuntimeException)
195 : {
196 0 : OUString name = extractStringProperty( future, getStatics().NAME );
197 : throw com::sun::star::sdbc::SQLException(
198 : ASCII_STR( "SDBC-POSTGRESQL: IndexesColumns.appendByDescriptor not yet implemented" ),
199 0 : *this, OUString(), 1, Any() );
200 : // osl::MutexGuard guard( m_refMutex->mutex );
201 : // Statics & st = getStatics();
202 : // Reference< XPropertySet > past = createDataDescriptor();
203 : // past->setPropertyValue( st.IS_NULLABLE, makeAny( com::sun::star::sdbc::ColumnValue::NULLABLE ) );
204 : // alterColumnByDescriptor(
205 : // m_schemaName, m_tableName, m_pSettings->encoding, m_origin->createStatement() , past, future );
206 :
207 : }
208 :
209 0 : void IndexColumns::dropByName( const ::rtl::OUString& elementName )
210 : throw (::com::sun::star::sdbc::SQLException,
211 : ::com::sun::star::container::NoSuchElementException,
212 : ::com::sun::star::uno::RuntimeException)
213 : {
214 : (void) elementName;
215 : throw com::sun::star::sdbc::SQLException(
216 : ASCII_STR( "SDBC-POSTGRESQL: IndexesColumns.dropByName not yet implemented" ),
217 0 : *this, OUString(), 1, Any() );
218 : // String2IntMap::const_iterator ii = m_name2index.find( elementName );
219 : // if( ii == m_name2index.end() )
220 : // {
221 : // OUStringBuffer buf( 128 );
222 : // buf.appendAscii( "Column " );
223 : // buf.append( elementName );
224 : // buf.appendAscii( " is unknown in table " );
225 : // buf.append( m_schemaName );
226 : // buf.appendAscii( "." );
227 : // buf.append( m_tableName );
228 : // buf.appendAscii( ", so it can't be dropped" );
229 : // throw com::sun::star::container::NoSuchElementException(
230 : // buf.makeStringAndClear(), *this );
231 : // }
232 : // dropByIndex( ii->second );
233 : }
234 :
235 0 : void IndexColumns::dropByIndex( sal_Int32 index )
236 : throw (::com::sun::star::sdbc::SQLException,
237 : ::com::sun::star::lang::IndexOutOfBoundsException,
238 : ::com::sun::star::uno::RuntimeException)
239 : {
240 : (void) index;
241 : throw com::sun::star::sdbc::SQLException(
242 : ASCII_STR( "SDBC-POSTGRESQL: IndexesColumns.dropByIndex not yet implemented" ),
243 0 : *this, OUString(), 1, Any() );
244 : // osl::MutexGuard guard( m_refMutex->mutex );
245 : // if( index < 0 || index >= m_values.getLength() )
246 : // {
247 : // OUStringBuffer buf( 128 );
248 : // buf.appendAscii( "COLUMNS: Index out of range (allowed 0 to " );
249 : // buf.append((sal_Int32)(m_values.getLength() -1) );
250 : // buf.appendAscii( ", got " );
251 : // buf.append( index );
252 : // buf.appendAscii( ")" );
253 : // throw com::sun::star::lang::IndexOutOfBoundsException(
254 : // buf.makeStringAndClear(), *this );
255 : // }
256 :
257 : // Reference< XPropertySet > set;
258 : // m_values[index] >>= set;
259 : // Statics &st = getStatics();
260 : // OUString name;
261 : // set->getPropertyValue( st.NAME ) >>= name;
262 :
263 : // OUStringBuffer update( 128 );
264 : // update.appendAscii( "ALTER TABLE ONLY");
265 : // bufferQuoteQualifiedIdentifier( update, m_schemaName, m_tableName );
266 : // update.appendAscii( "DROP COLUMN" );
267 : // bufferQuoteIdentifier( update, name );
268 : // Reference< XStatement > stmt = m_origin->createStatement( );
269 : // DisposeGuard disposeIt( stmt );
270 : // stmt->executeUpdate( update.makeStringAndClear() );
271 :
272 : }
273 :
274 :
275 0 : Reference< ::com::sun::star::beans::XPropertySet > IndexColumns::createDataDescriptor()
276 : throw (::com::sun::star::uno::RuntimeException)
277 : {
278 0 : return new IndexColumnDescriptor( m_refMutex, m_origin, m_pSettings );
279 : }
280 :
281 0 : Reference< com::sun::star::container::XNameAccess > IndexColumns::create(
282 : const ::rtl::Reference< RefCountedMutex > & refMutex,
283 : const ::com::sun::star::uno::Reference< com::sun::star::sdbc::XConnection > & origin,
284 : ConnectionSettings *pSettings,
285 : const rtl::OUString &schemaName,
286 : const rtl::OUString &tableName,
287 : const rtl::OUString &indexName,
288 : const Sequence< rtl::OUString > &columns )
289 : {
290 : IndexColumns *pIndexColumns = new IndexColumns(
291 0 : refMutex, origin, pSettings, schemaName, tableName, indexName, columns );
292 0 : Reference< com::sun::star::container::XNameAccess > ret = pIndexColumns;
293 0 : pIndexColumns->refresh();
294 :
295 0 : return ret;
296 : }
297 :
298 : //_________________________________________________________________________________________
299 0 : IndexColumnDescriptors::IndexColumnDescriptors(
300 : const ::rtl::Reference< RefCountedMutex > & refMutex,
301 : const ::com::sun::star::uno::Reference< com::sun::star::sdbc::XConnection > & origin,
302 : ConnectionSettings *pSettings)
303 0 : : Container( refMutex, origin, pSettings, getStatics().INDEX_COLUMN )
304 0 : {}
305 :
306 0 : Reference< com::sun::star::container::XNameAccess > IndexColumnDescriptors::create(
307 : const ::rtl::Reference< RefCountedMutex > & refMutex,
308 : const ::com::sun::star::uno::Reference< com::sun::star::sdbc::XConnection > & origin,
309 : ConnectionSettings *pSettings)
310 : {
311 0 : return new IndexColumnDescriptors( refMutex, origin, pSettings );
312 : }
313 :
314 0 : ::com::sun::star::uno::Reference< ::com::sun::star::beans::XPropertySet > IndexColumnDescriptors::createDataDescriptor()
315 : throw (::com::sun::star::uno::RuntimeException)
316 : {
317 0 : return new IndexColumnDescriptor( m_refMutex, m_origin, m_pSettings );
318 : }
319 :
320 : };
|
