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 : : * Some portions were adapted from JDBC PostgreSQL driver:
57 : : *
58 : : * Copyright (c) 2004-2008, PostgreSQL Global Development Group
59 : : *
60 : : * Licence of original JDBC driver code:
61 : : *
62 : : * Redistribution and use in source and binary forms, with or without
63 : : * modification, are permitted provided that the following conditions are met:
64 : : *
65 : : * 1. Redistributions of source code must retain the above copyright notice,
66 : : * this list of conditions and the following disclaimer.
67 : : * 2. Redistributions in binary form must reproduce the above copyright notice,
68 : : * this list of conditions and the following disclaimer in the documentation
69 : : * and/or other materials provided with the distribution.
70 : : * 3. Neither the name of the PostgreSQL Global Development Group nor the names
71 : : * of its contributors may be used to endorse or promote products derived
72 : : * from this software without specific prior written permission.
73 : : *
74 : : * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS"
75 : : * AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
76 : : * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
77 : : * ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT OWNER OR CONTRIBUTORS BE
78 : : * LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR
79 : : * CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF
80 : : * SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS
81 : : * INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN
82 : : * CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE)
83 : : * ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE
84 : : * POSSIBILITY OF SUCH DAMAGE.
85 : : *
86 : : ************************************************************************/
87 : :
88 : : #include <algorithm>
89 : : #include "pq_databasemetadata.hxx"
90 : : #include "pq_driver.hxx"
91 : : #include "pq_sequenceresultset.hxx"
92 : : #include "pq_statics.hxx"
93 : : #include "pq_tools.hxx"
94 : :
95 : : #include <rtl/ustrbuf.hxx>
96 : :
97 : : #include<com/sun/star/sdbc/TransactionIsolation.hpp>
98 : : #include<com/sun/star/sdbc/ResultSetType.hpp>
99 : : #include<com/sun/star/sdbc/XPreparedStatement.hpp>
100 : : #include<com/sun/star/sdbc/XParameters.hpp>
101 : : #include<com/sun/star/sdbc/DataType.hpp>
102 : : #include<com/sun/star/sdbc/IndexType.hpp>
103 : : #include<com/sun/star/sdbc/ColumnValue.hpp>
104 : : #include<com/sun/star/sdbc/ColumnSearch.hpp>
105 : : #include<com/sun/star/sdbc/KeyRule.hpp>
106 : : #include<com/sun/star/sdbc/Deferrability.hpp>
107 : :
108 : : using ::osl::MutexGuard;
109 : :
110 : : using ::rtl::OUString;
111 : :
112 : : using namespace com::sun::star::sdbc;
113 : :
114 : : using com::sun::star::uno::RuntimeException;
115 : : using com::sun::star::uno::Sequence;
116 : :
117 : : using com::sun::star::uno::Reference;
118 : : using com::sun::star::uno::Sequence;
119 : : using com::sun::star::uno::Any;
120 : : using com::sun::star::uno::makeAny;
121 : : using com::sun::star::uno::UNO_QUERY;
122 : : using com::sun::star::uno::UNO_QUERY_THROW;
123 : :
124 : : namespace pq_sdbc_driver
125 : : {
126 : : typedef
127 : : std::vector
128 : : <
129 : : com::sun::star::uno::Sequence< com::sun::star::uno::Any >,
130 : : Allocator< com::sun::star::uno::Sequence< com::sun::star::uno::Any > >
131 : : > SequenceAnyVector;
132 : :
133 : :
134 : : #define ASCII_STR(x) OUString( RTL_CONSTASCII_USTRINGPARAM( x ) )
135 : :
136 : : #define QUOTEME(X) #X
137 : : #define STRINGIFY(X) QUOTEME(X)
138 : :
139 : : // These are pre-processor versions of KeyRule.idl declarations
140 : : // These are inherited from JDBC, and thus won't change anytime soon.
141 : : // Having them as pre-processor definitions allows to include them
142 : : // into compile-time strings (through STRINGIFY), which can be passed to ASCII_STR.
143 : : // That is without resorting to horrendeous hacks in template meta-programming.
144 : : #define KEYRULE_CASCADE 0
145 : : #define KEYRULE_RESTRICT 1
146 : : #define KEYRULE_SET_NULL 2
147 : : #define KEYRULE_NO_ACTION 4
148 : : #define KEYRULE_SET_DEFAULT 4
149 : : // Ditto for Deferrability.idl
150 : : #define DEFERRABILITY_INITIALLY_DEFERRED 5
151 : : #define DEFERRABILITY_INITIALLY_IMMEDIATE 6
152 : : #define DEFERRABILITY_NONE 7
153 : :
154 : : // alphabetically ordered !
155 : : static const int PRIVILEGE_CREATE = 0x1;
156 : : static const int PRIVILEGE_DELETE = 0x2;
157 : : static const int PRIVILEGE_EXECUTE = 0x4;
158 : : static const int PRIVILEGE_INSERT = 0x8;
159 : : static const int PRIVILEGE_REFERENCES = 0x10;
160 : : static const int PRIVILEGE_RULE = 0x20;
161 : : static const int PRIVILEGE_SELECT = 0x40;
162 : : static const int PRIVILEGE_TEMPORARY = 0x80;
163 : : static const int PRIVILEGE_TRIGGER = 0x100;
164 : : static const int PRIVILEGE_UPDATE = 0x200;
165 : : static const int PRIVILEGE_USAGE = 0x400;
166 : : static const int PRIVILEGE_MAX = PRIVILEGE_USAGE;
167 : :
168 : 0 : void DatabaseMetaData::checkClosed()
169 : : throw (SQLException, RuntimeException)
170 : : {
171 : 0 : }
172 : :
173 : 0 : DatabaseMetaData::DatabaseMetaData(
174 : : const ::rtl::Reference< RefCountedMutex > & refMutex,
175 : : const ::com::sun::star::uno::Reference< com::sun::star::sdbc::XConnection > & origin,
176 : : ConnectionSettings *pSettings )
177 : : : m_refMutex( refMutex ),
178 : : m_pSettings( pSettings ),
179 : : m_origin( origin ),
180 : 0 : m_getIntSetting_stmt ( m_origin->prepareStatement(ASCII_STR( "SELECT setting FROM pg_catalog.pg_settings WHERE name=?" )) )
181 : : {
182 : 0 : init_getReferences_stmt();
183 : 0 : init_getPrivs_stmt();
184 : 0 : }
185 : :
186 : 0 : sal_Bool DatabaseMetaData::allProceduresAreCallable( ) throw (SQLException, RuntimeException)
187 : : {
188 : : // TODO
189 : 0 : return sal_False;
190 : : }
191 : :
192 : 0 : sal_Bool DatabaseMetaData::allTablesAreSelectable( ) throw (SQLException, RuntimeException)
193 : : {
194 : 0 : return sal_True;
195 : : }
196 : :
197 : 0 : OUString DatabaseMetaData::getURL( ) throw (SQLException, RuntimeException)
198 : : {
199 : : // TODO
200 : : // LEM TODO: implement
201 : 0 : return OUString();
202 : : }
203 : :
204 : 0 : OUString DatabaseMetaData::getUserName( ) throw (SQLException, RuntimeException)
205 : : {
206 : 0 : return m_pSettings->user;
207 : : }
208 : :
209 : 0 : sal_Bool DatabaseMetaData::isReadOnly( ) throw (SQLException, RuntimeException)
210 : : {
211 : 0 : return sal_False;
212 : : }
213 : :
214 : :
215 : 0 : sal_Bool DatabaseMetaData::nullsAreSortedHigh( ) throw (SQLException, RuntimeException)
216 : : {
217 : : // Whether NULL values are considered, for sorting purposes, LARGER than any other value.
218 : : // Specification: http://download.oracle.com/javase/6/docs/api/java/sql/DatabaseMetaData.html#nullsAreSortedHigh()
219 : : // PostgreSQL behaviour: http://www.postgresql.org/docs/9.1/static/queries-order.htlm
220 : 0 : return sal_True;
221 : : }
222 : :
223 : 0 : sal_Bool DatabaseMetaData::nullsAreSortedLow( ) throw (SQLException, RuntimeException)
224 : : {
225 : 0 : return ! nullsAreSortedHigh();
226 : : }
227 : :
228 : 0 : sal_Bool DatabaseMetaData::nullsAreSortedAtStart( ) throw (SQLException, RuntimeException)
229 : : {
230 : 0 : return sal_False;
231 : : }
232 : :
233 : 0 : sal_Bool DatabaseMetaData::nullsAreSortedAtEnd( ) throw (SQLException, RuntimeException)
234 : : {
235 : 0 : return sal_False;
236 : : }
237 : :
238 : 0 : OUString DatabaseMetaData::getDatabaseProductName( ) throw (SQLException, RuntimeException)
239 : : {
240 : 0 : return ASCII_STR("PostgreSQL");
241 : : }
242 : :
243 : 0 : OUString DatabaseMetaData::getDatabaseProductVersion( ) throw (SQLException, RuntimeException)
244 : : {
245 : 0 : return rtl::OUString::createFromAscii( PQparameterStatus( m_pSettings->pConnection, "server_version" ) );
246 : : }
247 : 0 : OUString DatabaseMetaData::getDriverName( ) throw (SQLException, RuntimeException)
248 : : {
249 : 0 : return ASCII_STR( "postgresql-sdbc" );
250 : : }
251 : :
252 : 0 : OUString DatabaseMetaData::getDriverVersion( ) throw (SQLException, RuntimeException)
253 : : {
254 : 0 : return ASCII_STR( PQ_SDBC_DRIVER_VERSION );
255 : : }
256 : :
257 : 0 : sal_Int32 DatabaseMetaData::getDriverMajorVersion( ) throw (RuntimeException)
258 : : {
259 : 0 : return PQ_SDBC_MAJOR;
260 : : }
261 : :
262 : 0 : sal_Int32 DatabaseMetaData::getDriverMinorVersion( ) throw (RuntimeException)
263 : : {
264 : 0 : return PQ_SDBC_MINOR;
265 : : }
266 : :
267 : 0 : sal_Bool DatabaseMetaData::usesLocalFiles( ) throw (SQLException, RuntimeException)
268 : : {
269 : : // LEM TODO:
270 : : // http://wiki.services.openoffice.org/wiki/Documentation/DevGuide/Database/XDatabaseMetaData_Interface
271 : : // says "Returns true when the catalog name of the
272 : : // database should not appear in the DatasourceBrowser
273 : : // of OpenOffice.org API, otherwise false is returned."
274 : : // So, hmmm, think about it.
275 : 0 : return sal_False;
276 : : }
277 : :
278 : 0 : sal_Bool DatabaseMetaData::usesLocalFilePerTable( ) throw (SQLException, RuntimeException)
279 : : {
280 : 0 : return sal_False;
281 : : }
282 : :
283 : 0 : sal_Bool DatabaseMetaData::supportsMixedCaseIdentifiers( ) throw (SQLException, RuntimeException)
284 : : {
285 : 0 : return sal_False;
286 : : }
287 : :
288 : 0 : sal_Bool DatabaseMetaData::storesUpperCaseIdentifiers( ) throw (SQLException, RuntimeException)
289 : : {
290 : 0 : return sal_False;
291 : : }
292 : :
293 : 0 : sal_Bool DatabaseMetaData::storesLowerCaseIdentifiers( ) throw (SQLException, RuntimeException)
294 : : {
295 : 0 : return sal_True;
296 : : }
297 : :
298 : :
299 : 0 : sal_Bool DatabaseMetaData::storesMixedCaseIdentifiers( ) throw (SQLException, RuntimeException)
300 : : {
301 : 0 : return sal_False;
302 : : }
303 : :
304 : :
305 : 0 : sal_Bool DatabaseMetaData::supportsMixedCaseQuotedIdentifiers( ) throw (SQLException, RuntimeException)
306 : : {
307 : 0 : return sal_True;
308 : : }
309 : :
310 : 0 : sal_Bool DatabaseMetaData::storesUpperCaseQuotedIdentifiers( ) throw (SQLException, RuntimeException)
311 : : {
312 : 0 : return sal_False;
313 : : }
314 : :
315 : :
316 : 0 : sal_Bool DatabaseMetaData::storesLowerCaseQuotedIdentifiers( ) throw (SQLException, RuntimeException)
317 : : {
318 : 0 : return sal_False;
319 : : }
320 : :
321 : :
322 : 0 : sal_Bool DatabaseMetaData::storesMixedCaseQuotedIdentifiers( ) throw (SQLException, RuntimeException)
323 : : {
324 : 0 : return sal_False;
325 : : }
326 : :
327 : :
328 : 0 : OUString DatabaseMetaData::getIdentifierQuoteString( ) throw (SQLException, RuntimeException)
329 : : {
330 : 0 : return ASCII_STR( "\"" );
331 : : }
332 : :
333 : 0 : OUString DatabaseMetaData::getSQLKeywords( ) throw (SQLException, RuntimeException)
334 : : {
335 : : // In Java 6, this is all keywords that are not SQL:2003
336 : : // In Java 2 v1.4 and as per LibreOffice SDK doc, this is all keywords that are not SQL92
337 : : // I understand this to mean "reserved keywords" only.
338 : : // See http://www.postgresql.org/docs/current/static/sql-keywords-appendix.html
339 : 0 : return ASCII_STR(
340 : : "ANALYSE,"
341 : : "ANALYZE,"
342 : : "ARRAY," //SQL:1999
343 : : "ASYMMETRIC," //SQL:2003
344 : : "BINARY," //SQL:1999
345 : : "CONCURRENTLY,"
346 : : "CURRENT_CATALOG," //SQL:2008
347 : : "CURRENT_ROLE," //SQL:1999
348 : : "CURRENT_SCHEMA," //SQL:2008
349 : : "DO,"
350 : : "FREEZE,"
351 : : "ILIKE,"
352 : : "ISNULL,"
353 : : "LIMIT," //SQL:1999; non-reserved in SQL:2003
354 : : "LOCALTIME," //SQL:1999
355 : : "LOCALTIMESTAMP," //SQL:1999
356 : : "NOTNULL,"
357 : : "OFFSET," //SQL:2008
358 : : "OVER," //SQL:2003
359 : : "PLACING," //non-reserved in SQL:2003
360 : : "RETURNING," //non-reserved in SQL:2008
361 : : "SIMILAR," //SQL:2003
362 : : "VARIADIC,"
363 : : "VERBOSE,"
364 : : "WINDOW" //SQL:2003
365 : : );
366 : : }
367 : 0 : OUString DatabaseMetaData::getNumericFunctions( ) throw (SQLException, RuntimeException)
368 : : {
369 : : // See http://www.postgresql.org/docs/9.1/static/functions-math.html
370 : : // LEM TODO: Err... http://wiki.services.openoffice.org/wiki/Documentation/DevGuide/Database/Support_Scalar_Functions
371 : : // says this should be "Open Group CLI" names, not PostgreSQL names.
372 : : // Currently this is just a list of supported functions in PostgreSQL, with PostgreSQL names.
373 : : // And it is my job to map from Open Group CLI names/syntax to PostgreSQL names/syntax. Where? By parsing the SQL???
374 : : // Should look at what the JDBC driver is doing.
375 : 0 : return ASCII_STR(
376 : : "abs,"
377 : : "cbrt,"
378 : : "ceil,"
379 : : "ceiling,"
380 : : "degrees,"
381 : : "div,"
382 : : "exp,"
383 : : "floor,"
384 : : "ln,"
385 : : "log,"
386 : : "mod,"
387 : : "pi,"
388 : : "power,"
389 : : "radians,"
390 : : "random,"
391 : : "round,"
392 : : "setseed,"
393 : : "sign,"
394 : : "sqrt,"
395 : : "trunc,"
396 : : "width_bucket,"
397 : : "acos,"
398 : : "asin,"
399 : : "atan,"
400 : : "atan2,"
401 : : "cos,"
402 : : "cot,"
403 : : "sin,"
404 : : "tan"
405 : : );
406 : : }
407 : :
408 : 0 : OUString DatabaseMetaData::getStringFunctions( ) throw (SQLException, RuntimeException)
409 : : {
410 : : // See http://www.postgresql.org/docs/9.1/static/functions-string.html
411 : 0 : return ASCII_STR(
412 : : "bit_length,"
413 : : "char_length,"
414 : : "character_length,"
415 : : "lower,"
416 : : "octet_length,"
417 : : "overlay,"
418 : : "position,"
419 : : "substring,"
420 : : "trim,"
421 : : "upper,"
422 : : "ascii,"
423 : : "btrim,"
424 : : "chr,"
425 : : "concat,"
426 : : "concat_ws,"
427 : : "convert,"
428 : : "convert_from,"
429 : : "convert_to,"
430 : : "decode,"
431 : : "encode,"
432 : : "foramt,"
433 : : "initcap,"
434 : : "left,"
435 : : "length,"
436 : : "lpad,"
437 : : "ltrim,"
438 : : "md5,"
439 : : "pg_client_encoding,"
440 : : "quote_ident,"
441 : : "quote_literal,"
442 : : "quote_nullable,"
443 : : "regexp_matches,"
444 : : "regexp_replace,"
445 : : "regexp_split_to_array,"
446 : : "regexp_split_to_table,"
447 : : "repeat,"
448 : : "replace,"
449 : : "reverse,"
450 : : "right,"
451 : : "rpad,"
452 : : "rtrim,"
453 : : "split_part,"
454 : : "strpos,"
455 : : "substr,"
456 : : "to_ascii,"
457 : : "to_hex,"
458 : : "translate"
459 : : );
460 : : }
461 : :
462 : 0 : OUString DatabaseMetaData::getSystemFunctions( ) throw (SQLException, RuntimeException)
463 : : {
464 : : // See http://www.postgresql.org/docs/9.1/static/functions-info.html
465 : : // and http://www.postgresql.org/docs/9.1/static/functions-admin.html
466 : 0 : return ASCII_STR(
467 : : "current_catalog,"
468 : : "current_database,"
469 : : "current_query,"
470 : : "current_schema,"
471 : : "current_schemas,"
472 : : "current_user,"
473 : : "inet_client_addr,"
474 : : "inet_client_port,"
475 : : "inet_server_addr,"
476 : : "inet_server_port,"
477 : : "pg_backend_pid,"
478 : : "pg_conf_load_time,"
479 : : "pg_is_other_temp_schema,"
480 : : "pg_listening_channels,"
481 : : "pg_my_temp_schema,"
482 : : "pg_postmaster_start_time,"
483 : : "session_user,"
484 : : "user,"
485 : : "version,"
486 : : "has_any_column_privilege,"
487 : : "has_any_column_privilege,"
488 : : "has_any_column_privilege,"
489 : : "has_column_privilege,"
490 : : "has_database_privilege,"
491 : : "has_foreign_data_wrapper_privilege,"
492 : : "has_function_privilege,"
493 : : "has_language_privilege,"
494 : : "has_schema_privilege,"
495 : : "has_sequence_privilege,"
496 : : "has_server_privilege,"
497 : : "has_table_privilege,"
498 : : "has_tablespace_privilege,"
499 : : "pg_has_role,"
500 : : "pg_collation_is_visible,"
501 : : "pg_conversion_is_visible,"
502 : : "pg_function_is_visible,"
503 : : "pg_opclass_is_visible,"
504 : : "pg_operator_is_visible,"
505 : : "pg_table_is_visible,"
506 : : "pg_ts_config_is_visible,"
507 : : "pg_ts_dict_is_visible,"
508 : : "pg_ts_parser_is_visible,"
509 : : "pg_ts_template_is_visible,"
510 : : "pg_type_is_visible,"
511 : : "format_type,"
512 : : "pg_describe_object,"
513 : : "pg_get_constraintdef,"
514 : : "pg_get_expr,"
515 : : "pg_get_functiondef,"
516 : : "pg_get_function_arguments,"
517 : : "pg_get_function_identity_arguments,"
518 : : "pg_get_function_result,"
519 : : "pg_get_indexdef,"
520 : : "pg_get_keywords,"
521 : : "pg_get_ruledef,"
522 : : "pg_get_serial_sequence,"
523 : : "pg_get_triggerdef,"
524 : : "pg_get_userbyid,"
525 : : "pg_get_viewdef,"
526 : : "pg_options_to_table,"
527 : : "pg_tablespace_databases,"
528 : : "pg_typeof,"
529 : : "col_description,"
530 : : "obj_description,"
531 : : "shobj_description,"
532 : : "txid_current,"
533 : : "txid_current_snapshot,"
534 : : "txid_snapshot_xip,"
535 : : "txid_snapshot_xmax,"
536 : : "txid_snapshot_xmin,"
537 : : "txid_visible_in_snapshot,"
538 : : "xmin,"
539 : : "xmax,"
540 : : "xip_list,"
541 : : "current_setting,"
542 : : "set_config,"
543 : : "pg_cancel_backend,"
544 : : "pg_reload_conf,"
545 : : "pg_rotate_logfile,"
546 : : "pg_terminate_backend,"
547 : : "pg_create_restore_point,"
548 : : "pg_current_xlog_insert_location,"
549 : : "pg_current_xlog_location,"
550 : : "pg_start_backup,"
551 : : "pg_stop_backup,"
552 : : "pg_switch_xlog,"
553 : : "pg_xlogfile_name,"
554 : : "pg_xlogfile_name_offset,"
555 : : "pg_is_in_recovery,"
556 : : "pg_last_xlog_receive_location,"
557 : : "pg_last_xlog_replay_location,"
558 : : "pg_last_xact_replay_timestamp,"
559 : : "pg_is_xlog_replay_paused,"
560 : : "pg_xlog_replay_pause,"
561 : : "pg_xlog_replay_resume,"
562 : : "pg_column_size,"
563 : : "pg_database_size,"
564 : : "pg_indexes_size,"
565 : : "pg_relation_size,"
566 : : "pg_size_pretty,"
567 : : "pg_table_size,"
568 : : "pg_tablespace_size,"
569 : : "pg_tablespace_size,"
570 : : "pg_total_relation_size,"
571 : : "pg_relation_filenode,"
572 : : "pg_relation_filepath,"
573 : : "pg_ls_dir,"
574 : : "pg_read_file,"
575 : : "pg_read_binary_file,"
576 : : "pg_stat_file,"
577 : : "pg_advisory_lock,"
578 : : "pg_advisory_lock_shared,"
579 : : "pg_advisory_unlock,"
580 : : "pg_advisory_unlock_all,"
581 : : "pg_advisory_unlock_shared,"
582 : : "pg_advisory_xact_lock,"
583 : : "pg_advisory_xact_lock_shared,"
584 : : "pg_try_advisory_lock,"
585 : : "pg_try_advisory_lock_shared,"
586 : : "pg_try_advisory_xact_lock,"
587 : : "pg_try_advisory_xact_lock_shared,"
588 : : "pg_sleep"
589 : : );
590 : : }
591 : 0 : OUString DatabaseMetaData::getTimeDateFunctions( ) throw (SQLException, RuntimeException)
592 : : {
593 : : // TODO
594 : 0 : return ASCII_STR(
595 : : "age,"
596 : : "age,"
597 : : "clock_timestamp,"
598 : : "current_date,"
599 : : "current_time,"
600 : : "current_timestamp,"
601 : : "date_part,"
602 : : "date_part,"
603 : : "date_trunc,"
604 : : "extract,"
605 : : "extract,"
606 : : "isfinite,"
607 : : "isfinite,"
608 : : "isfinite,"
609 : : "justify_days,"
610 : : "justify_hours,"
611 : : "justify_interval,"
612 : : "localtime,"
613 : : "localtimestamp,"
614 : : "now,"
615 : : "statement_timestamp,"
616 : : "timeofday,"
617 : : "transaction_timestamp,"
618 : : );
619 : : }
620 : 0 : OUString DatabaseMetaData::getSearchStringEscape( ) throw (SQLException, RuntimeException)
621 : : {
622 : 0 : return ASCII_STR( "\\" );
623 : : }
624 : 0 : OUString DatabaseMetaData::getExtraNameCharacters( ) throw (SQLException, RuntimeException)
625 : : {
626 : 0 : return ASCII_STR( "$" );
627 : : }
628 : :
629 : 0 : sal_Bool DatabaseMetaData::supportsAlterTableWithAddColumn( ) throw (SQLException, RuntimeException)
630 : : {
631 : 0 : return sal_True;
632 : : }
633 : :
634 : 0 : sal_Bool DatabaseMetaData::supportsAlterTableWithDropColumn( ) throw (SQLException, RuntimeException)
635 : : {
636 : 0 : return sal_True;
637 : : }
638 : :
639 : 0 : sal_Bool DatabaseMetaData::supportsColumnAliasing( ) throw (SQLException, RuntimeException)
640 : : {
641 : 0 : return sal_True;
642 : : }
643 : :
644 : 0 : sal_Bool DatabaseMetaData::nullPlusNonNullIsNull( ) throw (SQLException, RuntimeException)
645 : : {
646 : 0 : return sal_True;
647 : : }
648 : :
649 : 0 : sal_Bool DatabaseMetaData::supportsTypeConversion( ) throw (SQLException, RuntimeException)
650 : : {
651 : : // LEM: this is specifically whether the "CONVERT" function is supported
652 : : // It seems that in PostgreSQL, that function is only for string encoding, so no.
653 : 0 : return sal_False;
654 : : }
655 : :
656 : 0 : sal_Bool DatabaseMetaData::supportsConvert( sal_Int32 fromType, sal_Int32 toType ) throw (SQLException, RuntimeException)
657 : : {
658 : : (void) fromType; (void) toType;
659 : 0 : return sal_False;
660 : : }
661 : :
662 : 0 : sal_Bool DatabaseMetaData::supportsTableCorrelationNames( ) throw (SQLException, RuntimeException)
663 : : {
664 : : // LEM: A correlation name is "bar" in "SELECT foo FROM qux [AS] bar WHERE ..."
665 : 0 : return sal_True;
666 : : }
667 : :
668 : :
669 : 0 : sal_Bool DatabaseMetaData::supportsDifferentTableCorrelationNames( ) throw (SQLException, RuntimeException)
670 : : {
671 : 0 : return sal_False;
672 : : }
673 : 0 : sal_Bool DatabaseMetaData::supportsExpressionsInOrderBy( ) throw (SQLException, RuntimeException)
674 : : {
675 : 0 : return sal_True;
676 : : }
677 : :
678 : 0 : sal_Bool DatabaseMetaData::supportsOrderByUnrelated( ) throw (SQLException, RuntimeException)
679 : : {
680 : 0 : return sal_True;
681 : : }
682 : :
683 : 0 : sal_Bool DatabaseMetaData::supportsGroupBy( ) throw (SQLException, RuntimeException)
684 : : {
685 : 0 : return sal_True;
686 : : }
687 : :
688 : 0 : sal_Bool DatabaseMetaData::supportsGroupByUnrelated( ) throw (SQLException, RuntimeException)
689 : : {
690 : 0 : return sal_True;
691 : : }
692 : :
693 : 0 : sal_Bool DatabaseMetaData::supportsGroupByBeyondSelect( ) throw (SQLException, RuntimeException)
694 : : {
695 : 0 : return sal_True;
696 : : }
697 : :
698 : 0 : sal_Bool DatabaseMetaData::supportsLikeEscapeClause( ) throw (SQLException, RuntimeException)
699 : : {
700 : 0 : return sal_True;
701 : : }
702 : :
703 : 0 : sal_Bool DatabaseMetaData::supportsMultipleResultSets( ) throw (SQLException, RuntimeException)
704 : : {
705 : 0 : return sal_True;
706 : : }
707 : :
708 : 0 : sal_Bool DatabaseMetaData::supportsMultipleTransactions( ) throw (SQLException, RuntimeException)
709 : : {
710 : : // Allows multiple transactions open at once (on different connections!)
711 : 0 : return sal_True;
712 : : }
713 : :
714 : 0 : sal_Bool DatabaseMetaData::supportsNonNullableColumns( ) throw (SQLException, RuntimeException)
715 : : {
716 : 0 : return sal_True;
717 : : }
718 : :
719 : :
720 : 0 : sal_Bool DatabaseMetaData::supportsMinimumSQLGrammar( ) throw (SQLException, RuntimeException)
721 : : {
722 : 0 : return sal_True;
723 : : }
724 : :
725 : 0 : sal_Bool DatabaseMetaData::supportsCoreSQLGrammar( ) throw (SQLException, RuntimeException)
726 : : {
727 : : // LEM: jdbc driver says not, although the comments in it seem old
728 : : // fdo#45249 Base query design won't use any aggregate function
729 : : // (except COUNT(*) unless we say yes, so say yes.
730 : : // Actually, Base assumes *also* support for aggregate functions "collect, fusion, intersection"
731 : : // as soon as supportsCoreSQLGrammar() returns true.
732 : : // Those are *not* Core SQL, though. They are in optional feature S271 "Basic multiset support"
733 : 0 : return sal_True;
734 : : }
735 : :
736 : 0 : sal_Bool DatabaseMetaData::supportsExtendedSQLGrammar( ) throw (SQLException, RuntimeException)
737 : : {
738 : 0 : return sal_False;
739 : : }
740 : :
741 : 0 : sal_Bool DatabaseMetaData::supportsANSI92EntryLevelSQL( ) throw (SQLException, RuntimeException)
742 : : {
743 : 0 : return sal_True;
744 : : }
745 : :
746 : 0 : sal_Bool DatabaseMetaData::supportsANSI92IntermediateSQL( ) throw (SQLException, RuntimeException)
747 : : {
748 : : // LEM: jdbc driver says not, although the comments in it seem old
749 : 0 : return sal_False;
750 : : }
751 : :
752 : 0 : sal_Bool DatabaseMetaData::supportsANSI92FullSQL( ) throw (SQLException, RuntimeException)
753 : : {
754 : : // LEM: jdbc driver says not, although the comments in it seem old
755 : 0 : return sal_False;
756 : : }
757 : :
758 : 0 : sal_Bool DatabaseMetaData::supportsIntegrityEnhancementFacility( ) throw (SQLException, RuntimeException)
759 : : {
760 : : // LEM: jdbc driver says yes, although comment says they are not sure what this means...
761 : 0 : return sal_True;
762 : : }
763 : :
764 : 0 : sal_Bool DatabaseMetaData::supportsOuterJoins( ) throw (SQLException, RuntimeException)
765 : : {
766 : 0 : return sal_True;
767 : : }
768 : :
769 : 0 : sal_Bool DatabaseMetaData::supportsFullOuterJoins( ) throw (SQLException, RuntimeException)
770 : : {
771 : 0 : return sal_True;
772 : : }
773 : :
774 : 0 : sal_Bool DatabaseMetaData::supportsLimitedOuterJoins( ) throw (SQLException, RuntimeException)
775 : : {
776 : 0 : return sal_True;
777 : : }
778 : :
779 : :
780 : 0 : OUString DatabaseMetaData::getSchemaTerm( ) throw (SQLException, RuntimeException)
781 : : {
782 : 0 : return ASCII_STR( "SCHEMA" );
783 : : }
784 : :
785 : 0 : OUString DatabaseMetaData::getProcedureTerm( ) throw (SQLException, RuntimeException)
786 : : {
787 : 0 : return ASCII_STR( "function" );
788 : : }
789 : :
790 : 0 : OUString DatabaseMetaData::getCatalogTerm( ) throw (SQLException, RuntimeException)
791 : : {
792 : 0 : return ASCII_STR( "DATABASE" );
793 : : }
794 : :
795 : 0 : sal_Bool DatabaseMetaData::isCatalogAtStart( ) throw (SQLException, RuntimeException)
796 : : {
797 : :
798 : 0 : return sal_True;
799 : : }
800 : :
801 : 0 : OUString DatabaseMetaData::getCatalogSeparator( ) throw (SQLException, RuntimeException)
802 : : {
803 : 0 : return ASCII_STR( "." );
804 : : }
805 : :
806 : 0 : sal_Bool DatabaseMetaData::supportsSchemasInDataManipulation( ) throw (SQLException, RuntimeException)
807 : : {
808 : 0 : return sal_True;
809 : : }
810 : :
811 : 0 : sal_Bool DatabaseMetaData::supportsSchemasInProcedureCalls( ) throw (SQLException, RuntimeException)
812 : : {
813 : 0 : return sal_True;
814 : : }
815 : :
816 : 0 : sal_Bool DatabaseMetaData::supportsSchemasInTableDefinitions( ) throw (SQLException, RuntimeException)
817 : : {
818 : 0 : return sal_True;
819 : : }
820 : :
821 : 0 : sal_Bool DatabaseMetaData::supportsSchemasInIndexDefinitions( ) throw (SQLException, RuntimeException)
822 : : {
823 : 0 : return sal_True;
824 : : }
825 : :
826 : 0 : sal_Bool DatabaseMetaData::supportsSchemasInPrivilegeDefinitions( ) throw (SQLException, RuntimeException)
827 : : {
828 : 0 : return sal_True;
829 : : }
830 : :
831 : 0 : sal_Bool DatabaseMetaData::supportsCatalogsInDataManipulation( ) throw (SQLException, RuntimeException)
832 : : {
833 : 0 : return sal_False;
834 : : }
835 : :
836 : 0 : sal_Bool DatabaseMetaData::supportsCatalogsInProcedureCalls( ) throw (SQLException, RuntimeException)
837 : : {
838 : 0 : return sal_False;
839 : : }
840 : :
841 : 0 : sal_Bool DatabaseMetaData::supportsCatalogsInTableDefinitions( ) throw (SQLException, RuntimeException)
842 : : {
843 : 0 : return sal_False;
844 : : }
845 : :
846 : :
847 : 0 : sal_Bool DatabaseMetaData::supportsCatalogsInIndexDefinitions( ) throw (SQLException, RuntimeException)
848 : : {
849 : 0 : return sal_False;
850 : : }
851 : :
852 : :
853 : 0 : sal_Bool DatabaseMetaData::supportsCatalogsInPrivilegeDefinitions( ) throw (SQLException, RuntimeException)
854 : : {
855 : 0 : return sal_False;
856 : : }
857 : :
858 : :
859 : : // LEM TODO: positioned (through cursor) updates and deletes seem
860 : : // to be supported; see {UPDATE,DELETE} /table/ (...) WHERE CURRENT OF /cursor_name/" syntax
861 : : // and http://www.postgresql.org/docs/9.1/static/view-pg-cursors.html
862 : : // http://www.postgresql.org/docs/9.1/static/libpq-example.html actually uses a cursor :)
863 : 0 : sal_Bool DatabaseMetaData::supportsPositionedDelete( ) throw (SQLException, RuntimeException)
864 : : {
865 : : // LEM: jdbc driver says not, although the comments in it seem old
866 : 0 : return sal_False;
867 : : }
868 : :
869 : 0 : sal_Bool DatabaseMetaData::supportsPositionedUpdate( ) throw (SQLException, RuntimeException)
870 : : {
871 : : // LEM: jdbc driver says not, although the comments in it seem old
872 : 0 : return sal_False;
873 : : }
874 : :
875 : :
876 : 0 : sal_Bool DatabaseMetaData::supportsSelectForUpdate( ) throw (SQLException, RuntimeException)
877 : : {
878 : 0 : return sal_True;
879 : : }
880 : :
881 : :
882 : 0 : sal_Bool DatabaseMetaData::supportsStoredProcedures( ) throw (SQLException, RuntimeException)
883 : : {
884 : 0 : return sal_True;
885 : : }
886 : :
887 : :
888 : 0 : sal_Bool DatabaseMetaData::supportsSubqueriesInComparisons( ) throw (SQLException, RuntimeException)
889 : : {
890 : 0 : return sal_True;
891 : : }
892 : :
893 : 0 : sal_Bool DatabaseMetaData::supportsSubqueriesInExists( ) throw (SQLException, RuntimeException)
894 : : {
895 : 0 : return sal_True;
896 : : }
897 : :
898 : 0 : sal_Bool DatabaseMetaData::supportsSubqueriesInIns( ) throw (SQLException, RuntimeException)
899 : : {
900 : 0 : return sal_True;
901 : : }
902 : :
903 : 0 : sal_Bool DatabaseMetaData::supportsSubqueriesInQuantifieds( ) throw (SQLException, RuntimeException)
904 : : {
905 : : // LEM: jdbc driver says yes, although comment says they don't know what this means...
906 : 0 : return sal_True;
907 : : }
908 : :
909 : 0 : sal_Bool DatabaseMetaData::supportsCorrelatedSubqueries( ) throw (SQLException, RuntimeException)
910 : : {
911 : 0 : return sal_True;
912 : : }
913 : 0 : sal_Bool DatabaseMetaData::supportsUnion( ) throw (SQLException, RuntimeException)
914 : : {
915 : 0 : return sal_True;
916 : : }
917 : :
918 : 0 : sal_Bool DatabaseMetaData::supportsUnionAll( ) throw (SQLException, RuntimeException)
919 : : {
920 : 0 : return sal_True;
921 : : }
922 : :
923 : 0 : sal_Bool DatabaseMetaData::supportsOpenCursorsAcrossCommit( ) throw (SQLException, RuntimeException)
924 : : {
925 : 0 : return sal_False;
926 : : }
927 : :
928 : 0 : sal_Bool DatabaseMetaData::supportsOpenCursorsAcrossRollback( ) throw (SQLException, RuntimeException)
929 : : {
930 : 0 : return sal_False;
931 : : }
932 : :
933 : 0 : sal_Bool DatabaseMetaData::supportsOpenStatementsAcrossCommit( ) throw (SQLException, RuntimeException)
934 : : {
935 : 0 : return sal_True;
936 : : }
937 : 0 : sal_Bool DatabaseMetaData::supportsOpenStatementsAcrossRollback( ) throw (SQLException, RuntimeException)
938 : : {
939 : 0 : return sal_True;
940 : : }
941 : :
942 : 0 : sal_Int32 DatabaseMetaData::getMaxBinaryLiteralLength( ) throw (SQLException, RuntimeException)
943 : : {
944 : 0 : return 0;
945 : : }
946 : :
947 : 0 : sal_Int32 DatabaseMetaData::getMaxCharLiteralLength( ) throw (SQLException, RuntimeException)
948 : : {
949 : 0 : return 0;
950 : : }
951 : :
952 : : // Copied / adapted / simplified from JDBC driver
953 : 0 : sal_Int32 DatabaseMetaData::getIntSetting(OUString settingName)
954 : : throw (::com::sun::star::sdbc::SQLException, ::com::sun::star::uno::RuntimeException)
955 : : {
956 : 0 : MutexGuard guard( m_refMutex->mutex );
957 : :
958 : 0 : Reference< XParameters > params(m_getIntSetting_stmt, UNO_QUERY_THROW );
959 : 0 : params->setString(1, settingName );
960 : 0 : Reference< XResultSet > rs = m_getIntSetting_stmt->executeQuery();
961 : 0 : Reference< XRow > xRow( rs , UNO_QUERY_THROW );
962 : 0 : OSL_VERIFY(rs->next());
963 : : OSL_ENSURE(rs->isFirst(), "postgresql-sdbc DatabaseMetaData getIntSetting not on first row");
964 : : OSL_ENSURE(rs->isLast(), "postgresql-sdbc DatabaseMetaData getIntSetting not on last row");
965 : 0 : return xRow->getInt(1);
966 : : }
967 : :
968 : 0 : sal_Int32 DatabaseMetaData::getMaxNameLength()
969 : : throw (::com::sun::star::sdbc::SQLException, ::com::sun::star::uno::RuntimeException)
970 : : {
971 : 0 : if ( m_pSettings->maxNameLen == 0)
972 : 0 : m_pSettings->maxNameLen = getIntSetting( ASCII_STR("max_identifier_length") );
973 : : OSL_ENSURE(m_pSettings->maxNameLen, "postgresql-sdbc: maxNameLen is zero");
974 : 0 : return m_pSettings->maxNameLen;
975 : : }
976 : :
977 : 0 : sal_Int32 DatabaseMetaData::getMaxIndexKeys()
978 : : throw (::com::sun::star::sdbc::SQLException, ::com::sun::star::uno::RuntimeException)
979 : : {
980 : 0 : if ( m_pSettings->maxIndexKeys == 0)
981 : 0 : m_pSettings->maxIndexKeys = getIntSetting(ASCII_STR("max_index_keys"));
982 : : OSL_ENSURE(m_pSettings->maxIndexKeys, "postgresql-sdbc: maxIndexKeys is zero");
983 : 0 : return m_pSettings->maxIndexKeys;
984 : : }
985 : :
986 : 0 : sal_Int32 DatabaseMetaData::getMaxColumnNameLength( ) throw (SQLException, RuntimeException)
987 : : {
988 : 0 : return getMaxNameLength();
989 : : }
990 : :
991 : 0 : sal_Int32 DatabaseMetaData::getMaxColumnsInGroupBy( ) throw (SQLException, RuntimeException)
992 : : {
993 : 0 : return 0;
994 : : }
995 : :
996 : 0 : sal_Int32 DatabaseMetaData::getMaxColumnsInIndex( ) throw (SQLException, RuntimeException)
997 : : {
998 : 0 : return getMaxIndexKeys();
999 : : }
1000 : :
1001 : 0 : sal_Int32 DatabaseMetaData::getMaxColumnsInOrderBy( ) throw (SQLException, RuntimeException)
1002 : : {
1003 : 0 : return 0;
1004 : : }
1005 : :
1006 : 0 : sal_Int32 DatabaseMetaData::getMaxColumnsInSelect( ) throw (SQLException, RuntimeException)
1007 : : {
1008 : 0 : return 0;
1009 : : }
1010 : :
1011 : 0 : sal_Int32 DatabaseMetaData::getMaxColumnsInTable( ) throw (SQLException, RuntimeException)
1012 : : {
1013 : 0 : return 1600;
1014 : : }
1015 : :
1016 : 0 : sal_Int32 DatabaseMetaData::getMaxConnections( ) throw (SQLException, RuntimeException)
1017 : : {
1018 : : // LEM: The JDBC driver returns an arbitrary 8192; truth is as much as OS / hardware supports
1019 : 0 : return 0;
1020 : : }
1021 : :
1022 : 0 : sal_Int32 DatabaseMetaData::getMaxCursorNameLength( ) throw (SQLException, RuntimeException) //TODO, don't know
1023 : : {
1024 : 0 : return getMaxNameLength();
1025 : : }
1026 : :
1027 : 0 : sal_Int32 DatabaseMetaData::getMaxIndexLength( ) throw (SQLException, RuntimeException) //TODO, don't know
1028 : : {
1029 : : // LEM: that's the index itself, not its name
1030 : 0 : return 0;
1031 : : }
1032 : :
1033 : 0 : sal_Int32 DatabaseMetaData::getMaxSchemaNameLength( ) throw (SQLException, RuntimeException)
1034 : : {
1035 : 0 : return getMaxNameLength();
1036 : : }
1037 : :
1038 : 0 : sal_Int32 DatabaseMetaData::getMaxProcedureNameLength( ) throw (SQLException, RuntimeException)
1039 : : {
1040 : 0 : return getMaxNameLength();
1041 : : }
1042 : :
1043 : 0 : sal_Int32 DatabaseMetaData::getMaxCatalogNameLength( ) throw (SQLException, RuntimeException)
1044 : : {
1045 : 0 : return getMaxNameLength();
1046 : : }
1047 : :
1048 : 0 : sal_Int32 DatabaseMetaData::getMaxRowSize( ) throw (SQLException, RuntimeException)
1049 : : {
1050 : : // jdbc driver says 1GB, but http://www.postgresql.org/about/ says 1.6TB
1051 : : // and that 1GB is the maximum _field_ size
1052 : : // The row limit does not fit into a sal_Int32
1053 : 0 : return 0;
1054 : : }
1055 : :
1056 : 0 : sal_Bool DatabaseMetaData::doesMaxRowSizeIncludeBlobs( ) throw (SQLException, RuntimeException)
1057 : : {
1058 : : // LEM: Err... PostgreSQL basically does not do BLOBs well
1059 : : // In any case, BLOBs do not change the maximal row length AFAIK
1060 : 0 : return sal_True;
1061 : : }
1062 : :
1063 : 0 : sal_Int32 DatabaseMetaData::getMaxStatementLength( ) throw (SQLException, RuntimeException)
1064 : : {
1065 : : // LEM: actually, that would be 2^sizeof(size_t)-1
1066 : : // on the server? on the client (because of libpq)? minimum of the two? not sure
1067 : : // Anyway, big, so say unlimited.
1068 : 0 : return 0;
1069 : : }
1070 : :
1071 : 0 : sal_Int32 DatabaseMetaData::getMaxStatements( ) throw (SQLException, RuntimeException) //TODO, don't know
1072 : : {
1073 : 0 : return 0;
1074 : : }
1075 : :
1076 : 0 : sal_Int32 DatabaseMetaData::getMaxTableNameLength( ) throw (SQLException, RuntimeException)
1077 : : {
1078 : 0 : return getMaxNameLength();
1079 : : }
1080 : :
1081 : 0 : sal_Int32 DatabaseMetaData::getMaxTablesInSelect( ) throw (SQLException, RuntimeException)
1082 : : {
1083 : 0 : return 0;
1084 : : }
1085 : :
1086 : 0 : sal_Int32 DatabaseMetaData::getMaxUserNameLength( ) throw (SQLException, RuntimeException)
1087 : : {
1088 : 0 : return getMaxNameLength();
1089 : : }
1090 : :
1091 : 0 : sal_Int32 DatabaseMetaData::getDefaultTransactionIsolation( ) throw (SQLException, RuntimeException)
1092 : : {
1093 : 0 : return com::sun::star::sdbc::TransactionIsolation::READ_COMMITTED;
1094 : : }
1095 : :
1096 : 0 : sal_Bool DatabaseMetaData::supportsTransactions( ) throw (SQLException, RuntimeException)
1097 : : {
1098 : 0 : return sal_True;
1099 : : }
1100 : :
1101 : 0 : sal_Bool DatabaseMetaData::supportsTransactionIsolationLevel( sal_Int32 level ) throw (SQLException, RuntimeException)
1102 : : {
1103 : 0 : if ( level == com::sun::star::sdbc::TransactionIsolation::READ_COMMITTED
1104 : : || level == com::sun::star::sdbc::TransactionIsolation::SERIALIZABLE
1105 : : || level == com::sun::star::sdbc::TransactionIsolation::READ_UNCOMMITTED
1106 : : || level == com::sun::star::sdbc::TransactionIsolation::REPEATABLE_READ)
1107 : 0 : return sal_True;
1108 : : else
1109 : 0 : return sal_False;
1110 : : }
1111 : :
1112 : 0 : sal_Bool DatabaseMetaData::supportsDataDefinitionAndDataManipulationTransactions( )
1113 : : throw (SQLException, RuntimeException)
1114 : : {
1115 : 0 : return sal_True;
1116 : : }
1117 : :
1118 : 0 : sal_Bool DatabaseMetaData::supportsDataManipulationTransactionsOnly( ) throw (SQLException, RuntimeException)
1119 : : {
1120 : 0 : return sal_False;
1121 : : }
1122 : :
1123 : 0 : sal_Bool DatabaseMetaData::dataDefinitionCausesTransactionCommit( ) throw (SQLException, RuntimeException)
1124 : : {
1125 : 0 : return sal_False;
1126 : : }
1127 : :
1128 : 0 : sal_Bool DatabaseMetaData::dataDefinitionIgnoredInTransactions( ) throw (SQLException, RuntimeException)
1129 : : {
1130 : 0 : return sal_False;
1131 : : }
1132 : :
1133 : 0 : ::com::sun::star::uno::Reference< XResultSet > DatabaseMetaData::getProcedures(
1134 : : const ::com::sun::star::uno::Any& catalog,
1135 : : const OUString& schemaPattern,
1136 : : const OUString& procedureNamePattern ) throw (SQLException, RuntimeException)
1137 : : {
1138 : : (void) catalog; (void) schemaPattern; (void) procedureNamePattern;
1139 : : // 1. PROCEDURE_CAT string => procedure catalog (may be NULL )
1140 : : // 2. PROCEDURE_SCHEM string => procedure schema (may be NULL )
1141 : : // 3. PROCEDURE_NAME string => procedure name
1142 : : // 4. reserved for future use
1143 : : // 5. reserved for future use
1144 : : // 6. reserved for future use
1145 : : // 7. REMARKS string => explanatory comment on the procedure
1146 : : // 8. PROCEDURE_TYPE short => kind of procedure:
1147 : : // * UNKNOWN - May return a result
1148 : : // * NO - Does not return a result
1149 : : // * RETURN - Returns a result
1150 : :
1151 : : // LEM TODO: implement
1152 : : // LEM TODO: at least fake the columns, even if no row.
1153 : 0 : MutexGuard guard( m_refMutex->mutex );
1154 : 0 : checkClosed();
1155 : : return new SequenceResultSet(
1156 : 0 : m_refMutex, *this, Sequence< OUString >(), Sequence< Sequence< Any > > (), m_pSettings->tc );
1157 : : }
1158 : :
1159 : 0 : ::com::sun::star::uno::Reference< XResultSet > DatabaseMetaData::getProcedureColumns(
1160 : : const ::com::sun::star::uno::Any& catalog,
1161 : : const OUString& schemaPattern,
1162 : : const OUString& procedureNamePattern,
1163 : : const OUString& columnNamePattern ) throw (SQLException, RuntimeException)
1164 : : {
1165 : : (void) catalog; (void) schemaPattern; (void) procedureNamePattern; (void) columnNamePattern;
1166 : 0 : MutexGuard guard( m_refMutex->mutex );
1167 : 0 : checkClosed();
1168 : : // LEM TODO: implement
1169 : : // LEM TODO: at least fake the columns, even if no row.
1170 : : return new SequenceResultSet(
1171 : 0 : m_refMutex, *this, Sequence< OUString >(), Sequence< Sequence< Any > > (), m_pSettings->tc );
1172 : : }
1173 : :
1174 : 0 : ::com::sun::star::uno::Reference< XResultSet > DatabaseMetaData::getTables(
1175 : : const ::com::sun::star::uno::Any& catalog,
1176 : : const OUString& schemaPattern,
1177 : : const OUString& tableNamePattern,
1178 : : const ::com::sun::star::uno::Sequence< OUString >& types )
1179 : : throw (SQLException, RuntimeException)
1180 : : {
1181 : : (void) catalog; (void) types;
1182 : 0 : Statics &statics = getStatics();
1183 : :
1184 : 0 : MutexGuard guard( m_refMutex->mutex );
1185 : 0 : checkClosed();
1186 : :
1187 : 0 : if( isLog( m_pSettings, LogLevel::INFO ) )
1188 : : {
1189 : 0 : rtl::OUStringBuffer buf( 128 );
1190 : 0 : buf.appendAscii( "DatabaseMetaData::getTables got called with " );
1191 : 0 : buf.append( schemaPattern );
1192 : 0 : buf.appendAscii( "." );
1193 : 0 : buf.append( tableNamePattern );
1194 : 0 : log( m_pSettings, LogLevel::INFO, buf.makeStringAndClear() );
1195 : : }
1196 : : // ignore catalog, as a single pq connection does not support multiple catalogs
1197 : :
1198 : : // LEM TODO: this does not give the right column names, not the right number of columns, etc.
1199 : : // Take "inspiration" from JDBC driver
1200 : : // Ah, this is used to create a XResultSet manually... Try to do it directly in SQL
1201 : 0 : Reference< XPreparedStatement > statement = m_origin->prepareStatement(
1202 : : ASCII_STR(
1203 : : "SELECT "
1204 : : "DISTINCT ON (pg_namespace.nspname, relname ) " // avoid duplicates (pg_settings !)
1205 : : "pg_namespace.nspname, relname, relkind, pg_description.description "
1206 : : "FROM pg_namespace, pg_class LEFT JOIN pg_description ON pg_class.oid = pg_description.objoid "
1207 : : "WHERE relnamespace = pg_namespace.oid "
1208 : : "AND ( relkind = 'r' OR relkind = 'v') "
1209 : : "AND pg_namespace.nspname LIKE ? "
1210 : : "AND relname LIKE ? "
1211 : : // "ORDER BY pg_namespace.nspname || relname"
1212 : 0 : ) );
1213 : :
1214 : 0 : Reference< XParameters > parameters( statement, UNO_QUERY_THROW );
1215 : 0 : parameters->setString( 1 , schemaPattern );
1216 : 0 : parameters->setString( 2 , tableNamePattern );
1217 : :
1218 : 0 : Reference< XResultSet > rs = statement->executeQuery();
1219 : 0 : Reference< XRow > xRow( rs, UNO_QUERY_THROW );
1220 : 0 : SequenceAnyVector vec;
1221 : :
1222 : 0 : while( rs->next() )
1223 : : {
1224 : 0 : Sequence< Any > row( 5 );
1225 : :
1226 : 0 : row[0] <<= m_pSettings->catalog;
1227 : 0 : row[1] <<= xRow->getString( 1 );
1228 : 0 : row[2] <<= xRow->getString( 2 );
1229 : 0 : OUString type = xRow->getString(3);
1230 : 0 : if( 0 == type.compareToAscii( "r" ) )
1231 : : {
1232 : 0 : if( 0 == xRow->getString(1).compareToAscii( "pg_catalog" ) )
1233 : : {
1234 : 0 : row[3] <<= statics.SYSTEM_TABLE;
1235 : : }
1236 : : else
1237 : : {
1238 : 0 : row[3] <<= statics.TABLE;
1239 : : }
1240 : : }
1241 : 0 : else if( 0 == type.compareToAscii( "v" ) )
1242 : : {
1243 : 0 : row[3] <<= statics.VIEW;
1244 : : }
1245 : : else
1246 : : {
1247 : 0 : row[3] <<= statics.UNKNOWN;
1248 : : }
1249 : 0 : row[4] <<= xRow->getString(4);
1250 : :
1251 : : // no description in postgresql AFAIK
1252 : 0 : vec.push_back( row );
1253 : 0 : }
1254 : 0 : Reference< XCloseable > closeable( statement, UNO_QUERY );
1255 : 0 : if( closeable.is() )
1256 : 0 : closeable->close();
1257 : :
1258 : : return new SequenceResultSet(
1259 : 0 : m_refMutex, *this, statics.tablesRowNames, sequence_of_vector(vec), m_pSettings->tc );
1260 : : }
1261 : :
1262 : : struct SortInternalSchemasLastAndPublicFirst
1263 : : {
1264 : 0 : bool operator () ( const Sequence< Any > & a, const Sequence< Any > & b )
1265 : : {
1266 : 0 : OUString valueA;
1267 : 0 : OUString valueB;
1268 : 0 : a[0] >>= valueA;
1269 : 0 : b[0] >>= valueB;
1270 : 0 : bool ret = false;
1271 : 0 : if( valueA.compareToAscii( RTL_CONSTASCII_STRINGPARAM( "public" ) ) == 0 )
1272 : : {
1273 : 0 : ret = true;
1274 : : }
1275 : 0 : else if( valueB.compareToAscii( RTL_CONSTASCII_STRINGPARAM( "public" ) ) == 0 )
1276 : : {
1277 : 0 : ret = false;
1278 : : }
1279 : 0 : else if( valueA.matchAsciiL( RTL_CONSTASCII_STRINGPARAM( "pg_" ) ) &&
1280 : 0 : valueB.matchAsciiL( RTL_CONSTASCII_STRINGPARAM( "pg_" ) ) )
1281 : : {
1282 : 0 : ret = valueA.compareTo( valueB ) < 0; // sorts equal !
1283 : : }
1284 : 0 : else if( valueA.matchAsciiL( RTL_CONSTASCII_STRINGPARAM( "pg_" ) ))
1285 : : {
1286 : 0 : ret = false; // sorts last !
1287 : : }
1288 : 0 : else if( valueB.matchAsciiL( RTL_CONSTASCII_STRINGPARAM( "pg_" ) ) )
1289 : : {
1290 : 0 : ret = true; // sorts first !
1291 : : }
1292 : : else
1293 : : {
1294 : 0 : ret = (valueA.compareTo( valueB ) < 0);
1295 : : }
1296 : 0 : return ret;
1297 : : }
1298 : : };
1299 : :
1300 : 0 : ::com::sun::star::uno::Reference< XResultSet > DatabaseMetaData::getSchemas( )
1301 : : throw (SQLException, RuntimeException)
1302 : : {
1303 : 0 : MutexGuard guard( m_refMutex->mutex );
1304 : 0 : checkClosed();
1305 : :
1306 : 0 : if( isLog( m_pSettings, LogLevel::INFO ) )
1307 : : {
1308 : 0 : log( m_pSettings, LogLevel::INFO, "DatabaseMetaData::getSchemas() got called" );
1309 : : }
1310 : : // <b>TABLE_SCHEM</b> string =&gt; schema name
1311 : 0 : Reference< XStatement > statement = m_origin->createStatement();
1312 : 0 : Reference< XResultSet > rs = statement->executeQuery(
1313 : 0 : ASCII_STR("SELECT nspname from pg_namespace") );
1314 : : // LEM TODO: look at JDBC driver and consider doing the same
1315 : : // in particular, excluding temporary schemas, but maybe better through pg_is_other_temp_schema(oid) OR == pg_my_temp_schema()
1316 : :
1317 : 0 : Reference< XRow > xRow( rs, UNO_QUERY_THROW );
1318 : 0 : SequenceAnyVector vec;
1319 : 0 : while( rs->next() )
1320 : : {
1321 : 0 : Sequence<Any> row(1);
1322 : 0 : row[0] <<= xRow->getString(1);
1323 : 0 : vec.push_back( row );
1324 : 0 : }
1325 : :
1326 : : // sort public first, sort internal schemas last, sort rest in alphabetic order
1327 : 0 : std::sort( vec.begin(), vec.end(), SortInternalSchemasLastAndPublicFirst() );
1328 : :
1329 : 0 : Reference< XCloseable > closeable( statement, UNO_QUERY );
1330 : 0 : if( closeable.is() )
1331 : 0 : closeable->close();
1332 : : return new SequenceResultSet(
1333 : 0 : m_refMutex, *this, getStatics().schemaNames, sequence_of_vector(vec), m_pSettings->tc );
1334 : : }
1335 : :
1336 : 0 : ::com::sun::star::uno::Reference< XResultSet > DatabaseMetaData::getCatalogs( )
1337 : : throw (SQLException, RuntimeException)
1338 : : {
1339 : : // LEM TODO: return the current catalog like JDBC driver?
1340 : : // at least fake the columns, even if no content
1341 : 0 : MutexGuard guard( m_refMutex->mutex );
1342 : 0 : checkClosed();
1343 : : return new SequenceResultSet(
1344 : 0 : m_refMutex, *this, Sequence< OUString >(), Sequence< Sequence< Any > > (), m_pSettings->tc );
1345 : : }
1346 : :
1347 : 0 : ::com::sun::star::uno::Reference< XResultSet > DatabaseMetaData::getTableTypes( )
1348 : : throw (SQLException, RuntimeException)
1349 : : {
1350 : : // LEM TODO: this can be made dynamic, see JDBC driver
1351 : 0 : MutexGuard guard( m_refMutex->mutex );
1352 : 0 : checkClosed();
1353 : : return new SequenceResultSet(
1354 : 0 : m_refMutex, *this, getStatics().tableTypeNames, getStatics().tableTypeData,
1355 : 0 : m_pSettings->tc );
1356 : : }
1357 : :
1358 : :
1359 : : /** returns the constant from sdbc.DataType
1360 : : */
1361 : 0 : sal_Int32 typeNameToDataType( const OUString &typeName, const OUString &typtype )
1362 : : {
1363 : : // sal_Int32 ret = com::sun::star::sdbc::DataType::DISTINCT;
1364 : : // map all unknown types to memo (longvarchar). This allows to show them in
1365 : : // string representation. Additionally, the edit-table-type-selection-box
1366 : : // is not so unuseable anymore.
1367 : 0 : sal_Int32 ret = com::sun::star::sdbc::DataType::LONGVARCHAR;
1368 : 0 : if( 0 == typtype.compareToAscii( "b" ) )
1369 : : {
1370 : : // as long as the OOo framework does not support arrays,
1371 : : // the user is better of with interpreting arrays as strings !
1372 : : // if( typeName.getLength() && '_' == typeName[0] )
1373 : : // {
1374 : : // its just a naming convention, but as long as we don't have anything better,
1375 : : // we take it as granted
1376 : : // ret = com::sun::star::sdbc::DataType::ARRAY;
1377 : : // }
1378 : : // base type
1379 : 0 : Statics &statics = getStatics();
1380 : 0 : BaseTypeMap::iterator ii = statics.baseTypeMap.find( typeName );
1381 : 0 : if( ii != statics.baseTypeMap.end() )
1382 : : {
1383 : 0 : ret = ii->second;
1384 : : }
1385 : : }
1386 : 0 : else if( 0 == typtype.compareToAscii( "c" ) )
1387 : : {
1388 : 0 : ret = com::sun::star::sdbc::DataType::STRUCT;
1389 : : }
1390 : 0 : else if( 0 == typtype.compareToAscii( "d" ) )
1391 : : {
1392 : 0 : ret = com::sun::star::sdbc::DataType::LONGVARCHAR;
1393 : : }
1394 : 0 : return ret;
1395 : : }
1396 : :
1397 : : namespace {
1398 : 0 : inline bool isSystemColumn( sal_Int16 attnum )
1399 : : {
1400 : 0 : return attnum <= 0;
1401 : : }
1402 : : }
1403 : :
1404 : : // is not exported by the postgres header
1405 : : const static int PQ_VARHDRSZ = sizeof( sal_Int32 );
1406 : :
1407 : : // Oh, quelle horreur
1408 : : // LEM TODO: Need to severely rewrite that!
1409 : : // should probably just "do the same" as ODBC or JDBC drivers...
1410 : 0 : static void extractPrecisionAndScale(
1411 : : sal_Int32 dataType, sal_Int32 atttypmod, sal_Int32 *precision, sal_Int32 *scale )
1412 : : {
1413 : 0 : if( atttypmod < PQ_VARHDRSZ )
1414 : : {
1415 : 0 : *precision = 0;
1416 : 0 : *scale = 0;
1417 : : }
1418 : : else
1419 : : {
1420 : 0 : switch( dataType )
1421 : : {
1422 : : case com::sun::star::sdbc::DataType::NUMERIC:
1423 : : case com::sun::star::sdbc::DataType::DECIMAL:
1424 : : {
1425 : 0 : *precision = ( ( atttypmod - PQ_VARHDRSZ ) >> 16 ) & 0xffff;
1426 : 0 : *scale = (atttypmod - PQ_VARHDRSZ ) & 0xffff;
1427 : 0 : break;
1428 : : }
1429 : : default:
1430 : 0 : *precision = atttypmod - PQ_VARHDRSZ;
1431 : 0 : *scale = 0;
1432 : : }
1433 : : }
1434 : 0 : }
1435 : :
1436 : 0 : struct DatabaseTypeDescription
1437 : : {
1438 : 0 : DatabaseTypeDescription()
1439 : 0 : {}
1440 : 0 : DatabaseTypeDescription( const OUString &name, const OUString & type ) :
1441 : : typeName( name ),
1442 : 0 : typeType( type )
1443 : 0 : {}
1444 : 0 : DatabaseTypeDescription( const DatabaseTypeDescription &source ) :
1445 : : typeName( source.typeName ),
1446 : 0 : typeType( source.typeType )
1447 : 0 : {}
1448 : 0 : DatabaseTypeDescription & operator = ( const DatabaseTypeDescription & source )
1449 : : {
1450 : 0 : typeName = source.typeName;
1451 : 0 : typeType = source.typeType;
1452 : 0 : return *this;
1453 : : }
1454 : : OUString typeName;
1455 : : OUString typeType;
1456 : : };
1457 : :
1458 : : typedef ::boost::unordered_map
1459 : : <
1460 : : sal_Int32,
1461 : : DatabaseTypeDescription,
1462 : : ::boost::hash< sal_Int32 >,
1463 : : ::std::equal_to< sal_Int32 >,
1464 : : Allocator< ::std::pair< sal_Int32, DatabaseTypeDescription > >
1465 : : > Oid2DatabaseTypeDescriptionMap;
1466 : :
1467 : 0 : static void columnMetaData2DatabaseTypeDescription(
1468 : : Oid2DatabaseTypeDescriptionMap &oidMap,
1469 : : const Reference< XResultSet > &rs,
1470 : : const Reference< XStatement > &stmt )
1471 : : {
1472 : 0 : Reference< XRow > row( rs, UNO_QUERY_THROW );
1473 : 0 : int domains = 0;
1474 : 0 : rtl::OUStringBuffer queryBuf(128);
1475 : 0 : queryBuf.appendAscii( RTL_CONSTASCII_STRINGPARAM( "SELECT oid,typtype,typname FROM pg_TYPE WHERE " ) );
1476 : 0 : while( rs->next() )
1477 : : {
1478 : 0 : if( row->getString( 9 ) == "d" && oidMap.find( row->getInt( 12 ) ) == oidMap.end() )
1479 : : {
1480 : 0 : oidMap[row->getInt(12)] = DatabaseTypeDescription();
1481 : 0 : if( domains )
1482 : 0 : queryBuf.appendAscii( " OR " );
1483 : 0 : queryBuf.appendAscii( "oid = " );
1484 : 0 : queryBuf.append( row->getInt(12 ), 10 );
1485 : 0 : domains ++;
1486 : : }
1487 : : }
1488 : 0 : rs->beforeFirst();
1489 : :
1490 : 0 : if( domains )
1491 : : {
1492 : 0 : Reference< XResultSet > rsDomain = stmt->executeQuery( queryBuf.makeStringAndClear() );
1493 : 0 : row = Reference< XRow >( rsDomain, UNO_QUERY_THROW );
1494 : 0 : while( rsDomain->next() )
1495 : : {
1496 : 0 : oidMap[row->getInt(1)] = DatabaseTypeDescription(row->getString(3), row->getString(2) );
1497 : : }
1498 : 0 : disposeNoThrow( stmt );
1499 : 0 : }
1500 : :
1501 : 0 : }
1502 : :
1503 : :
1504 : :
1505 : 0 : ::com::sun::star::uno::Reference< XResultSet > DatabaseMetaData::getColumns(
1506 : : const ::com::sun::star::uno::Any& catalog,
1507 : : const OUString& schemaPattern,
1508 : : const OUString& tableNamePattern,
1509 : : const OUString& columnNamePattern ) throw (SQLException, RuntimeException)
1510 : : {
1511 : : (void) catalog;
1512 : : // LEM TODO: review in comparison with JDBC driver
1513 : 0 : Statics &statics = getStatics();
1514 : :
1515 : : // continue !
1516 : 0 : MutexGuard guard( m_refMutex->mutex );
1517 : 0 : checkClosed();
1518 : :
1519 : 0 : if( isLog( m_pSettings, LogLevel::INFO ) )
1520 : : {
1521 : 0 : rtl::OUStringBuffer buf( 128 );
1522 : 0 : buf.appendAscii( "DatabaseMetaData::getColumns got called with " );
1523 : 0 : buf.append( schemaPattern );
1524 : 0 : buf.appendAscii( "." );
1525 : 0 : buf.append( tableNamePattern );
1526 : 0 : buf.appendAscii( "." );
1527 : 0 : buf.append( columnNamePattern );
1528 : 0 : log( m_pSettings, LogLevel::INFO, buf.makeStringAndClear() );
1529 : : }
1530 : :
1531 : : // ignore catalog, as a single pq connection
1532 : : // does not support multiple catalogs anyway
1533 : : // We don't use information_schema.columns because it contains
1534 : : // only the columns the current user has any privilege over.
1535 : :
1536 : : // 1. TABLE_CAT string => table catalog (may be NULL)
1537 : : // => not supported
1538 : : // 2. TABLE_SCHEM string => table schema (may be NULL)
1539 : : // => pg_namespace.nspname
1540 : : // 3. TABLE_NAME string => table name
1541 : : // => pg_class.relname
1542 : : // 4. COLUMN_NAME string => column name
1543 : : // => pg_attribure.attname
1544 : : // 5. DATA_TYPE short => SQL type from java.sql.Types
1545 : : // => pg_type.typname => sdbc.DataType
1546 : : // 6. TYPE_NAME string => Data source dependent type name, for a UDT the
1547 : : // type name is fully qualified
1548 : : // => pg_type.typname
1549 : : // 7. COLUMN_SIZE long => column size. For char or date types this is
1550 : : // the maximum number of characters, for numeric
1551 : : // or decimal types this is precision.
1552 : : // => pg_attribute.atttypmod
1553 : : // 8. BUFFER_LENGTH is not used.
1554 : : // => not used
1555 : : // 9. DECIMAL_DIGITS long => the number of fractional digits
1556 : : // => don't know ! TODO !
1557 : : // 10. NUM_PREC_RADIX long => Radix (typically either 10 or 2)
1558 : : // => TODO ??
1559 : : // 11. NULLABLE long => is NULL allowed?
1560 : : // NO_NULLS - might not allow NULL values
1561 : : // NULABLE - definitely allows NULL values
1562 : : // NULLABLE_UNKNOWN - nullability unknown
1563 : : // => pg_attribute.attnotnull
1564 : : // 12. REMARKS string => comment describing column (may be NULL )
1565 : : // => pg_description.description
1566 : : // 13. COLUMN_DEF string => default value (may be NULL)
1567 : : // => pg_type.typdefault
1568 : : // 14. SQL_DATA_TYPE long => unused
1569 : : // => empty
1570 : : // 15. SQL_DATETIME_SUB long => unused
1571 : : // => empty
1572 : : // 16. CHAR_OCTET_LENGTH long => for char types the maximum number of
1573 : : // bytes in the column
1574 : : // => pg_type.typlen
1575 : : // 17. ORDINAL_POSITION int => index of column in table (starting at 1)
1576 : : // pg_attribute.attnum
1577 : : // 18. IS_NULLABLE string => "NO" means column definitely does not allow
1578 : : // NULL values; "YES" means the column might
1579 : : // allow NULL values. An empty string means
1580 : : // nobody knows.
1581 : : // => pg_attribute.attnotnull
1582 : :
1583 : 0 : Reference< XPreparedStatement > statement = m_origin->prepareStatement(
1584 : : ASCII_STR(
1585 : :
1586 : : "SELECT pg_namespace.nspname, " // 1
1587 : : "pg_class.relname, " // 2
1588 : : "pg_attribute.attname, " // 3
1589 : : "pg_type.typname, " // 4
1590 : : "pg_attribute.atttypmod, " // 5
1591 : : "pg_attribute.attnotnull, " // 6
1592 : : "pg_type.typdefault, " // 7
1593 : : "pg_type.typtype, " // 8
1594 : : "pg_attrdef.adsrc, " // 9
1595 : : "pg_description.description, " // 10
1596 : : "pg_type.typbasetype, " // 11
1597 : : "pg_attribute.attnum " // 12
1598 : : "FROM pg_class, "
1599 : : "pg_attribute LEFT JOIN pg_attrdef ON pg_attribute.attrelid = pg_attrdef.adrelid AND pg_attribute.attnum = pg_attrdef.adnum "
1600 : : "LEFT JOIN pg_description ON pg_attribute.attrelid = pg_description.objoid AND pg_attribute.attnum=pg_description.objsubid,"
1601 : : " pg_type, pg_namespace "
1602 : : "WHERE pg_attribute.attrelid = pg_class.oid "
1603 : : "AND pg_attribute.atttypid = pg_type.oid "
1604 : : "AND pg_class.relnamespace = pg_namespace.oid "
1605 : : "AND NOT pg_attribute.attisdropped "
1606 : : "AND pg_namespace.nspname LIKE ? "
1607 : : "AND pg_class.relname LIKE ? "
1608 : : "AND pg_attribute.attname LIKE ? "
1609 : : "ORDER BY pg_namespace.nspname, pg_class.relname, pg_attribute.attnum"
1610 : 0 : ) );
1611 : :
1612 : 0 : Reference< XParameters > parameters( statement, UNO_QUERY_THROW );
1613 : 0 : parameters->setString( 1 , schemaPattern );
1614 : 0 : parameters->setString( 2 , tableNamePattern );
1615 : 0 : parameters->setString( 3 , columnNamePattern );
1616 : :
1617 : 0 : Reference< XResultSet > rs = statement->executeQuery();
1618 : 0 : Reference< XRow > xRow( rs, UNO_QUERY_THROW );
1619 : 0 : SequenceAnyVector vec;
1620 : :
1621 : 0 : Oid2DatabaseTypeDescriptionMap domainMap;
1622 : 0 : Reference< XStatement > domainTypeStmt = m_origin->createStatement();
1623 : 0 : columnMetaData2DatabaseTypeDescription( domainMap, rs, domainTypeStmt );
1624 : :
1625 : 0 : sal_uInt32 colNum(0);
1626 : 0 : OUString sSchema( ASCII_STR("#invalid#") );
1627 : 0 : OUString sTable( ASCII_STR("#invalid#") );
1628 : :
1629 : 0 : while( rs->next() )
1630 : : {
1631 : 0 : if( m_pSettings->showSystemColumns || ! isSystemColumn( xRow->getShort( 12 ) ) )
1632 : : {
1633 : 0 : OUString sNewSchema( xRow->getString(1) );
1634 : 0 : OUString sNewTable( xRow->getString(2) );
1635 : 0 : if ( sNewSchema != sSchema || sNewTable != sTable )
1636 : : {
1637 : 0 : colNum = 1;
1638 : 0 : sSchema = sNewSchema;
1639 : 0 : sTable = sNewTable;
1640 : : }
1641 : : else
1642 : 0 : ++colNum;
1643 : : sal_Int32 precision, scale, type;
1644 : 0 : Sequence< Any > row( 18 );
1645 : 0 : row[0] <<= m_pSettings->catalog;
1646 : 0 : row[1] <<= sNewSchema;
1647 : 0 : row[2] <<= sNewTable;
1648 : 0 : row[3] <<= xRow->getString(3);
1649 : 0 : if( xRow->getString(8) == "d" )
1650 : : {
1651 : 0 : DatabaseTypeDescription desc( domainMap[xRow->getInt(11)] );
1652 : 0 : type = typeNameToDataType( desc.typeName, desc.typeType );
1653 : : }
1654 : : else
1655 : : {
1656 : 0 : type = typeNameToDataType( xRow->getString(4), xRow->getString(8) );
1657 : : }
1658 : 0 : extractPrecisionAndScale( type, xRow->getInt(5) , &precision, &scale );
1659 : 0 : row[4] <<= type;
1660 : 0 : row[5] <<= xRow->getString(4);
1661 : 0 : row[6] <<= precision;
1662 : : // row[7] BUFFER_LENGTH not used
1663 : 0 : row[8] <<= scale;
1664 : : // row[9] RADIX TODO
1665 : 0 : if( xRow->getBoolean( 6 ) && ! isSystemColumn(xRow->getInt( 12 )) )
1666 : : {
1667 : 0 : row[10] <<= OUString::valueOf(com::sun::star::sdbc::ColumnValue::NO_NULLS);
1668 : 0 : row[17] <<= statics.NO;
1669 : : }
1670 : : else
1671 : : {
1672 : 0 : row[10] <<= OUString::valueOf(com::sun::star::sdbc::ColumnValue::NULLABLE);
1673 : 0 : row[17] <<= statics.YES;
1674 : : }
1675 : :
1676 : 0 : row[11] <<= xRow->getString( 10 ); // comment
1677 : 0 : row[12] <<= xRow->getString( 9 ); // COLUMN_DEF = pg_type.typdefault
1678 : : // row[13] SQL_DATA_TYPE not used
1679 : : // row[14] SQL_DATETIME_SUB not used
1680 : 0 : row[15] <<= precision;
1681 : 0 : row[16] <<= colNum ;
1682 : :
1683 : 0 : vec.push_back( row );
1684 : : }
1685 : : }
1686 : 0 : Reference< XCloseable > closeable( statement, UNO_QUERY );
1687 : 0 : if( closeable.is() )
1688 : 0 : closeable->close();
1689 : :
1690 : : return new SequenceResultSet(
1691 : 0 : m_refMutex, *this, statics.columnRowNames, sequence_of_vector(vec), m_pSettings->tc );
1692 : : }
1693 : :
1694 : 0 : ::com::sun::star::uno::Reference< XResultSet > DatabaseMetaData::getColumnPrivileges(
1695 : : const ::com::sun::star::uno::Any& catalog,
1696 : : const OUString& schema,
1697 : : const OUString& table,
1698 : : const OUString& columnNamePattern ) throw (SQLException, RuntimeException)
1699 : : {
1700 : : (void) catalog;
1701 : :
1702 : 0 : MutexGuard guard( m_refMutex->mutex );
1703 : 0 : checkClosed();
1704 : :
1705 : 0 : if( isLog( m_pSettings, LogLevel::INFO ) )
1706 : : {
1707 : 0 : rtl::OUStringBuffer buf( 128 );
1708 : 0 : buf.appendAscii( "DatabaseMetaData::getColumnPrivileges got called with " );
1709 : 0 : buf.append( schema );
1710 : 0 : buf.appendAscii( "." );
1711 : 0 : buf.append( table );
1712 : 0 : buf.appendAscii( "." );
1713 : 0 : buf.append( columnNamePattern );
1714 : 0 : log( m_pSettings, LogLevel::INFO, buf.makeStringAndClear() );
1715 : : }
1716 : :
1717 : 0 : Reference< XParameters > parameters( m_getColumnPrivs_stmt, UNO_QUERY_THROW );
1718 : 0 : parameters->setString( 1 , schema );
1719 : 0 : parameters->setString( 2 , table );
1720 : 0 : parameters->setString( 3 , columnNamePattern );
1721 : :
1722 : 0 : Reference< XResultSet > rs = m_getColumnPrivs_stmt->executeQuery();
1723 : :
1724 : 0 : return rs;
1725 : : }
1726 : :
1727 : 0 : ::com::sun::star::uno::Reference< XResultSet > DatabaseMetaData::getTablePrivileges(
1728 : : const ::com::sun::star::uno::Any& catalog,
1729 : : const OUString& schemaPattern,
1730 : : const OUString& tableNamePattern ) throw (SQLException, RuntimeException)
1731 : : {
1732 : : (void) catalog;
1733 : 0 : MutexGuard guard( m_refMutex->mutex );
1734 : 0 : checkClosed();
1735 : :
1736 : 0 : if( isLog( m_pSettings, LogLevel::INFO ) )
1737 : : {
1738 : 0 : rtl::OUStringBuffer buf( 128 );
1739 : 0 : buf.appendAscii( "DatabaseMetaData::getTablePrivileges got called with " );
1740 : 0 : buf.append( schemaPattern );
1741 : 0 : buf.appendAscii( "." );
1742 : 0 : buf.append( tableNamePattern );
1743 : 0 : log( m_pSettings, LogLevel::INFO, buf.makeStringAndClear() );
1744 : : }
1745 : :
1746 : 0 : Reference< XParameters > parameters( m_getTablePrivs_stmt, UNO_QUERY_THROW );
1747 : 0 : parameters->setString( 1 , schemaPattern );
1748 : 0 : parameters->setString( 2 , tableNamePattern );
1749 : :
1750 : 0 : Reference< XResultSet > rs = m_getTablePrivs_stmt->executeQuery();
1751 : :
1752 : 0 : return rs;
1753 : : }
1754 : :
1755 : 0 : ::com::sun::star::uno::Reference< XResultSet > DatabaseMetaData::getBestRowIdentifier(
1756 : : const ::com::sun::star::uno::Any& catalog,
1757 : : const OUString& schema,
1758 : : const OUString& table,
1759 : : sal_Int32 scope,
1760 : : sal_Bool nullable ) throw (SQLException, RuntimeException)
1761 : : {
1762 : : (void) catalog; (void) schema; (void) table; (void) scope; (void) nullable;
1763 : : //LEM TODO: implement! See JDBC driver
1764 : 0 : MutexGuard guard( m_refMutex->mutex );
1765 : 0 : checkClosed();
1766 : : return new SequenceResultSet(
1767 : 0 : m_refMutex, *this, Sequence< OUString >(), Sequence< Sequence< Any > > (), m_pSettings->tc );
1768 : : }
1769 : :
1770 : 0 : ::com::sun::star::uno::Reference< XResultSet > DatabaseMetaData::getVersionColumns(
1771 : : const ::com::sun::star::uno::Any& catalog,
1772 : : const OUString& schema,
1773 : : const OUString& table ) throw (SQLException, RuntimeException)
1774 : : {
1775 : : (void) catalog; (void) schema; (void) table;
1776 : : //LEM TODO: implement! See JDBC driver
1777 : 0 : MutexGuard guard( m_refMutex->mutex );
1778 : 0 : checkClosed();
1779 : : return new SequenceResultSet(
1780 : 0 : m_refMutex, *this, Sequence< OUString >(), Sequence< Sequence< Any > > (), m_pSettings->tc );
1781 : : }
1782 : :
1783 : 0 : ::com::sun::star::uno::Reference< XResultSet > DatabaseMetaData::getPrimaryKeys(
1784 : : const ::com::sun::star::uno::Any& catalog,
1785 : : const OUString& schema,
1786 : : const OUString& table ) throw (SQLException, RuntimeException)
1787 : : {
1788 : : (void) catalog;
1789 : : //LEM TODO: review
1790 : 0 : MutexGuard guard( m_refMutex->mutex );
1791 : 0 : checkClosed();
1792 : :
1793 : : // 1. TABLE_CAT string => table catalog (may be NULL )
1794 : : // 2. TABLE_SCHEM string => table schema (may be NULL )
1795 : : // 3. TABLE_NAME string => table name
1796 : : // 4. COLUMN_NAME string => column name
1797 : : // 5. KEY_SEQ short => sequence number within primary key
1798 : : // 6. PK_NAME string => primary key name (may be NULL )
1799 : :
1800 : 0 : if( isLog( m_pSettings, LogLevel::INFO ) )
1801 : : {
1802 : 0 : rtl::OUStringBuffer buf( 128 );
1803 : 0 : buf.appendAscii( "DatabaseMetaData::getPrimaryKeys got called with " );
1804 : 0 : buf.append( schema );
1805 : 0 : buf.appendAscii( "." );
1806 : 0 : buf.append( table );
1807 : 0 : log( m_pSettings, LogLevel::INFO, buf.makeStringAndClear() );
1808 : : }
1809 : :
1810 : 0 : Reference< XPreparedStatement > statement = m_origin->prepareStatement(
1811 : : ASCII_STR(
1812 : : "SELECT nmsp.nspname, "
1813 : : "cl.relname, "
1814 : : "con.conkey, "
1815 : : "con.conname, "
1816 : : "con.conrelid "
1817 : : "FROM pg_constraint as con,pg_class as cl, pg_namespace as nmsp "
1818 : : "WHERE con.connamespace = nmsp.oid AND con.conrelid = cl.oid AND con.contype = 'p' "
1819 : 0 : "AND nmsp.nspname LIKE ? AND cl.relname LIKE ?" ) );
1820 : :
1821 : 0 : Reference< XParameters > parameters( statement, UNO_QUERY_THROW );
1822 : 0 : parameters->setString( 1 , schema );
1823 : 0 : parameters->setString( 2 , table );
1824 : :
1825 : 0 : Reference< XResultSet > rs = statement->executeQuery();
1826 : 0 : Reference< XRow > xRow( rs, UNO_QUERY_THROW );
1827 : 0 : SequenceAnyVector vec;
1828 : :
1829 : 0 : while( rs->next() )
1830 : : {
1831 : 0 : Sequence< Any > row( 6 );
1832 : 0 : row[0] <<= m_pSettings->catalog;
1833 : 0 : row[1] <<= xRow->getString(1); //
1834 : 0 : row[2] <<= xRow->getString(2);
1835 : 0 : OUString array = xRow->getString(3);
1836 : 0 : row[4] <<= xRow->getString(5); // the relid
1837 : 0 : row[5] <<= xRow->getString(4);
1838 : :
1839 : 0 : int i = 0;
1840 : : // now retrieve the columns information
1841 : : // unfortunately, postgresql does not allow array of variable size in
1842 : : // WHERE clauses (in the default installation), so we have to choose
1843 : : // this expensive and somewhat ugly way
1844 : : // annotation: postgresql shouldn't have choosen an array here, instead they
1845 : : // should have multiple rows per table
1846 : : // LEM: to transform an array into several rows, see unnest;
1847 : : // it is as simple as "SELECT foo, bar, unnest(qux) FROM ..."
1848 : : // where qux is the column that contains an array.
1849 : 0 : while( array[i] && '}' != array[i] )
1850 : : {
1851 : 0 : i++;
1852 : 0 : int start = i;
1853 : 0 : while( array[i] && array[i] != '}' && array[i] != ',' ) i++;
1854 : 0 : row[3] <<= OUString( &array.getStr()[start], i - start );
1855 : 0 : vec.push_back( row );
1856 : : }
1857 : 0 : }
1858 : :
1859 : : {
1860 : 0 : Reference< XCloseable > closeable( statement, UNO_QUERY );
1861 : 0 : if( closeable.is() )
1862 : 0 : closeable->close();
1863 : : }
1864 : :
1865 : :
1866 : 0 : SequenceAnyVector::iterator ii = vec.begin();
1867 : 0 : OUString lastTableOid;
1868 : 0 : sal_Int32 index = 0;
1869 : 0 : Sequence< Sequence< Any > > ret( vec.size() );
1870 : 0 : int elements = 0;
1871 : 0 : for( ; ii != vec.end() ; ++ ii )
1872 : : {
1873 : :
1874 : 0 : Sequence< Any > row = *ii;
1875 : 0 : OUString tableOid;
1876 : 0 : OUString attnum;
1877 : :
1878 : 0 : row[4] >>= tableOid;
1879 : 0 : row[3] >>= attnum;
1880 : 0 : statement = m_origin->prepareStatement(
1881 : : ASCII_STR(
1882 : : "SELECT att.attname FROM "
1883 : : "pg_attribute AS att, pg_class AS cl WHERE "
1884 : 0 : "att.attrelid = ? AND att.attnum = ?" ));
1885 : :
1886 : 0 : parameters = Reference< XParameters >( statement, UNO_QUERY_THROW );
1887 : 0 : parameters->setString( 1 , tableOid );
1888 : 0 : parameters->setString( 2 , attnum );
1889 : :
1890 : 0 : rs = statement->executeQuery();
1891 : 0 : xRow = Reference< XRow >( rs, UNO_QUERY_THROW );
1892 : 0 : if( rs->next() )
1893 : : {
1894 : : // column name
1895 : 0 : row[3] <<= xRow->getString( 1 );
1896 : 0 : if( tableOid != lastTableOid )
1897 : 0 : index = 1;
1898 : 0 : lastTableOid = tableOid;
1899 : 0 : row[4] <<= OUString::valueOf( index );
1900 : 0 : index ++;
1901 : : }
1902 : : {
1903 : 0 : Reference< XCloseable > closeable( statement, UNO_QUERY );
1904 : 0 : if( closeable.is() )
1905 : 0 : closeable->close();
1906 : : }
1907 : 0 : ret[elements] = row;
1908 : 0 : elements ++;
1909 : 0 : }
1910 : : return new SequenceResultSet(
1911 : 0 : m_refMutex, *this, getStatics().primaryKeyNames, ret , m_pSettings->tc );
1912 : : }
1913 : :
1914 : : // Copied / adapted / simplified from JDBC driver
1915 : : #define SQL_CASE_KEYRULE " WHEN 'c' THEN " STRINGIFY(KEYRULE_CASCADE) \
1916 : : " WHEN 'n' THEN " STRINGIFY(KEYRULE_SET_NULL) \
1917 : : " WHEN 'd' THEN " STRINGIFY(KEYRULE_SET_DEFAULT) \
1918 : : " WHEN 'r' THEN " STRINGIFY(KEYRULE_RESTRICT) \
1919 : : " WHEN 'a' THEN " STRINGIFY(KEYRULE_NO_ACTION) \
1920 : : " ELSE NULL "
1921 : :
1922 : : #define SQL_GET_REFERENCES \
1923 : : "WITH con AS (SELECT oid, conname, contype, condeferrable, condeferred, conrelid, confrelid, confupdtype, confdeltype, generate_subscripts(conkey,1) AS conkeyseq, unnest(conkey) AS conkey , unnest(confkey) AS confkey FROM pg_catalog.pg_constraint) " \
1924 : : "SELECT NULL::text AS PKTABLE_CAT, pkn.nspname AS PKTABLE_SCHEM, pkc.relname AS PKTABLE_NAME, pka.attname AS PKCOLUMN_NAME, " \
1925 : : " NULL::text AS FKTABLE_CAT, fkn.nspname AS FKTABLE_SCHEM, fkc.relname AS FKTABLE_NAME, fka.attname AS FKCOLUMN_NAME, " \
1926 : : " con.conkeyseq AS KEY_SEQ, " \
1927 : : " CASE con.confupdtype " \
1928 : : SQL_CASE_KEYRULE \
1929 : : " END AS UPDATE_RULE, " \
1930 : : " CASE con.confdeltype " \
1931 : : SQL_CASE_KEYRULE \
1932 : : " END AS DELETE_RULE, " \
1933 : : " con.conname AS FK_NAME, pkic.relname AS PK_NAME, " \
1934 : : " CASE " \
1935 : : " WHEN con.condeferrable AND con.condeferred THEN " STRINGIFY(DEFERRABILITY_INITIALLY_DEFERRED) \
1936 : : " WHEN con.condeferrable THEN " STRINGIFY(DEFERRABILITY_INITIALLY_IMMEDIATE) \
1937 : : " ELSE " STRINGIFY(DEFERRABILITY_NONE) \
1938 : : " END AS DEFERRABILITY " \
1939 : : "FROM " \
1940 : : " pg_catalog.pg_namespace pkn, pg_catalog.pg_class pkc, pg_catalog.pg_attribute pka, " \
1941 : : " pg_catalog.pg_namespace fkn, pg_catalog.pg_class fkc, pg_catalog.pg_attribute fka, " \
1942 : : " con, pg_catalog.pg_depend dep, pg_catalog.pg_class pkic " \
1943 : : "WHERE pkn.oid = pkc.relnamespace AND pkc.oid = pka.attrelid AND pka.attnum = con.confkey AND con.confrelid = pkc.oid " \
1944 : : " AND fkn.oid = fkc.relnamespace AND fkc.oid = fka.attrelid AND fka.attnum = con.conkey AND con.conrelid = fkc.oid " \
1945 : : " AND con.contype = 'f' AND con.oid = dep.objid AND pkic.oid = dep.refobjid AND pkic.relkind = 'i' AND dep.classid = 'pg_constraint'::regclass::oid AND dep.refclassid = 'pg_class'::regclass::oid "
1946 : :
1947 : : #define SQL_GET_REFERENCES_PSCHEMA " AND pkn.nspname = ? "
1948 : : #define SQL_GET_REFERENCES_PTABLE " AND pkc.relname = ? "
1949 : : #define SQL_GET_REFERENCES_FSCHEMA " AND fkn.nspname = ? "
1950 : : #define SQL_GET_REFERENCES_FTABLE " AND fkc.relname = ? "
1951 : : #define SQL_GET_REFERENCES_ORDER_SOME_PTABLE "ORDER BY fkn.nspname, fkc.relname, conkeyseq"
1952 : : #define SQL_GET_REFERENCES_ORDER_NO_PTABLE "ORDER BY pkn.nspname, pkc.relname, conkeyseq"
1953 : :
1954 : : #define SQL_GET_REFERENCES_NONE_NONE_NONE_NONE \
1955 : : SQL_GET_REFERENCES \
1956 : : SQL_GET_REFERENCES_ORDER_NO_PTABLE
1957 : :
1958 : : #define SQL_GET_REFERENCES_SOME_NONE_NONE_NONE \
1959 : : SQL_GET_REFERENCES \
1960 : : SQL_GET_REFERENCES_PSCHEMA \
1961 : : SQL_GET_REFERENCES_ORDER_NO_PTABLE
1962 : :
1963 : : #define SQL_GET_REFERENCES_NONE_SOME_NONE_NONE \
1964 : : SQL_GET_REFERENCES \
1965 : : SQL_GET_REFERENCES_PTABLE \
1966 : : SQL_GET_REFERENCES_ORDER_SOME_PTABLE
1967 : :
1968 : : #define SQL_GET_REFERENCES_SOME_SOME_NONE_NONE \
1969 : : SQL_GET_REFERENCES \
1970 : : SQL_GET_REFERENCES_PSCHEMA \
1971 : : SQL_GET_REFERENCES_PTABLE \
1972 : : SQL_GET_REFERENCES_ORDER_SOME_PTABLE
1973 : :
1974 : : #define SQL_GET_REFERENCES_NONE_NONE_SOME_NONE \
1975 : : SQL_GET_REFERENCES \
1976 : : SQL_GET_REFERENCES_FSCHEMA \
1977 : : SQL_GET_REFERENCES_ORDER_NO_PTABLE
1978 : :
1979 : : #define SQL_GET_REFERENCES_NONE_NONE_NONE_SOME \
1980 : : SQL_GET_REFERENCES \
1981 : : SQL_GET_REFERENCES_FTABLE \
1982 : : SQL_GET_REFERENCES_ORDER_NO_PTABLE
1983 : :
1984 : : #define SQL_GET_REFERENCES_NONE_NONE_SOME_SOME \
1985 : : SQL_GET_REFERENCES \
1986 : : SQL_GET_REFERENCES_FSCHEMA \
1987 : : SQL_GET_REFERENCES_FTABLE \
1988 : : SQL_GET_REFERENCES_ORDER_NO_PTABLE
1989 : :
1990 : : #define SQL_GET_REFERENCES_SOME_NONE_SOME_NONE \
1991 : : SQL_GET_REFERENCES \
1992 : : SQL_GET_REFERENCES_PSCHEMA \
1993 : : SQL_GET_REFERENCES_FSCHEMA \
1994 : : SQL_GET_REFERENCES_ORDER_NO_PTABLE
1995 : :
1996 : : #define SQL_GET_REFERENCES_SOME_NONE_NONE_SOME \
1997 : : SQL_GET_REFERENCES \
1998 : : SQL_GET_REFERENCES_PSCHEMA \
1999 : : SQL_GET_REFERENCES_FTABLE \
2000 : : SQL_GET_REFERENCES_ORDER_NO_PTABLE
2001 : :
2002 : : #define SQL_GET_REFERENCES_SOME_NONE_SOME_SOME \
2003 : : SQL_GET_REFERENCES \
2004 : : SQL_GET_REFERENCES_PSCHEMA \
2005 : : SQL_GET_REFERENCES_FSCHEMA \
2006 : : SQL_GET_REFERENCES_FTABLE \
2007 : : SQL_GET_REFERENCES_ORDER_NO_PTABLE
2008 : :
2009 : : #define SQL_GET_REFERENCES_NONE_SOME_SOME_NONE \
2010 : : SQL_GET_REFERENCES \
2011 : : SQL_GET_REFERENCES_PTABLE \
2012 : : SQL_GET_REFERENCES_FSCHEMA \
2013 : : SQL_GET_REFERENCES_ORDER_SOME_PTABLE
2014 : :
2015 : : #define SQL_GET_REFERENCES_NONE_SOME_NONE_SOME \
2016 : : SQL_GET_REFERENCES \
2017 : : SQL_GET_REFERENCES_PTABLE \
2018 : : SQL_GET_REFERENCES_FTABLE \
2019 : : SQL_GET_REFERENCES_ORDER_SOME_PTABLE
2020 : :
2021 : : #define SQL_GET_REFERENCES_NONE_SOME_SOME_SOME \
2022 : : SQL_GET_REFERENCES \
2023 : : SQL_GET_REFERENCES_PTABLE \
2024 : : SQL_GET_REFERENCES_FSCHEMA \
2025 : : SQL_GET_REFERENCES_FTABLE \
2026 : : SQL_GET_REFERENCES_ORDER_SOME_PTABLE
2027 : :
2028 : : #define SQL_GET_REFERENCES_SOME_SOME_SOME_NONE \
2029 : : SQL_GET_REFERENCES \
2030 : : SQL_GET_REFERENCES_PSCHEMA \
2031 : : SQL_GET_REFERENCES_PTABLE \
2032 : : SQL_GET_REFERENCES_FSCHEMA \
2033 : : SQL_GET_REFERENCES_ORDER_SOME_PTABLE
2034 : :
2035 : : #define SQL_GET_REFERENCES_SOME_SOME_NONE_SOME \
2036 : : SQL_GET_REFERENCES \
2037 : : SQL_GET_REFERENCES_PSCHEMA \
2038 : : SQL_GET_REFERENCES_PTABLE \
2039 : : SQL_GET_REFERENCES_FTABLE \
2040 : : SQL_GET_REFERENCES_ORDER_SOME_PTABLE
2041 : :
2042 : : #define SQL_GET_REFERENCES_SOME_SOME_SOME_SOME \
2043 : : SQL_GET_REFERENCES \
2044 : : SQL_GET_REFERENCES_PSCHEMA \
2045 : : SQL_GET_REFERENCES_PTABLE \
2046 : : SQL_GET_REFERENCES_FSCHEMA \
2047 : : SQL_GET_REFERENCES_FTABLE \
2048 : : SQL_GET_REFERENCES_ORDER_SOME_PTABLE
2049 : :
2050 : 0 : void DatabaseMetaData::init_getReferences_stmt ()
2051 : : {
2052 : 0 : m_getReferences_stmt[0] = m_origin->prepareStatement(ASCII_STR( SQL_GET_REFERENCES_NONE_NONE_NONE_NONE ));
2053 : 0 : m_getReferences_stmt[1] = m_origin->prepareStatement(ASCII_STR( SQL_GET_REFERENCES_SOME_NONE_NONE_NONE ));
2054 : 0 : m_getReferences_stmt[2] = m_origin->prepareStatement(ASCII_STR( SQL_GET_REFERENCES_NONE_SOME_NONE_NONE ));
2055 : 0 : m_getReferences_stmt[3] = m_origin->prepareStatement(ASCII_STR( SQL_GET_REFERENCES_SOME_SOME_NONE_NONE ));
2056 : 0 : m_getReferences_stmt[4] = m_origin->prepareStatement(ASCII_STR( SQL_GET_REFERENCES_NONE_NONE_SOME_NONE ));
2057 : 0 : m_getReferences_stmt[5] = m_origin->prepareStatement(ASCII_STR( SQL_GET_REFERENCES_SOME_NONE_SOME_NONE ));
2058 : 0 : m_getReferences_stmt[6] = m_origin->prepareStatement(ASCII_STR( SQL_GET_REFERENCES_NONE_SOME_SOME_NONE ));
2059 : 0 : m_getReferences_stmt[7] = m_origin->prepareStatement(ASCII_STR( SQL_GET_REFERENCES_SOME_SOME_SOME_NONE ));
2060 : 0 : m_getReferences_stmt[8] = m_origin->prepareStatement(ASCII_STR( SQL_GET_REFERENCES_NONE_NONE_NONE_SOME ));
2061 : 0 : m_getReferences_stmt[9] = m_origin->prepareStatement(ASCII_STR( SQL_GET_REFERENCES_SOME_NONE_NONE_SOME ));
2062 : 0 : m_getReferences_stmt[10] = m_origin->prepareStatement(ASCII_STR( SQL_GET_REFERENCES_NONE_SOME_NONE_SOME ));
2063 : 0 : m_getReferences_stmt[11] = m_origin->prepareStatement(ASCII_STR( SQL_GET_REFERENCES_SOME_SOME_NONE_SOME ));
2064 : 0 : m_getReferences_stmt[12] = m_origin->prepareStatement(ASCII_STR( SQL_GET_REFERENCES_NONE_NONE_SOME_SOME ));
2065 : 0 : m_getReferences_stmt[13] = m_origin->prepareStatement(ASCII_STR( SQL_GET_REFERENCES_SOME_NONE_SOME_SOME ));
2066 : 0 : m_getReferences_stmt[14] = m_origin->prepareStatement(ASCII_STR( SQL_GET_REFERENCES_NONE_SOME_SOME_SOME ));
2067 : 0 : m_getReferences_stmt[15] = m_origin->prepareStatement(ASCII_STR( SQL_GET_REFERENCES_SOME_SOME_SOME_SOME ));
2068 : 0 : }
2069 : :
2070 : 0 : void DatabaseMetaData::init_getPrivs_stmt ()
2071 : : {
2072 : 0 : rtl::OUStringBuffer sSQL(300);
2073 : : sSQL.append( ASCII_STR(
2074 : : " SELECT dp.TABLE_CAT, dp.TABLE_SCHEM, dp.TABLE_NAME, dp.GRANTOR, pr.rolname AS GRANTEE, dp.privilege, dp.is_grantable "
2075 : : " FROM ("
2076 : : " SELECT table_catalog AS TABLE_CAT, table_schema AS TABLE_SCHEM, table_name,"
2077 : : " grantor, grantee, privilege_type AS PRIVILEGE, is_grantable"
2078 : 0 : " FROM information_schema.table_privileges") );
2079 : 0 : if ( PQserverVersion( m_pSettings->pConnection ) < 90200 )
2080 : : // information_schema.table_privileges does not fill in default ACLs when no ACL
2081 : : // assume default ACL is "owner has all privileges" and add it
2082 : : sSQL.append( ASCII_STR(
2083 : : " UNION "
2084 : : " SELECT current_database() AS TABLE_CAT, pn.nspname AS TABLE_SCHEM, c.relname AS TABLE_NAME,"
2085 : : " ro.rolname AS GRANTOR, rg.rolname AS GRANTEE, p.privilege, 'YES' AS is_grantable"
2086 : : " FROM pg_catalog.pg_class c,"
2087 : : " (VALUES ('SELECT'), ('INSERT'), ('UPDATE'), ('DELETE'), ('TRUNCATE'), ('REFERENCES'), ('TRIGGER')) p (privilege),"
2088 : : " pg_catalog.pg_roles ro,"
2089 : : " ( SELECT oid, rolname FROM pg_catalog.pg_roles"
2090 : : " UNION ALL"
2091 : : " VALUES (0::oid, 'PUBLIC')"
2092 : : " ) AS rg (oid, rolname),"
2093 : : " pg_catalog.pg_namespace pn"
2094 : : " WHERE c.relkind IN ('r', 'v') AND c.relacl IS NULL AND pg_has_role(rg.oid, c.relowner, 'USAGE')"
2095 : 0 : " AND c.relowner=ro.oid AND c.relnamespace = pn.oid") );
2096 : : sSQL.append( ASCII_STR(
2097 : : " ) dp,"
2098 : : " (SELECT oid, rolname FROM pg_catalog.pg_roles UNION ALL VALUES (0, 'PUBLIC')) pr"
2099 : : " WHERE table_schem LIKE ? AND table_name LIKE ? AND (dp.grantee = 'PUBLIC' OR pg_has_role(pr.oid, dp.grantee, 'USAGE'))"
2100 : 0 : " ORDER BY table_schem, table_name, privilege" ) );
2101 : :
2102 : 0 : m_getTablePrivs_stmt = m_origin->prepareStatement( sSQL.makeStringAndClear() );
2103 : :
2104 : : sSQL.append( ASCII_STR(
2105 : : " SELECT dp.TABLE_CAT, dp.TABLE_SCHEM, dp.TABLE_NAME, dp.COLUMN_NAME, dp.GRANTOR, pr.rolname AS GRANTEE, dp.PRIVILEGE, dp.IS_GRANTABLE FROM ("
2106 : : " SELECT table_catalog AS TABLE_CAT, table_schema AS TABLE_SCHEM, table_name, column_name,"
2107 : : " grantor, grantee, privilege_type AS PRIVILEGE, is_grantable"
2108 : 0 : " FROM information_schema.column_privileges") );
2109 : 0 : if ( PQserverVersion( m_pSettings->pConnection ) < 90200 )
2110 : : // information_schema.table_privileges does not fill in default ACLs when no ACL
2111 : : // assume default ACL is "owner has all privileges" and add it
2112 : : sSQL.append( ASCII_STR(
2113 : : " UNION "
2114 : : " SELECT current_database() AS TABLE_CAT, pn.nspname AS TABLE_SCHEM, c.relname AS TABLE_NAME, a.attname AS column_name,"
2115 : : " ro.rolname AS GRANTOR, rg.rolname AS GRANTEE, p.privilege, 'YES' AS is_grantable"
2116 : : " FROM pg_catalog.pg_class c, pg_catalog.pg_attribute a,"
2117 : : " (VALUES ('SELECT'), ('INSERT'), ('UPDATE'), ('REFERENCES')) p (privilege),"
2118 : : " pg_catalog.pg_roles ro,"
2119 : : " ( SELECT oid, rolname FROM pg_catalog.pg_roles"
2120 : : " UNION ALL"
2121 : : " VALUES (0::oid, 'PUBLIC')"
2122 : : " ) AS rg (oid, rolname),"
2123 : : " pg_catalog.pg_namespace pn"
2124 : : " WHERE c.relkind IN ('r', 'v') AND c.relacl IS NULL AND pg_has_role(rg.oid, c.relowner, 'USAGE')"
2125 : 0 : " AND c.relowner=ro.oid AND c.relnamespace = pn.oid AND a.attrelid = c.oid AND a.attnum > 0") );
2126 : : sSQL.append( ASCII_STR(
2127 : : " ) dp,"
2128 : : " (SELECT oid, rolname FROM pg_catalog.pg_roles UNION ALL VALUES (0, 'PUBLIC')) pr"
2129 : : " WHERE table_schem = ? AND table_name = ? AND column_name LIKE ? AND (dp.grantee = 'PUBLIC' OR pg_has_role(pr.oid, dp.grantee, 'USAGE'))"
2130 : 0 : " ORDER BY column_name, privilege" ) );
2131 : :
2132 : 0 : m_getColumnPrivs_stmt = m_origin->prepareStatement( sSQL.makeStringAndClear() );
2133 : 0 : }
2134 : :
2135 : 0 : ::com::sun::star::uno::Reference< XResultSet > DatabaseMetaData::getImportedExportedKeys(
2136 : : const Any& /* primaryCatalog */,
2137 : : const OUString& primarySchema,
2138 : : const OUString& primaryTable,
2139 : : const Any& /* foreignCatalog */,
2140 : : const OUString& foreignSchema,
2141 : : const OUString& foreignTable ) throw (SQLException, RuntimeException)
2142 : : {
2143 : 0 : unsigned int i = 0;
2144 : 0 : if ( ! primarySchema.isEmpty() )
2145 : 0 : i |= 0x01;
2146 : 0 : if ( ! primaryTable.isEmpty() )
2147 : 0 : i |= 0x02;
2148 : 0 : if ( ! foreignSchema.isEmpty() )
2149 : 0 : i |= 0x04;
2150 : 0 : if ( ! foreignTable.isEmpty() )
2151 : 0 : i |= 0x08;
2152 : :
2153 : 0 : Reference< XPreparedStatement > stmt = m_getReferences_stmt[i];
2154 : 0 : Reference< XParameters > param ( stmt, UNO_QUERY_THROW );
2155 : :
2156 : 0 : unsigned int j = 1;
2157 : 0 : if ( i & 0x01 )
2158 : 0 : param->setString( j++, primarySchema );
2159 : 0 : if ( i & 0x02 )
2160 : 0 : param->setString( j++, primaryTable );
2161 : 0 : if ( i & 0x04 )
2162 : 0 : param->setString( j++, foreignSchema );
2163 : 0 : if ( i & 0x08 )
2164 : 0 : param->setString( j++, foreignTable );
2165 : :
2166 : 0 : Reference< XResultSet > rs = stmt->executeQuery();
2167 : :
2168 : 0 : return rs;
2169 : : }
2170 : :
2171 : :
2172 : 0 : ::com::sun::star::uno::Reference< XResultSet > DatabaseMetaData::getImportedKeys(
2173 : : const ::com::sun::star::uno::Any& catalog,
2174 : : const OUString& schema,
2175 : : const OUString& table ) throw (SQLException, RuntimeException)
2176 : : {
2177 : 0 : return getImportedExportedKeys(Any(), OUString(), OUString(), catalog, schema, table);
2178 : : }
2179 : :
2180 : 0 : ::com::sun::star::uno::Reference< XResultSet > DatabaseMetaData::getExportedKeys(
2181 : : const ::com::sun::star::uno::Any& catalog,
2182 : : const OUString& schema,
2183 : : const OUString& table ) throw (SQLException, RuntimeException)
2184 : : {
2185 : 0 : return getImportedExportedKeys(catalog, schema, table, Any(), OUString(), OUString());
2186 : : }
2187 : :
2188 : 0 : ::com::sun::star::uno::Reference< XResultSet > DatabaseMetaData::getCrossReference(
2189 : : const ::com::sun::star::uno::Any& primaryCatalog,
2190 : : const OUString& primarySchema,
2191 : : const OUString& primaryTable,
2192 : : const ::com::sun::star::uno::Any& foreignCatalog,
2193 : : const OUString& foreignSchema,
2194 : : const OUString& foreignTable ) throw (SQLException, RuntimeException)
2195 : : {
2196 : 0 : return getImportedExportedKeys( primaryCatalog, primarySchema, primaryTable, foreignCatalog, foreignSchema, foreignTable );
2197 : : }
2198 : :
2199 : :
2200 : : struct TypeInfoByDataTypeSorter
2201 : : {
2202 : 0 : bool operator () ( const Sequence< Any > & a, const Sequence< Any > & b )
2203 : : {
2204 : 0 : OUString valueA;
2205 : 0 : OUString valueB;
2206 : 0 : a[1 /*DATA_TYPE*/] >>= valueA;
2207 : 0 : b[1 /*DATA_TYPE*/] >>= valueB;
2208 : 0 : if( valueB.toInt32() == valueA.toInt32() )
2209 : : {
2210 : 0 : OUString nameA;
2211 : 0 : OUString nameB;
2212 : 0 : a[0 /*TYPE_NAME*/] >>= nameA;
2213 : 0 : b[0 /*TYPE_NAME*/] >>= nameB;
2214 : 0 : if( nameA.compareToAscii( RTL_CONSTASCII_STRINGPARAM( "int4" ) ) == 0 )
2215 : 0 : return 1;
2216 : 0 : if( nameB.compareToAscii( RTL_CONSTASCII_STRINGPARAM( "int4" ) ) == 0 )
2217 : 0 : return 0;
2218 : 0 : return nameA.compareTo( nameB ) < 0;
2219 : : }
2220 : :
2221 : 0 : return valueA.toInt32() < valueB.toInt32();
2222 : : // sal_Int32 valueA;
2223 : : // sal_Int32 valueB;
2224 : : // a[1 /*DATA_TYPE*/] >>= valueA;
2225 : : // b[1 /*DATA_TYPE*/] >>= valueB;
2226 : : // if( valueB == valueA )
2227 : : // {
2228 : : // OUString nameA;
2229 : : // OUString nameB;
2230 : : // a[0 /*TYPE_NAME*/] >>= nameA;
2231 : : // b[0 /*TYPE_NAME*/] >>= nameB;
2232 : : // return nameA.compareTo( nameB ) < 0;
2233 : : // }
2234 : :
2235 : : // return valueA < valueB;
2236 : : }
2237 : : };
2238 : :
2239 : 0 : static sal_Int32 calcSearchable( sal_Int32 dataType )
2240 : : {
2241 : 0 : sal_Int32 ret = com::sun::star::sdbc::ColumnSearch::FULL;
2242 : 0 : if( com::sun::star::sdbc::DataType::BINARY == dataType ||
2243 : : com::sun::star::sdbc::DataType::VARBINARY == dataType ||
2244 : : com::sun::star::sdbc::DataType::LONGVARBINARY == dataType )
2245 : 0 : ret = com::sun::star::sdbc::ColumnSearch::NONE;
2246 : :
2247 : 0 : return ret;
2248 : : }
2249 : :
2250 : 0 : static sal_Int32 getMaxScale( sal_Int32 dataType )
2251 : : {
2252 : : // LEM TODO: review, see where used, see JDBC, ...
2253 : 0 : sal_Int32 ret = 0;
2254 : 0 : if( dataType == com::sun::star::sdbc::DataType::NUMERIC )
2255 : 0 : ret = 1000; // see pg-docs DataType/numeric
2256 : : // else if( dataType == DataType::DOUBLE )
2257 : : // ret = 308;
2258 : : // else if( dataType == DataType::FLOAT )
2259 : : // ret =
2260 : 0 : return ret;
2261 : : }
2262 : :
2263 : :
2264 : : struct RawType
2265 : : {
2266 : : const char * typeName;
2267 : : const char * createParam;
2268 : : sal_Int32 sdbcType;
2269 : : sal_Int32 precision;
2270 : : sal_Int32 nullable;
2271 : : bool caseSensitive;
2272 : : sal_Int32 searchable;
2273 : : };
2274 : :
2275 : 0 : static void pgTypeInfo2ResultSet(
2276 : : SequenceAnyVector &vec,
2277 : : const Reference< XResultSet > &rs )
2278 : : {
2279 : : static const sal_Int32 TYPE_NAME = 0; // string Type name
2280 : : static const sal_Int32 DATA_TYPE = 1; // short SQL data type from java.sql.Types
2281 : : static const sal_Int32 PRECISION = 2; // long maximum precision
2282 : : static const sal_Int32 CREATE_PARAMS = 5; // string => parameters used in creating the type (may be NULL )
2283 : : static const sal_Int32 NULLABLE = 6; // short ==> can you use NULL for this type?
2284 : : // - NO_NULLS - does not allow NULL values
2285 : : // - NULLABLE - allows NULL values
2286 : : // - NULLABLE_UNKNOWN - nullability unknown
2287 : :
2288 : : static const sal_Int32 CASE_SENSITIVE = 7; // boolean==> is it case sensitive
2289 : : static const sal_Int32 SEARCHABLE = 8; // short ==>; can you use
2290 : : // "WHERE" based on this type:
2291 : : // - NONE - No support
2292 : : // - CHAR - Only supported with WHERE .. LIKE
2293 : : // - BASIC - Supported except for WHERE .. LIKE
2294 : : // - FULL - Supported for all WHERE ..
2295 : : static const sal_Int32 UNSIGNED_ATTRIBUTE = 9; // boolean ==> is it unsigned?
2296 : : static const sal_Int32 FIXED_PREC_SCALE = 10; // boolean ==> can it be a money value?
2297 : : static const sal_Int32 AUTO_INCREMENT = 11; // boolean ==> can it be used for
2298 : : // an auto-increment value?
2299 : : static const sal_Int32 MINIMUM_SCALE = 13; // short ==> minimum scale supported
2300 : : static const sal_Int32 MAXIMUM_SCALE = 14; // short ==> maximum scale supported
2301 : : static const sal_Int32 NUM_PREC_RADIX = 17; // long ==> usually 2 or 10
2302 : :
2303 : : /* not filled so far
2304 : : 3. LITERAL_PREFIX string ==> prefix used to quote a literal
2305 : : (may be <NULL/>)
2306 : : 4, LITERAL_SUFFIX string ==> suffix used to quote a literal
2307 : : (may be <NULL/>)
2308 : : 5. CREATE_PARAMS string ==> parameters used in creating thw type (may be <NULL/>)
2309 : : 12. LOCAL_TYPE_NAME string ==> localized version of type name (may be <NULL/>)
2310 : : 15, SQL_DATA_TYPE long ==> unused
2311 : : 16. SQL_DATETIME_SUB long ==> unused
2312 : : */
2313 : 0 : Reference< XRow > xRow( rs, UNO_QUERY_THROW );
2314 : 0 : while( rs->next() )
2315 : : {
2316 : 0 : Sequence< Any > row(18);
2317 : :
2318 : 0 : sal_Int32 dataType =typeNameToDataType(xRow->getString(5),xRow->getString(2));
2319 : 0 : sal_Int32 precision = xRow->getString(3).toInt32();
2320 : :
2321 : 0 : if( dataType == com::sun::star::sdbc::DataType::CHAR ||
2322 : : ( dataType == com::sun::star::sdbc::DataType::VARCHAR &&
2323 : 0 : xRow->getString(TYPE_NAME+1).equalsIgnoreAsciiCaseAsciiL(RTL_CONSTASCII_STRINGPARAM("varchar")) ) )
2324 : : {
2325 : : // reflect varchar as varchar with upper limit !
2326 : : //NOTE: the sql spec requires varchar to have an upper limit, however
2327 : : // in postgresql the upper limit is optional, no limit means unlimited
2328 : : // length (=1GB).
2329 : 0 : precision = 0x40000000; // about 1 GB, see character type docs in postgresql
2330 : 0 : row[CREATE_PARAMS] <<= ASCII_STR( "length" );
2331 : : }
2332 : 0 : else if( dataType == com::sun::star::sdbc::DataType::NUMERIC )
2333 : : {
2334 : 0 : precision = 1000;
2335 : 0 : row[CREATE_PARAMS] <<= ASCII_STR( "length, scale" );
2336 : : }
2337 : :
2338 : 0 : row[TYPE_NAME] <<= xRow->getString(1);
2339 : 0 : row[DATA_TYPE] <<= OUString::valueOf(dataType);
2340 : 0 : row[PRECISION] <<= OUString::valueOf( precision );
2341 : 0 : sal_Int32 nullable = xRow->getBoolean(4) ?
2342 : : com::sun::star::sdbc::ColumnValue::NO_NULLS :
2343 : 0 : com::sun::star::sdbc::ColumnValue::NULLABLE;
2344 : 0 : row[NULLABLE] <<= OUString::valueOf(nullable);
2345 : 0 : row[CASE_SENSITIVE] <<= OUString::valueOf((sal_Int32)1);
2346 : 0 : row[SEARCHABLE] <<= OUString::valueOf( calcSearchable( dataType ) );
2347 : 0 : row[UNSIGNED_ATTRIBUTE] <<= ASCII_STR( "0" ); //
2348 : 0 : if( com::sun::star::sdbc::DataType::INTEGER == dataType ||
2349 : : com::sun::star::sdbc::DataType::BIGINT == dataType )
2350 : 0 : row[AUTO_INCREMENT] <<= ASCII_STR( "1" ); // TODO
2351 : : else
2352 : 0 : row[AUTO_INCREMENT] <<= ASCII_STR( "0" ); // TODO
2353 : 0 : row[MINIMUM_SCALE] <<= ASCII_STR( "0" ); // TODO: what is this ?
2354 : 0 : row[MAXIMUM_SCALE] <<= OUString::valueOf( getMaxScale( dataType ) );
2355 : 0 : row[NUM_PREC_RADIX] <<= ASCII_STR( "10" ); // TODO: what is this ?
2356 : : (void)FIXED_PREC_SCALE;
2357 : 0 : vec.push_back( row );
2358 : 0 : }
2359 : :
2360 : 0 : }
2361 : :
2362 : :
2363 : 0 : ::com::sun::star::uno::Reference< XResultSet > DatabaseMetaData::getTypeInfo( )
2364 : : throw (SQLException, RuntimeException)
2365 : : {
2366 : : // Note: Indexes start at 0 (in the API doc, they start at 1)
2367 : 0 : MutexGuard guard( m_refMutex->mutex );
2368 : 0 : checkClosed();
2369 : :
2370 : 0 : if( isLog( m_pSettings, LogLevel::INFO ) )
2371 : : {
2372 : 0 : log( m_pSettings, LogLevel::INFO, "DatabaseMetaData::getTypeInfo() got called" );
2373 : : }
2374 : :
2375 : 0 : Reference< XStatement > statement = m_origin->createStatement();
2376 : 0 : Reference< XResultSet > rs = statement->executeQuery(
2377 : : ASCII_STR(
2378 : : "SELECT pg_type.typname AS typname," //1
2379 : : "pg_type.typtype AS typtype," //2
2380 : : "pg_type.typlen AS typlen," //3
2381 : : "pg_type.typnotnull AS typnotnull," //4
2382 : : "pg_type.typname AS typname " //5
2383 : : "FROM pg_type "
2384 : : "WHERE pg_type.typtype = 'b' "
2385 : : "OR pg_type.typtype = 'p'"
2386 : 0 : ) );
2387 : :
2388 : 0 : SequenceAnyVector vec;
2389 : 0 : pgTypeInfo2ResultSet( vec, rs );
2390 : :
2391 : : // check for domain types
2392 : 0 : rs = statement->executeQuery(
2393 : : ASCII_STR(
2394 : : "SELECT t1.typname as typname,"
2395 : : "t2.typtype AS typtype,"
2396 : : "t2.typlen AS typlen,"
2397 : : "t2.typnotnull AS typnotnull,"
2398 : : "t2.typname as realtypname "
2399 : : "FROM pg_type as t1 LEFT JOIN pg_type AS t2 ON t1.typbasetype=t2.oid "
2400 : 0 : "WHERE t1.typtype = 'd'" ) );
2401 : 0 : pgTypeInfo2ResultSet( vec, rs );
2402 : :
2403 : 0 : std::sort( vec.begin(), vec.end(), TypeInfoByDataTypeSorter() );
2404 : :
2405 : : return new SequenceResultSet(
2406 : : m_refMutex,
2407 : : *this,
2408 : 0 : getStatics().typeinfoColumnNames,
2409 : : sequence_of_vector(vec),
2410 : : m_pSettings->tc,
2411 : 0 : &( getStatics().typeInfoMetaData ));
2412 : : }
2413 : :
2414 : :
2415 : 0 : static sal_Int32 seqContains( const Sequence< sal_Int32 > &seq, sal_Int32 value )
2416 : : {
2417 : 0 : sal_Int32 ret = -1;
2418 : 0 : for( int i = 0; i < seq.getLength(); i ++ )
2419 : : {
2420 : 0 : if( seq[i] == value )
2421 : : {
2422 : 0 : ret = i;
2423 : 0 : break;
2424 : : }
2425 : : }
2426 : 0 : return ret;
2427 : : }
2428 : :
2429 : 0 : ::com::sun::star::uno::Reference< XResultSet > DatabaseMetaData::getIndexInfo(
2430 : : const ::com::sun::star::uno::Any& catalog,
2431 : : const OUString& schema,
2432 : : const OUString& table,
2433 : : sal_Bool unique,
2434 : : sal_Bool approximate ) throw (SQLException, RuntimeException)
2435 : : {
2436 : : (void) catalog; (void) approximate;
2437 : : //LEM TODO: review
2438 : 0 : MutexGuard guard( m_refMutex->mutex );
2439 : 0 : checkClosed();
2440 : :
2441 : : /*
2442 : : 1. TABLE_CAT string -> table catalog (may be NULL )
2443 : : 2. TABLE_SCHEM string -> table schema (may be NULL )
2444 : : 3. TABLE_NAME string -> table name
2445 : : 4. NON_UNIQUE boolean -> Can index values be non-unique?
2446 : : false when TYPE is tableIndexStatistic
2447 : : 5. INDEX_QUALIFIER string -> index catalog (may be NULL );
2448 : : NULL when TYPE is tableIndexStatistic
2449 : : 6. INDEX_NAME string -> index name; NULL when TYPE is tableIndexStatistic
2450 : : 7. TYPE short -> index type:
2451 : : * 0 - this identifies table statistics that are returned
2452 : : in conjuction with a table's index descriptions
2453 : : * CLUSTERED - this is a clustered index
2454 : : * HASHED - this is a hashed index
2455 : : * OTHER - this is some other style of index
2456 : : 8. ORDINAL_POSITION short -> column sequence number within index;
2457 : : zero when TYPE is tableIndexStatistic
2458 : : 9. COLUMN_NAME string -> column name; NULL when TYPE is tableIndexStatistic
2459 : : 10. ASC_OR_DESC string -> column sort sequence, "A"= ascending,
2460 : : "D" = descending, may be NULL if sort sequence
2461 : : is not supported; NULL when TYPE is tableIndexStatistic
2462 : : 11. CARDINALITY long -> When TYPE is tableIndexStatistic, then this is
2463 : : the number of rows in the table; otherwise, it
2464 : : is the number of unique values in the index.
2465 : : 12. PAGES long -> When TYPE is tableIndexStatisic then this is
2466 : : the number of pages used for the table, otherwise
2467 : : it is the number of pages used for the current index.
2468 : : 13. FILTER_CONDITION string -> Filter condition, if any. (may be NULL )
2469 : :
2470 : : */
2471 : : static const sal_Int32 C_SCHEMA = 1;
2472 : : static const sal_Int32 C_TABLENAME = 2;
2473 : : static const sal_Int32 C_INDEXNAME = 3;
2474 : : static const sal_Int32 C_IS_CLUSTERED = 4;
2475 : : static const sal_Int32 C_IS_UNIQUE = 5;
2476 : : static const sal_Int32 C_IS_PRIMARY = 6;
2477 : : static const sal_Int32 C_COLUMNS = 7;
2478 : :
2479 : : static const sal_Int32 R_TABLE_SCHEM = 1;
2480 : : static const sal_Int32 R_TABLE_NAME = 2;
2481 : : static const sal_Int32 R_NON_UNIQUE = 3;
2482 : : static const sal_Int32 R_INDEX_NAME = 5;
2483 : : static const sal_Int32 R_TYPE = 6;
2484 : : static const sal_Int32 R_ORDINAL_POSITION = 7;
2485 : : static const sal_Int32 R_COLUMN_NAME = 8;
2486 : :
2487 : 0 : Reference< XPreparedStatement > stmt = m_origin->prepareStatement(
2488 : : ASCII_STR(
2489 : : "SELECT nspname, " // 1
2490 : : "pg_class.relname, " // 2
2491 : : "class2.relname, " // 3
2492 : : "indisclustered, " // 4
2493 : : "indisunique, " // 5
2494 : : "indisprimary, " // 6
2495 : : "indkey " // 7
2496 : : "FROM pg_index INNER JOIN pg_class ON indrelid = pg_class.oid "
2497 : : "INNER JOIN pg_namespace ON pg_class.relnamespace = pg_namespace.oid "
2498 : : "INNER JOIN pg_class as class2 ON pg_index.indexrelid = class2.oid "
2499 : 0 : "WHERE nspname = ? AND pg_class.relname = ?" ) );
2500 : :
2501 : 0 : Reference< XParameters > param ( stmt, UNO_QUERY_THROW );
2502 : 0 : param->setString( 1, schema );
2503 : 0 : param->setString( 2, table );
2504 : 0 : Reference< XResultSet > rs = stmt->executeQuery();
2505 : 0 : Reference< XRow > xRow ( rs, UNO_QUERY_THROW );
2506 : :
2507 : 0 : SequenceAnyVector vec;
2508 : 0 : while( rs->next() )
2509 : : {
2510 : 0 : Sequence< sal_Int32 > columns = parseIntArray( xRow->getString(C_COLUMNS) );
2511 : 0 : Reference< XPreparedStatement > columnsStmt = m_origin->prepareStatement(
2512 : : ASCII_STR(
2513 : : "SELECT attnum, attname "
2514 : : "FROM pg_attribute "
2515 : : " INNER JOIN pg_class ON attrelid = pg_class.oid "
2516 : : " INNER JOIN pg_namespace ON pg_class.relnamespace=pg_namespace.oid "
2517 : 0 : " WHERE pg_namespace.nspname=? AND pg_class.relname=?" ) );
2518 : 0 : Reference< XParameters > paramColumn ( columnsStmt, UNO_QUERY_THROW );
2519 : 0 : OUString currentSchema = xRow->getString( C_SCHEMA );
2520 : 0 : OUString currentTable = xRow->getString( C_TABLENAME );
2521 : 0 : OUString currentIndexName = xRow->getString( C_INDEXNAME );
2522 : 0 : sal_Bool isNonUnique = ! xRow->getBoolean( C_IS_UNIQUE );
2523 : 0 : sal_Bool isPrimary = xRow->getBoolean( C_IS_PRIMARY );
2524 : : (void)isPrimary;
2525 : 0 : sal_Int32 indexType = xRow->getBoolean( C_IS_CLUSTERED ) ?
2526 : : com::sun::star::sdbc::IndexType::CLUSTERED :
2527 : 0 : com::sun::star::sdbc::IndexType::HASHED;
2528 : :
2529 : 0 : paramColumn->setString( C_SCHEMA, currentSchema );
2530 : 0 : paramColumn->setString( C_TABLENAME, currentTable );
2531 : :
2532 : 0 : Reference< XResultSet > rsColumn = columnsStmt->executeQuery();
2533 : 0 : Reference< XRow > rowColumn( rsColumn, UNO_QUERY_THROW );
2534 : 0 : while( rsColumn->next() )
2535 : : {
2536 : 0 : sal_Int32 pos = seqContains( columns, rowColumn->getInt( 1 ) );
2537 : 0 : if( pos >= 0 && ( ! isNonUnique || ! unique ) )
2538 : : {
2539 : 0 : Sequence< Any > result( 13 );
2540 : 0 : result[R_TABLE_SCHEM] = makeAny(currentSchema);
2541 : 0 : result[R_TABLE_NAME] = makeAny(currentTable);
2542 : 0 : result[R_INDEX_NAME] = makeAny(currentIndexName);
2543 : 0 : result[R_NON_UNIQUE] =
2544 : 0 : Any( &isNonUnique, getBooleanCppuType() );
2545 : 0 : result[R_TYPE] = makeAny( indexType );
2546 : 0 : result[R_COLUMN_NAME] = makeAny( rowColumn->getString(2) );
2547 : 0 : sal_Int32 nPos = ((sal_Int32)pos+1); // MSVC++ nonsense
2548 : 0 : result[R_ORDINAL_POSITION] = makeAny( nPos );
2549 : 0 : vec.push_back( result );
2550 : : }
2551 : : }
2552 : 0 : }
2553 : : return new SequenceResultSet(
2554 : 0 : m_refMutex, *this, getStatics().indexinfoColumnNames,
2555 : : sequence_of_vector(vec),
2556 : 0 : m_pSettings->tc );
2557 : : }
2558 : :
2559 : 0 : sal_Bool DatabaseMetaData::supportsResultSetType( sal_Int32 setType )
2560 : : throw (SQLException, RuntimeException)
2561 : : {
2562 : 0 : if ( setType == com::sun::star::sdbc::ResultSetType::SCROLL_SENSITIVE )
2563 : 0 : return sal_False;
2564 : : else
2565 : 0 : return sal_True;
2566 : : }
2567 : :
2568 : 0 : sal_Bool DatabaseMetaData::supportsResultSetConcurrency(
2569 : : sal_Int32 setType, sal_Int32 concurrency ) throw (SQLException, RuntimeException)
2570 : : {
2571 : : (void) concurrency;
2572 : 0 : if ( ! supportsResultSetType( setType ) )
2573 : 0 : return sal_False;
2574 : : else
2575 : 0 : return sal_True;
2576 : : }
2577 : :
2578 : 0 : sal_Bool DatabaseMetaData::ownUpdatesAreVisible( sal_Int32 /* setType */ ) throw (SQLException, RuntimeException)
2579 : : {
2580 : 0 : return sal_True;
2581 : : }
2582 : :
2583 : 0 : sal_Bool DatabaseMetaData::ownDeletesAreVisible( sal_Int32 /* setType */ ) throw (SQLException, RuntimeException)
2584 : : {
2585 : 0 : return sal_True;
2586 : : }
2587 : :
2588 : 0 : sal_Bool DatabaseMetaData::ownInsertsAreVisible( sal_Int32 /* setType */ ) throw (SQLException, RuntimeException)
2589 : : {
2590 : 0 : return sal_True;
2591 : : }
2592 : :
2593 : 0 : sal_Bool DatabaseMetaData::othersUpdatesAreVisible( sal_Int32 /* setType */ ) throw (SQLException, RuntimeException)
2594 : : {
2595 : 0 : return sal_False;
2596 : : }
2597 : :
2598 : 0 : sal_Bool DatabaseMetaData::othersDeletesAreVisible( sal_Int32 /* setType */ ) throw (SQLException, RuntimeException)
2599 : : {
2600 : 0 : return sal_False;
2601 : : }
2602 : :
2603 : 0 : sal_Bool DatabaseMetaData::othersInsertsAreVisible( sal_Int32 /* setType */ ) throw (SQLException, RuntimeException)
2604 : : {
2605 : 0 : return sal_False;
2606 : : }
2607 : :
2608 : 0 : sal_Bool DatabaseMetaData::updatesAreDetected( sal_Int32 /* setType */ ) throw (SQLException, RuntimeException)
2609 : : {
2610 : 0 : return sal_False;
2611 : : }
2612 : :
2613 : 0 : sal_Bool DatabaseMetaData::deletesAreDetected( sal_Int32 /* setType */ ) throw (SQLException, RuntimeException)
2614 : : {
2615 : 0 : return sal_False;
2616 : : }
2617 : 0 : sal_Bool DatabaseMetaData::insertsAreDetected( sal_Int32 /* setType */ ) throw (SQLException, RuntimeException)
2618 : : {
2619 : 0 : return sal_False;
2620 : : }
2621 : :
2622 : 0 : sal_Bool DatabaseMetaData::supportsBatchUpdates( ) throw (SQLException, RuntimeException)
2623 : : {
2624 : 0 : return sal_True;
2625 : : }
2626 : :
2627 : 0 : ::com::sun::star::uno::Reference< XResultSet > DatabaseMetaData::getUDTs( const ::com::sun::star::uno::Any& catalog, const OUString& schemaPattern, const OUString& typeNamePattern, const ::com::sun::star::uno::Sequence< sal_Int32 >& types ) throw (SQLException, RuntimeException)
2628 : : {
2629 : : (void) catalog; (void) schemaPattern; (void) typeNamePattern; (void) types;
2630 : : //LEM TODO: implement! See JDBC driver
2631 : 0 : MutexGuard guard( m_refMutex->mutex );
2632 : 0 : checkClosed();
2633 : : return new SequenceResultSet(
2634 : 0 : m_refMutex, *this, Sequence< OUString >(), Sequence< Sequence< Any > > (), m_pSettings->tc );
2635 : : }
2636 : :
2637 : 0 : ::com::sun::star::uno::Reference< com::sun::star::sdbc::XConnection > DatabaseMetaData::getConnection()
2638 : : throw (SQLException, RuntimeException)
2639 : : {
2640 : 0 : return m_origin;
2641 : : }
2642 : : }
|
