diff options
Diffstat (limited to 'dbaccess/source/ui/relationdesign/RTableConnectionData.cxx')
| -rw-r--r-- | dbaccess/source/ui/relationdesign/RTableConnectionData.cxx | 466 |
1 files changed, 466 insertions, 0 deletions
diff --git a/dbaccess/source/ui/relationdesign/RTableConnectionData.cxx b/dbaccess/source/ui/relationdesign/RTableConnectionData.cxx new file mode 100644 index 000000000000..a8e34493e320 --- /dev/null +++ b/dbaccess/source/ui/relationdesign/RTableConnectionData.cxx @@ -0,0 +1,466 @@ +/************************************************************************* + * + * 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 + * <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_dbaccess.hxx" +#include "RTableConnectionData.hxx" +#include <tools/debug.hxx> +#include <com/sun/star/sdbc/KeyRule.hpp> +#include <com/sun/star/sdbcx/KeyType.hpp> +#include <com/sun/star/sdbcx/XKeysSupplier.hpp> +#include <com/sun/star/sdbcx/XColumnsSupplier.hpp> +#include <com/sun/star/sdbcx/XDataDescriptorFactory.hpp> +#include <com/sun/star/sdbcx/XAppend.hpp> +#include <com/sun/star/sdbcx/XDrop.hpp> +#include <com/sun/star/container/XIndexAccess.hpp> +#include "dbustrings.hrc" +#include "dbu_rel.hrc" +#include "UITools.hxx" +#include "moduledbu.hxx" +#include <connectivity/dbexception.hxx> +#include <connectivity/dbtools.hxx> + +using namespace dbaui; +using namespace ::com::sun::star::sdbc; +using namespace ::com::sun::star::sdbcx; +using namespace ::com::sun::star::uno; +using namespace ::com::sun::star::beans; +using namespace ::com::sun::star::container; +using namespace ::com::sun::star::lang; + +DBG_NAME(ORelationTableConnectionData) +//======================================================================== +// class ORelationTableConnectionData +//======================================================================== +//------------------------------------------------------------------------ +ORelationTableConnectionData::ORelationTableConnectionData() + :OTableConnectionData() + ,m_nUpdateRules(KeyRule::NO_ACTION) + ,m_nDeleteRules(KeyRule::NO_ACTION) + ,m_nCardinality(CARDINAL_UNDEFINED) +{ + DBG_CTOR(ORelationTableConnectionData,NULL); +} +//------------------------------------------------------------------------ +ORelationTableConnectionData::ORelationTableConnectionData( const TTableWindowData::value_type& _pReferencingTable, + const TTableWindowData::value_type& _pReferencedTable, + const ::rtl::OUString& rConnName ) + :OTableConnectionData( _pReferencingTable, _pReferencedTable ) + ,m_nUpdateRules(KeyRule::NO_ACTION) + ,m_nDeleteRules(KeyRule::NO_ACTION) + ,m_nCardinality(CARDINAL_UNDEFINED) +{ + DBG_CTOR(ORelationTableConnectionData,NULL); + m_aConnName = rConnName; + + if ( m_aConnName.Len() ) + SetCardinality(); +} + +//------------------------------------------------------------------------ +ORelationTableConnectionData::ORelationTableConnectionData( const ORelationTableConnectionData& rConnData ) + :OTableConnectionData( rConnData ) +{ + DBG_CTOR(ORelationTableConnectionData,NULL); + *this = rConnData; +} + +//------------------------------------------------------------------------ +ORelationTableConnectionData::~ORelationTableConnectionData() +{ + DBG_DTOR(ORelationTableConnectionData,NULL); +} + +//------------------------------------------------------------------------ +BOOL ORelationTableConnectionData::DropRelation() +{ + DBG_CHKTHIS(ORelationTableConnectionData,NULL); + ::osl::MutexGuard aGuard( m_aMutex ); + //////////////////////////////////////////////////////////// + // Relation loeschen + Reference< XIndexAccess> xKeys = getReferencingTable()->getKeys(); + if( m_aConnName.Len() && xKeys.is() ) + { + const sal_Int32 nCount = xKeys->getCount(); + for(sal_Int32 i = 0;i < nCount;++i) + { + Reference< XPropertySet> xKey(xKeys->getByIndex(i),UNO_QUERY); + OSL_ENSURE(xKey.is(),"Key is not valid!"); + if(xKey.is()) + { + ::rtl::OUString sName; + xKey->getPropertyValue(PROPERTY_NAME) >>= sName; + if(String(sName) == m_aConnName) + { + Reference< XDrop> xDrop(xKeys,UNO_QUERY); + OSL_ENSURE(xDrop.is(),"can't drop key because we haven't a drop interface!"); + if(xDrop.is()) + xDrop->dropByIndex(i); + break; + } + } + } + } + return TRUE; +} + +//------------------------------------------------------------------------ +void ORelationTableConnectionData::ChangeOrientation() +{ + DBG_CHKTHIS(ORelationTableConnectionData,NULL); + ////////////////////////////////////////////////////////////////////// + // Source- und DestFieldName der Linien austauschen + ::rtl::OUString sTempString; + OConnectionLineDataVec::iterator aIter = m_vConnLineData.begin(); + OConnectionLineDataVec::iterator aEnd = m_vConnLineData.end(); + for(;aIter != aEnd;++aIter) + { + sTempString = (*aIter)->GetSourceFieldName(); + (*aIter)->SetSourceFieldName( (*aIter)->GetDestFieldName() ); + (*aIter)->SetDestFieldName( sTempString ); + } + + ////////////////////////////////////////////////////////////////////// + // Member anpassen + TTableWindowData::value_type pTemp = m_pReferencingTable; + m_pReferencingTable = m_pReferencedTable; + m_pReferencedTable = pTemp; +} + +//------------------------------------------------------------------------ +void ORelationTableConnectionData::SetCardinality() +{ + DBG_CHKTHIS(ORelationTableConnectionData,NULL); + ::osl::MutexGuard aGuard( m_aMutex ); + m_nCardinality = CARDINAL_UNDEFINED; + + if( IsSourcePrimKey() ) + { + if( IsDestPrimKey() ) + m_nCardinality = CARDINAL_ONE_ONE; + else + m_nCardinality = CARDINAL_ONE_MANY; + } + + if( IsDestPrimKey() ) + { + if( !IsSourcePrimKey() ) + m_nCardinality = CARDINAL_MANY_ONE; + } + +} +// ----------------------------------------------------------------------------- +BOOL ORelationTableConnectionData::checkPrimaryKey(const Reference< XPropertySet>& i_xTable,EConnectionSide _eEConnectionSide) const +{ + // check if Table has the primary key column dependig on _eEConnectionSide + USHORT nPrimKeysCount = 0, + nValidLinesCount = 0; + const Reference< XNameAccess> xKeyColumns = dbtools::getPrimaryKeyColumns_throw(i_xTable); + if ( xKeyColumns.is() ) + { + Sequence< ::rtl::OUString> aKeyColumns = xKeyColumns->getElementNames(); + const ::rtl::OUString* pKeyIter = aKeyColumns.getConstArray(); + const ::rtl::OUString* pKeyEnd = pKeyIter + aKeyColumns.getLength(); + + for(;pKeyIter != pKeyEnd;++pKeyIter) + { + OConnectionLineDataVec::const_iterator aIter = m_vConnLineData.begin(); + OConnectionLineDataVec::const_iterator aEnd = m_vConnLineData.end(); + for(;aIter != aEnd;++aIter) + { + ++nValidLinesCount; + if ( (*aIter)->GetFieldName(_eEConnectionSide) == *pKeyIter ) + { + ++nPrimKeysCount; + break; + } + } + } + if ( nPrimKeysCount != aKeyColumns.getLength() ) + return FALSE; + } + if ( !nPrimKeysCount || nPrimKeysCount != nValidLinesCount ) + return FALSE; + + return TRUE; +} +//------------------------------------------------------------------------ +BOOL ORelationTableConnectionData::IsConnectionPossible() +{ + DBG_CHKTHIS(ORelationTableConnectionData,NULL); + ::osl::MutexGuard aGuard( m_aMutex ); + + ////////////////////////////////////////////////////////////////////// + // Wenn die SourceFelder ein PrimKey sind, ist nur die Orientierung falsch + if ( IsSourcePrimKey() && !IsDestPrimKey() ) + ChangeOrientation(); + + return TRUE; +} + +//------------------------------------------------------------------------ +OConnectionLineDataRef ORelationTableConnectionData::CreateLineDataObj() +{ + return new OConnectionLineData(); +} + +//------------------------------------------------------------------------ +OConnectionLineDataRef ORelationTableConnectionData::CreateLineDataObj( const OConnectionLineData& rConnLineData ) +{ + return new OConnectionLineData( rConnLineData ); +} + +//------------------------------------------------------------------------ +void ORelationTableConnectionData::CopyFrom(const OTableConnectionData& rSource) +{ + // wie in der Basisklasse zurueckziehen auf das (nicht-virtuelle) operator= + *this = *static_cast<const ORelationTableConnectionData*>(&rSource); +} + +//------------------------------------------------------------------------ +ORelationTableConnectionData& ORelationTableConnectionData::operator=( const ORelationTableConnectionData& rConnData ) +{ + if (&rConnData == this) + return *this; + + OTableConnectionData::operator=( rConnData ); + m_nUpdateRules = rConnData.GetUpdateRules(); + m_nDeleteRules = rConnData.GetDeleteRules(); + m_nCardinality = rConnData.GetCardinality(); + + return *this; +} +namespace dbaui +{ +//------------------------------------------------------------------------- +bool operator==(const ORelationTableConnectionData& lhs, const ORelationTableConnectionData& rhs) +{ + bool bEqual = (lhs.m_nUpdateRules == rhs.m_nUpdateRules) + && (lhs.m_nDeleteRules == rhs.m_nDeleteRules) + && (lhs.m_nCardinality == rhs.m_nCardinality) + && (lhs.getReferencingTable() == rhs.getReferencingTable()) + && (lhs.getReferencedTable() == rhs.getReferencedTable()) + && (lhs.m_aConnName == rhs.m_aConnName) + && (lhs.m_vConnLineData.size() == rhs.m_vConnLineData.size()); + + if ( bEqual ) + { + std::vector< OConnectionLineDataRef >::const_iterator aIter = lhs.m_vConnLineData.begin(); + std::vector< OConnectionLineDataRef >::const_iterator aEnd = lhs.m_vConnLineData.end(); + for (sal_Int32 i = 0; aIter != aEnd; ++aIter,++i) + { + if ( *(rhs.m_vConnLineData[i]) != **aIter ) + break; + } + bEqual = aIter == aEnd; + } + return bEqual; +} +} +//------------------------------------------------------------------------ +BOOL ORelationTableConnectionData::Update() +{ + ::osl::MutexGuard aGuard( m_aMutex ); + //////////////////////////////////////////////////////////// + // Alte Relation loeschen + { + DropRelation(); + if( !IsConnectionPossible() ) + return FALSE; + } + + // reassign the keys because the orientaion could be changed + Reference<XPropertySet> xTableProp(getReferencingTable()->getTable()); + Reference< XIndexAccess> xKeys ( getReferencingTable()->getKeys()); + + if ( !xKeys.is() ) + return FALSE; + //////////////////////////////////////////////////////////// + // Neue Relation erzeugen + Reference<XDataDescriptorFactory> xKeyFactory(xKeys,UNO_QUERY); + OSL_ENSURE(xKeyFactory.is(),"No XDataDescriptorFactory Interface!"); + Reference<XAppend> xAppend(xKeyFactory,UNO_QUERY); + OSL_ENSURE(xAppend.is(),"No XAppend Interface!"); + + Reference<XPropertySet> xKey = xKeyFactory->createDataDescriptor(); + OSL_ENSURE(xKey.is(),"Key is null!"); + if ( xKey.is() && xTableProp.is() ) + { + // build a foreign key name + ::rtl::OUString sSourceName; + xTableProp->getPropertyValue(PROPERTY_NAME) >>= sSourceName; + ::rtl::OUString sKeyName = sSourceName; + sKeyName += getReferencedTable()->GetTableName(); + + xKey->setPropertyValue(PROPERTY_NAME,makeAny(sKeyName)); + xKey->setPropertyValue(PROPERTY_TYPE,makeAny(KeyType::FOREIGN)); + xKey->setPropertyValue(PROPERTY_REFERENCEDTABLE,makeAny(::rtl::OUString(getReferencedTable()->GetTableName()))); + xKey->setPropertyValue(PROPERTY_UPDATERULE, makeAny(GetUpdateRules())); + xKey->setPropertyValue(PROPERTY_DELETERULE, makeAny(GetDeleteRules())); + } + + Reference<XColumnsSupplier> xColSup(xKey,UNO_QUERY); + if ( xColSup.is() ) + { + Reference<XNameAccess> xColumns = xColSup->getColumns(); + Reference<XDataDescriptorFactory> xColumnFactory(xColumns,UNO_QUERY); + Reference<XAppend> xColumnAppend(xColumns,UNO_QUERY); + if ( xColumnFactory.is() ) + { + OConnectionLineDataVec::iterator aIter = m_vConnLineData.begin(); + OConnectionLineDataVec::iterator aEnd = m_vConnLineData.end(); + for(;aIter != aEnd;++aIter) + { + if((*aIter)->GetSourceFieldName().getLength() && (*aIter)->GetDestFieldName().getLength()) + { + Reference<XPropertySet> xColumn; + xColumn = xColumnFactory->createDataDescriptor(); + if ( xColumn.is() ) + { + xColumn->setPropertyValue(PROPERTY_NAME,makeAny((*aIter)->GetSourceFieldName())); + xColumn->setPropertyValue(PROPERTY_RELATEDCOLUMN,makeAny((*aIter)->GetDestFieldName())); + xColumnAppend->appendByDescriptor(xColumn); + } + } + } + + if ( xColumns->hasElements() ) + xAppend->appendByDescriptor(xKey); + } + // to get the key we have to reget it because after append it is no longer valid + } + + // get the name of foreign key // search for columns + m_aConnName = ::rtl::OUString(); +xKey.clear(); + bool bDropRelation = false; + for(sal_Int32 i=0;i<xKeys->getCount();++i) + { + xKeys->getByIndex(i) >>= xKey; + OSL_ENSURE(xKey.is(),"Key is not valid!"); + if ( xKey.is() ) + { + sal_Int32 nType = 0; + xKey->getPropertyValue(PROPERTY_TYPE) >>= nType; + ::rtl::OUString sReferencedTable; + xKey->getPropertyValue(PROPERTY_REFERENCEDTABLE) >>= sReferencedTable; + if ( sReferencedTable == ::rtl::OUString(getReferencedTable()->GetTableName()) ) + { + xColSup.set(xKey,UNO_QUERY_THROW); + try + { + Reference<XNameAccess> xColumns = xColSup->getColumns(); + Sequence< ::rtl::OUString> aNames = xColumns->getElementNames(); + const ::rtl::OUString* pIter = aNames.getConstArray(); + const ::rtl::OUString* pEnd = pIter + aNames.getLength(); + + Reference<XPropertySet> xColumn; + ::rtl::OUString sName,sRelatedColumn; + for ( ; pIter != pEnd ; ++pIter ) + { + xColumn.set(xColumns->getByName(*pIter),UNO_QUERY_THROW); + xColumn->getPropertyValue(PROPERTY_NAME) >>= sName; + xColumn->getPropertyValue(PROPERTY_RELATEDCOLUMN) >>= sRelatedColumn; + + OConnectionLineDataVec::iterator aIter = m_vConnLineData.begin(); + OConnectionLineDataVec::iterator aEnd = m_vConnLineData.end(); + for(;aIter != aEnd;++aIter) + { + if( (*aIter)->GetSourceFieldName() == sName + && (*aIter)->GetDestFieldName() == sRelatedColumn ) + { + break; + } + } + if ( aIter == m_vConnLineData.end() ) + break; + } + if ( pIter == pEnd ) + { + xKey->getPropertyValue(PROPERTY_NAME) >>= sName; + m_aConnName = sName; + bDropRelation = aNames.getLength() == 0; // the key contains no column, so it isn't valid and we have to drop it + //here we already know our column structure so we don't have to recreate the table connection data + xColSup.clear(); + break; + } + } + catch(Exception&) + { + } + } + } + xKey.clear(); + } // for(sal_Int32 i=0;i<xKeys->getCount();++i) + if ( bDropRelation ) + { + DropRelation(); + String sError(ModuleRes(STR_QUERY_REL_COULD_NOT_CREATE)); + ::dbtools::throwGenericSQLException(sError,NULL); + } + +// OSL_ENSURE(xKey.is(),"No key found have insertion!"); + + // The fields the relation marks may not be the same as our LineDatas mark after the relation has been updated + if ( xColSup.is() ) + { + OConnectionLineDataVec().swap(m_vConnLineData); + Reference<XNameAccess> xColumns = xColSup->getColumns(); + Sequence< ::rtl::OUString> aNames = xColumns->getElementNames(); + const ::rtl::OUString* pIter = aNames.getConstArray(); + const ::rtl::OUString* pEnd = pIter + aNames.getLength(); + + m_vConnLineData.reserve( aNames.getLength() ); + Reference<XPropertySet> xColumn; + ::rtl::OUString sName,sRelatedColumn; + + for(;pIter != pEnd;++pIter) + { + xColumns->getByName(*pIter) >>= xColumn; + if ( xColumn.is() ) + { + OConnectionLineDataRef pNewData = CreateLineDataObj(); + + xColumn->getPropertyValue(PROPERTY_NAME) >>= sName; + xColumn->getPropertyValue(PROPERTY_RELATEDCOLUMN) >>= sRelatedColumn; + + pNewData->SetSourceFieldName(sName); + pNewData->SetDestFieldName(sRelatedColumn); + m_vConnLineData.push_back(pNewData); + } + } + } // if ( xColSup.is() ) + // NOTE : the caller is resposible for updating any other objects referencing the old LineDatas (for instance a ConnLine) + + //////////////////////////////////////////////////////////// + // Kardinalitaet bestimmen + SetCardinality(); + + return TRUE; +} +// ----------------------------------------------------------------------------- + |