Files
libreoffice/connectivity/source/drivers/dbase/dindexnode.cxx

753 lines
24 KiB
C++
Raw Normal View History

2000-09-18 15:18:56 +00:00
/*************************************************************************
*
* $RCSfile: dindexnode.cxx,v $
*
* $Revision: 1.12 $
2000-09-18 15:18:56 +00:00
*
* last change: $Author: oj $ $Date: 2001-05-23 09:13:10 $
2000-09-18 15:18:56 +00:00
*
* The Contents of this file are made available subject to the terms of
* either of the following licenses
*
* - GNU Lesser General Public License Version 2.1
* - Sun Industry Standards Source License Version 1.1
*
* Sun Microsystems Inc., October, 2000
*
* GNU Lesser General Public License Version 2.1
* =============================================
* Copyright 2000 by Sun Microsystems, Inc.
* 901 San Antonio Road, Palo Alto, CA 94303, USA
*
* This library is free software; you can redistribute it and/or
* modify it under the terms of the GNU Lesser General Public
* License version 2.1, as published by the Free Software Foundation.
*
* This library 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 for more details.
*
* You should have received a copy of the GNU Lesser General Public
* License along with this library; if not, write to the Free Software
* Foundation, Inc., 59 Temple Place, Suite 330, Boston,
* MA 02111-1307 USA
*
*
* Sun Industry Standards Source License Version 1.1
* =================================================
* The contents of this file are subject to the Sun Industry Standards
* Source License Version 1.1 (the "License"); You may not use this file
* except in compliance with the License. You may obtain a copy of the
* License at http://www.openoffice.org/license.html.
*
* Software provided under this License is provided on an "AS IS" basis,
* WITHOUT WARRANTY OF ANY KIND, EITHER EXPRESSED OR IMPLIED, INCLUDING,
* WITHOUT LIMITATION, WARRANTIES THAT THE SOFTWARE IS FREE OF DEFECTS,
* MERCHANTABLE, FIT FOR A PARTICULAR PURPOSE, OR NON-INFRINGING.
* See the License for the specific provisions governing your rights and
* obligations concerning the Software.
*
* The Initial Developer of the Original Code is: Sun Microsystems, Inc.
*
* Copyright: 2000 by Sun Microsystems, Inc.
*
* All Rights Reserved.
*
* Contributor(s): _______________________________________
*
*
************************************************************************/
#ifndef _CONNECTIVITY_DBASE_INDEXNODE_HXX_
#include "dbase/dindexnode.hxx"
#endif
#ifndef _CONNECTIVITY_COMMONTOOLS_HXX_
#include "connectivity/CommonTools.hxx"
#endif
#ifndef _OSL_THREAD_H_
#include <osl/thread.h>
#endif
#ifndef _CONNECTIVITY_DBASE_INDEX_HXX_
#include "dbase/DIndex.hxx"
#endif
2000-10-19 10:56:36 +00:00
#ifndef _TOOLS_DEBUG_HXX
#include <tools/debug.hxx>
#endif
2000-09-18 15:18:56 +00:00
using namespace connectivity;
using namespace connectivity::dbase;
using namespace connectivity::file;
using namespace com::sun::star::sdbc;
// -----------------------------------------------------------------------------
ONDXKey::ONDXKey(UINT32 nRec)
:nRecord(nRec)
{
}
// -----------------------------------------------------------------------------
ONDXKey::ONDXKey(const ORowSetValue& rVal, sal_Int32 eType, UINT32 nRec)
: ONDXKey_BASE(eType)
, nRecord(nRec)
, xValue(rVal)
{
}
// -----------------------------------------------------------------------------
ONDXKey::ONDXKey(const rtl::OUString& aStr, UINT32 nRec)
: ONDXKey_BASE(::com::sun::star::sdbc::DataType::VARCHAR)
,nRecord(nRec)
{
if (aStr.getLength())
{
xValue = aStr;
xValue.setBound(sal_True);
}
}
// -----------------------------------------------------------------------------
ONDXKey::ONDXKey(double aVal, UINT32 nRec)
: ONDXKey_BASE(::com::sun::star::sdbc::DataType::DOUBLE)
,nRecord(nRec)
,xValue(aVal)
{
}
// -----------------------------------------------------------------------------
2000-09-18 15:18:56 +00:00
//==================================================================
// Index Seite
//==================================================================
ONDXPage::ONDXPage(ODbaseIndex& rInd, sal_uInt32 nPos, ONDXPage* pParent)
:rIndex(rInd)
,nPagePos(nPos)
,nCount(0)
,bModified(FALSE)
,ppNodes(NULL)
2001-05-08 12:26:37 +00:00
,aParent(pParent)
2000-09-18 15:18:56 +00:00
{
2001-04-30 12:38:23 +00:00
sal_uInt16 nT = rIndex.getHeader().db_maxkeys;
2000-09-18 15:18:56 +00:00
ppNodes = new ONDXNode[nT];
}
//------------------------------------------------------------------
ONDXPage::~ONDXPage()
{
delete[] ppNodes;
2001-05-08 12:26:37 +00:00
// delete aParent;
// delete aChild;
2000-09-18 15:18:56 +00:00
}
//------------------------------------------------------------------
void ONDXPage::QueryDelete()
{
// Ablegen im GarbageCollector
2001-05-10 13:31:14 +00:00
if (IsModified() && rIndex.m_pFileStream)
2001-03-30 13:01:50 +00:00
(*rIndex.m_pFileStream) << *this;
2000-09-18 15:18:56 +00:00
bModified = FALSE;
if (rIndex.UseCollector())
{
2001-05-08 12:26:37 +00:00
if (aChild.Is())
aChild->Release(FALSE);
2000-09-18 15:18:56 +00:00
for (USHORT i = 0; i < rIndex.getHeader().db_maxkeys;i++)
{
if (ppNodes[i].GetChild().Is())
ppNodes[i].GetChild()->Release(FALSE);
ppNodes[i] = ONDXNode();
}
2001-05-08 12:26:37 +00:00
RestoreNoDelete();
2000-09-18 15:18:56 +00:00
nCount = 0;
2001-05-08 12:26:37 +00:00
aParent.Clear();
2000-09-18 15:18:56 +00:00
rIndex.Collect(this);
}
2001-03-30 13:01:50 +00:00
else
2001-05-08 12:26:37 +00:00
SvRefBase::QueryDelete();
2000-09-18 15:18:56 +00:00
}
//------------------------------------------------------------------
ONDXPagePtr& ONDXPage::GetChild(ODbaseIndex* pIndex)
{
2001-05-08 12:26:37 +00:00
if (!aChild.Is() && pIndex)
2000-09-18 15:18:56 +00:00
{
2001-05-08 12:26:37 +00:00
aChild = rIndex.CreatePage(aChild.GetPagePos(),this,aChild.HasPage());
2000-09-18 15:18:56 +00:00
}
2001-05-08 12:26:37 +00:00
return aChild;
2000-09-18 15:18:56 +00:00
}
//------------------------------------------------------------------
USHORT ONDXPage::FindPos(const ONDXKey& rKey) const
{
// sucht nach Platz fuer den vorgegeben key auf einer Seite
USHORT i = 0;
while (i < nCount && rKey > ((*this)[i]).GetKey())
i++;
return i;
}
//------------------------------------------------------------------
BOOL ONDXPage::Find(const ONDXKey& rKey)
{
// sucht den vorgegeben key
// Besonderheit: gelangt der Algorithmus ans Ende
// wird immer die aktuelle Seite und die Knotenposition vermerkt
// auf die die Bedingung <= zutrifft
// dieses findet beim Insert besondere Beachtung
USHORT i = 0;
while (i < nCount && rKey > ((*this)[i]).GetKey())
i++;
BOOL bResult = FALSE;
if (!IsLeaf())
{
// weiter absteigen
ONDXPagePtr aPage = (i==0) ? GetChild(&rIndex) : ((*this)[i-1]).GetChild(&rIndex, this);
bResult = aPage.Is() && aPage->Find(rKey);
}
else if (i == nCount)
{
rIndex.m_aCurLeaf = this;
rIndex.m_nCurNode = i - 1;
bResult = FALSE;
}
else
{
bResult = rKey == ((*this)[i]).GetKey();
rIndex.m_aCurLeaf = this;
rIndex.m_nCurNode = bResult ? i : i - 1;
}
return bResult;
}
//------------------------------------------------------------------
BOOL ONDXPage::Insert(ONDXNode& rNode, sal_uInt32 nRowsLeft)
{
// beim Erzeugen eines Index koennen auch mehrere Knoten eingefuegt werden
// diese sin dann aufsteigend sortiert
BOOL bAppend = nRowsLeft > 0;
if (IsFull())
{
BOOL bResult = TRUE;
ONDXNode aSplitNode;
if (bAppend)
aSplitNode = rNode;
else
{
// merken des letzten Knotens
aSplitNode = (*this)[nCount-1];
if(rNode.GetKey() <= aSplitNode.GetKey())
{
// und damit habe ich im folgenden praktisch eine Node weniger
2001-05-08 12:26:37 +00:00
if (IsLeaf() && this == &rIndex.m_aCurLeaf)
2000-09-18 15:18:56 +00:00
{
// geht davon aus, dass der Knoten, auf dem die Bedingung (<=)
// zutrifft, als m_nCurNode gesetzt ist
--nCount; // (sonst bekomme ich u.U. Assertions und GPFs - 60593)
bResult = Insert(rIndex.m_nCurNode + 1, rNode);
}
else // Position unbekannt
{
USHORT nPos = NODE_NOTFOUND;
while (++nPos < nCount && rNode.GetKey() > ((*this)[nPos]).GetKey());
--nCount; // (sonst bekomme ich u.U. Assertions und GPFs - 60593)
bResult = Insert(nPos, rNode);
}
// konnte der neue Knoten eingefuegt werden
if (!bResult)
{
nCount++;
aSplitNode = rNode;
}
}
else
aSplitNode = rNode;
}
sal_uInt32 nNewPagePos = rIndex.GetPageCount();
sal_uInt32 nNewPageCount = nNewPagePos + 1;
// Herausgeloesten Knoten beim Vater einfuegen
if (!HasParent())
{
// Kein Vater, dann neue Wurzel
ONDXPagePtr aNewRoot = rIndex.CreatePage(nNewPagePos + 1);
aNewRoot->SetChild(this);
rIndex.m_aRoot = aNewRoot;
rIndex.SetRootPos(nNewPagePos + 1);
rIndex.SetPageCount(++nNewPageCount);
}
// neues blatt erzeugen und Seite aufteilen
2001-05-08 12:26:37 +00:00
ONDXPagePtr aNewPage = rIndex.CreatePage(nNewPagePos,aParent);
2000-09-18 15:18:56 +00:00
rIndex.SetPageCount(nNewPageCount);
// wieviele Knoten weren noch eingefuegt
// kommen noch ausreichend, dann koennen die Seiten bis zum Rand vollgestopft werden
ONDXNode aInnerNode;
if (!IsLeaf() || nRowsLeft < (sal_uInt32)(rIndex.GetMaxNodes() / 2))
aInnerNode = Split(*aNewPage);
else
{
aInnerNode = (*this)[nCount - 1];
//aInnerNode = aSplitNode;
// Knoten zeigt auf neue Seite
aInnerNode.SetChild(aNewPage);
// innere Knoten haben keine Recordnummer
if (rIndex.isUnique())
aInnerNode.GetKey().ResetRecord();
// neue Seite zeigt nun auf Seite des herausgel<65>sten Knoten
if (!IsLeaf())
aNewPage->SetChild(aInnerNode.GetChild());
}
aNewPage->Append(aSplitNode);
2001-05-08 12:26:37 +00:00
ONDXPagePtr aTempParent = aParent;
2000-09-18 15:18:56 +00:00
if (IsLeaf())
{
rIndex.m_aCurLeaf = aNewPage;
rIndex.m_nCurNode = rIndex.m_aCurLeaf->Count() - 1;
// Freigeben nicht benoetigter Seiten, danach besteht keine Referenz
// mehr auf die Seite, danach kann 'this' nicht mehr gueltig sein!!!
ReleaseFull();
}
// Einfuegen des herausgeloesten Knotens
return aTempParent->Insert(aInnerNode);
}
else // Seite einfach weiter auffuellen
{
if (bAppend)
{
if (IsLeaf())
rIndex.m_nCurNode = nCount - 1;
return Append(rNode);
}
else
{
USHORT nNodePos = FindPos(rNode.GetKey());
if (IsLeaf())
rIndex.m_nCurNode = nNodePos;
return Insert(nNodePos, rNode);
}
}
}
//------------------------------------------------------------------
BOOL ONDXPage::Insert(USHORT nPos, ONDXNode& rNode)
{
USHORT nMaxCount = rIndex.getHeader().db_maxkeys;
if (nPos >= nMaxCount)
return FALSE;
if (nCount)
{
++nCount;
// nach rechts verschieben
for (USHORT i = min(nMaxCount-1, nCount-1); nPos < i; i--)
(*this)[i] = (*this)[i-1];
}
else
if (nCount < nMaxCount)
nCount++;
// einfuegen an der Position
ONDXNode& rInsertNode = (*this)[nPos];
rInsertNode = rNode;
if (rInsertNode.GetChild().Is())
{
rInsertNode.GetChild()->SetParent(this);
rNode.GetChild()->SetParent(this);
}
bModified = TRUE;
return TRUE;
}
//------------------------------------------------------------------
BOOL ONDXPage::Append(ONDXNode& rNode)
{
DBG_ASSERT(!IsFull(), "kein Append moeglich");
return Insert(nCount, rNode);
}
//------------------------------------------------------------------
void ONDXPage::Release(BOOL bSave)
{
// freigeben der Pages
2001-05-08 12:26:37 +00:00
if (aChild.Is())
aChild->Release(bSave);
2000-09-18 15:18:56 +00:00
// Pointer freigeben
2001-05-08 12:26:37 +00:00
aChild.Clear();
2000-09-18 15:18:56 +00:00
for (USHORT i = 0; i < rIndex.getHeader().db_maxkeys;i++)
{
2001-05-08 12:26:37 +00:00
if (ppNodes[i].GetChild())
2000-09-18 15:18:56 +00:00
ppNodes[i].GetChild()->Release(bSave);
ppNodes[i].GetChild().Clear();
}
2001-05-08 12:26:37 +00:00
aParent = NULL;
2000-09-18 15:18:56 +00:00
}
//------------------------------------------------------------------
void ONDXPage::ReleaseFull(BOOL bSave)
{
2001-05-08 12:26:37 +00:00
ONDXPagePtr aTempParent = aParent;
2000-09-18 15:18:56 +00:00
Release(bSave);
if (aTempParent.Is())
{
// Freigeben nicht benoetigter Seiten, danach besteht keine Referenz
// mehr auf die Seite, danach kann 'this' nicht mehr gueltig sein!!!
USHORT nParentPos = aTempParent->Search(this);
if (nParentPos != NODE_NOTFOUND)
(*aTempParent)[nParentPos].GetChild().Clear();
else
aTempParent->GetChild().Clear();
}
}
//------------------------------------------------------------------
BOOL ONDXPage::Delete(USHORT nNodePos)
{
if (IsLeaf())
{
// Letztes Element wird geloescht
if (nNodePos == (nCount - 1))
{
ONDXNode aNode = (*this)[nNodePos];
// beim Parent muss nun der KeyValue ausgetauscht werden
if (HasParent())
2001-05-08 12:26:37 +00:00
aParent->SearchAndReplace(aNode.GetKey(),
2000-09-18 15:18:56 +00:00
(*this)[nNodePos-1].GetKey());
}
}
// Loeschen des Knoten
Remove(nNodePos);
// Unterlauf
if (HasParent() && nCount < (rIndex.GetMaxNodes() / 2))
{
// Feststellen, welcher Knoten auf die Seite zeigt
2001-05-08 12:26:37 +00:00
USHORT nParentNodePos = aParent->Search(this);
2000-09-18 15:18:56 +00:00
// letzte Element auf Vaterseite
// -> zusammenlegen mit vorletzter Seite
2001-05-08 12:26:37 +00:00
if (nParentNodePos == (aParent->Count() - 1))
2000-09-18 15:18:56 +00:00
{
if (!nParentNodePos)
// zusammenlegen mit linken nachbarn
2001-05-08 12:26:37 +00:00
Merge(nParentNodePos,aParent->GetChild(&rIndex));
2000-09-18 15:18:56 +00:00
else
2001-05-08 12:26:37 +00:00
Merge(nParentNodePos,(*aParent)[nParentNodePos-1].GetChild(&rIndex,aParent));
2000-09-18 15:18:56 +00:00
}
// sonst Seite mit naechster Seite zusammenlegen
else
{
// zusammenlegen mit rechten nachbarn
2001-05-08 12:26:37 +00:00
Merge(nParentNodePos + 1,((*aParent)[nParentNodePos + 1].GetChild(&rIndex,aParent)));
2000-09-18 15:18:56 +00:00
nParentNodePos++;
}
2001-05-08 12:26:37 +00:00
if (HasParent() && !(*aParent)[nParentNodePos].HasChild())
aParent->Delete(nParentNodePos);
2000-09-18 15:18:56 +00:00
/*
// letzte Element auf Vaterseite
// -> zusammenlegen mit vorletzter Seite
2001-05-08 12:26:37 +00:00
if (nParentNodePos == (aParent->Count() - 1))
2000-09-18 15:18:56 +00:00
{
if (!nParentNodePos)
// zusammenlegen mit linken nachbarn
2001-05-08 12:26:37 +00:00
Merge(nParentNodePos,aParent->GetChild(&rIndex));
2000-09-18 15:18:56 +00:00
else
2001-05-08 12:26:37 +00:00
Merge(nParentNodePos,(*aParent)[nParentNodePos-1].GetChild(&rIndex,aParent));
2000-09-18 15:18:56 +00:00
}
// sonst Seite mit naechster Seite zusammenlegen
else if(nParentNodePos != NODE_NOTFOUND)
{
// zusammenlegen mit rechten nachbarn
2001-05-08 12:26:37 +00:00
Merge(nParentNodePos + 1,((*aParent)[nParentNodePos + 1].GetChild(&rIndex,aParent)));
2000-09-18 15:18:56 +00:00
nParentNodePos++;
}
else // Sonderbehandlung
{
2001-05-08 12:26:37 +00:00
// Page ist aChild Page vom Parent => erste Page aus ppNodes an aChild anh<6E>ngen
Merge(0,(*aParent)[0].GetChild(&rIndex,aParent));
2000-09-18 15:18:56 +00:00
nParentNodePos = 0;
}
2001-05-08 12:26:37 +00:00
if (HasParent() && !(*aParent)[nParentNodePos].HasChild())
aParent->Delete(nParentNodePos);
2000-09-18 15:18:56 +00:00
*/
}
else if (IsRoot())
// Sicherstellen das die Position der Wurzel festgehalten wird
rIndex.SetRootPos(nPagePos);
return TRUE;
}
//------------------------------------------------------------------
ONDXNode ONDXPage::Split(ONDXPage& rPage)
{
DBG_ASSERT(IsFull(), "Falsches Splitting");
/* Aufteilen einer Seite auf zwei
Blatt:
Seite 1 behaelt (n - (n/2))
Seite 2 erhaelt (n/2)
Knoten n/2 wird dupliziert
Innerer Knoten:
Seite 1 behaelt (n+1)/2
Seite 2 erhaelt (n/2-1)
Knoten ((n+1)/2 + 1) : wird herausgenommen
*/
ONDXNode aResultNode;
if (IsLeaf())
{
for (USHORT i = (nCount - (nCount / 2)), j = 0 ; i < nCount; i++)
rPage.Insert(j++,(*this)[i]);
// dieser Knoten enthaelt einen Schluessel der noch einmal im Tree vorkommt
// und ersetzt werden muss
ONDXNode aLastNode = (*this)[nCount - 1];
nCount = nCount - (nCount / 2);
aResultNode = (*this)[nCount - 1];
if (HasParent())
2001-05-08 12:26:37 +00:00
aParent->SearchAndReplace(aLastNode.GetKey(),
2000-09-18 15:18:56 +00:00
aResultNode.GetKey());
}
else
{
for (USHORT i = (nCount + 1) / 2 + 1, j = 0 ; i < nCount; i++)
rPage.Insert(j++,(*this)[i]);
aResultNode = (*this)[(nCount + 1) / 2];
nCount = (nCount + 1) / 2;
// neue Seite zeigt nun auf Seite des herausgel<65>sten Knoten
rPage.SetChild(aResultNode.GetChild());
}
// Knoten zeigt auf neue Seite
aResultNode.SetChild(&rPage);
// innere Knoten haben keine Recordnummer
if (rIndex.isUnique())
aResultNode.GetKey().ResetRecord();
bModified = TRUE;
return aResultNode;
}
//------------------------------------------------------------------
void ONDXPage::Merge(USHORT nParentNodePos, ONDXPagePtr xPage)
{
DBG_ASSERT(HasParent(), "kein Vater vorhanden");
DBG_ASSERT(nParentNodePos != NODE_NOTFOUND, "Falscher Indexaufbau");
/* Zusammenlegen zweier Seiten */
ONDXNode aResultNode;
USHORT nMaxNodes = rIndex.GetMaxNodes(),
nMaxNodes_2 = nMaxNodes / 2;
// Feststellen ob Seite rechter oder linker Nachbar
BOOL bRight = ((*xPage)[0].GetKey() > (*this)[0].GetKey()); // TRUE, wenn xPage die rechte Seite ist
USHORT nNewCount = (*xPage).Count() + Count();
if (IsLeaf())
{
// Bedingung fuers zusammenlegen
if (nNewCount < (nMaxNodes_2 * 2))
{
USHORT nLastNode = bRight ? Count() - 1 : xPage->Count() - 1;
if (bRight)
{
2001-05-08 12:26:37 +00:00
DBG_ASSERT(&xPage != this,"xPage und THIS d<>rfen nicht gleich sein: Endlosschleife");
2000-09-18 15:18:56 +00:00
// alle Knoten aus xPage auf den linken Knoten verschieben (anh<6E>ngen)
while (xPage->Count())
{
Append((*xPage)[0]);
xPage->Remove(0);
}
}
else
{
2001-05-08 12:26:37 +00:00
DBG_ASSERT(&xPage != this,"xPage und THIS d<>rfen nicht gleich sein: Endlosschleife");
2000-09-18 15:18:56 +00:00
// xPage ist die linke Page und THIS die rechte
while (xPage->Count())
{
Insert(0,(*xPage)[xPage->Count()-1]);
xPage->Remove(xPage->Count()-1);
}
// alte Position von xPage beim Parent mit this ersetzen
if (nParentNodePos)
2001-05-08 12:26:37 +00:00
(*aParent)[nParentNodePos-1].SetChild(this,aParent);
2000-09-18 15:18:56 +00:00
else // oder als rechten Knoten setzen
2001-05-08 12:26:37 +00:00
aParent->SetChild(this);
aParent->SetModified(TRUE);
2000-09-18 15:18:56 +00:00
}
// Child beziehung beim Vaterknoten aufheben
2001-05-08 12:26:37 +00:00
(*aParent)[nParentNodePos].SetChild();
2000-09-18 15:18:56 +00:00
// Austauschen des KnotenWertes, nur wenn geaenderte Page
// die linke ist, ansonsten werde
2001-05-08 12:26:37 +00:00
if(aParent->IsRoot() && aParent->Count() == 1)
2000-09-18 15:18:56 +00:00
{
2001-05-08 12:26:37 +00:00
(*aParent)[0].SetChild();
aParent->ReleaseFull();
aParent = NULL;
2000-09-18 15:18:56 +00:00
rIndex.SetRootPos(nPagePos);
rIndex.m_aRoot = this;
SetModified(TRUE);
}
else
2001-05-08 12:26:37 +00:00
aParent->SearchAndReplace((*this)[nLastNode].GetKey(),(*this)[nCount-1].GetKey());
2000-09-18 15:18:56 +00:00
xPage->SetModified(FALSE);
xPage->ReleaseFull(); // wird nicht mehr benoetigt
}
// Ausgleichen der Elemente nNewCount >= (nMaxNodes_2 * 2)
else
{
if (bRight)
{
// alle Knoten aus xPage auf den linken Knoten verschieben (anh<6E>ngen)
ONDXNode aReplaceNode = (*this)[nCount - 1];
while (nCount < nMaxNodes_2)
{
Append((*xPage)[0]);
xPage->Remove(0);
}
// Austauschen des KnotenWertes: Setzt alten letzten Wert durch den letzten von xPage
2001-05-08 12:26:37 +00:00
aParent->SearchAndReplace(aReplaceNode.GetKey(),(*this)[nCount-1].GetKey());
2000-09-18 15:18:56 +00:00
}
else
{
// alle Knoten aus this vor die xPage Knoten einf<6E>gen
ONDXNode aReplaceNode = (*this)[nCount - 1];
while (xPage->Count() < nMaxNodes_2)
{
xPage->Insert(0,(*this)[nCount-1]);
Remove(nCount-1);
}
// Austauschen des KnotenWertes
2001-05-08 12:26:37 +00:00
aParent->SearchAndReplace(aReplaceNode.GetKey(),(*this)[Count()-1].GetKey());
2000-09-18 15:18:56 +00:00
}
}
}
else // !IsLeaf()
{
// Bedingung fuers zusammenlegen
if (nNewCount < nMaxNodes_2 * 2)
{
if (bRight)
{
2001-05-08 12:26:37 +00:00
DBG_ASSERT(&xPage != this,"xPage und THIS d<>rfen nicht gleich sein: Endlosschleife");
2000-09-18 15:18:56 +00:00
// Vaterknoten wird mit integriert
// erhaelt zunaechst Child von xPage
2001-05-08 12:26:37 +00:00
(*aParent)[nParentNodePos].SetChild(xPage->GetChild(),aParent);
Append((*aParent)[nParentNodePos]);
2000-09-18 15:18:56 +00:00
for (USHORT i = 0 ; i < xPage->Count(); i++)
Append((*xPage)[i]);
}
else
{
2001-05-08 12:26:37 +00:00
DBG_ASSERT(&xPage != this,"xPage und THIS d<>rfen nicht gleich sein: Endlosschleife");
2000-09-18 15:18:56 +00:00
// Vaterknoten wird mit integriert
// erhaelt zunaechst Child
2001-05-08 12:26:37 +00:00
(*aParent)[nParentNodePos].SetChild(GetChild(),aParent); // Parent merkt sich mein Child
Insert(0,(*aParent)[nParentNodePos]); // Node vom Parent bei mir einf<6E>gen
2000-09-18 15:18:56 +00:00
while (xPage->Count())
{
Insert(0,(*xPage)[xPage->Count()-1]);
xPage->Remove(xPage->Count()-1);
}
SetChild(xPage->GetChild());
if (nParentNodePos)
2001-05-08 12:26:37 +00:00
(*aParent)[nParentNodePos-1].SetChild(this,aParent);
2000-09-18 15:18:56 +00:00
else
2001-05-08 12:26:37 +00:00
aParent->SetChild(this);
2000-09-18 15:18:56 +00:00
}
// danach wird der Vaterknoten zurueckgesetzt
2001-05-08 12:26:37 +00:00
(*aParent)[nParentNodePos].SetChild();
aParent->SetModified(TRUE);
2000-09-18 15:18:56 +00:00
2001-05-08 12:26:37 +00:00
if(aParent->IsRoot() && aParent->Count() == 1)
2000-09-18 15:18:56 +00:00
{
2001-05-08 12:26:37 +00:00
(*aParent).SetChild();
aParent->ReleaseFull();
aParent = NULL;
2000-09-18 15:18:56 +00:00
rIndex.SetRootPos(nPagePos);
rIndex.m_aRoot = this;
SetModified(TRUE);
}
else if(nParentNodePos)
// Austauschen des KnotenWertes
// beim Append wird der Bereich erweitert, beim INsert verweist der alte Knoten von xPage auf this
// deshalb mu<6D> der Knoten auch hier aktualisiert werden
2001-05-08 12:26:37 +00:00
aParent->SearchAndReplace((*aParent)[nParentNodePos-1].GetKey(),(*aParent)[nParentNodePos].GetKey());
2000-09-18 15:18:56 +00:00
xPage->SetModified(FALSE);
xPage->ReleaseFull();
}
// Ausgleichen der Elemente
else
{
if (bRight)
{
while (nCount < nMaxNodes_2)
{
2001-05-08 12:26:37 +00:00
(*aParent)[nParentNodePos].SetChild(xPage->GetChild(),aParent);
Append((*aParent)[nParentNodePos]);
(*aParent)[nParentNodePos] = (*xPage)[0];
2000-09-18 15:18:56 +00:00
xPage->Remove(0);
}
2001-05-08 12:26:37 +00:00
xPage->SetChild((*aParent)[nParentNodePos].GetChild());
(*aParent)[nParentNodePos].SetChild(xPage,aParent);
2000-09-18 15:18:56 +00:00
}
else
{
while (nCount < nMaxNodes_2)
{
2001-05-08 12:26:37 +00:00
(*aParent)[nParentNodePos].SetChild(GetChild(),aParent);
Insert(0,(*aParent)[nParentNodePos]);
(*aParent)[nParentNodePos] = (*xPage)[xPage->Count()-1];
2000-09-18 15:18:56 +00:00
xPage->Remove(xPage->Count()-1);
}
2001-05-08 12:26:37 +00:00
SetChild((*aParent)[nParentNodePos].GetChild());
(*aParent)[nParentNodePos].SetChild(this,aParent);
2000-09-18 15:18:56 +00:00
}
2001-05-08 12:26:37 +00:00
aParent->SetModified(TRUE);
2000-09-18 15:18:56 +00:00
}
}
}
// -------------------------------------------------------------------------
2001-04-30 09:16:19 +00:00
// -----------------------------------------------------------------------------
2001-05-08 12:26:37 +00:00
//namespace connectivity
//{
// namespace dbase
// {
// SV_IMPL_REF(ONDXPage);
// }
//}
2001-04-30 09:16:19 +00:00
2000-09-18 15:18:56 +00:00