office-gobmx/connectivity/source/drivers/file/fanalyzer.cxx
Jens-Heiner Rechtien 0416c98d43 CWS-TOOLING: integrate CWS sb102
2008-12-11 16:18:12 +0100 sb  r265332 : #i95065# cleanup, to make Windows linking work
2008-12-11 16:16:03 +0100 sb  r265331 : #i95065# missing SAL_DLLPUBLIC_EXPORT
2008-12-09 17:40:28 +0100 sb  r265122 : #i94469# move CJK specific configuration data to brand layer
2008-12-09 16:09:08 +0100 sb  r265112 : #i96959# use PTHREAD_MUTEX_RECURSIVE on all platforms
2008-12-09 15:54:31 +0100 sb  r265110 : #i95065# do not derive apphelper::LifeTimeGuard from osl::ResettableMutexGuard to avoid problems with VISIBILITY_HIDDEN=TRUE on MSC
2008-12-09 15:40:51 +0100 sb  r265104 : #i95065# add VISIBILITY_HIDDEN=TRUE to connectivity/source/drivers/mozab
2008-12-09 15:36:21 +0100 sb  r265102 : #i95501# updated SDK_HOME
2008-12-09 15:31:46 +0100 sb  r265099 : typo (temppath vs. tmppath)
2008-12-08 11:48:08 +0100 sb  r264979 : #i95065# removed spurious ExplicitCategoriesProvider.obj (ExplicitCategoriesProvider.cxx is not in this directory)
2008-12-07 19:41:07 +0100 sb  r264960 : #i96994# erroneously doubled backslash caused visibility feature to be disabled for all GCC versions on Mac OS X
2008-12-06 23:54:49 +0100 sb  r264948 : changes from trunk that CWS-TOOLING's rebase to DEV300:m37 (r264891) had missed, as files had been moved around on this CWS
2008-12-05 20:29:23 +0100 sb  r264919 : #i85508# versions of flex apparently differ in whether input() resp. yyinput() returns zero or EOF upon end of file
2008-12-05 15:37:23 +0100 sb  r264908 : #i95315# removed obsolete jut
2008-12-05 15:34:59 +0100 sb  r264907 : #i95531# removed empty obsolete directories
2008-12-05 10:09:23 +0100 sb  r264891 : CWS-TOOLING: rebase CWS sb102 to trunk@264807 (milestone: DEV300:m37)
2008-12-04 14:50:20 +0100 sb  r264845 : #i95065# introduced VISIBILITY_HIDDEN makefile flag to reduce duplications; made additional libraries use VISIBILITY_HIDDEN=TRUE to avoid warnings with recent GCC 4 versions (had to split certain code directories to make changes that would otherwise erroneously affect multiple libraries built in the same makefile); changed connectivity::ORefVector to no longer derive from std::vector, as that caused problems with the MSC implementation of VISIBILITY_HIDDEN=TRUE; replaced uses of JNIEXPORT with SAL_DLLPUBLIC_EXPORT, as the former does not expand to visibility attributes on some platforms where the latter does
2008-12-03 11:29:38 +0100 sb  r264759 : #i94583# remove unnecessary (and wrong) assertion check for rtl_getAppCommandArg return value (which is guaranteed to return osl_Process_E_None or not return at all)
2008-12-02 17:18:31 +0100 sb  r264724 : #i96809# silenced GCC 4.3.2 warning
2008-12-02 13:29:34 +0100 sb  r264695 : #i96797# make get_tmp_dir fail less often
2008-11-28 17:19:24 +0100 sb  r264566 : #i95691# inadvertently missing from -c 264564
2008-11-28 17:07:50 +0100 sb  r264564 : #i95691# only structs of exactly 1, 2, 4, or 8 bytes are returned through registers
2008-11-25 13:28:08 +0100 sb  r264291 : #i96427# support for SAL_EXCEPTION_DLLPUBLIC_EXPORT (patch by np)
2008-11-21 14:45:22 +0100 sb  r264140 : #i95428# added SAL_EXCEPTION_DLLPUBLIC_EXPORT and SAL_EXCEPTION_DLLPRIVATE
2008-11-19 13:19:37 +0100 sb  r263984 : #i95525# removed erroneous application/octet-stream svn:mime-type properties
2008-12-30 13:32:01 +00:00

322 lines
13 KiB
C++

/*************************************************************************
*
* DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER.
*
* Copyright 2008 by Sun Microsystems, Inc.
*
* OpenOffice.org - a multi-platform office productivity suite
*
* $RCSfile: fanalyzer.cxx,v $
* $Revision: 1.26.56.1 $
*
* 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
* <http://www.openoffice.org/license.html>
* for a copy of the LGPLv3 License.
*
************************************************************************/
// MARKER(update_precomp.py): autogen include statement, do not remove
#include "precompiled_connectivity.hxx"
#include "file/fanalyzer.hxx"
#include "connectivity/sqlparse.hxx"
#include <osl/diagnose.h>
#include <tools/debug.hxx>
#include <comphelper/extract.hxx>
#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,set_fct_spec) )
{
::vos::ORef<OPredicateCompiler> pCompiler = new OPredicateCompiler(this);
pCompiler->setOrigColumns(m_aCompiler->getOrigColumns());
::vos::ORef<OPredicateInterpreter> 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
m_aSelectionEvaluations.push_back( TPredicates() );
}
}
}
m_aCompiler->start(pSQLParseNode);
}
//------------------------------------------------------------------
void OSQLAnalyzer::bindRow(OCodeList& rCodeList,const OValueRefRow& _pRow,OEvaluateSetList& _rEvaluateSetList)
{
// Zaehlen, wieviele Kriterien
// wenn nur ein Kriterium, und das entsprechende Feld ist indiziert
// dann wird der Index verwendet
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.isValid() )
bindRow( aIter->first->m_aCodeList,_pRow,aEvaluateSetList);
}
}
//------------------------------------------------------------------
::std::vector<sal_Int32>* OSQLAnalyzer::bindEvaluationRow(OValueRefRow& _pRow)
{
OEvaluateSetList aEvaluateSetList;
bindRow( m_aCompiler->m_aCodeList,_pRow,aEvaluateSetList);
::std::vector<sal_Int32>* pKeySet = NULL;
OEvaluateSet* pEvaluateSet = NULL;
// Keyset erzeugen mit kleinster Liste
if(!aEvaluateSetList.empty())
{
// welche Liste hat den kleinsten 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<sal_Int32>(pEvaluateSet->size());
sal_Int32 k=0;
for(OEvaluateSet::iterator j = pEvaluateSet->begin(); j != pEvaluateSet->end(); ++j,++k)
{
(*pKeySet)[k] = j->second;
}
// alle loeschen
for(i = aEvaluateSetList.begin(); i != aEvaluateSetList.end();++i)
delete (*i);
}
return pKeySet;
}
//------------------------------------------------------------------
void OSQLAnalyzer::describeParam(::vos::ORef<OSQLColumns> rParameterColumns)
{
OCodeList& rCodeList = m_aCompiler->m_aCodeList;
OCodeStack aCodeStack;
if (!rCodeList.size())
return; // kein Praedikat
if (!rParameterColumns->get().size())
return; // keine Parameter
// Anlegen von Columns, die eine genauere Beschreibung fuer die enthalten
::vos::ORef<OSQLColumns> aNewParamColumns = new OSQLColumns(*rParameterColumns);
// Anlegen einer Testzeile, wird benoetigt um die Parameter zu beschreiben
OValueRefRow aParameterRow = new OValueRefVector(rParameterColumns->get().size());
bindParameterRow(aParameterRow);
OValueRefRow aTestRow = new OValueRefVector(Reference< XIndexAccess>(m_aCompiler->getOrigColumns(),UNO_QUERY)->getCount());
delete bindEvaluationRow(aTestRow); // Binden der Attribute an die Values
for(OCodeList::iterator aIter = rCodeList.begin(); aIter != rCodeList.end(); ++aIter)
{
OOperand* pOperand = PTR_CAST(OOperand,(*aIter));
OOperator* pOperator = PTR_CAST(OOperator,(*aIter));
if (pOperand)
aCodeStack.push(pOperand);
else
{
if (pOperator->getRequestedOperands() == 2) // bei zwei Operatoren ist es moeglich
{ // einen Parameter weiter zu spezifizieren
OOperandParam *pParam = PTR_CAST(OOperandParam,aCodeStack.top());
if (pParam) // Anpassen des ParameterTyps, wenn der linke Operand ein Attribut ist
{
OOperandAttr *pLeft = PTR_CAST(OOperandAttr,*(rCodeList.end() - 2));
if (pLeft)
{
Reference< XPropertySet> xCol;
Reference< XIndexAccess>(m_aCompiler->getOrigColumns(),UNO_QUERY)->getByIndex(pLeft->getRowPos()) >>= xCol;
OSL_ENSURE(xCol.is(), "Ungueltige Struktur");
pParam->describe(xCol, aNewParamColumns);
}
}
}
pOperator->Exec(aCodeStack);
}
}
OOperand* pOperand = aCodeStack.top();
aCodeStack.pop();
OSL_ENSURE(aCodeStack.size() == 0, "StackFehler");
OSL_ENSURE(pOperand, "StackFehler");
if (IS_TYPE(OOperandResult,pOperand))
delete pOperand;
else
OSL_ENSURE(0,"Illegal here!");
rParameterColumns = aNewParamColumns;
// m_aCompiler->setParameterColumns(rParameterColumns);
}
// -----------------------------------------------------------------------------
OOperandAttr* OSQLAnalyzer::createOperandAttr(sal_Int32 _nPos,
const Reference< XPropertySet>& _xCol,
const Reference< XNameAccess>& /*_xIndexes*/)
{
return new OOperandAttr(static_cast<sal_uInt16>(_nPos),_xCol);
}
// -----------------------------------------------------------------------------
BOOL OSQLAnalyzer::hasRestriction() const
{
return m_aCompiler->hasCode();
}
// -----------------------------------------------------------------------------
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.isValid() )
m_bHasSelectionCode = aIter->first->hasCode();
}
}
return m_bHasSelectionCode;;
}
// -----------------------------------------------------------------------------
void OSQLAnalyzer::setSelectionEvaluationResult(OValueRefRow& _pRow,const ::std::vector<sal_Int32>& _rColumnMapping)
{
sal_Int32 nPos = 1;
for ( ::std::vector< TPredicates >::iterator aIter = m_aSelectionEvaluations.begin(); aIter != m_aSelectionEvaluations.end();++aIter,++nPos)
{
if ( aIter->second.isValid() )
{
sal_Int32 map = nPos;
// the first column (index 0) is for convenience only. The first real select column is no 1.
if ( (nPos > 0) && (nPos < static_cast<sal_Int32>(_rColumnMapping.size())) )
map = _rColumnMapping[nPos];
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.isValid() )
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.isValid() )
aIter->first->setOrigColumns(rCols);
}
}
// -----------------------------------------------------------------------------