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: 200? 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 <cppuhelper/queryinterface.hxx>
62 : : #include <cppuhelper/typeprovider.hxx>
63 : :
64 : : #include <com/sun/star/sdbc/XGeneratedResultSet.hpp>
65 : :
66 : : #include "pq_updateableresultset.hxx"
67 : : #include "pq_resultsetmetadata.hxx"
68 : : #include "pq_tools.hxx"
69 : : #include "pq_statics.hxx"
70 : :
71 : : #include <string.h>
72 : :
73 : : using osl::MutexGuard;
74 : :
75 : : using rtl::OUString;
76 : : using rtl::OUStringBuffer;
77 : : using rtl::OStringBuffer;
78 : : using rtl::OString;
79 : :
80 : : using com::sun::star::uno::Reference;
81 : : using com::sun::star::uno::makeAny;
82 : : using com::sun::star::uno::Sequence;
83 : : using com::sun::star::uno::UNO_QUERY;
84 : : using com::sun::star::uno::Any;
85 : : using com::sun::star::uno::Type;
86 : : using com::sun::star::uno::RuntimeException;
87 : :
88 : : using com::sun::star::sdbc::XGeneratedResultSet;
89 : : using com::sun::star::sdbc::XResultSetMetaDataSupplier;
90 : : using com::sun::star::sdbc::SQLException;
91 : : using com::sun::star::sdbc::XResultSet;
92 : : using com::sun::star::sdbc::XCloseable;
93 : : using com::sun::star::sdbc::XColumnLocate;
94 : : using com::sun::star::sdbc::XResultSetUpdate;
95 : : using com::sun::star::sdbc::XRowUpdate;
96 : : using com::sun::star::sdbc::XRow;
97 : : using com::sun::star::sdbc::XStatement;
98 : :
99 : : using com::sun::star::beans::XFastPropertySet;
100 : : using com::sun::star::beans::XPropertySet;
101 : : using com::sun::star::beans::XMultiPropertySet;
102 : :
103 : : #define ASCII_STR(x) OUString( RTL_CONSTASCII_USTRINGPARAM( x ) )
104 : :
105 : : namespace pq_sdbc_driver
106 : : {
107 : :
108 : :
109 : 0 : com::sun::star::uno::Reference< com::sun::star::sdbc::XCloseable > UpdateableResultSet::createFromPGResultSet(
110 : : const ::rtl::Reference< RefCountedMutex > & mutex,
111 : : const com::sun::star::uno::Reference< com::sun::star::uno::XInterface > &owner,
112 : : ConnectionSettings **ppSettings,
113 : : PGresult *result,
114 : : const rtl::OUString &schema,
115 : : const rtl::OUString &table,
116 : : const com::sun::star::uno::Sequence< ::rtl::OUString > &primaryKey )
117 : : {
118 : 0 : ConnectionSettings *pSettings = *ppSettings;
119 : 0 : sal_Int32 columnCount = PQnfields( result );
120 : 0 : sal_Int32 rowCount = PQntuples( result );
121 : 0 : Sequence< OUString > columnNames( columnCount );
122 : 0 : for( int i = 0 ; i < columnCount ; i ++ )
123 : : {
124 : 0 : char * name = PQfname( result, i );
125 : 0 : columnNames[i] = rtl::OUString( name, strlen(name), pSettings->encoding );
126 : : }
127 : 0 : Sequence< Sequence< Any > > data( rowCount );
128 : :
129 : : // copy all the data into unicode strings (also binaries, as we yet
130 : : // don't know, what a binary is and what not!)
131 : 0 : for( int row = 0 ; row < rowCount ; row ++ )
132 : : {
133 : 0 : Sequence< Any > aRow( columnCount );
134 : 0 : for( int col = 0 ; col < columnCount ; col ++ )
135 : : {
136 : 0 : if( ! PQgetisnull( result, row, col ) )
137 : : {
138 : 0 : char * val = PQgetvalue( result, row, col );
139 : :
140 : 0 : aRow[col] = makeAny(
141 : 0 : rtl::OUString( val, strlen( val ) , (*ppSettings)->encoding ) );
142 : : }
143 : : }
144 : 0 : data[row] = aRow;
145 : 0 : }
146 : :
147 : : UpdateableResultSet *pRS = new UpdateableResultSet(
148 : 0 : mutex, owner, columnNames, data, ppSettings, schema, table , primaryKey );
149 : :
150 : 0 : Reference <XCloseable > ret = pRS; // give it an refcount
151 : :
152 : 0 : pRS->m_meta = new ResultSetMetaData( mutex, pRS,0, ppSettings, result, schema, table );
153 : :
154 : 0 : PQclear( result ); // we don't need it anymore
155 : :
156 : 0 : return ret;
157 : : }
158 : :
159 : 0 : com::sun::star::uno::Any UpdateableResultSet::queryInterface(
160 : : const com::sun::star::uno::Type & reqType )
161 : : throw (com::sun::star::uno::RuntimeException)
162 : : {
163 : 0 : Any ret = SequenceResultSet::queryInterface( reqType );
164 : 0 : if( ! ret.hasValue() )
165 : : ret = ::cppu::queryInterface(
166 : : reqType,
167 : : static_cast< XResultSetUpdate * > ( this ),
168 : 0 : static_cast< XRowUpdate * > ( this ) );
169 : 0 : return ret;
170 : : }
171 : :
172 : :
173 : 0 : com::sun::star::uno::Sequence< com::sun::star::uno::Type > UpdateableResultSet::getTypes()
174 : : throw( com::sun::star::uno::RuntimeException )
175 : : {
176 : : static cppu::OTypeCollection *pCollection;
177 : 0 : if( ! pCollection )
178 : : {
179 : 0 : MutexGuard guard( osl::Mutex::getGlobalMutex() );
180 : 0 : if( !pCollection )
181 : : {
182 : : static cppu::OTypeCollection collection(
183 : 0 : getCppuType( (Reference< XResultSetUpdate> *) 0 ),
184 : 0 : getCppuType( (Reference< XRowUpdate> *) 0 ),
185 : 0 : SequenceResultSet::getTypes());
186 : 0 : pCollection = &collection;
187 : 0 : }
188 : : }
189 : 0 : return pCollection->getTypes();
190 : :
191 : : }
192 : :
193 : 0 : com::sun::star::uno::Sequence< sal_Int8> UpdateableResultSet::getImplementationId()
194 : : throw( com::sun::star::uno::RuntimeException )
195 : : {
196 : : static cppu::OImplementationId *pId;
197 : 0 : if( ! pId )
198 : : {
199 : 0 : MutexGuard guard( osl::Mutex::getGlobalMutex() );
200 : 0 : if( ! pId )
201 : : {
202 : 0 : static cppu::OImplementationId id(sal_False);
203 : 0 : pId = &id;
204 : 0 : }
205 : : }
206 : 0 : return pId->getImplementationId();
207 : : }
208 : :
209 : 0 : OUString UpdateableResultSet::buildWhereClause()
210 : : {
211 : 0 : OUString ret;
212 : 0 : if( m_primaryKey.getLength() )
213 : : {
214 : 0 : OUStringBuffer buf( 128 );
215 : 0 : buf.appendAscii( RTL_CONSTASCII_STRINGPARAM( " WHERE " ) );
216 : 0 : for( int i = 0 ; i < m_primaryKey.getLength() ; i ++ )
217 : : {
218 : 0 : if( i > 0 )
219 : 0 : buf.appendAscii( RTL_CONSTASCII_STRINGPARAM( " AND " ) );
220 : 0 : sal_Int32 index = findColumn( m_primaryKey[i] );
221 : 0 : bufferQuoteIdentifier( buf, m_primaryKey[i], *m_ppSettings );
222 : 0 : buf.appendAscii( RTL_CONSTASCII_STRINGPARAM( " = " ) );
223 : 0 : bufferQuoteConstant( buf, getString( index ), *m_ppSettings );
224 : : }
225 : 0 : ret = buf.makeStringAndClear();
226 : : }
227 : 0 : return ret;
228 : : }
229 : :
230 : :
231 : 0 : void UpdateableResultSet::insertRow( ) throw (SQLException, RuntimeException)
232 : : {
233 : 0 : MutexGuard guard( m_refMutex->mutex );
234 : 0 : if( isLog( *m_ppSettings, LogLevel::INFO ) )
235 : : {
236 : 0 : log( *m_ppSettings, LogLevel::INFO,"UpdateableResultSet::insertRow got called" );
237 : : }
238 : 0 : if( ! m_insertRow )
239 : : throw SQLException(
240 : : ASCII_STR("pq_resultset.insertRow: moveToInsertRow has not been called !" ),
241 : 0 : *this, OUString(), 1, Any() );
242 : :
243 : 0 : OUStringBuffer buf( 128 );
244 : 0 : buf.appendAscii( RTL_CONSTASCII_STRINGPARAM( "INSERT INTO " ) );
245 : 0 : bufferQuoteQualifiedIdentifier( buf, m_schema, m_table, *m_ppSettings );
246 : 0 : buf.appendAscii( RTL_CONSTASCII_STRINGPARAM( " ( " ) );
247 : :
248 : 0 : int columns = 0;
249 : 0 : for( UpdateableFieldVector::size_type i = 0 ; i < m_updateableField.size() ; i++ )
250 : : {
251 : 0 : if( m_updateableField[i].isTouched )
252 : : {
253 : 0 : if( columns > 0 )
254 : 0 : buf.appendAscii( RTL_CONSTASCII_STRINGPARAM( ", " ) );
255 : 0 : columns ++;
256 : 0 : bufferQuoteIdentifier( buf, m_columnNames[i], *m_ppSettings);
257 : : }
258 : : }
259 : 0 : buf.appendAscii( RTL_CONSTASCII_STRINGPARAM( " ) VALUES ( " ) );
260 : :
261 : 0 : columns = 0;
262 : 0 : for( UpdateableFieldVector::size_type i = 0 ; i < m_updateableField.size() ; i ++ )
263 : : {
264 : 0 : if( m_updateableField[i].isTouched )
265 : : {
266 : 0 : if( columns > 0 )
267 : 0 : buf.appendAscii( RTL_CONSTASCII_STRINGPARAM( " , " ) );
268 : 0 : columns ++;
269 : 0 : bufferQuoteAnyConstant( buf, m_updateableField[i].value, *m_ppSettings );
270 : :
271 : : // OUString val;
272 : : // m_updateableField[i].value >>= val;
273 : : // buf.append( val );
274 : : // rtl::OStringToOUString(val, (*m_ppSettings)->encoding ) );
275 : : }
276 : : }
277 : :
278 : 0 : buf.appendAscii( RTL_CONSTASCII_STRINGPARAM( " )" ) );
279 : :
280 : : Reference< XStatement > stmt =
281 : 0 : extractConnectionFromStatement(m_owner)->createStatement();
282 : 0 : DisposeGuard dispGuard( stmt );
283 : 0 : stmt->executeUpdate( buf.makeStringAndClear() );
284 : :
285 : : // reflect the changes !
286 : 0 : m_rowCount ++;
287 : 0 : m_data.realloc( m_rowCount );
288 : 0 : m_data[m_rowCount-1] = Sequence< Any > ( m_fieldCount );
289 : 0 : Reference< XGeneratedResultSet > result( stmt, UNO_QUERY );
290 : 0 : if( result.is() )
291 : : {
292 : 0 : Reference< XResultSet > rs = result->getGeneratedValues();
293 : 0 : if( rs.is() && rs->next() )
294 : : {
295 : 0 : Reference< XColumnLocate > columnLocate( rs, UNO_QUERY );
296 : 0 : Reference< XRow> xRow ( rs, UNO_QUERY );
297 : 0 : for( int i = 0 ; i < m_fieldCount ; i++ )
298 : : {
299 : 0 : int field = columnLocate->findColumn( m_columnNames[i] );
300 : 0 : if( field >= 1 )
301 : : {
302 : 0 : m_data[m_rowCount-1][i] <<= xRow->getString( field );
303 : : // printf( "adding %s %s\n" ,
304 : : // OUStringToOString( m_columnNames[i], RTL_TEXTENCODING_ASCII_US).getStr(),
305 : : // OUStringToOString( xRow->getString( field ), RTL_TEXTENCODING_ASCII_US).getStr() );
306 : :
307 : : }
308 : 0 : }
309 : : }
310 : : else
311 : : {
312 : : // do the best we can ( DEFAULT and AUTO increment values fail ! )
313 : 0 : for( int i = 0 ; i < m_fieldCount ; i ++ )
314 : : {
315 : 0 : if( m_updateableField[i].isTouched )
316 : 0 : m_data[m_rowCount-1][i] = m_updateableField[i].value;
317 : : }
318 : 0 : }
319 : : }
320 : :
321 : : // cleanup
322 : 0 : m_updateableField = UpdateableFieldVector();
323 : 0 : }
324 : :
325 : 0 : void UpdateableResultSet::updateRow( ) throw (SQLException, RuntimeException)
326 : : {
327 : 0 : MutexGuard guard( m_refMutex->mutex );
328 : 0 : if( isLog( *m_ppSettings, LogLevel::INFO ) )
329 : : {
330 : 0 : log( *m_ppSettings, LogLevel::INFO,"UpdateableResultSet::updateRow got called" );
331 : : }
332 : 0 : if( m_insertRow )
333 : : throw SQLException(
334 : : ASCII_STR("pq_resultset.updateRow: moveToCurrentRow has not been called !" ),
335 : 0 : *this, OUString(), 1, Any() );
336 : :
337 : 0 : OUStringBuffer buf( 128 );
338 : 0 : buf.appendAscii( RTL_CONSTASCII_STRINGPARAM( "UPDATE " ) );
339 : 0 : bufferQuoteQualifiedIdentifier( buf, m_schema, m_table, *m_ppSettings );
340 : 0 : buf.appendAscii( RTL_CONSTASCII_STRINGPARAM( "SET " ) );
341 : :
342 : 0 : int columns = 0;
343 : 0 : for( UpdateableFieldVector::size_type i = 0; i < m_updateableField.size() ; i ++ )
344 : : {
345 : 0 : if( m_updateableField[i].isTouched )
346 : : {
347 : 0 : if( columns > 0 )
348 : 0 : buf.appendAscii( RTL_CONSTASCII_STRINGPARAM( ", " ) );
349 : 0 : columns ++;
350 : :
351 : 0 : buf.append( m_columnNames[i] );
352 : 0 : buf.appendAscii( RTL_CONSTASCII_STRINGPARAM(" = " ) );
353 : 0 : bufferQuoteAnyConstant( buf, m_updateableField[i].value, *m_ppSettings );
354 : : // OUString val;
355 : : // m_updateableField[i].value >>= val;
356 : : // bufferQuoteConstant( buf, val ):
357 : : // buf.append( val );
358 : : }
359 : : }
360 : 0 : buf.append( buildWhereClause() );
361 : :
362 : 0 : Reference< XStatement > stmt = extractConnectionFromStatement(m_owner)->createStatement();
363 : 0 : DisposeGuard dispGuard( stmt );
364 : 0 : stmt->executeUpdate( buf.makeStringAndClear() );
365 : :
366 : : // reflect the changes !
367 : 0 : for( int i = 0 ; i < m_fieldCount ; i ++ )
368 : : {
369 : 0 : if( m_updateableField[i].isTouched )
370 : 0 : m_data[m_row][i] = m_updateableField[i].value;
371 : : }
372 : 0 : m_updateableField = UpdateableFieldVector();
373 : 0 : }
374 : :
375 : 0 : void UpdateableResultSet::deleteRow( ) throw (SQLException, RuntimeException)
376 : : {
377 : 0 : if( isLog( *m_ppSettings, LogLevel::INFO ) )
378 : : {
379 : 0 : log( *m_ppSettings, LogLevel::INFO,"UpdateableResultSet::deleteRow got called" );
380 : : }
381 : 0 : if( m_insertRow )
382 : : throw SQLException(
383 : : ASCII_STR("pq_resultset.deleteRow: deleteRow cannot be called when on insert row !" ),
384 : 0 : *this, OUString(), 1, Any() );
385 : :
386 : 0 : if( m_row < 0 || m_row >= m_rowCount )
387 : : {
388 : 0 : OUStringBuffer buf( 128 );
389 : 0 : buf.appendAscii( "deleteRow cannot be called on invalid row (" );
390 : 0 : buf.append( m_row );
391 : 0 : buf.appendAscii( ")" );
392 : 0 : throw SQLException( buf.makeStringAndClear() , *this, OUString(), 0, Any() );
393 : : }
394 : :
395 : 0 : Reference< XStatement > stmt = extractConnectionFromStatement(m_owner)->createStatement();
396 : 0 : DisposeGuard dispGuard( stmt );
397 : 0 : OUStringBuffer buf( 128 );
398 : 0 : buf.appendAscii( "DELETE FROM " );
399 : 0 : bufferQuoteQualifiedIdentifier( buf, m_schema, m_table, *m_ppSettings );
400 : 0 : buf.appendAscii( " " );
401 : 0 : buf.append( buildWhereClause() );
402 : :
403 : 0 : stmt->executeUpdate( buf.makeStringAndClear() );
404 : :
405 : : // reflect the changes !
406 : 0 : for( int i = m_row + 1; i < m_row ; i ++ )
407 : : {
408 : 0 : m_data[i-1] = m_data[i];
409 : : }
410 : 0 : m_rowCount --;
411 : 0 : m_data.realloc( m_rowCount );
412 : 0 : }
413 : :
414 : 0 : void UpdateableResultSet::cancelRowUpdates( ) throw (SQLException, RuntimeException)
415 : : {
416 : 0 : MutexGuard guard( m_refMutex->mutex );
417 : 0 : m_updateableField = UpdateableFieldVector();
418 : 0 : }
419 : :
420 : 0 : void UpdateableResultSet::moveToInsertRow( ) throw (SQLException, RuntimeException)
421 : : {
422 : 0 : m_insertRow = true;
423 : 0 : }
424 : :
425 : 0 : void UpdateableResultSet::moveToCurrentRow( ) throw (SQLException, RuntimeException)
426 : : {
427 : 0 : m_insertRow = false;
428 : 0 : }
429 : :
430 : 0 : void UpdateableResultSet::checkUpdate( sal_Int32 columnIndex)
431 : : {
432 : 0 : checkColumnIndex( columnIndex );
433 : 0 : if( m_updateableField.empty() )
434 : 0 : m_updateableField = UpdateableFieldVector( m_fieldCount );
435 : 0 : m_updateableField[columnIndex-1].isTouched = true;
436 : 0 : }
437 : :
438 : 0 : void UpdateableResultSet::updateNull( sal_Int32 columnIndex ) throw (SQLException, RuntimeException)
439 : : {
440 : 0 : MutexGuard guard( m_refMutex->mutex );
441 : 0 : checkClosed();
442 : 0 : checkUpdate( columnIndex );
443 : 0 : m_updateableField[columnIndex-1].value = Any();
444 : 0 : }
445 : :
446 : 0 : void UpdateableResultSet::updateBoolean( sal_Int32 columnIndex, sal_Bool x ) throw (SQLException, RuntimeException)
447 : : {
448 : 0 : MutexGuard guard( m_refMutex->mutex );
449 : 0 : checkClosed();
450 : 0 : checkUpdate( columnIndex );
451 : :
452 : 0 : Statics &st = getStatics();
453 : 0 : if( x )
454 : 0 : m_updateableField[columnIndex-1].value <<= ( x ? st.TRUE : st.FALSE );
455 : :
456 : 0 : }
457 : :
458 : 0 : void UpdateableResultSet::updateByte( sal_Int32 columnIndex, sal_Int8 x ) throw (SQLException, RuntimeException)
459 : : {
460 : 0 : updateInt(columnIndex,x);
461 : 0 : }
462 : :
463 : 0 : void UpdateableResultSet::updateShort( sal_Int32 columnIndex, sal_Int16 x ) throw (SQLException, RuntimeException)
464 : : {
465 : 0 : updateInt( columnIndex, x );
466 : 0 : }
467 : :
468 : 0 : void UpdateableResultSet::updateInt( sal_Int32 columnIndex, sal_Int32 x ) throw (SQLException, RuntimeException)
469 : : {
470 : 0 : updateLong( columnIndex, x );
471 : : // MutexGuard guard( m_refMutex->mutex );
472 : : // checkClosed();
473 : : // checkUpdate( columnIndex );
474 : :
475 : : // m_updateableField[columnIndex-1].value <<= OUString::valueOf( x );
476 : :
477 : 0 : }
478 : :
479 : 0 : void UpdateableResultSet::updateLong( sal_Int32 columnIndex, sal_Int64 x ) throw (SQLException, RuntimeException)
480 : : {
481 : 0 : MutexGuard guard( m_refMutex->mutex );
482 : 0 : checkClosed();
483 : 0 : checkUpdate( columnIndex );
484 : :
485 : : // OStringBuffer buf( 20 );
486 : : // buf.append( "'" );
487 : : // buf.append( (sal_Int64) x );
488 : : // buf.append( "'" );
489 : 0 : m_updateableField[columnIndex-1].value <<= OUString::valueOf( x );
490 : 0 : }
491 : :
492 : 0 : void UpdateableResultSet::updateFloat( sal_Int32 columnIndex, float x ) throw (SQLException, RuntimeException)
493 : : {
494 : :
495 : 0 : MutexGuard guard( m_refMutex->mutex );
496 : 0 : checkClosed();
497 : 0 : checkUpdate( columnIndex );
498 : :
499 : 0 : m_updateableField[columnIndex-1].value <<= OUString::valueOf( x );
500 : 0 : }
501 : :
502 : 0 : void UpdateableResultSet::updateDouble( sal_Int32 columnIndex, double x ) throw (SQLException, RuntimeException)
503 : : {
504 : 0 : MutexGuard guard( m_refMutex->mutex );
505 : 0 : checkClosed();
506 : 0 : checkUpdate( columnIndex );
507 : :
508 : 0 : m_updateableField[columnIndex-1].value <<= OUString::valueOf( x );
509 : 0 : }
510 : :
511 : 0 : void UpdateableResultSet::updateString( sal_Int32 columnIndex, const ::rtl::OUString& x ) throw (SQLException, RuntimeException)
512 : : {
513 : 0 : MutexGuard guard( m_refMutex->mutex );
514 : 0 : checkClosed();
515 : 0 : checkUpdate( columnIndex );
516 : :
517 : 0 : m_updateableField[columnIndex-1].value <<= x;
518 : 0 : }
519 : :
520 : 0 : void UpdateableResultSet::updateBytes( sal_Int32 columnIndex, const ::com::sun::star::uno::Sequence< sal_Int8 >& x ) throw (SQLException, RuntimeException)
521 : : {
522 : 0 : MutexGuard guard( m_refMutex->mutex );
523 : 0 : checkClosed();
524 : 0 : checkUpdate( columnIndex );
525 : :
526 : : size_t len;
527 : : unsigned char * escapedString =
528 : 0 : PQescapeBytea( (unsigned char *)x.getConstArray(), x.getLength(), &len);
529 : 0 : if( ! escapedString )
530 : : {
531 : : throw SQLException(
532 : : ASCII_STR("pq_preparedstatement.setBytes: Error during converting bytesequence to an SQL conform string" ),
533 : 0 : *this, OUString(), 1, Any() );
534 : : }
535 : : // buf.append( (const sal_Char *)escapedString, len -1 );
536 : :
537 : 0 : m_updateableField[columnIndex-1].value <<=
538 : 0 : OUString( (sal_Char*) escapedString, len, RTL_TEXTENCODING_ASCII_US );
539 : 0 : free( escapedString );
540 : 0 : }
541 : :
542 : 0 : void UpdateableResultSet::updateDate( sal_Int32 columnIndex, const ::com::sun::star::util::Date& x ) throw (SQLException, RuntimeException)
543 : : {
544 : 0 : updateString( columnIndex, date2String( x ) );
545 : 0 : }
546 : :
547 : 0 : void UpdateableResultSet::updateTime( sal_Int32 columnIndex, const ::com::sun::star::util::Time& x ) throw (SQLException, RuntimeException)
548 : : {
549 : 0 : updateString( columnIndex, time2String( x ) );
550 : 0 : }
551 : :
552 : 0 : void UpdateableResultSet::updateTimestamp( sal_Int32 columnIndex, const ::com::sun::star::util::DateTime& x ) throw (SQLException, RuntimeException)
553 : : {
554 : 0 : updateString( columnIndex, dateTime2String( x ) );
555 : 0 : }
556 : :
557 : 0 : void UpdateableResultSet::updateBinaryStream( sal_Int32 /* columnIndex */, const ::com::sun::star::uno::Reference< ::com::sun::star::io::XInputStream >& /* x */, sal_Int32 /* length */ ) throw (SQLException, RuntimeException)
558 : : {
559 : 0 : }
560 : :
561 : 0 : void UpdateableResultSet::updateCharacterStream( sal_Int32 /* columnIndex */, const ::com::sun::star::uno::Reference< ::com::sun::star::io::XInputStream >& /* x */, sal_Int32 /* length */ ) throw (SQLException, RuntimeException)
562 : : {
563 : 0 : }
564 : :
565 : 0 : void UpdateableResultSet::updateObject( sal_Int32 /* columnIndex */, const ::com::sun::star::uno::Any& /* x */ ) throw (SQLException, RuntimeException)
566 : : {
567 : 0 : }
568 : :
569 : 0 : void UpdateableResultSet::updateNumericObject( sal_Int32 /* columnIndex */, const ::com::sun::star::uno::Any& /* x */, sal_Int32 /* scale */ ) throw (SQLException, RuntimeException)
570 : : {
571 : 0 : }
572 : :
573 : :
574 : 0 : ::com::sun::star::uno::Reference< ::com::sun::star::sdbc::XResultSetMetaData > UpdateableResultSet::getMetaData( )
575 : : throw (::com::sun::star::sdbc::SQLException, ::com::sun::star::uno::RuntimeException)
576 : : {
577 : 0 : return m_meta;
578 : : }
579 : :
580 : 0 : Sequence< Type > UpdateableResultSet::getStaticTypes( bool updateable )
581 : : throw( com::sun::star::uno::RuntimeException )
582 : : {
583 : 0 : if( updateable )
584 : : {
585 : : cppu::OTypeCollection collection(
586 : 0 : getCppuType( (Reference< XResultSetUpdate> *) 0 ),
587 : 0 : getCppuType( (Reference< XRowUpdate> *) 0 ),
588 : : // getCppuType( (Reference< com::sun::star::sdbcx::XRowLocate > *) 0 ),
589 : 0 : getStaticTypes( false /* updateable */ ) );
590 : 0 : return collection.getTypes();
591 : : }
592 : : else
593 : : {
594 : : cppu::OTypeCollection collection(
595 : 0 : getCppuType( (Reference< XResultSet> *) 0 ),
596 : 0 : getCppuType( (Reference< XResultSetMetaDataSupplier> *) 0 ),
597 : 0 : getCppuType( (Reference< XRow> *) 0 ),
598 : 0 : getCppuType( (Reference< XColumnLocate> *) 0 ),
599 : 0 : getCppuType( (Reference< XCloseable> *) 0 ),
600 : 0 : getCppuType( (Reference< XPropertySet >*) 0 ),
601 : 0 : getCppuType( (Reference< XFastPropertySet > *) 0 ),
602 : 0 : getCppuType( (Reference< XMultiPropertySet > *) 0 ),
603 : 0 : getCppuType( (const Reference< com::sun::star::lang::XComponent > *)0 ), // OComponentHelper
604 : 0 : getCppuType( (const Reference< com::sun::star::lang::XTypeProvider > *)0 ),
605 : 0 : getCppuType( (const Reference< com::sun::star::uno::XAggregation > *)0 ),
606 : 0 : getCppuType( (const Reference< com::sun::star::uno::XWeak > *)0 ) );
607 : 0 : return collection.getTypes();
608 : : }
609 : : }
610 : :
611 : : }
|
