connectivity/source/drivers/evoab/LNoException.cxx

   1 /*************************************************************************
   2  *
   3  * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER.
   4  *
   5  * Copyright 2008 by Sun Microsystems, Inc.
   6  *
   7  * OpenOffice.org - a multi-platform office productivity suite
   8  *
   9  * $RCSfile: LNoException.cxx,v $
  10  * $Revision: 1.6 $
  11  *
  12  * This file is part of OpenOffice.org.
  13  *
  14  * OpenOffice.org is free software: you can redistribute it and/or modify
  15  * it under the terms of the GNU Lesser General Public License version 3
  16  * only, as published by the Free Software Foundation.
  17  *
  18  * OpenOffice.org is distributed in the hope that it will be useful,
  19  * but WITHOUT ANY WARRANTY; without even the implied warranty of
  20  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  21  * GNU Lesser General Public License version 3 for more details
  22  * (a copy is included in the LICENSE file that accompanied this code).
  23  *
  24  * You should have received a copy of the GNU Lesser General Public License
  25  * version 3 along with OpenOffice.org.  If not, see
  26  * <http://www.openoffice.org/license.html>
  27  * for a copy of the LGPLv3 License.
  28  *
  29  ************************************************************************/
  30
  31 // MARKER(update_precomp.py): autogen include statement, do not remove
  32 #include "precompiled_connectivity.hxx"
  33 #include "LTable.hxx"
  34 #include "LConnection.hxx"
  35
  36 using namespace connectivity;
  37 using namespace connectivity::evoab;
  38
  39 //------------------------------------------------------------------
  40 xub_StrLen OEvoabString::GetTokenCount( sal_Unicode cTok, sal_Unicode cStrDel ) const
  41 {
  42     if ( !Len() )
  43         return 0;
  44
  45     xub_StrLen nTokCount = 1;
  46     BOOL bStart = TRUE;         // Stehen wir auf dem ersten Zeichen im Token?
  47     BOOL bInString = FALSE;     // Befinden wir uns INNERHALB eines (cStrDel delimited) String?
  48
  49     // Suche bis Stringende nach dem ersten nicht uebereinstimmenden Zeichen
  50     for( xub_StrLen i = 0; i < Len(); i++ )
  51     {
  52         if (bStart)
  53         {
  54             bStart = FALSE;
  55             // Erstes Zeichen ein String-Delimiter?
  56             if ((*this).GetChar(i) == cStrDel)
  57             {
  58                 bInString = TRUE;       // dann sind wir jetzt INNERHALB des Strings!
  59                 continue;                       // dieses Zeichen ueberlesen!
  60             }
  61         }
  62
  63         if (bInString) {
  64             // Wenn jetzt das String-Delimiter-Zeichen auftritt ...
  65             if ( (*this).GetChar(i) == cStrDel )
  66             {
  67                 if ((i+1 < Len()) && ((*this).GetChar(i+1) == cStrDel))
  68                 {
  69                     // Verdoppeltes String-Delimiter-Zeichen:
  70                     i++;        // kein String-Ende, naechstes Zeichen ueberlesen.
  71                 }
  72                 else
  73                 {
  74                     // String-Ende
  75                     bInString = FALSE;
  76                 }
  77             }
  78         } else {
  79             // Stimmt das Tokenzeichen ueberein, dann erhoehe TokCount
  80             if ( (*this).GetChar(i) == cTok )
  81             {
  82                 nTokCount++;
  83                 bStart = TRUE;
  84             }
  85         }
  86     }
  87     //OSL_TRACE("OEvoabString::nTokCount = %d\n", ((OUtoCStr(::rtl::OUString(nTokCount))) ? (OUtoCStr(::rtl::OUString(nTokCount))):("NULL")) );
  88
  89     return nTokCount;
  90 }
  91
  92 //------------------------------------------------------------------
  93 void OEvoabString::GetTokenSpecial( String& _rStr,xub_StrLen& nStartPos, sal_Unicode cTok, sal_Unicode cStrDel ) const
  94 {
  95     _rStr.Erase();
  96     xub_StrLen nLen = Len();
  97     if ( nLen )
  98     {
  99         BOOL bInString = (nStartPos < nLen) && ((*this).GetChar(nStartPos) == cStrDel); // Befinden wir uns INNERHALB eines (cStrDel delimited) String?
 100
 101         // Erstes Zeichen ein String-Delimiter?
 102         if (bInString )
 103             ++nStartPos;                        // dieses Zeichen ueberlesen!
 104         // Suche bis Stringende nach dem ersten nicht uebereinstimmenden Zeichen
 105         for( xub_StrLen i = nStartPos; i < nLen; ++i )
 106         {
 107             if (bInString)
 108             {
 109                 // Wenn jetzt das String-Delimiter-Zeichen auftritt ...
 110                 if ( (*this).GetChar(i) == cStrDel )
 111                 {
 112                     if ((i+1 < nLen) && ((*this).GetChar(i+1) == cStrDel))
 113                     {
 114                         // Verdoppeltes String-Delimiter-Zeichen:
 115                         ++i;    // kein String-Ende, naechstes Zeichen ueberlesen.
 116
 117                         _rStr += (*this).GetChar(i);    // Zeichen gehoert zum Resultat-String
 118                     }
 119                     else
 120                     {
 121                         // String-Ende
 122                         bInString = FALSE;
 123                     }
 124                 }
 125                 else
 126                 {
 127                     _rStr += (*this).GetChar(i);        // Zeichen gehoert zum Resultat-String
 128                 }
 129
 130             }
 131             else
 132             {
 133                 // Stimmt das Tokenzeichen ueberein, dann erhoehe nTok
 134                 if ( (*this).GetChar(i) == cTok )
 135                 {
 136                     // Vorzeitiger Abbruch der Schleife moeglich, denn
 137                     // wir haben, was wir wollten.
 138                     nStartPos = i+1;
 139                     break;
 140                 }
 141                 else
 142                 {
 143                     _rStr += (*this).GetChar(i);        // Zeichen gehoert zum Resultat-String
 144                 }
 145             }
 146         }
 147     }
 148 }
 149 // -----------------------------------------------------------------------------
 150 void OEvoabTable::refreshIndexes()
 151 {
 152 }
 153 // -----------------------------------------------------------------------------
 154 sal_Bool OEvoabTable::checkHeaderLine()
 155 {
 156     if (m_nFilePos == 0 && ((OEvoabConnection*)m_pConnection)->isHeaderLine())
 157     {
 158         BOOL bRead2;
 159         do
 160         {
 161             bRead2 = m_pFileStream->ReadByteStringLine(m_aCurrentLine,m_pConnection->getTextEncoding());
 162         }
 163         while(bRead2 && !m_aCurrentLine.Len());
 164
 165         m_nFilePos = m_pFileStream->Tell();
 166         if (m_pFileStream->IsEof())
 167             return sal_False;
 168     }
 169     return sal_True;
 170 }
 171 //------------------------------------------------------------------
 172 sal_Bool OEvoabTable::seekRow(IResultSetHelper::Movement eCursorPosition, sal_Int32 nOffset, sal_Int32& nCurPos)
 173 {
 174     //OSL_TRACE("OEvoabTable::(before SeekRow)m_aCurrentLine = %d\n", ((OUtoCStr(::rtl::OUString(m_aCurrentLine))) ? (OUtoCStr(::rtl::OUString(m_aCurrentLine))):("NULL")) );
 175
 176     if ( !m_pFileStream )
 177         return sal_False;
 178     OEvoabConnection* pConnection = (OEvoabConnection*)m_pConnection;
 179     // ----------------------------------------------------------
 180     // Positionierung vorbereiten:
 181     //OSL_TRACE("OEvoabTable::(before SeekRow,m_pFileStriam Exist)m_aCurrentLine = %d\n", ((OUtoCStr(::rtl::OUString(m_aCurrentLine))) ? (OUtoCStr(::rtl::OUString(m_aCurrentLine))):("NULL")) );
 182
 183     m_nFilePos = nCurPos;
 184
 185     switch(eCursorPosition)
 186     {
 187         case IResultSetHelper::FIRST:
 188             m_nFilePos = 0;
 189             m_nRowPos = 1;
 190             // run through
 191         case IResultSetHelper::NEXT:
 192             if(eCursorPosition != IResultSetHelper::FIRST)
 193                 ++m_nRowPos;
 194             m_pFileStream->Seek(m_nFilePos);
 195             if (m_pFileStream->IsEof() || !checkHeaderLine())
 196             {
 197                 m_nMaxRowCount = m_nRowPos;
 198                 return sal_False;
 199             }
 200
 201             m_aRowToFilePos.insert(::std::map<sal_Int32,sal_Int32>::value_type(m_nRowPos,m_nFilePos));
 202
 203             m_pFileStream->ReadByteStringLine(m_aCurrentLine,pConnection->getTextEncoding());
 204             if (m_pFileStream->IsEof())
 205             {
 206                 m_nMaxRowCount = m_nRowPos;
 207                 return sal_False;
 208             }
 209             nCurPos = m_pFileStream->Tell();
 210             break;
 211         case IResultSetHelper::PRIOR:
 212             --m_nRowPos;
 213             if(m_nRowPos > 0)
 214             {
 215                 m_nFilePos = m_aRowToFilePos.find(m_nRowPos)->second;
 216                 m_pFileStream->Seek(m_nFilePos);
 217                 if (m_pFileStream->IsEof() || !checkHeaderLine())
 218                     return sal_False;
 219                 m_pFileStream->ReadByteStringLine(m_aCurrentLine,pConnection->getTextEncoding());
 220                 if (m_pFileStream->IsEof())
 221                     return sal_False;
 222                 nCurPos = m_pFileStream->Tell();
 223             }
 224             else
 225                 m_nRowPos = 0;
 226
 227             break;
 228
 229             break;
 230         case IResultSetHelper::LAST:
 231             if(m_nMaxRowCount)
 232             {
 233                 m_nFilePos = m_aRowToFilePos.rbegin()->second;
 234                 m_nRowPos  = m_aRowToFilePos.rbegin()->first;
 235                 m_pFileStream->Seek(m_nFilePos);
 236                 if (m_pFileStream->IsEof() || !checkHeaderLine())
 237                     return sal_False;
 238                 m_pFileStream->ReadByteStringLine(m_aCurrentLine,pConnection->getTextEncoding());
 239                 if (m_pFileStream->IsEof())
 240                     return sal_False;
 241                 nCurPos = m_pFileStream->Tell();
 242             }
 243             else
 244             {
 245                 while(seekRow(IResultSetHelper::NEXT,1,nCurPos)) ; // run through after last row
 246                 // now I know all
 247                 seekRow(IResultSetHelper::PRIOR,1,nCurPos);
 248             }
 249             break;
 250         case IResultSetHelper::RELATIVE:
 251             if(nOffset > 0)
 252             {
 253                 for(sal_Int32 i = 0;i<nOffset;++i)
 254                     seekRow(IResultSetHelper::NEXT,1,nCurPos);
 255             }
 256             else if(nOffset < 0)
 257             {
 258                 for(sal_Int32 i = nOffset;i;++i)
 259                     seekRow(IResultSetHelper::PRIOR,1,nCurPos);
 260             }
 261             break;
 262         case IResultSetHelper::ABSOLUTE:
 263             {
 264                 if(nOffset < 0)
 265                     nOffset = m_nRowPos + nOffset;
 266                 ::std::map<sal_Int32,sal_Int32>::const_iterator aIter = m_aRowToFilePos.find(nOffset);
 267                 if(aIter != m_aRowToFilePos.end())
 268                 {
 269                     m_nFilePos = aIter->second;
 270                     m_pFileStream->Seek(m_nFilePos);
 271                     if (m_pFileStream->IsEof() || !checkHeaderLine())
 272                         return sal_False;
 273                     m_pFileStream->ReadByteStringLine(m_aCurrentLine,pConnection->getTextEncoding());
 274                     if (m_pFileStream->IsEof())
 275                         return sal_False;
 276                     nCurPos = m_pFileStream->Tell();
 277                 }
 278                 else if(m_nMaxRowCount && nOffset > m_nMaxRowCount) // offset is outside the table
 279                 {
 280                     m_nRowPos = m_nMaxRowCount;
 281                     return sal_False;
 282                 }
 283                 else
 284                 {
 285                     aIter = m_aRowToFilePos.upper_bound(nOffset);
 286                     if(aIter == m_aRowToFilePos.end())
 287                     {
 288                         m_nRowPos       = m_aRowToFilePos.rbegin()->first;
 289                         nCurPos = m_nFilePos = m_aRowToFilePos.rbegin()->second;
 290                         while(m_nRowPos != nOffset)
 291                             seekRow(IResultSetHelper::NEXT,1,nCurPos);
 292                     }
 293                     else
 294                     {
 295                         --aIter;
 296                         m_nRowPos       = aIter->first;
 297                         m_nFilePos      = aIter->second;
 298                         m_pFileStream->Seek(m_nFilePos);
 299                         if (m_pFileStream->IsEof() || !checkHeaderLine())
 300                             return sal_False;
 301                         m_pFileStream->ReadByteStringLine(m_aCurrentLine,pConnection->getTextEncoding());
 302                         if (m_pFileStream->IsEof())
 303                             return sal_False;
 304                         nCurPos = m_pFileStream->Tell();
 305                     }
 306                 }
 307             }
 308
 309             break;
 310         case IResultSetHelper::BOOKMARK:
 311             m_pFileStream->Seek(nOffset);
 312             if (m_pFileStream->IsEof())
 313                 return sal_False;
 314
 315             m_nFilePos = m_pFileStream->Tell(); // Byte-Position in der Datei merken (am ZeilenANFANG)
 316             m_pFileStream->ReadByteStringLine(m_aCurrentLine,pConnection->getTextEncoding());
 317             if (m_pFileStream->IsEof())
 318                 return sal_False;
 319             nCurPos  = m_pFileStream->Tell();
 320             break;
 321     }
 322
 323     //OSL_TRACE("OEvoabTable::(after SeekRow)m_aCurrentLine = %d\n", ((OUtoCStr(::rtl::OUString(m_aCurrentLine))) ? (OUtoCStr(::rtl::OUString(m_aCurrentLine))):("NULL")) );
 324
 325     return sal_True;
 326 }
 327 // -----------------------------------------------------------------------------