connectivity/source/commontools/TDatabaseMetaDataBase.cxx

   1 /* -*- Mode: C++; tab-width: 4; indent-tabs-mode: nil; c-basic-offset: 4 -*- */
   2 /*
   3  * This file is part of the LibreOffice project.
   4  *
   5  * This Source Code Form is subject to the terms of the Mozilla Public
   6  * License, v. 2.0. If a copy of the MPL was not distributed with this
   7  * file, You can obtain one at http://mozilla.org/MPL/2.0/.
   8  *
   9  * This file incorporates work covered by the following license notice:
  10  *
  11  *   Licensed to the Apache Software Foundation (ASF) under one or more
  12  *   contributor license agreements. See the NOTICE file distributed
  13  *   with this work for additional information regarding copyright
  14  *   ownership. The ASF licenses this file to you under the Apache
  15  *   License, Version 2.0 (the "License"); you may not use this file
  16  *   except in compliance with the License. You may obtain a copy of
  17  *   the License at http://www.apache.org/licenses/LICENSE-2.0 .
  18  */
  19
  20 #include <TDatabaseMetaDataBase.hxx>
  21 #include <RowFunctionParser.hxx>
  22
  23 #include <comphelper/sequenceashashmap.hxx>
  24 #include <comphelper/evtlistenerhlp.hxx>
  25 #include <comphelper/types.hxx>
  26 #include <com/sun/star/lang/XComponent.hpp>
  27 #include <resource/sharedresources.hxx>
  28 #include <strings.hrc>
  29 #include <connectivity/dbexception.hxx>
  30 #include <sal/macros.h>
  31
  32 using namespace com::sun::star::uno;
  33 using namespace com::sun::star::lang;
  34 using namespace com::sun::star::sdbc;
  35 using namespace com::sun::star::beans;
  36 using namespace comphelper;
  37 using namespace connectivity;
  38
  39
  40 ODatabaseMetaDataBase::ODatabaseMetaDataBase(const Reference< XConnection >& _rxConnection,const Sequence< PropertyValue >& _rInfo)
  41     : m_aConnectionInfo(_rInfo)
  42     ,m_isCatalogAtStart(false,false)
  43     ,m_sCatalogSeparator(false,OUString())
  44     ,m_sIdentifierQuoteString(false,OUString())
  45     ,m_supportsCatalogsInTableDefinitions(false,false)
  46     ,m_supportsSchemasInTableDefinitions(false,false)
  47     ,m_supportsCatalogsInDataManipulation(false,false)
  48     ,m_supportsSchemasInDataManipulation(false,false)
  49     ,m_supportsMixedCaseQuotedIdentifiers(false,false)
  50     ,m_supportsAlterTableWithAddColumn(false,false)
  51     ,m_supportsAlterTableWithDropColumn(false,false)
  52     ,m_MaxStatements(false,0)
  53     ,m_MaxTablesInSelect(false,0)
  54     ,m_storesMixedCaseQuotedIdentifiers(false,false)
  55     , m_xConnection(_rxConnection)
  56 {
  57     osl_atomic_increment( &m_refCount );
  58     {
  59         m_xListenerHelper = new OEventListenerHelper(this);
  60         Reference<XComponent> xCom(m_xConnection,UNO_QUERY);
  61         if(xCom.is())
  62             xCom->addEventListener(m_xListenerHelper);
  63     }
  64     osl_atomic_decrement( &m_refCount );
  65 }
  66
  67 ODatabaseMetaDataBase::~ODatabaseMetaDataBase()
  68 {
  69 }
  70
  71
  72 Sequence< PropertyValue > SAL_CALL ODatabaseMetaDataBase::getConnectionInfo(  )
  73 {
  74     return m_aConnectionInfo;
  75 }
  76
  77
  78 void SAL_CALL ODatabaseMetaDataBase::disposing( const EventObject& /*Source*/ )
  79 {
  80     // cut off all references to the connection
  81 m_xConnection.clear();
  82 m_xListenerHelper.clear();
  83 }
  84
  85 Reference< XResultSet > SAL_CALL ODatabaseMetaDataBase::getTypeInfo(  )
  86 {
  87     ::osl::MutexGuard aGuard( m_aMutex );
  88     if ( m_aTypeInfoRows.empty() )
  89     {
  90         Reference< XResultSet > xRet = impl_getTypeInfo_throw();
  91         Reference< XRow > xRow(xRet,UNO_QUERY);
  92         ::comphelper::SequenceAsHashMap aMap(m_aConnectionInfo);
  93         Sequence< Any > aTypeInfoSettings;
  94         aTypeInfoSettings = aMap.getUnpackedValueOrDefault("TypeInfoSettings",aTypeInfoSettings);
  95
  96         if ( xRow.is() )
  97         {
  98             static const sal_Int32 pTypes[] = {
  99                                         DataType::VARCHAR
 100                                         ,DataType::INTEGER
 101                                         ,DataType::INTEGER
 102                                         ,DataType::VARCHAR
 103                                         ,DataType::VARCHAR
 104                                         ,DataType::VARCHAR
 105                                         ,DataType::INTEGER
 106                                         ,DataType::BOOLEAN
 107                                         ,DataType::INTEGER
 108                                         ,DataType::BOOLEAN
 109                                         ,DataType::BOOLEAN
 110                                         ,DataType::BOOLEAN
 111                                         ,DataType::VARCHAR
 112                                         ,DataType::INTEGER
 113                                         ,DataType::INTEGER
 114                                         ,DataType::INTEGER
 115                                         ,DataType::INTEGER
 116                                         ,DataType::INTEGER
 117                                     };
 118             std::vector<std::shared_ptr<ExpressionNode>> aConditions;
 119             if ( aTypeInfoSettings.getLength() > 1 && ((aTypeInfoSettings.getLength() % 2) == 0) )
 120             {
 121                 const Any* pIter = aTypeInfoSettings.getConstArray();
 122                 const Any* pEnd  = pIter + aTypeInfoSettings.getLength();
 123                 try
 124                 {
 125                     for(;pIter != pEnd;++pIter)
 126                         aConditions.push_back(FunctionParser::parseFunction(::comphelper::getString(*pIter)));
 127                 }
 128                 catch(ParseError&)
 129                 {
 130                     ::connectivity::SharedResources aResources;
 131                     const OUString sError( aResources.getResourceString(STR_FORMULA_WRONG));
 132                     ::dbtools::throwGenericSQLException(sError,*this);
 133                 }
 134             }
 135
 136             ::connectivity::ODatabaseMetaDataResultSet::ORows aTypeInfoRows;
 137             while( xRet->next() )
 138             {
 139                 ::connectivity::ODatabaseMetaDataResultSet::ORow aRow;
 140                 aRow.push_back(ODatabaseMetaDataResultSet::getEmptyValue());
 141                 const sal_Int32* pType = pTypes;
 142                 for (sal_Int32 i = 1; i <= sal_Int32(SAL_N_ELEMENTS(pTypes)); ++i,++pType)
 143                 {
 144                     ORowSetValue aValue;
 145                     aValue.fill(i,*pType,xRow);
 146                     aRow.push_back(new ORowSetValueDecorator(aValue));
 147                 }
 148
 149                 std::vector<std::shared_ptr<ExpressionNode>>::iterator aIter = aConditions.begin();
 150                 std::vector<std::shared_ptr<ExpressionNode>>::const_iterator aEnd = aConditions.end();
 151                 for (; aIter != aEnd; ++aIter)
 152                 {
 153                     if ( (*aIter)->evaluate(aRow)->getValue().getBool() )
 154                     {
 155                         ++aIter;
 156                         (*aIter)->fill(aRow);
 157                     }
 158                     else
 159                         ++aIter;
 160                 }
 161                 aTypeInfoRows.push_back(aRow);
 162             }
 163             m_aTypeInfoRows = aTypeInfoRows;
 164         }
 165     }
 166     ::connectivity::ODatabaseMetaDataResultSet* pResult = new ::connectivity::ODatabaseMetaDataResultSet(::connectivity::ODatabaseMetaDataResultSet::eTypeInfo);
 167     Reference< XResultSet > xRet = pResult;
 168     pResult->setRows(m_aTypeInfoRows);
 169     return xRet;
 170 }
 171
 172 Reference< XResultSet > SAL_CALL ODatabaseMetaDataBase::getExportedKeys(
 173         const Any& /*catalog*/, const OUString& /*schema*/, const OUString& /*table*/ )
 174 {
 175     return new ODatabaseMetaDataResultSet( ODatabaseMetaDataResultSet::eExportedKeys );
 176 }
 177
 178 Reference< XResultSet > SAL_CALL ODatabaseMetaDataBase::getImportedKeys(
 179         const Any& /*catalog*/, const OUString& /*schema*/, const OUString& /*table*/ )
 180 {
 181     return new ODatabaseMetaDataResultSet( ODatabaseMetaDataResultSet::eImportedKeys );
 182 }
 183
 184 Reference< XResultSet > SAL_CALL ODatabaseMetaDataBase::getPrimaryKeys(
 185         const Any& /*catalog*/, const OUString& /*schema*/, const OUString& /*table*/ )
 186 {
 187     return new ODatabaseMetaDataResultSet( ODatabaseMetaDataResultSet::ePrimaryKeys );
 188 }
 189
 190 Reference< XResultSet > SAL_CALL ODatabaseMetaDataBase::getIndexInfo(
 191         const Any& /*catalog*/, const OUString& /*schema*/, const OUString& /*table*/,
 192         sal_Bool /*unique*/, sal_Bool /*approximate*/ )
 193 {
 194     return new ODatabaseMetaDataResultSet( ODatabaseMetaDataResultSet::eIndexInfo );
 195 }
 196
 197 Reference< XResultSet > SAL_CALL ODatabaseMetaDataBase::getBestRowIdentifier(
 198         const Any& /*catalog*/, const OUString& /*schema*/, const OUString& /*table*/, sal_Int32 /*scope*/,
 199         sal_Bool /*nullable*/ )
 200 {
 201     return new ODatabaseMetaDataResultSet( ODatabaseMetaDataResultSet::eBestRowIdentifier );
 202 }
 203
 204 Reference< XResultSet > SAL_CALL ODatabaseMetaDataBase::getCrossReference(
 205         const Any& /*primaryCatalog*/, const OUString& /*primarySchema*/,
 206         const OUString& /*primaryTable*/, const Any& /*foreignCatalog*/,
 207         const OUString& /*foreignSchema*/, const OUString& /*foreignTable*/ )
 208 {
 209     return new ODatabaseMetaDataResultSet( ODatabaseMetaDataResultSet::eCrossReference );
 210 }
 211
 212 Reference< XConnection > SAL_CALL ODatabaseMetaDataBase::getConnection(  )
 213 {
 214     return m_xConnection;
 215 }
 216
 217 Reference< XResultSet > SAL_CALL ODatabaseMetaDataBase::getProcedureColumns(
 218         const Any& /*catalog*/, const OUString& /*schemaPattern*/,
 219         const OUString& /*procedureNamePattern*/, const OUString& /*columnNamePattern*/ )
 220 {
 221     return new ODatabaseMetaDataResultSet( ODatabaseMetaDataResultSet::eProcedureColumns );
 222 }
 223
 224 Reference< XResultSet > SAL_CALL ODatabaseMetaDataBase::getProcedures(
 225         const Any& /*catalog*/, const OUString& /*schemaPattern*/,
 226         const OUString& /*procedureNamePattern*/ )
 227 {
 228     return new ODatabaseMetaDataResultSet( ODatabaseMetaDataResultSet::eProcedures );
 229 }
 230
 231 Reference< XResultSet > SAL_CALL ODatabaseMetaDataBase::getVersionColumns(
 232         const Any& /*catalog*/, const OUString& /*schema*/, const OUString& /*table*/ )
 233 {
 234     return new ODatabaseMetaDataResultSet( ODatabaseMetaDataResultSet::eVersionColumns );
 235 }
 236
 237 Reference< XResultSet > SAL_CALL ODatabaseMetaDataBase::getSchemas(  )
 238 {
 239     return new ODatabaseMetaDataResultSet( ODatabaseMetaDataResultSet::eSchemas );
 240 }
 241
 242 Reference< XResultSet > SAL_CALL ODatabaseMetaDataBase::getColumnPrivileges(
 243         const Any& /*catalog*/, const OUString& /*schema*/, const OUString& /*table*/,
 244         const OUString& /*columnNamePattern*/ )
 245 {
 246     return new ODatabaseMetaDataResultSet( ODatabaseMetaDataResultSet::eColumnPrivileges );
 247 }
 248
 249 Reference< XResultSet > SAL_CALL ODatabaseMetaDataBase::getTablePrivileges(
 250         const Any& /*catalog*/, const OUString& /*schema*/, const OUString& /*table*/)
 251 {
 252     return new ODatabaseMetaDataResultSet( ODatabaseMetaDataResultSet::eTablePrivileges );
 253 }
 254
 255 Reference< XResultSet > SAL_CALL ODatabaseMetaDataBase::getCatalogs(  )
 256 {
 257     return new ODatabaseMetaDataResultSet( ODatabaseMetaDataResultSet::eCatalogs );
 258 }
 259
 260 OUString SAL_CALL ODatabaseMetaDataBase::getIdentifierQuoteString(  )
 261 {
 262     return callImplMethod(m_sIdentifierQuoteString,std::function<OUString(ODatabaseMetaDataBase *)>(&ODatabaseMetaDataBase::impl_getIdentifierQuoteString_throw));
 263 }
 264
 265 sal_Bool SAL_CALL ODatabaseMetaDataBase::isCatalogAtStart(  )
 266 {
 267     return callImplMethod(m_isCatalogAtStart,std::function<bool(ODatabaseMetaDataBase *)>(&ODatabaseMetaDataBase::impl_isCatalogAtStart_throw));
 268 }
 269
 270 OUString SAL_CALL ODatabaseMetaDataBase::getCatalogSeparator(  )
 271 {
 272     return callImplMethod(m_sCatalogSeparator,std::function<OUString(ODatabaseMetaDataBase *)>(&ODatabaseMetaDataBase::impl_getCatalogSeparator_throw));
 273 }
 274
 275 sal_Bool SAL_CALL ODatabaseMetaDataBase::supportsCatalogsInTableDefinitions(  )
 276 {
 277     return callImplMethod(m_supportsCatalogsInTableDefinitions,std::function<bool(ODatabaseMetaDataBase *)>(&ODatabaseMetaDataBase::impl_supportsCatalogsInTableDefinitions_throw));
 278 }
 279
 280 sal_Bool SAL_CALL ODatabaseMetaDataBase::supportsSchemasInTableDefinitions(  )
 281 {
 282     return callImplMethod(m_supportsSchemasInTableDefinitions,std::function<bool(ODatabaseMetaDataBase *)>(&ODatabaseMetaDataBase::impl_supportsSchemasInTableDefinitions_throw));
 283 }
 284
 285 sal_Bool SAL_CALL ODatabaseMetaDataBase::supportsCatalogsInDataManipulation(  )
 286 {
 287     return callImplMethod(m_supportsCatalogsInDataManipulation,std::function<bool(ODatabaseMetaDataBase *)>(&ODatabaseMetaDataBase::impl_supportsCatalogsInDataManipulation_throw));
 288 }
 289
 290 sal_Bool SAL_CALL ODatabaseMetaDataBase::supportsSchemasInDataManipulation(  )
 291 {
 292     return callImplMethod(m_supportsSchemasInDataManipulation,std::function<bool(ODatabaseMetaDataBase *)>(&ODatabaseMetaDataBase::impl_supportsSchemasInDataManipulation_throw));
 293 }
 294
 295 sal_Bool SAL_CALL ODatabaseMetaDataBase::supportsMixedCaseQuotedIdentifiers(  )
 296 {
 297     return callImplMethod(m_supportsMixedCaseQuotedIdentifiers,std::function<bool(ODatabaseMetaDataBase *)>(&ODatabaseMetaDataBase::impl_supportsMixedCaseQuotedIdentifiers_throw));
 298 }
 299
 300 sal_Bool SAL_CALL ODatabaseMetaDataBase::supportsAlterTableWithAddColumn(  )
 301 {
 302     return callImplMethod(m_supportsAlterTableWithAddColumn,std::function<bool(ODatabaseMetaDataBase *)>(&ODatabaseMetaDataBase::impl_supportsAlterTableWithAddColumn_throw));
 303 }
 304
 305 sal_Bool SAL_CALL ODatabaseMetaDataBase::supportsAlterTableWithDropColumn(  )
 306 {
 307     return callImplMethod(m_supportsAlterTableWithDropColumn,std::function<bool(ODatabaseMetaDataBase *)>(&ODatabaseMetaDataBase::impl_supportsAlterTableWithDropColumn_throw));
 308 }
 309
 310 sal_Int32 SAL_CALL ODatabaseMetaDataBase::getMaxStatements(  )
 311 {
 312     return callImplMethod(m_MaxStatements,std::function<sal_Int32(ODatabaseMetaDataBase *)>(&ODatabaseMetaDataBase::impl_getMaxStatements_throw));
 313 }
 314
 315 sal_Int32 SAL_CALL ODatabaseMetaDataBase::getMaxTablesInSelect(  )
 316 {
 317     return callImplMethod(m_MaxTablesInSelect,std::function<sal_Int32(ODatabaseMetaDataBase *)>(&ODatabaseMetaDataBase::impl_getMaxTablesInSelect_throw));
 318 }
 319
 320 sal_Bool SAL_CALL ODatabaseMetaDataBase::storesMixedCaseQuotedIdentifiers(  )
 321 {
 322     return callImplMethod(m_storesMixedCaseQuotedIdentifiers,std::function<bool(ODatabaseMetaDataBase *)>(&ODatabaseMetaDataBase::impl_storesMixedCaseQuotedIdentifiers_throw));
 323 }
 324
 325
 326 /* vim:set shiftwidth=4 softtabstop=4 expandtab: */