Files
libreoffice/dbaccess/source/ui/relationdesign/RTableConnectionData.cxx
Release Engineers b88a62cc97 CWS-TOOLING: integrate CWS dbaperf2
2009-06-22 11:04:36 +0200 msc  r273202 : #100000# fix to run this test
2009-06-22 09:41:04 +0200 msc  r273200 : #100000# correct case
2009-06-22 09:02:42 +0200 msc  r273199 : new SRB
2009-06-22 08:53:26 +0200 msc  r273198 : #100000
2009-06-15 12:36:32 +0200 oj  r272976 : test
2009-06-12 14:23:23 +0200 msc  r272918 : #101587# unused feature was removed
2009-06-12 06:45:17 +0200 oj  r272903 : use GUI instead of OS
2009-06-11 09:12:30 +0200 oj  r272845 : remove unused dep
2009-06-11 09:11:09 +0200 oj  r272844 : ColumnAliasInOrderBy not supported
2009-06-11 08:27:00 +0200 oj  r272843 : CWS-TOOLING: rebase CWS dbaperf2 to trunk@272827 (milestone: DEV300:m50)
2009-06-10 15:30:17 +0200 msc  r272822 : #100000
2009-06-10 15:27:40 +0200 msc  r272820 : #102515# new function for the database type list
2009-06-10 15:26:09 +0200 msc  r272818 : move file to dbaccess/tools/dbcreatetools.inc
2009-06-10 15:20:10 +0200 msc  r272816 : #102515# new function for the database type list
2009-06-10 12:34:46 +0200 oj  r272803 : #i101587# check extension
2009-06-10 11:53:45 +0200 oj  r272800 : remove unused code
2009-06-09 09:57:25 +0200 oj  r272752 : #i101587# EscapeDateTime moved into features section
2009-06-09 09:56:26 +0200 oj  r272751 : enable finish
2009-06-08 11:50:37 +0200 oj  r272726 : #i102588# move convert tzo saveDataSource
2009-06-05 11:54:20 +0200 jsk  r272676 : #i102515# - NEW: Functions to retrieve Database names from API
2009-06-05 10:52:22 +0200 jsk  r272671 : NEW: Functions to retrieve Database names from API
2009-06-05 09:36:54 +0200 oj  r272666 : handle win and unx differently
2009-06-05 09:36:28 +0200 oj  r272665 : handle win and unx differently
2009-06-04 13:41:56 +0200 oj  r272625 : #i101268# make use of stringbuffer instead of oustring
2009-06-04 10:18:14 +0200 oj  r272612 : add SAL_DLLPUBLIC_EXPORT 
2009-05-28 10:56:33 +0200 oj  r272381 : #i101587# create langpacks
2009-05-28 10:41:59 +0200 oj  r272380 : #i101587# create langpacks
2009-05-28 10:29:30 +0200 oj  r272379 : #i101587# create langpacks
2009-05-07 10:11:46 +0200 oj  r271635 : fix compile warnings
2009-05-07 07:01:31 +0200 oj  r271619 : change type from int32 to PathID
2009-05-07 06:53:19 +0200 oj  r271618 : add all
2009-05-06 14:57:02 +0200 oj  r271595 : add missing lib
2009-05-06 14:56:54 +0200 oj  r271594 : no used anymore
2009-05-06 14:56:08 +0200 oj  r271593 : no used anymore
2009-05-06 14:54:25 +0200 oj  r271592 : no used anymore
2009-05-06 14:45:59 +0200 oj  r271591 : add missing lib
2009-05-06 14:41:54 +0200 oj  r271590 : change wnt
2009-05-06 14:22:21 +0200 oj  r271589 : #i101587# use config for the drivers
2009-05-06 14:21:39 +0200 oj  r271588 : #i101587# add new set for metadata and config data for driver
2009-05-06 14:19:36 +0200 oj  r271587 : #i101587# handle metadata and props of driver
2009-05-06 10:11:11 +0200 oj  r271570 : #i101587# correct wrong use of reference
2009-05-06 09:24:33 +0200 oj  r271567 : #i101587# add new set for metadata
2009-05-06 08:52:06 +0200 oj  r271563 : #i101587# add driver configuration
2009-05-06 08:51:04 +0200 oj  r271562 : #i101587# add driver configuration
2009-05-04 10:24:41 +0200 oj  r271442 : CWS-TOOLING: rebase CWS dbaperf2 to trunk@271427 (milestone: DEV300:m47)
2009-04-28 07:06:22 +0200 oj  r271303 : compile error
2009-04-27 14:12:48 +0200 oj  r271270 : #i101268# make use of stringbuffer instead of oustring
2009-04-27 14:12:27 +0200 oj  r271269 : #i101268# make use of stringbuffer instead of oustring
2009-04-27 09:30:10 +0200 oj  r271255 : use string buffer when possible
2009-04-24 11:56:01 +0200 oj  r271207 : #i101268# remove end() call from loop
2009-04-23 14:24:03 +0200 oj  r271171 : add dep
2009-04-23 13:25:25 +0200 oj  r271164 : #i101268# add config entries for database drivers
2009-04-23 13:07:13 +0200 oj  r271161 : #i101268# add config entries for database drivers
2009-04-23 13:06:33 +0200 oj  r271160 : #i101268# add parent url pattern entry for driver node
2009-04-23 13:05:39 +0200 oj  r271159 : #i101268# add config entry for driver node
2009-04-23 13:04:09 +0200 oj  r271157 : #i101268# add config entry for driver node
2009-04-23 06:41:32 +0200 oj  r271142 : #i101268# add new configuration file Drivers
2009-04-22 13:49:19 +0200 oj  r271103 : convert EOL
2009-04-22 13:29:17 +0200 oj  r271101 : #i101268# use of driver configuration entries for features and properties
2009-04-22 13:28:08 +0200 oj  r271100 : #i101268# use of driver configuration entries for features and properties
2009-04-22 13:15:26 +0200 oj  r271098 : #i101268# add new configuration file Drivers
2009-04-22 13:14:43 +0200 oj  r271097 : #i101268# use of driver configuration entries for features and properties
2009-07-03 12:24:35 +00:00

475 lines
19 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: RTableConnectionData.cxx,v $
* $Revision: 1.16 $
*
* 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>
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< XIndexAccess>& _xKeys,EConnectionSide _eEConnectionSide) const
{
// check if Table has the primary key column dependig on _eEConnectionSide
USHORT nPrimKeysCount = 0,
nValidLinesCount = 0;
::std::vector<Reference<XNameAccess> > vKeyColumns = ::dbaui::getKeyColumns(_xKeys,KeyType::PRIMARY);
if ( vKeyColumns.size() == 1 )
{
// OSL_ENSURE(vKeyColumns.size()==1,"There can be only one primary key in a table!");
Sequence< ::rtl::OUString> aKeyColumns;
Reference<XNameAccess> xKeyColumns = *vKeyColumns.begin();
if ( xKeyColumns.is() )
{
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 = NULL;
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 = NULL;
} // 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;
}
// -----------------------------------------------------------------------------