/* -*- Mode: C++; tab-width: 4; indent-tabs-mode: nil; c-basic-offset: 4 -*- */ /************************************************************************* * * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER. * * Copyright 2000, 2010 Oracle and/or its affiliates. * * OpenOffice.org - a multi-platform office productivity suite * * This file is part of OpenOffice.org. * * OpenOffice.org is free software: you can redistribute it and/or modify * it under the terms of the GNU Lesser General Public License version 3 * only, as published by the Free Software Foundation. * * OpenOffice.org is distributed in the hope that it will be useful, * but WITHOUT ANY WARRANTY; without even the implied warranty of * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the * GNU Lesser General Public License version 3 for more details * (a copy is included in the LICENSE file that accompanied this code). * * You should have received a copy of the GNU Lesser General Public License * version 3 along with OpenOffice.org. If not, see * * for a copy of the LGPLv3 License. * ************************************************************************/ #include "file/fanalyzer.hxx" #include "connectivity/sqlparse.hxx" #include #include #include #include "connectivity/sqlnode.hxx" #include "connectivity/dbexception.hxx" #include "file/FConnection.hxx" #include "resource/file_res.hrc" using namespace ::connectivity; using namespace ::connectivity::file; using namespace ::com::sun::star::uno; using namespace ::com::sun::star::beans; using namespace ::com::sun::star::sdbc; using namespace ::com::sun::star::container; DBG_NAME( file_OSQLAnalyzer ) //------------------------------------------------------------------ OSQLAnalyzer::OSQLAnalyzer(OConnection* _pConnection) :m_pConnection(_pConnection) ,m_bHasSelectionCode(sal_False) ,m_bSelectionFirstTime(sal_True) { DBG_CTOR( file_OSQLAnalyzer, NULL ); m_aCompiler = new OPredicateCompiler(this); m_aInterpreter = new OPredicateInterpreter(m_aCompiler); } // ----------------------------------------------------------------------------- OSQLAnalyzer::~OSQLAnalyzer() { DBG_DTOR( file_OSQLAnalyzer, NULL ); } // ----------------------------------------------------------------------------- void OSQLAnalyzer::setIndexes(const Reference< XNameAccess>& _xIndexes) { m_aCompiler->m_xIndexes = _xIndexes; } //------------------------------------------------------------------ void OSQLAnalyzer::start(OSQLParseNode* pSQLParseNode) { if (SQL_ISRULE(pSQLParseNode,select_statement)) { DBG_ASSERT(pSQLParseNode->count() >= 4,"OFILECursor: Fehler im Parse Tree"); // check that we don't use anything other than count(*) as function OSQLParseNode* pSelection = pSQLParseNode->getChild(2); if ( SQL_ISRULE(pSelection,scalar_exp_commalist) ) { for (sal_uInt32 i = 0; i < pSelection->count(); i++) { OSQLParseNode *pColumnRef = pSelection->getChild(i)->getChild(0); if ( ( SQL_ISRULE(pColumnRef,set_fct_spec) && pColumnRef->count() == 4 ) || SQL_ISRULE(pColumnRef,char_value_fct) || SQL_ISRULE(pColumnRef,char_substring_fct) || SQL_ISRULE(pColumnRef,position_exp) || SQL_ISRULE(pColumnRef,fold) || SQL_ISRULE(pColumnRef,length_exp) || SQL_ISRULE(pColumnRef,num_value_exp) || SQL_ISRULE(pColumnRef,term) || SQL_ISRULE(pColumnRef,factor) || SQL_ISRULE(pColumnRef,set_fct_spec) ) { ::rtl::Reference pCompiler = new OPredicateCompiler(this); pCompiler->setOrigColumns(m_aCompiler->getOrigColumns()); ::rtl::Reference pInterpreter = new OPredicateInterpreter(pCompiler); pCompiler->execute( pColumnRef ); m_aSelectionEvaluations.push_back( TPredicates(pCompiler,pInterpreter) ); } else if ( ( SQL_ISRULE(pColumnRef,general_set_fct) && pColumnRef->count() != 4 ) ) { m_pConnection->throwGenericSQLException(STR_QUERY_COMPLEX_COUNT,NULL); } else { if ( SQL_ISPUNCTUATION( pColumnRef, "*" ) || ( SQL_ISRULE( pColumnRef, column_ref ) && ( pColumnRef->count() == 3 ) && ( pColumnRef->getChild(0)->getNodeType() == SQL_NODE_NAME ) && SQL_ISPUNCTUATION( pColumnRef->getChild(1), "." ) && SQL_ISRULE( pColumnRef->getChild(2), column_val ) && SQL_ISPUNCTUATION( pColumnRef->getChild(2)->getChild(0), "*" ) ) ) { // push one element for each column of our table const Reference< XNameAccess > xColumnNames( m_aCompiler->getOrigColumns() ); const Sequence< ::rtl::OUString > aColumnNames( xColumnNames->getElementNames() ); for ( sal_Int32 j=0; jstart(pSQLParseNode); } //------------------------------------------------------------------ void OSQLAnalyzer::bindRow(OCodeList& rCodeList,const OValueRefRow& _pRow,OEvaluateSetList& _rEvaluateSetList) { // count criteria // if only one criterion, and the corresponding field is indexed // then the index will be used OEvaluateSet* pEvaluateSet = NULL; for (OCodeList::iterator aIter = rCodeList.begin(); aIter != rCodeList.end(); ++aIter) { OOperandAttr* pAttr = PTR_CAST(OOperandAttr,(*aIter)); if (pAttr) { if (pAttr->isIndexed() && !m_aCompiler->hasORCondition()) { OCode* pCode1 = *(aIter + 1); OCode* pCode2 = *(aIter + 2); if (PTR_CAST(OOperand,pCode1)) pEvaluateSet = pAttr->preProcess(PTR_CAST(OBoolOperator,pCode2), PTR_CAST(OOperand,pCode1)); else pEvaluateSet = pAttr->preProcess(PTR_CAST(OBoolOperator,pCode1)); } if (pEvaluateSet) { _rEvaluateSetList.push_back(pEvaluateSet); pEvaluateSet = NULL; } pAttr->bindValue(_pRow); } } } //------------------------------------------------------------------ void OSQLAnalyzer::bindSelectRow(const OValueRefRow& _pRow) { // first the select part OEvaluateSetList aEvaluateSetList; for ( ::std::vector< TPredicates >::iterator aIter = m_aSelectionEvaluations.begin(); aIter != m_aSelectionEvaluations.end();++aIter) { if ( aIter->first.is() ) bindRow( aIter->first->m_aCodeList,_pRow,aEvaluateSetList); } } //------------------------------------------------------------------ ::std::vector* OSQLAnalyzer::bindEvaluationRow(OValueRefRow& _pRow) { OEvaluateSetList aEvaluateSetList; bindRow( m_aCompiler->m_aCodeList,_pRow,aEvaluateSetList); ::std::vector* pKeySet = NULL; OEvaluateSet* pEvaluateSet = NULL; // create Keyset with smallest list if(!aEvaluateSetList.empty()) { // which list has the smallest count? OEvaluateSetList::iterator i = aEvaluateSetList.begin(); pEvaluateSet = *(i); for(++i; i != aEvaluateSetList.end();++i) { OEvaluateSet* pEvaluateSetComp = (*i); for(OEvaluateSet::reverse_iterator j = pEvaluateSet->rbegin(); j != pEvaluateSet->rend(); ++j) { if (pEvaluateSetComp->find(j->second) != pEvaluateSetComp->end()) pEvaluateSet->erase(j->second); } } pKeySet = new ::std::vector(pEvaluateSet->size()); sal_Int32 k=0; for(OEvaluateSet::iterator j = pEvaluateSet->begin(); j != pEvaluateSet->end(); ++j,++k) { (*pKeySet)[k] = j->second; } // delete all for(i = aEvaluateSetList.begin(); i != aEvaluateSetList.end();++i) delete (*i); } return pKeySet; } // ----------------------------------------------------------------------------- OOperandAttr* OSQLAnalyzer::createOperandAttr(sal_Int32 _nPos, const Reference< XPropertySet>& _xCol, const Reference< XNameAccess>& /*_xIndexes*/) { return new OOperandAttr(static_cast(_nPos),_xCol); } // ----------------------------------------------------------------------------- sal_Bool OSQLAnalyzer::hasRestriction() const { return m_aCompiler->hasCode(); } // ----------------------------------------------------------------------------- sal_Bool OSQLAnalyzer::hasFunctions() const { if ( m_bSelectionFirstTime ) { m_bSelectionFirstTime = sal_False; for ( ::std::vector< TPredicates >::const_iterator aIter = m_aSelectionEvaluations.begin(); aIter != m_aSelectionEvaluations.end() && !m_bHasSelectionCode ;++aIter) { if ( aIter->first.is() ) m_bHasSelectionCode = aIter->first->hasCode(); } } return m_bHasSelectionCode; } // ----------------------------------------------------------------------------- void OSQLAnalyzer::setSelectionEvaluationResult(OValueRefRow& _pRow,const ::std::vector& _rColumnMapping) { sal_Int32 nPos = 1; for ( ::std::vector< TPredicates >::iterator aIter = m_aSelectionEvaluations.begin(); aIter != m_aSelectionEvaluations.end();++aIter,++nPos) { if ( aIter->second.is() ) { // the first column (index 0) is for convenience only. The first real select column is no 1. sal_Int32 map = nPos; if ( nPos < static_cast< sal_Int32 >( _rColumnMapping.size() ) ) map = _rColumnMapping[nPos]; if ( map > 0 ) aIter->second->startSelection( (_pRow->get())[map] ); } } } // ----------------------------------------------------------------------------- void OSQLAnalyzer::dispose() { m_aCompiler->dispose(); for ( ::std::vector< TPredicates >::iterator aIter = m_aSelectionEvaluations.begin(); aIter != m_aSelectionEvaluations.end();++aIter) { if ( aIter->first.is() ) aIter->first->dispose(); } } // ----------------------------------------------------------------------------- void OSQLAnalyzer::setOrigColumns(const OFileColumns& rCols) { m_aCompiler->setOrigColumns(rCols); for ( ::std::vector< TPredicates >::iterator aIter = m_aSelectionEvaluations.begin(); aIter != m_aSelectionEvaluations.end();++aIter) { if ( aIter->first.is() ) aIter->first->setOrigColumns(rCols); } } // ----------------------------------------------------------------------------- /* vim:set shiftwidth=4 softtabstop=4 expandtab: */