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 "pq_resultset.hxx"
59 : #include "pq_resultsetmetadata.hxx"
60 :
61 : #include <com/sun/star/sdbc/FetchDirection.hpp>
62 : #include <com/sun/star/sdbc/ResultSetConcurrency.hpp>
63 : #include <com/sun/star/sdbc/ResultSetType.hpp>
64 : #include <com/sun/star/sdbc/DataType.hpp>
65 :
66 : using rtl::OUString;
67 : using rtl::OUStringToOString;
68 :
69 : using osl::MutexGuard;
70 :
71 : using com::sun::star::uno::RuntimeException;
72 : using com::sun::star::uno::Any;
73 : using com::sun::star::uno::makeAny;
74 : using com::sun::star::uno::Reference;
75 : using com::sun::star::uno::XInterface;
76 :
77 : using com::sun::star::sdbc::SQLException;
78 : using com::sun::star::sdbc::XResultSetMetaData;
79 :
80 :
81 : namespace pq_sdbc_driver
82 : {
83 : #define ASCII_STR(x) OUString( RTL_CONSTASCII_USTRINGPARAM( x ) )
84 :
85 0 : void ResultSet::checkClosed()
86 : throw ( com::sun::star::sdbc::SQLException, com::sun::star::uno::RuntimeException )
87 : {
88 0 : if( ! m_result )
89 : {
90 : throw SQLException( ASCII_STR( "pq_resultset: already closed" ),
91 0 : *this, OUString(), 1, Any() );
92 : }
93 :
94 0 : if( ! m_ppSettings || ! *m_ppSettings || ! (*m_ppSettings)->pConnection )
95 : {
96 : throw SQLException( ASCII_STR( "pq_resultset: statement has been closed already" ),
97 0 : *this, OUString(), 1, Any() );
98 : }
99 :
100 0 : }
101 :
102 0 : ResultSet::ResultSet( const ::rtl::Reference< RefCountedMutex > & refMutex,
103 : const Reference< XInterface > & owner,
104 : ConnectionSettings **ppSettings,
105 : PGresult * result,
106 : const rtl::OUString &schema,
107 : const rtl::OUString &table)
108 : : BaseResultSet(
109 0 : refMutex, owner, PQntuples( result ),
110 0 : PQnfields( result ),(*ppSettings)->tc ),
111 : m_result( result ),
112 : m_schema( schema ),
113 : m_table( table ),
114 0 : m_ppSettings( ppSettings )
115 : {
116 : // LEM TODO: shouldn't these things be inherited from the statement or something like that?
117 0 : sal_Bool b = sal_False;
118 : // Positioned update/delete not supported, so no cursor name
119 : // Fetch direction and size are cursor-specific things, so not used now.
120 : // Fetch size not set
121 : m_props[ BASERESULTSET_FETCH_DIRECTION ] = makeAny(
122 0 : com::sun::star::sdbc::FetchDirection::UNKNOWN);
123 : // No escape processing for now
124 0 : m_props[ BASERESULTSET_ESCAPE_PROCESSING ] = Any( &b, getBooleanCppuType() );
125 : // Bookmarks not implemented for now
126 0 : m_props[ BASERESULTSET_IS_BOOKMARKABLE ] = Any( &b, getBooleanCppuType() );
127 : m_props[ BASERESULTSET_RESULT_SET_CONCURRENCY ] = makeAny(
128 0 : com::sun::star::sdbc::ResultSetConcurrency::READ_ONLY );
129 : m_props[ BASERESULTSET_RESULT_SET_TYPE ] = makeAny(
130 0 : com::sun::star::sdbc::ResultSetType::SCROLL_INSENSITIVE );
131 0 : }
132 :
133 :
134 0 : Any ResultSet::getValue( sal_Int32 columnIndex )
135 : {
136 0 : Any ret;
137 0 : if( PQgetisnull( m_result, m_row, columnIndex -1 ) )
138 : {
139 0 : m_wasNull = true;
140 : }
141 : else
142 : {
143 0 : m_wasNull = false;
144 : ret <<= ::rtl::OUString(
145 0 : PQgetvalue( m_result, m_row , columnIndex -1 ) ,
146 0 : PQgetlength( m_result, m_row , columnIndex -1 ) ,
147 0 : (*m_ppSettings)->encoding );
148 :
149 : }
150 0 : return ret;
151 : }
152 :
153 0 : ResultSet::~ResultSet()
154 0 : {}
155 :
156 0 : void ResultSet::close( ) throw (SQLException, RuntimeException)
157 : {
158 0 : Reference< XInterface > owner;
159 : {
160 0 : MutexGuard guard( m_refMutex->mutex );
161 0 : if( m_result )
162 : {
163 0 : PQclear(m_result );
164 0 : m_result = 0;
165 0 : m_row = -1;
166 : }
167 0 : owner = m_owner;
168 0 : m_owner.clear();
169 0 : }
170 0 : }
171 :
172 0 : Reference< XResultSetMetaData > ResultSet::getMetaData( ) throw (SQLException, RuntimeException)
173 : {
174 0 : MutexGuard guard( m_refMutex->mutex );
175 0 : checkClosed();
176 : return new ResultSetMetaData(
177 0 : m_refMutex, this, this, m_ppSettings, m_result, m_schema, m_table );
178 : }
179 :
180 0 : sal_Int32 ResultSet::findColumn( const ::rtl::OUString& columnName )
181 : throw (SQLException, RuntimeException)
182 : {
183 0 : MutexGuard guard( m_refMutex->mutex );
184 0 : checkClosed();
185 : return PQfnumber(
186 : m_result,
187 0 : OUStringToOString( columnName, (*m_ppSettings)->encoding ).getStr())
188 0 : +1;
189 : }
190 :
191 0 : static bool isNumber( const char * data, sal_Int32 len )
192 : {
193 0 : bool ret = false;
194 0 : if( len )
195 : {
196 0 : ret = true;
197 0 : for( int i = 0 ; i < len ; i ++ )
198 : {
199 0 : if( ( data[i] >= '0' && data[i] <= '9' ) ||
200 0 : data[i] == '-' || data[i] == '+' || data[i] == '.' || data[i] == ',' )
201 : {
202 0 : if( data[i] == '-' && i != 0 && i != len-1 )
203 : {
204 : // no number, maybe a date
205 0 : ret = false;
206 0 : break;
207 : }
208 : }
209 : else
210 : {
211 0 : ret = false;
212 0 : break;
213 : }
214 : }
215 : }
216 0 : return ret;
217 : }
218 :
219 0 : static bool isInteger( const char * data, sal_Int32 len )
220 : {
221 0 : bool ret = false;
222 0 : if( len )
223 : {
224 0 : ret = true;
225 0 : for( int i = 0 ; i < len ; i ++ )
226 : {
227 0 : if( ( data[i] >= '0' && data[i] <= '9' ) ||
228 0 : data[i] == '-' || data[i] == '+' )
229 : {
230 0 : if( data[i] == '-' && i != 0 && i != len-1 )
231 : {
232 : // no number, maybe a date
233 0 : ret = false;
234 0 : break;
235 : }
236 : }
237 : else
238 : {
239 0 : ret = false;
240 0 : break;
241 : }
242 : }
243 : }
244 0 : return ret;
245 : }
246 :
247 0 : static bool isDate( const char * data, sal_Int32 len )
248 : {
249 : return 10 == len &&
250 0 : '-' == data[4] &&
251 0 : '-' == data[7] &&
252 0 : isInteger( &(data[0]),4 ) &&
253 0 : isInteger( &(data[5]),2) &&
254 0 : isInteger( &(data[8]),2 );
255 : }
256 :
257 0 : static bool isTime( const char * data, sal_Int32 len )
258 : {
259 : return 8 == len &&
260 0 : ':' == data[2] &&
261 0 : ':' == data[5] &&
262 0 : isInteger( &(data[0]),2 ) &&
263 0 : isInteger( &(data[3]),2) &&
264 0 : isInteger( &(data[6]),2 );
265 :
266 : }
267 :
268 0 : static bool isTimestamp( const char * data, sal_Int32 len )
269 : {
270 0 : return len == 19 && isDate( data, 10) && isTime( &(data[11]),8 );
271 : }
272 :
273 0 : sal_Int32 ResultSet::guessDataType( sal_Int32 column )
274 : {
275 : // we don't look into more than 100 rows ...
276 0 : sal_Int32 ret = com::sun::star::sdbc::DataType::INTEGER;
277 :
278 0 : int maxRows = ( m_rowCount > 100 ? 100 : m_rowCount );
279 0 : for( int i = 0 ; i < maxRows ; i ++ )
280 : {
281 0 : if( ! PQgetisnull( m_result, i , column-1 ) )
282 : {
283 0 : const char * p = PQgetvalue( m_result, i , column -1 );
284 0 : int len = PQgetlength( m_result, i , column -1 );
285 :
286 0 : if( com::sun::star::sdbc::DataType::INTEGER == ret )
287 : {
288 0 : if( ! isInteger( p,len ) )
289 0 : ret = com::sun::star::sdbc::DataType::NUMERIC;
290 : }
291 0 : if( com::sun::star::sdbc::DataType::NUMERIC == ret )
292 : {
293 0 : if( ! isNumber( p,len ) )
294 : {
295 0 : ret = com::sun::star::sdbc::DataType::DATE;
296 : }
297 : }
298 0 : if( com::sun::star::sdbc::DataType::DATE == ret )
299 : {
300 0 : if( ! isDate( p,len ) )
301 : {
302 0 : ret = com::sun::star::sdbc::DataType::TIME;
303 : }
304 : }
305 0 : if( com::sun::star::sdbc::DataType::TIME == ret )
306 : {
307 0 : if( ! isTime( p,len ) )
308 : {
309 0 : ret = com::sun::star::sdbc::DataType::TIMESTAMP;
310 : }
311 : }
312 0 : if( com::sun::star::sdbc::DataType::TIMESTAMP == ret )
313 : {
314 0 : if( ! isTimestamp( p,len ) )
315 : {
316 0 : ret = com::sun::star::sdbc::DataType::LONGVARCHAR;
317 0 : break;
318 : }
319 : }
320 : }
321 : }
322 0 : return ret;
323 : }
324 :
325 : }
|
