Line data Source code
1 : /* -*- Mode: C++; tab-width: 4; indent-tabs-mode: nil; c-basic-offset: 4 -*- */
2 : /*
3 : * This file is part of the LibreOffice project.
4 : *
5 : * This Source Code Form is subject to the terms of the Mozilla Public
6 : * License, v. 2.0. If a copy of the MPL was not distributed with this
7 : * file, You can obtain one at http://mozilla.org/MPL/2.0/.
8 : *
9 : * This file incorporates work covered by the following license notice:
10 : *
11 : * Licensed to the Apache Software Foundation (ASF) under one or more
12 : * contributor license agreements. See the NOTICE file distributed
13 : * with this work for additional information regarding copyright
14 : * ownership. The ASF licenses this file to you under the Apache
15 : * License, Version 2.0 (the "License"); you may not use this file
16 : * except in compliance with the License. You may obtain a copy of
17 : * the License at http://www.apache.org/licenses/LICENSE-2.0 .
18 : */
19 :
20 : #include "dbase/DTable.hxx"
21 : #include <com/sun/star/sdbc/ColumnValue.hpp>
22 : #include <com/sun/star/sdbc/DataType.hpp>
23 : #include <com/sun/star/ucb/XContentAccess.hpp>
24 : #include <com/sun/star/sdbc/XRow.hpp>
25 : #include <svl/converter.hxx>
26 : #include "dbase/DConnection.hxx"
27 : #include "dbase/DColumns.hxx"
28 : #include <osl/thread.h>
29 : #include <tools/config.hxx>
30 : #include "dbase/DIndex.hxx"
31 : #include "dbase/DIndexes.hxx"
32 : #include <comphelper/processfactory.hxx>
33 : #include <comphelper/sequence.hxx>
34 : #include <svl/zforlist.hxx>
35 : #include <unotools/syslocale.hxx>
36 : #include <rtl/math.hxx>
37 : #include <stdio.h>
38 : #include <ucbhelper/content.hxx>
39 : #include <connectivity/dbexception.hxx>
40 : #include <connectivity/dbconversion.hxx>
41 : #include <com/sun/star/lang/DisposedException.hpp>
42 : #include <comphelper/property.hxx>
43 : #include <comphelper/string.hxx>
44 : #include <unotools/tempfile.hxx>
45 : #include <unotools/ucbhelper.hxx>
46 : #include <comphelper/types.hxx>
47 : #include <cppuhelper/exc_hlp.hxx>
48 : #include "connectivity/PColumn.hxx"
49 : #include "connectivity/dbtools.hxx"
50 : #include "connectivity/FValue.hxx"
51 : #include "connectivity/dbconversion.hxx"
52 : #include "resource/dbase_res.hrc"
53 : #include <rtl/strbuf.hxx>
54 :
55 : #include <algorithm>
56 :
57 : using namespace ::comphelper;
58 : using namespace connectivity;
59 : using namespace connectivity::sdbcx;
60 : using namespace connectivity::dbase;
61 : using namespace connectivity::file;
62 : using namespace ::ucbhelper;
63 : using namespace ::utl;
64 : using namespace ::cppu;
65 : using namespace ::dbtools;
66 : using namespace ::com::sun::star::uno;
67 : using namespace ::com::sun::star::ucb;
68 : using namespace ::com::sun::star::beans;
69 : using namespace ::com::sun::star::sdbcx;
70 : using namespace ::com::sun::star::sdbc;
71 : using namespace ::com::sun::star::container;
72 : using namespace ::com::sun::star::lang;
73 : using namespace ::com::sun::star::i18n;
74 :
75 : // stored as the Field Descriptor terminator
76 : #define FIELD_DESCRIPTOR_TERMINATOR 0x0D
77 : #define DBF_EOL 0x1A
78 :
79 : namespace
80 : {
81 16 : sal_Size lcl_getFileSize(SvStream& _rStream)
82 : {
83 16 : sal_Size nFileSize = 0;
84 16 : _rStream.Seek(STREAM_SEEK_TO_END);
85 16 : _rStream.SeekRel(-1);
86 : char cEOL;
87 16 : _rStream.ReadChar( cEOL );
88 16 : nFileSize = _rStream.Tell();
89 16 : if ( cEOL == DBF_EOL )
90 8 : nFileSize -= 1;
91 16 : return nFileSize;
92 : }
93 : /**
94 : calculates the Julian date
95 : */
96 0 : void lcl_CalcJulDate(sal_Int32& _nJulianDate,sal_Int32& _nJulianTime,const com::sun::star::util::DateTime _aDateTime)
97 : {
98 0 : com::sun::star::util::DateTime aDateTime = _aDateTime;
99 : // weird: months fix
100 0 : if (aDateTime.Month > 12)
101 : {
102 0 : aDateTime.Month--;
103 0 : sal_uInt16 delta = _aDateTime.Month / 12;
104 0 : aDateTime.Year += delta;
105 0 : aDateTime.Month -= delta * 12;
106 0 : aDateTime.Month++;
107 : }
108 :
109 0 : _nJulianTime = ((aDateTime.Hours*3600000)+(aDateTime.Minutes*60000)+(aDateTime.Seconds*1000)+(aDateTime.NanoSeconds/1000000));
110 : /* conversion factors */
111 : sal_uInt16 iy0;
112 : sal_uInt16 im0;
113 0 : if ( aDateTime.Month <= 2 )
114 : {
115 0 : iy0 = aDateTime.Year - 1;
116 0 : im0 = aDateTime.Month + 12;
117 : }
118 : else
119 : {
120 0 : iy0 = aDateTime.Year;
121 0 : im0 = aDateTime.Month;
122 : }
123 0 : sal_Int32 ia = iy0 / 100;
124 0 : sal_Int32 ib = 2 - ia + (ia >> 2);
125 : /* calculate julian date */
126 0 : if ( aDateTime.Year <= 0 )
127 : {
128 0 : _nJulianDate = (sal_Int32) ((365.25 * iy0) - 0.75)
129 0 : + (sal_Int32) (30.6001 * (im0 + 1) )
130 0 : + aDateTime.Day + 1720994;
131 : } // if ( _aDateTime.Year <= 0 )
132 : else
133 : {
134 0 : _nJulianDate = static_cast<sal_Int32>( ((365.25 * iy0)
135 0 : + (sal_Int32) (30.6001 * (im0 + 1))
136 0 : + aDateTime.Day + 1720994));
137 : }
138 0 : double JD = _nJulianDate + 0.5;
139 0 : _nJulianDate = (sal_Int32)( JD + 0.5);
140 0 : const double gyr = aDateTime.Year + (0.01 * aDateTime.Month) + (0.0001 * aDateTime.Day);
141 0 : if ( gyr >= 1582.1015 ) /* on or after 15 October 1582 */
142 0 : _nJulianDate += ib;
143 0 : }
144 :
145 : /**
146 : calculates date time from the Julian Date
147 : */
148 0 : void lcl_CalDate(sal_Int32 _nJulianDate,sal_Int32 _nJulianTime,com::sun::star::util::DateTime& _rDateTime)
149 : {
150 0 : if ( _nJulianDate )
151 : {
152 : sal_Int32 ialp;
153 0 : sal_Int32 ka = _nJulianDate;
154 0 : if ( _nJulianDate >= 2299161 )
155 : {
156 0 : ialp = (sal_Int32)( ((double) _nJulianDate - 1867216.25 ) / ( 36524.25 ));
157 0 : ka = _nJulianDate + 1 + ialp - ( ialp >> 2 );
158 : }
159 0 : sal_Int32 kb = ka + 1524;
160 0 : sal_Int32 kc = (sal_Int32) ( ((double) kb - 122.1 ) / 365.25 );
161 0 : sal_Int32 kd = (sal_Int32) ((double) kc * 365.25);
162 0 : sal_Int32 ke = (sal_Int32) ((double) ( kb - kd ) / 30.6001 );
163 0 : _rDateTime.Day = static_cast<sal_uInt16>(kb - kd - ((sal_Int32) ( (double) ke * 30.6001 )));
164 0 : if ( ke > 13 )
165 0 : _rDateTime.Month = static_cast<sal_uInt16>(ke - 13);
166 : else
167 0 : _rDateTime.Month = static_cast<sal_uInt16>(ke - 1);
168 0 : if ( (_rDateTime.Month == 2) && (_rDateTime.Day > 28) )
169 0 : _rDateTime.Day = 29;
170 0 : if ( (_rDateTime.Month == 2) && (_rDateTime.Day == 29) && (ke == 3) )
171 0 : _rDateTime.Year = static_cast<sal_uInt16>(kc - 4716);
172 0 : else if ( _rDateTime.Month > 2 )
173 0 : _rDateTime.Year = static_cast<sal_uInt16>(kc - 4716);
174 : else
175 0 : _rDateTime.Year = static_cast<sal_uInt16>(kc - 4715);
176 : }
177 :
178 0 : if ( _nJulianTime )
179 : {
180 0 : double d_s = _nJulianTime / 1000;
181 0 : double d_m = d_s / 60;
182 0 : double d_h = d_m / 60;
183 0 : _rDateTime.Hours = (sal_uInt16) (d_h);
184 0 : _rDateTime.Minutes = (sal_uInt16) d_m;
185 0 : _rDateTime.Seconds = static_cast<sal_uInt16>(( d_m - (double) _rDateTime.Minutes ) * 60.0);
186 : }
187 0 : }
188 :
189 : }
190 :
191 :
192 15 : void ODbaseTable::readHeader()
193 : {
194 : SAL_INFO( "connectivity.drivers", "dbase Ocke.Janssen@sun.com ODbaseTable::readHeader" );
195 : OSL_ENSURE(m_pFileStream,"No Stream available!");
196 15 : if(!m_pFileStream)
197 15 : return;
198 15 : m_pFileStream->RefreshBuffer(); // Make sure, that the header information actually is read again
199 15 : m_pFileStream->Seek(STREAM_SEEK_TO_BEGIN);
200 :
201 15 : sal_uInt8 nType=0;
202 15 : (*m_pFileStream).ReadUChar( nType );
203 15 : if(ERRCODE_NONE != m_pFileStream->GetErrorCode())
204 0 : throwInvalidDbaseFormat();
205 :
206 15 : m_pFileStream->Read((char*)(&m_aHeader.db_aedat), 3*sizeof(sal_uInt8));
207 15 : if(ERRCODE_NONE != m_pFileStream->GetErrorCode())
208 0 : throwInvalidDbaseFormat();
209 15 : (*m_pFileStream).ReadUInt32( m_aHeader.db_anz );
210 15 : if(ERRCODE_NONE != m_pFileStream->GetErrorCode())
211 0 : throwInvalidDbaseFormat();
212 15 : (*m_pFileStream).ReadUInt16( m_aHeader.db_kopf );
213 15 : if(ERRCODE_NONE != m_pFileStream->GetErrorCode())
214 0 : throwInvalidDbaseFormat();
215 15 : (*m_pFileStream).ReadUInt16( m_aHeader.db_slng );
216 15 : if(ERRCODE_NONE != m_pFileStream->GetErrorCode())
217 0 : throwInvalidDbaseFormat();
218 15 : m_pFileStream->Read((char*)(&m_aHeader.db_frei), 20*sizeof(sal_uInt8));
219 15 : if(ERRCODE_NONE != m_pFileStream->GetErrorCode())
220 0 : throwInvalidDbaseFormat();
221 :
222 15 : if ( ( ( m_aHeader.db_kopf - 1 ) / 32 - 1 ) <= 0 ) // number of fields
223 : {
224 : // no dbase file
225 0 : throwInvalidDbaseFormat();
226 : }
227 : else
228 : {
229 : // Consistency check of the header:
230 15 : m_aHeader.db_typ = (DBFType)nType;
231 15 : switch (m_aHeader.db_typ)
232 : {
233 : case dBaseIII:
234 : case dBaseIV:
235 : case dBaseV:
236 : case VisualFoxPro:
237 : case VisualFoxProAuto:
238 : case dBaseFS:
239 : case dBaseFSMemo:
240 : case dBaseIVMemoSQL:
241 : case dBaseIIIMemo:
242 : case FoxProMemo:
243 15 : m_pFileStream->SetNumberFormatInt(NUMBERFORMAT_INT_LITTLEENDIAN);
244 30 : if ( m_aHeader.db_frei[17] != 0x00
245 15 : && !m_aHeader.db_frei[18] && !m_aHeader.db_frei[19] && getConnection()->isTextEncodingDefaulted() )
246 : {
247 0 : switch(m_aHeader.db_frei[17])
248 : {
249 0 : case 0x01: m_eEncoding = RTL_TEXTENCODING_IBM_437; break; // DOS USA code page 437
250 0 : case 0x02: m_eEncoding = RTL_TEXTENCODING_IBM_850; break; // DOS Multilingual code page 850
251 0 : case 0x03: m_eEncoding = RTL_TEXTENCODING_MS_1252; break; // Windows ANSI code page 1252
252 0 : case 0x04: m_eEncoding = RTL_TEXTENCODING_APPLE_ROMAN; break; // Standard Macintosh
253 0 : case 0x64: m_eEncoding = RTL_TEXTENCODING_IBM_852; break; // EE MS-DOS code page 852
254 0 : case 0x65: m_eEncoding = RTL_TEXTENCODING_IBM_865; break; // Nordic MS-DOS code page 865
255 0 : case 0x66: m_eEncoding = RTL_TEXTENCODING_IBM_866; break; // Russian MS-DOS code page 866
256 0 : case 0x67: m_eEncoding = RTL_TEXTENCODING_IBM_861; break; // Icelandic MS-DOS
257 : //case 0x68: m_eEncoding = ; break; // Kamenicky (Czech) MS-DOS
258 : //case 0x69: m_eEncoding = ; break; // Mazovia (Polish) MS-DOS
259 0 : case 0x6A: m_eEncoding = RTL_TEXTENCODING_IBM_737; break; // Greek MS-DOS (437G)
260 0 : case 0x6B: m_eEncoding = RTL_TEXTENCODING_IBM_857; break; // Turkish MS-DOS
261 0 : case 0x6C: m_eEncoding = RTL_TEXTENCODING_IBM_863; break; // MS-DOS, Canada
262 0 : case 0x78: m_eEncoding = RTL_TEXTENCODING_MS_950; break; // Windows, Traditional Chinese
263 0 : case 0x79: m_eEncoding = RTL_TEXTENCODING_MS_949; break; // Windows, Korean (Hangul)
264 0 : case 0x7A: m_eEncoding = RTL_TEXTENCODING_MS_936; break; // Windows, Simplified Chinese
265 0 : case 0x7B: m_eEncoding = RTL_TEXTENCODING_MS_932; break; // Windows, Japanese (Shift-jis)
266 0 : case 0x7C: m_eEncoding = RTL_TEXTENCODING_MS_874; break; // Windows, Thai
267 0 : case 0x7D: m_eEncoding = RTL_TEXTENCODING_MS_1255; break; // Windows, Hebrew
268 0 : case 0x7E: m_eEncoding = RTL_TEXTENCODING_MS_1256; break; // Windows, Arabic
269 0 : case 0x96: m_eEncoding = RTL_TEXTENCODING_APPLE_CYRILLIC; break; // Russian Macintosh
270 0 : case 0x97: m_eEncoding = RTL_TEXTENCODING_APPLE_CENTEURO; break; // Eastern European Macintosh
271 0 : case 0x98: m_eEncoding = RTL_TEXTENCODING_APPLE_GREEK; break; // Greek Macintosh
272 0 : case 0xC8: m_eEncoding = RTL_TEXTENCODING_MS_1250; break; // Windows EE code page 1250
273 0 : case 0xC9: m_eEncoding = RTL_TEXTENCODING_MS_1251; break; // Russian Windows
274 0 : case 0xCA: m_eEncoding = RTL_TEXTENCODING_MS_1254; break; // Turkish Windows
275 0 : case 0xCB: m_eEncoding = RTL_TEXTENCODING_MS_1253; break; // Greek Windows
276 0 : case 0xCC: m_eEncoding = RTL_TEXTENCODING_MS_1257; break; // Windows, Baltic
277 : default:
278 : // Default Encoding
279 0 : m_eEncoding = RTL_TEXTENCODING_IBM_850;
280 0 : break;
281 : }
282 : }
283 15 : break;
284 : case dBaseIVMemo:
285 0 : m_pFileStream->SetNumberFormatInt(NUMBERFORMAT_INT_LITTLEENDIAN);
286 0 : break;
287 : default:
288 : {
289 0 : throwInvalidDbaseFormat();
290 : }
291 : }
292 : }
293 : }
294 :
295 15 : void ODbaseTable::fillColumns()
296 : {
297 : SAL_INFO( "connectivity.drivers", "dbase Ocke.Janssen@sun.com ODbaseTable::fillColumns" );
298 15 : m_pFileStream->Seek(STREAM_SEEK_TO_BEGIN);
299 15 : m_pFileStream->Seek(32L);
300 :
301 15 : if(!m_aColumns.is())
302 0 : m_aColumns = new OSQLColumns();
303 : else
304 15 : m_aColumns->get().clear();
305 :
306 15 : m_aTypes.clear();
307 15 : m_aPrecisions.clear();
308 15 : m_aScales.clear();
309 :
310 : // Number of fields:
311 15 : const sal_Int32 nFieldCount = (m_aHeader.db_kopf - 1) / 32 - 1;
312 : OSL_ENSURE(nFieldCount,"No columns in table!");
313 :
314 15 : m_aColumns->get().reserve(nFieldCount);
315 15 : m_aTypes.reserve(nFieldCount);
316 15 : m_aPrecisions.reserve(nFieldCount);
317 15 : m_aScales.reserve(nFieldCount);
318 :
319 15 : OUString aTypeName;
320 15 : const sal_Bool bCase = getConnection()->getMetaData()->supportsMixedCaseQuotedIdentifiers();
321 15 : const bool bFoxPro = m_aHeader.db_typ == VisualFoxPro || m_aHeader.db_typ == VisualFoxProAuto || m_aHeader.db_typ == FoxProMemo;
322 :
323 15 : sal_Int32 i = 0;
324 320 : for (; i < nFieldCount; i++)
325 : {
326 : DBFColumn aDBFColumn;
327 305 : m_pFileStream->Read((char*)&aDBFColumn, sizeof(aDBFColumn));
328 305 : if ( FIELD_DESCRIPTOR_TERMINATOR == aDBFColumn.db_fnm[0] ) // 0x0D stored as the Field Descriptor terminator.
329 0 : break;
330 :
331 305 : sal_Bool bIsRowVersion = bFoxPro && ( aDBFColumn.db_frei2[0] & 0x01 ) == 0x01;
332 305 : const OUString aColumnName((const char *)aDBFColumn.db_fnm, strlen((const char *)aDBFColumn.db_fnm), m_eEncoding);
333 :
334 305 : m_aRealFieldLengths.push_back(aDBFColumn.db_flng);
335 305 : sal_Int32 nPrecision = aDBFColumn.db_flng;
336 : sal_Int32 eType;
337 305 : sal_Bool bIsCurrency = sal_False;
338 :
339 : char cType[2];
340 305 : cType[0] = aDBFColumn.db_typ;
341 305 : cType[1] = 0;
342 305 : aTypeName = OUString::createFromAscii(cType);
343 : SAL_INFO( "connectivity.drivers","column type: " << aDBFColumn.db_typ);
344 :
345 305 : switch (aDBFColumn.db_typ)
346 : {
347 : case 'C':
348 106 : eType = DataType::VARCHAR;
349 106 : aTypeName = "VARCHAR";
350 106 : break;
351 : case 'F':
352 : case 'N':
353 40 : aTypeName = "DECIMAL";
354 40 : if ( aDBFColumn.db_typ == 'N' )
355 40 : aTypeName = "NUMERIC";
356 40 : eType = DataType::DECIMAL;
357 :
358 : // for numeric fields two characters more are written, than the precision of the column description predescribes,
359 : // to keep room for the possible sign and the comma. This has to be considered...
360 40 : nPrecision = SvDbaseConverter::ConvertPrecisionToOdbc(nPrecision,aDBFColumn.db_dez);
361 : // This is not true for older versions ....
362 40 : break;
363 : case 'L':
364 8 : eType = DataType::BIT;
365 8 : aTypeName = "BOOLEAN";
366 8 : break;
367 : case 'Y':
368 0 : bIsCurrency = sal_True;
369 0 : eType = DataType::DOUBLE;
370 0 : aTypeName = "DOUBLE";
371 0 : break;
372 : case 'D':
373 16 : eType = DataType::DATE;
374 16 : aTypeName = "DATE";
375 16 : break;
376 : case 'T':
377 0 : eType = DataType::TIMESTAMP;
378 0 : aTypeName = "TIMESTAMP";
379 0 : break;
380 : case 'I':
381 0 : eType = DataType::INTEGER;
382 0 : aTypeName = "INTEGER";
383 0 : break;
384 : case 'M':
385 135 : if ( bFoxPro && ( aDBFColumn.db_frei2[0] & 0x04 ) == 0x04 )
386 : {
387 0 : eType = DataType::LONGVARBINARY;
388 0 : aTypeName = "LONGVARBINARY";
389 : }
390 : else
391 : {
392 135 : aTypeName = "LONGVARCHAR";
393 135 : eType = DataType::LONGVARCHAR;
394 : }
395 135 : nPrecision = 2147483647;
396 135 : break;
397 : case 'P':
398 0 : aTypeName = "LONGVARBINARY";
399 0 : eType = DataType::LONGVARBINARY;
400 0 : nPrecision = 2147483647;
401 0 : break;
402 : case '0':
403 : case 'B':
404 0 : if ( m_aHeader.db_typ == VisualFoxPro || m_aHeader.db_typ == VisualFoxProAuto )
405 : {
406 0 : aTypeName = "DOUBLE";
407 0 : eType = DataType::DOUBLE;
408 : }
409 : else
410 : {
411 0 : aTypeName = "LONGVARBINARY";
412 0 : eType = DataType::LONGVARBINARY;
413 0 : nPrecision = 2147483647;
414 : }
415 0 : break;
416 : default:
417 0 : eType = DataType::OTHER;
418 : }
419 :
420 305 : m_aTypes.push_back(eType);
421 305 : m_aPrecisions.push_back(nPrecision);
422 305 : m_aScales.push_back(aDBFColumn.db_dez);
423 :
424 : Reference< XPropertySet> xCol = new sdbcx::OColumn(aColumnName,
425 : aTypeName,
426 : OUString(),
427 : OUString(),
428 : ColumnValue::NULLABLE,
429 : nPrecision,
430 : aDBFColumn.db_dez,
431 : eType,
432 : false,
433 : bIsRowVersion,
434 : bIsCurrency,
435 : bCase,
436 305 : m_CatalogName, getSchema(), getName());
437 305 : m_aColumns->get().push_back(xCol);
438 305 : } // for (; i < nFieldCount; i++)
439 15 : OSL_ENSURE(i,"No columns in table!");
440 15 : }
441 :
442 0 : ODbaseTable::ODbaseTable(sdbcx::OCollection* _pTables, ODbaseConnection* _pConnection)
443 : : ODbaseTable_BASE(_pTables,_pConnection)
444 : , m_pMemoStream(NULL)
445 0 : , m_bWriteableMemo(sal_False)
446 : {
447 : SAL_INFO( "connectivity.drivers", "dbase Ocke.Janssen@sun.com ODbaseTable::ODbaseTable" );
448 : // initialize the header
449 0 : memset(&m_aHeader, 0, sizeof(m_aHeader));
450 0 : m_aHeader.db_typ = dBaseIII;
451 0 : m_eEncoding = getConnection()->getTextEncoding();
452 0 : }
453 :
454 15 : ODbaseTable::ODbaseTable(sdbcx::OCollection* _pTables, ODbaseConnection* _pConnection,
455 : const OUString& _Name,
456 : const OUString& _Type,
457 : const OUString& _Description ,
458 : const OUString& _SchemaName,
459 : const OUString& _CatalogName )
460 : : ODbaseTable_BASE(_pTables,_pConnection,_Name,
461 : _Type,
462 : _Description,
463 : _SchemaName,
464 : _CatalogName)
465 : , m_pMemoStream(NULL)
466 15 : , m_bWriteableMemo(sal_False)
467 : {
468 : SAL_INFO( "connectivity.drivers", "dbase Ocke.Janssen@sun.com ODbaseTable::ODbaseTable" );
469 15 : memset(&m_aHeader, 0, sizeof(m_aHeader));
470 15 : m_eEncoding = getConnection()->getTextEncoding();
471 15 : }
472 :
473 :
474 15 : void ODbaseTable::construct()
475 : {
476 : SAL_INFO( "connectivity.drivers", "dbase Ocke.Janssen@sun.com ODbaseTable::construct" );
477 : // initialize the header
478 15 : m_aHeader.db_typ = dBaseIII;
479 15 : m_aHeader.db_anz = 0;
480 15 : m_aHeader.db_kopf = 0;
481 15 : m_aHeader.db_slng = 0;
482 15 : m_aMemoHeader.db_size = 0;
483 :
484 15 : OUString sFileName(getEntry(m_pConnection, m_Name));
485 :
486 30 : INetURLObject aURL;
487 15 : aURL.SetURL(sFileName);
488 :
489 : OSL_ENSURE( m_pConnection->matchesExtension( aURL.getExtension() ),
490 : "ODbaseTable::ODbaseTable: invalid extension!");
491 : // getEntry is expected to ensure the correct file name
492 :
493 15 : m_pFileStream = createStream_simpleError( sFileName, STREAM_READWRITE | STREAM_NOCREATE | STREAM_SHARE_DENYWRITE);
494 15 : m_bWriteable = ( m_pFileStream != NULL );
495 :
496 15 : if ( !m_pFileStream )
497 : {
498 0 : m_bWriteable = sal_False;
499 0 : m_pFileStream = createStream_simpleError( sFileName, STREAM_READ | STREAM_NOCREATE | STREAM_SHARE_DENYNONE);
500 : }
501 :
502 15 : if(m_pFileStream)
503 : {
504 15 : readHeader();
505 15 : if (HasMemoFields())
506 : {
507 : // Create Memo-Filename (.DBT):
508 : // nyi: Ugly for Unix and Mac!
509 :
510 15 : if ( m_aHeader.db_typ == FoxProMemo || VisualFoxPro == m_aHeader.db_typ || VisualFoxProAuto == m_aHeader.db_typ ) // foxpro uses another extension
511 0 : aURL.SetExtension("fpt");
512 : else
513 15 : aURL.SetExtension("dbt");
514 :
515 : // If the memo file isn't found, the data will be displayed anyhow.
516 : // However, updates can't be done
517 : // but the operation is executed
518 15 : m_pMemoStream = createStream_simpleError( aURL.GetMainURL(INetURLObject::NO_DECODE), STREAM_READWRITE | STREAM_NOCREATE | STREAM_SHARE_DENYWRITE);
519 15 : if ( !m_pMemoStream )
520 : {
521 8 : m_bWriteableMemo = sal_False;
522 8 : m_pMemoStream = createStream_simpleError( aURL.GetMainURL(INetURLObject::NO_DECODE), STREAM_READ | STREAM_NOCREATE | STREAM_SHARE_DENYNONE);
523 : }
524 15 : if (m_pMemoStream)
525 7 : ReadMemoHeader();
526 : }
527 15 : fillColumns();
528 :
529 15 : sal_Size nFileSize = lcl_getFileSize(*m_pFileStream);
530 15 : m_pFileStream->Seek(STREAM_SEEK_TO_BEGIN);
531 15 : if ( m_aHeader.db_anz == 0 && ((nFileSize-m_aHeader.db_kopf)/m_aHeader.db_slng) > 0) // seems to be empty or someone wrote bullshit into the dbase file
532 0 : m_aHeader.db_anz = ((nFileSize-m_aHeader.db_kopf)/m_aHeader.db_slng);
533 :
534 : // Buffersize dependent on the file size
535 : m_pFileStream->SetBufferSize(nFileSize > 1000000 ? 32768 :
536 : nFileSize > 100000 ? 16384 :
537 15 : nFileSize > 10000 ? 4096 : 1024);
538 :
539 15 : if (m_pMemoStream)
540 : {
541 : // set the buffer extactly to the length of a record
542 7 : m_pMemoStream->Seek(STREAM_SEEK_TO_END);
543 7 : nFileSize = m_pMemoStream->Tell();
544 7 : m_pMemoStream->Seek(STREAM_SEEK_TO_BEGIN);
545 :
546 : // Buffersize dependent on the file size
547 : m_pMemoStream->SetBufferSize(nFileSize > 1000000 ? 32768 :
548 : nFileSize > 100000 ? 16384 :
549 : nFileSize > 10000 ? 4096 :
550 7 : m_aMemoHeader.db_size);
551 : }
552 :
553 15 : AllocBuffer();
554 15 : }
555 15 : }
556 :
557 7 : sal_Bool ODbaseTable::ReadMemoHeader()
558 : {
559 : SAL_INFO( "connectivity.drivers", "dbase Ocke.Janssen@sun.com ODbaseTable::ReadMemoHeader" );
560 7 : m_pMemoStream->SetNumberFormatInt(NUMBERFORMAT_INT_LITTLEENDIAN);
561 7 : m_pMemoStream->RefreshBuffer(); // make sure that the header information is actually read again
562 7 : m_pMemoStream->Seek(0L);
563 :
564 7 : (*m_pMemoStream).ReadUInt32( m_aMemoHeader.db_next );
565 7 : switch (m_aHeader.db_typ)
566 : {
567 : case dBaseIIIMemo: // dBase III: fixed block size
568 : case dBaseIVMemo:
569 : // sometimes dBase3 is attached to dBase4 memo
570 7 : m_pMemoStream->Seek(20L);
571 7 : (*m_pMemoStream).ReadUInt16( m_aMemoHeader.db_size );
572 7 : if (m_aMemoHeader.db_size > 1 && m_aMemoHeader.db_size != 512) // 1 is also for dBase 3
573 0 : m_aMemoHeader.db_typ = MemodBaseIV;
574 7 : else if (m_aMemoHeader.db_size > 1 && m_aMemoHeader.db_size == 512)
575 : {
576 : // There are files using size specification, though they are dBase-files
577 : char sHeader[4];
578 0 : m_pMemoStream->Seek(m_aMemoHeader.db_size);
579 0 : m_pMemoStream->Read(sHeader,4);
580 :
581 0 : if ((m_pMemoStream->GetErrorCode() != ERRCODE_NONE) || ((sal_uInt8)sHeader[0]) != 0xFF || ((sal_uInt8)sHeader[1]) != 0xFF || ((sal_uInt8)sHeader[2]) != 0x08)
582 0 : m_aMemoHeader.db_typ = MemodBaseIII;
583 : else
584 0 : m_aMemoHeader.db_typ = MemodBaseIV;
585 : }
586 : else
587 : {
588 7 : m_aMemoHeader.db_typ = MemodBaseIII;
589 7 : m_aMemoHeader.db_size = 512;
590 : }
591 7 : break;
592 : case VisualFoxPro:
593 : case VisualFoxProAuto:
594 : case FoxProMemo:
595 0 : m_aMemoHeader.db_typ = MemoFoxPro;
596 0 : m_pMemoStream->Seek(6L);
597 0 : m_pMemoStream->SetNumberFormatInt(NUMBERFORMAT_INT_BIGENDIAN);
598 0 : (*m_pMemoStream).ReadUInt16( m_aMemoHeader.db_size );
599 0 : break;
600 : default:
601 : SAL_WARN( "connectivity.drivers", "ODbaseTable::ReadMemoHeader: unsupported memo type!" );
602 0 : break;
603 : }
604 7 : return sal_True;
605 : }
606 :
607 30 : OUString ODbaseTable::getEntry(OConnection* _pConnection,const OUString& _sName )
608 : {
609 : SAL_INFO( "connectivity.drivers", "dbase Ocke.Janssen@sun.com ODbaseTable::getEntry" );
610 30 : OUString sURL;
611 : try
612 : {
613 30 : Reference< XResultSet > xDir = _pConnection->getDir()->getStaticResultSet();
614 60 : Reference< XRow> xRow(xDir,UNO_QUERY);
615 60 : OUString sName;
616 60 : OUString sExt;
617 60 : INetURLObject aURL;
618 30 : static const OUString s_sSeparator("/");
619 30 : xDir->beforeFirst();
620 162 : while(xDir->next())
621 : {
622 132 : sName = xRow->getString(1);
623 132 : aURL.SetSmartProtocol(INET_PROT_FILE);
624 132 : OUString sUrl = _pConnection->getURL() + s_sSeparator + sName;
625 132 : aURL.SetSmartURL( sUrl );
626 :
627 : // cut the extension
628 132 : sExt = aURL.getExtension();
629 :
630 : // name and extension have to coincide
631 132 : if ( _pConnection->matchesExtension( sExt ) )
632 : {
633 60 : sName = sName.replaceAt(sName.getLength() - (sExt.getLength() + 1), sExt.getLength() + 1, OUString());
634 60 : if ( sName == _sName )
635 : {
636 30 : Reference< XContentAccess > xContentAccess( xDir, UNO_QUERY );
637 30 : sURL = xContentAccess->queryContentIdentifierString();
638 30 : break;
639 : }
640 : }
641 102 : }
642 60 : xDir->beforeFirst(); // move back to before first record
643 : }
644 0 : catch(const Exception&)
645 : {
646 : OSL_ASSERT(false);
647 : }
648 30 : return sURL;
649 : }
650 :
651 15 : void ODbaseTable::refreshColumns()
652 : {
653 : SAL_INFO( "connectivity.drivers", "dbase Ocke.Janssen@sun.com ODbaseTable::refreshColumns" );
654 15 : ::osl::MutexGuard aGuard( m_aMutex );
655 :
656 30 : TStringVector aVector;
657 15 : aVector.reserve(m_aColumns->get().size());
658 :
659 320 : for(OSQLColumns::Vector::const_iterator aIter = m_aColumns->get().begin();aIter != m_aColumns->get().end();++aIter)
660 305 : aVector.push_back(Reference< XNamed>(*aIter,UNO_QUERY)->getName());
661 :
662 15 : if(m_pColumns)
663 0 : m_pColumns->reFill(aVector);
664 : else
665 30 : m_pColumns = new ODbaseColumns(this,m_aMutex,aVector);
666 15 : }
667 :
668 15 : void ODbaseTable::refreshIndexes()
669 : {
670 : SAL_INFO( "connectivity.drivers", "dbase Ocke.Janssen@sun.com ODbaseTable::refreshIndexes" );
671 15 : TStringVector aVector;
672 15 : if(m_pFileStream && (!m_pIndexes || m_pIndexes->getCount() == 0))
673 : {
674 15 : INetURLObject aURL;
675 15 : aURL.SetURL(getEntry(m_pConnection,m_Name));
676 :
677 15 : aURL.setExtension("inf");
678 30 : Config aInfFile(aURL.getFSysPath(INetURLObject::FSYS_DETECT));
679 15 : aInfFile.SetGroup(dBASE_III_GROUP);
680 15 : sal_uInt16 nKeyCnt = aInfFile.GetKeyCount();
681 30 : OString aKeyName;
682 :
683 15 : for (sal_uInt16 nKey = 0; nKey < nKeyCnt; nKey++)
684 : {
685 : // Refences the key an index-file?
686 0 : aKeyName = aInfFile.GetKeyName( nKey );
687 : //...if yes, add the index list of the table
688 0 : if (aKeyName.copy(0,3).equals("NDX"))
689 : {
690 0 : OString aIndexName = aInfFile.ReadKey(aKeyName);
691 0 : aURL.setName(OStringToOUString(aIndexName, m_eEncoding));
692 : try
693 : {
694 0 : Content aCnt(aURL.GetMainURL(INetURLObject::NO_DECODE),Reference<XCommandEnvironment>(), comphelper::getProcessComponentContext());
695 0 : if (aCnt.isDocument())
696 : {
697 0 : aVector.push_back(aURL.getBase());
698 0 : }
699 : }
700 0 : catch(const Exception&) // an exception is thrown when no file exists
701 : {
702 0 : }
703 : }
704 15 : }
705 : }
706 15 : if(m_pIndexes)
707 0 : m_pIndexes->reFill(aVector);
708 : else
709 15 : m_pIndexes = new ODbaseIndexes(this,m_aMutex,aVector);
710 15 : }
711 :
712 :
713 15 : void SAL_CALL ODbaseTable::disposing(void)
714 : {
715 : SAL_INFO( "connectivity.drivers", "dbase Ocke.Janssen@sun.com ODbaseTable::disposing" );
716 15 : OFileTable::disposing();
717 15 : ::osl::MutexGuard aGuard(m_aMutex);
718 15 : m_aColumns = NULL;
719 15 : }
720 :
721 0 : Sequence< Type > SAL_CALL ODbaseTable::getTypes( ) throw(RuntimeException, std::exception)
722 : {
723 : SAL_INFO( "connectivity.drivers", "dbase Ocke.Janssen@sun.com ODbaseTable::getTypes" );
724 0 : Sequence< Type > aTypes = OTable_TYPEDEF::getTypes();
725 0 : ::std::vector<Type> aOwnTypes;
726 0 : aOwnTypes.reserve(aTypes.getLength());
727 :
728 0 : const Type* pBegin = aTypes.getConstArray();
729 0 : const Type* pEnd = pBegin + aTypes.getLength();
730 0 : for(;pBegin != pEnd;++pBegin)
731 : {
732 0 : if(!(*pBegin == ::getCppuType((const Reference<XKeysSupplier>*)0) ||
733 0 : *pBegin == ::getCppuType((const Reference<XDataDescriptorFactory>*)0)))
734 : {
735 0 : aOwnTypes.push_back(*pBegin);
736 : }
737 : }
738 0 : aOwnTypes.push_back(::getCppuType( (const Reference< ::com::sun::star::lang::XUnoTunnel > *)0 ));
739 0 : Type *pTypes = aOwnTypes.empty() ? 0 : &aOwnTypes[0];
740 0 : return Sequence< Type >(pTypes, aOwnTypes.size());
741 : }
742 :
743 :
744 2748 : Any SAL_CALL ODbaseTable::queryInterface( const Type & rType ) throw(RuntimeException, std::exception)
745 : {
746 : SAL_INFO( "connectivity.drivers", "dbase Ocke.Janssen@sun.com ODbaseTable::queryInterface" );
747 5496 : if( rType == ::getCppuType((const Reference<XKeysSupplier>*)0) ||
748 2748 : rType == ::getCppuType((const Reference<XDataDescriptorFactory>*)0))
749 0 : return Any();
750 :
751 2748 : Any aRet = OTable_TYPEDEF::queryInterface(rType);
752 2748 : return aRet.hasValue() ? aRet : ::cppu::queryInterface(rType,static_cast< ::com::sun::star::lang::XUnoTunnel*> (this));
753 : }
754 :
755 :
756 61 : Sequence< sal_Int8 > ODbaseTable::getUnoTunnelImplementationId()
757 : {
758 : SAL_INFO( "connectivity.drivers", "dbase Ocke.Janssen@sun.com ODbaseTable::getUnoTunnelImplementationId" );
759 : static ::cppu::OImplementationId * pId = 0;
760 61 : if (! pId)
761 : {
762 4 : ::osl::MutexGuard aGuard( ::osl::Mutex::getGlobalMutex() );
763 4 : if (! pId)
764 : {
765 4 : static ::cppu::OImplementationId aId;
766 4 : pId = &aId;
767 4 : }
768 : }
769 61 : return pId->getImplementationId();
770 : }
771 :
772 : // com::sun::star::lang::XUnoTunnel
773 :
774 61 : sal_Int64 ODbaseTable::getSomething( const Sequence< sal_Int8 > & rId ) throw (RuntimeException, std::exception)
775 : {
776 : SAL_INFO( "connectivity.drivers", "dbase Ocke.Janssen@sun.com ODbaseTable::getSomething" );
777 244 : return (rId.getLength() == 16 && 0 == memcmp(getUnoTunnelImplementationId().getConstArray(), rId.getConstArray(), 16 ) )
778 : ? reinterpret_cast< sal_Int64 >( this )
779 183 : : ODbaseTable_BASE::getSomething(rId);
780 : }
781 :
782 1701 : sal_Bool ODbaseTable::fetchRow(OValueRefRow& _rRow,const OSQLColumns & _rCols, sal_Bool _bUseTableDefs,sal_Bool bRetrieveData)
783 : {
784 : SAL_INFO( "connectivity.drivers", "dbase Ocke.Janssen@sun.com ODbaseTable::fetchRow" );
785 : // Read the data
786 1701 : bool bIsCurRecordDeleted = (char)m_pBuffer[0] == '*';
787 :
788 : // only read the bookmark
789 :
790 : // Mark record as deleted
791 1701 : _rRow->setDeleted(bIsCurRecordDeleted);
792 1701 : *(_rRow->get())[0] = m_nFilePos;
793 :
794 1701 : if (!bRetrieveData)
795 114 : return sal_True;
796 :
797 1587 : sal_Size nByteOffset = 1;
798 : // Fields:
799 1587 : OSQLColumns::Vector::const_iterator aIter = _rCols.get().begin();
800 1587 : OSQLColumns::Vector::const_iterator aEnd = _rCols.get().end();
801 1587 : const sal_Size nCount = _rRow->get().size();
802 48104 : for (sal_Size i = 1; aIter != aEnd && nByteOffset <= m_nBufferSize && i < nCount;++aIter, i++)
803 : {
804 : // Lengths depending on data type:
805 46517 : sal_Int32 nLen = 0;
806 46517 : sal_Int32 nType = 0;
807 46517 : if(_bUseTableDefs)
808 : {
809 46517 : nLen = m_aPrecisions[i-1];
810 46517 : nType = m_aTypes[i-1];
811 : }
812 : else
813 : {
814 0 : (*aIter)->getPropertyValue(OMetaConnection::getPropMap().getNameByIndex(PROPERTY_ID_PRECISION)) >>= nLen;
815 0 : (*aIter)->getPropertyValue(OMetaConnection::getPropMap().getNameByIndex(PROPERTY_ID_TYPE)) >>= nType;
816 : }
817 46517 : switch(nType)
818 : {
819 : case DataType::INTEGER:
820 : case DataType::DOUBLE:
821 : case DataType::TIMESTAMP:
822 : case DataType::DATE:
823 : case DataType::BIT:
824 : case DataType::LONGVARCHAR:
825 : case DataType::LONGVARBINARY:
826 25371 : nLen = m_aRealFieldLengths[i-1];
827 25371 : break;
828 : case DataType::DECIMAL:
829 670 : if(_bUseTableDefs)
830 670 : nLen = SvDbaseConverter::ConvertPrecisionToDbase(nLen,m_aScales[i-1]);
831 : else
832 0 : nLen = SvDbaseConverter::ConvertPrecisionToDbase(nLen,getINT32((*aIter)->getPropertyValue(OMetaConnection::getPropMap().getNameByIndex(PROPERTY_ID_SCALE))));
833 670 : break; // the sign and the comma
834 :
835 : case DataType::BINARY:
836 : case DataType::OTHER:
837 0 : nByteOffset += nLen;
838 24597 : continue;
839 : }
840 :
841 : // Is the variable bound?
842 46517 : if ( !(_rRow->get())[i]->isBound() )
843 : {
844 : // No - next field.
845 18780 : nByteOffset += nLen;
846 : OSL_ENSURE( nByteOffset <= m_nBufferSize ,"ByteOffset > m_nBufferSize!");
847 18780 : continue;
848 : } // if ( !(_rRow->get())[i]->isBound() )
849 27737 : if ( ( nByteOffset + nLen) > m_nBufferSize )
850 0 : break; // length doesn't match buffer size.
851 :
852 27737 : char *pData = (char *) (m_pBuffer + nByteOffset);
853 :
854 27737 : if (nType == DataType::CHAR || nType == DataType::VARCHAR)
855 : {
856 12316 : sal_Int32 nLastPos = -1;
857 3113244 : for (sal_Int32 k = 0; k < nLen; ++k)
858 : {
859 3100928 : if (pData[k] != ' ')
860 : // Record last non-empty position.
861 32954 : nLastPos = k;
862 : }
863 12316 : if (nLastPos < 0)
864 : {
865 : // Empty string. Skip it.
866 7627 : (_rRow->get())[i]->setNull();
867 : }
868 : else
869 : {
870 : // Commit the string. Use intern() to ref-count it.
871 4689 : *(_rRow->get())[i] = OUString::intern(pData, static_cast<sal_Int32>(nLastPos+1), m_eEncoding);
872 12316 : }
873 : } // if (nType == DataType::CHAR || nType == DataType::VARCHAR)
874 15421 : else if ( DataType::TIMESTAMP == nType )
875 : {
876 0 : sal_Int32 nDate = 0,nTime = 0;
877 0 : memcpy(&nDate, pData, 4);
878 0 : memcpy(&nTime, pData+ 4, 4);
879 0 : if ( !nDate && !nTime )
880 : {
881 0 : (_rRow->get())[i]->setNull();
882 : }
883 : else
884 : {
885 0 : ::com::sun::star::util::DateTime aDateTime;
886 0 : lcl_CalDate(nDate,nTime,aDateTime);
887 0 : *(_rRow->get())[i] = aDateTime;
888 : }
889 : }
890 15421 : else if ( DataType::INTEGER == nType )
891 : {
892 0 : sal_Int32 nValue = 0;
893 0 : memcpy(&nValue, pData, nLen);
894 0 : *(_rRow->get())[i] = nValue;
895 : }
896 15421 : else if ( DataType::DOUBLE == nType )
897 : {
898 0 : double d = 0.0;
899 0 : if (getBOOL((*aIter)->getPropertyValue(OMetaConnection::getPropMap().getNameByIndex(PROPERTY_ID_ISCURRENCY)))) // Currency is treated separately
900 : {
901 0 : sal_Int64 nValue = 0;
902 0 : memcpy(&nValue, pData, nLen);
903 :
904 0 : if ( m_aScales[i-1] )
905 0 : d = (double)(nValue / pow(10.0,(int)m_aScales[i-1]));
906 : else
907 0 : d = (double)(nValue);
908 : }
909 : else
910 : {
911 0 : memcpy(&d, pData, nLen);
912 : }
913 :
914 0 : *(_rRow->get())[i] = d;
915 : }
916 : else
917 : {
918 15421 : sal_Int32 nPos1 = -1, nPos2 = -1;
919 : // If the string contains Nul-characters, then convert them to blanks!
920 173035 : for (sal_Int32 k = 0; k < nLen; k++)
921 : {
922 157614 : if (pData[k] == '\0')
923 14394 : pData[k] = ' ';
924 :
925 157614 : if (pData[k] != ' ')
926 : {
927 95608 : if (nPos1 < 0)
928 : // first non-empty char position.
929 9604 : nPos1 = k;
930 :
931 : // last non-empty char position.
932 95608 : nPos2 = k;
933 : }
934 : }
935 :
936 15421 : if (nPos1 < 0)
937 : {
938 : // Empty string. Skip it.
939 5817 : nByteOffset += nLen;
940 5817 : (_rRow->get())[i]->setNull(); // no values -> done
941 5817 : continue;
942 : }
943 :
944 9604 : OUString aStr = OUString::intern(pData+nPos1, nPos2-nPos1+1, m_eEncoding);
945 :
946 9604 : switch (nType)
947 : {
948 : case DataType::DATE:
949 : {
950 54 : if (aStr.getLength() != nLen)
951 : {
952 0 : (_rRow->get())[i]->setNull();
953 0 : break;
954 : }
955 54 : const sal_uInt16 nYear = (sal_uInt16)aStr.copy( 0, 4 ).toInt32();
956 54 : const sal_uInt16 nMonth = (sal_uInt16)aStr.copy( 4, 2 ).toInt32();
957 54 : const sal_uInt16 nDay = (sal_uInt16)aStr.copy( 6, 2 ).toInt32();
958 :
959 54 : const ::com::sun::star::util::Date aDate(nDay,nMonth,nYear);
960 54 : *(_rRow->get())[i] = aDate;
961 : }
962 54 : break;
963 : case DataType::DECIMAL:
964 108 : *(_rRow->get())[i] = ORowSetValue(aStr);
965 108 : break;
966 : case DataType::BIT:
967 : {
968 : sal_Bool b;
969 0 : switch (* ((const char *)pData))
970 : {
971 : case 'T':
972 : case 'Y':
973 0 : case 'J': b = sal_True; break;
974 0 : default: b = sal_False; break;
975 : }
976 0 : *(_rRow->get())[i] = b;
977 : }
978 0 : break;
979 : case DataType::LONGVARBINARY:
980 : case DataType::BINARY:
981 : case DataType::LONGVARCHAR:
982 : {
983 9442 : const long nBlockNo = aStr.toInt32(); // read blocknumber
984 9442 : if (nBlockNo > 0 && m_pMemoStream) // Read data from memo-file, only if
985 : {
986 18884 : if ( !ReadMemo(nBlockNo, (_rRow->get())[i]->get()) )
987 0 : break;
988 : }
989 : else
990 0 : (_rRow->get())[i]->setNull();
991 9442 : } break;
992 : default:
993 : SAL_WARN( "connectivity.drivers","Falscher Type");
994 : }
995 9604 : (_rRow->get())[i]->setTypeKind(nType);
996 : }
997 :
998 21920 : nByteOffset += nLen;
999 : OSL_ENSURE( nByteOffset <= m_nBufferSize ,"ByteOffset > m_nBufferSize!");
1000 : }
1001 1587 : return sal_True;
1002 : }
1003 :
1004 :
1005 15 : void ODbaseTable::FileClose()
1006 : {
1007 : SAL_INFO( "connectivity.drivers", "dbase Ocke.Janssen@sun.com ODbaseTable::FileClose" );
1008 15 : ::osl::MutexGuard aGuard(m_aMutex);
1009 : // if not everything has been written yet
1010 15 : if (m_pMemoStream && m_pMemoStream->IsWritable())
1011 7 : m_pMemoStream->Flush();
1012 :
1013 15 : delete m_pMemoStream;
1014 15 : m_pMemoStream = NULL;
1015 :
1016 15 : ODbaseTable_BASE::FileClose();
1017 15 : }
1018 :
1019 0 : sal_Bool ODbaseTable::CreateImpl()
1020 : {
1021 : SAL_INFO( "connectivity.drivers", "dbase Ocke.Janssen@sun.com ODbaseTable::CreateImpl" );
1022 : OSL_ENSURE(!m_pFileStream, "SequenceError");
1023 :
1024 0 : if ( m_pConnection->isCheckEnabled() && ::dbtools::convertName2SQLName(m_Name,OUString()) != m_Name )
1025 : {
1026 0 : const OUString sError( getConnection()->getResources().getResourceStringWithSubstitution(
1027 : STR_SQL_NAME_ERROR,
1028 : "$name$", m_Name
1029 0 : ) );
1030 0 : ::dbtools::throwGenericSQLException( sError, *this );
1031 : }
1032 :
1033 0 : INetURLObject aURL;
1034 0 : aURL.SetSmartProtocol(INET_PROT_FILE);
1035 0 : OUString aName = getEntry(m_pConnection, m_Name);
1036 0 : if(aName.isEmpty())
1037 : {
1038 0 : OUString aIdent = m_pConnection->getContent()->getIdentifier()->getContentIdentifier();
1039 0 : if ( aIdent.lastIndexOf('/') != (aIdent.getLength()-1) )
1040 0 : aIdent += "/";
1041 0 : aIdent += m_Name;
1042 0 : aName = aIdent.getStr();
1043 : }
1044 0 : aURL.SetURL(aName);
1045 :
1046 0 : if ( !m_pConnection->matchesExtension( aURL.getExtension() ) )
1047 0 : aURL.setExtension(m_pConnection->getExtension());
1048 :
1049 : try
1050 : {
1051 0 : Content aContent(aURL.GetMainURL(INetURLObject::NO_DECODE),Reference<XCommandEnvironment>(), comphelper::getProcessComponentContext());
1052 0 : if (aContent.isDocument())
1053 : {
1054 : // Only if the file exists with length > 0 raise an error
1055 0 : SvStream* pFileStream = createStream_simpleError( aURL.GetMainURL(INetURLObject::NO_DECODE),STREAM_READ);
1056 :
1057 0 : if (pFileStream && pFileStream->Seek(STREAM_SEEK_TO_END))
1058 : {
1059 0 : return sal_False;
1060 : }
1061 0 : delete pFileStream;
1062 0 : }
1063 : }
1064 0 : catch(const Exception&) // an exception is thrown when no file exists
1065 : {
1066 : }
1067 :
1068 0 : sal_Bool bMemoFile = sal_False;
1069 :
1070 0 : sal_Bool bOk = CreateFile(aURL, bMemoFile);
1071 :
1072 0 : FileClose();
1073 :
1074 0 : if (!bOk)
1075 : {
1076 : try
1077 : {
1078 0 : Content aContent(aURL.GetMainURL(INetURLObject::NO_DECODE),Reference<XCommandEnvironment>(), comphelper::getProcessComponentContext());
1079 0 : aContent.executeCommand( "delete", css::uno::Any( true ) );
1080 : }
1081 0 : catch(const Exception&) // an exception is thrown when no file exists
1082 : {
1083 : }
1084 0 : return sal_False;
1085 : }
1086 :
1087 0 : if (bMemoFile)
1088 : {
1089 0 : OUString aExt = aURL.getExtension();
1090 0 : aURL.setExtension("dbt"); // extension for memo file
1091 0 : Content aMemo1Content(aURL.GetMainURL(INetURLObject::NO_DECODE),Reference<XCommandEnvironment>(), comphelper::getProcessComponentContext());
1092 :
1093 0 : sal_Bool bMemoAlreadyExists = sal_False;
1094 : try
1095 : {
1096 0 : bMemoAlreadyExists = aMemo1Content.isDocument();
1097 : }
1098 0 : catch(const Exception&) // an exception is thrown when no file exists
1099 : {
1100 : }
1101 0 : if (bMemoAlreadyExists)
1102 : {
1103 0 : aURL.setExtension(aExt); // kill dbf file
1104 : try
1105 : {
1106 0 : Content aMemoContent(aURL.GetMainURL(INetURLObject::NO_DECODE),Reference<XCommandEnvironment>(), comphelper::getProcessComponentContext());
1107 0 : aMemoContent.executeCommand( "delete", css::uno::Any( true ) );
1108 : }
1109 0 : catch(const Exception&)
1110 : {
1111 :
1112 0 : const OUString sError( getConnection()->getResources().getResourceStringWithSubstitution(
1113 : STR_COULD_NOT_DELETE_FILE,
1114 : "$name$", aName
1115 0 : ) );
1116 0 : ::dbtools::throwGenericSQLException( sError, *this );
1117 : }
1118 : }
1119 0 : if (!CreateMemoFile(aURL))
1120 : {
1121 0 : aURL.setExtension(aExt); // kill dbf file
1122 0 : Content aMemoContent(aURL.GetMainURL(INetURLObject::NO_DECODE),Reference<XCommandEnvironment>(), comphelper::getProcessComponentContext());
1123 0 : aMemoContent.executeCommand( "delete", css::uno::Any( true ) );
1124 0 : return sal_False;
1125 : }
1126 0 : m_aHeader.db_typ = dBaseIIIMemo;
1127 : }
1128 : else
1129 0 : m_aHeader.db_typ = dBaseIII;
1130 :
1131 0 : return sal_True;
1132 : }
1133 :
1134 0 : void ODbaseTable::throwInvalidColumnType(const sal_uInt16 _nErrorId,const OUString& _sColumnName)
1135 : {
1136 : SAL_INFO( "connectivity.drivers", "dbase Ocke.Janssen@sun.com ODbaseTable::throwInvalidColumnType" );
1137 : try
1138 : {
1139 : // we have to drop the file because it is corrupted now
1140 0 : DropImpl();
1141 : }
1142 0 : catch(const Exception&)
1143 : {
1144 : }
1145 :
1146 0 : const OUString sError( getConnection()->getResources().getResourceStringWithSubstitution(
1147 : _nErrorId,
1148 : "$columnname$", _sColumnName
1149 0 : ) );
1150 0 : ::dbtools::throwGenericSQLException( sError, *this );
1151 0 : }
1152 :
1153 : // creates in principle dBase IV file format
1154 0 : sal_Bool ODbaseTable::CreateFile(const INetURLObject& aFile, sal_Bool& bCreateMemo)
1155 : {
1156 : SAL_INFO( "connectivity.drivers", "dbase Ocke.Janssen@sun.com ODbaseTable::CreateFile" );
1157 0 : bCreateMemo = sal_False;
1158 0 : Date aDate( Date::SYSTEM ); // current date
1159 :
1160 0 : m_pFileStream = createStream_simpleError( aFile.GetMainURL(INetURLObject::NO_DECODE),STREAM_READWRITE | STREAM_SHARE_DENYWRITE | STREAM_TRUNC );
1161 :
1162 0 : if (!m_pFileStream)
1163 0 : return sal_False;
1164 :
1165 0 : sal_uInt8 nDbaseType = dBaseIII;
1166 0 : Reference<XIndexAccess> xColumns(getColumns(),UNO_QUERY);
1167 0 : Reference<XPropertySet> xCol;
1168 0 : const OUString sPropType = OMetaConnection::getPropMap().getNameByIndex(PROPERTY_ID_TYPE);
1169 :
1170 : try
1171 : {
1172 0 : const sal_Int32 nCount = xColumns->getCount();
1173 0 : for(sal_Int32 i=0;i<nCount;++i)
1174 : {
1175 0 : xColumns->getByIndex(i) >>= xCol;
1176 : OSL_ENSURE(xCol.is(),"This should be a column!");
1177 :
1178 0 : switch (getINT32(xCol->getPropertyValue(sPropType)))
1179 : {
1180 : case DataType::DOUBLE:
1181 : case DataType::INTEGER:
1182 : case DataType::TIMESTAMP:
1183 : case DataType::LONGVARBINARY:
1184 0 : nDbaseType = VisualFoxPro;
1185 0 : i = nCount; // no more columns need to be checked
1186 0 : break;
1187 : } // switch (getINT32(xCol->getPropertyValue(sPropType)))
1188 : }
1189 : }
1190 0 : catch ( const Exception& e )
1191 : {
1192 : (void)e;
1193 :
1194 : try
1195 : {
1196 : // we have to drop the file because it is corrupted now
1197 0 : DropImpl();
1198 : }
1199 0 : catch(const Exception&) { }
1200 0 : throw;
1201 : }
1202 :
1203 : char aBuffer[21]; // write buffer
1204 0 : memset(aBuffer,0,sizeof(aBuffer));
1205 :
1206 0 : m_pFileStream->Seek(0L);
1207 0 : (*m_pFileStream).WriteUChar( (sal_uInt8) nDbaseType ); // dBase format
1208 0 : (*m_pFileStream).WriteUChar( (sal_uInt8) (aDate.GetYear() % 100) ); // current date
1209 :
1210 :
1211 0 : (*m_pFileStream).WriteUChar( (sal_uInt8) aDate.GetMonth() );
1212 0 : (*m_pFileStream).WriteUChar( (sal_uInt8) aDate.GetDay() );
1213 0 : (*m_pFileStream).WriteUInt32( (sal_uInt32)0 ); // number of data records
1214 0 : (*m_pFileStream).WriteUInt16( (sal_uInt16)((m_pColumns->getCount()+1) * 32 + 1) ); // header information,
1215 : // pColumns contains always an additional column
1216 0 : (*m_pFileStream).WriteUInt16( (sal_uInt16) 0 ); // record length will be determined later
1217 0 : m_pFileStream->Write(aBuffer, 20);
1218 :
1219 0 : sal_uInt16 nRecLength = 1; // Length 1 for deleted flag
1220 0 : sal_Int32 nMaxFieldLength = m_pConnection->getMetaData()->getMaxColumnNameLength();
1221 0 : OUString aName;
1222 0 : const OUString sPropName = OMetaConnection::getPropMap().getNameByIndex(PROPERTY_ID_NAME);
1223 0 : const OUString sPropPrec = OMetaConnection::getPropMap().getNameByIndex(PROPERTY_ID_PRECISION);
1224 0 : const OUString sPropScale = OMetaConnection::getPropMap().getNameByIndex(PROPERTY_ID_SCALE);
1225 :
1226 : try
1227 : {
1228 0 : const sal_Int32 nCount = xColumns->getCount();
1229 0 : for(sal_Int32 i=0;i<nCount;++i)
1230 : {
1231 0 : xColumns->getByIndex(i) >>= xCol;
1232 : OSL_ENSURE(xCol.is(),"This should be a column!");
1233 :
1234 0 : char cTyp( 'C' );
1235 :
1236 0 : xCol->getPropertyValue(sPropName) >>= aName;
1237 :
1238 0 : OString aCol;
1239 0 : if ( DBTypeConversion::convertUnicodeString( aName, aCol, m_eEncoding ) > nMaxFieldLength)
1240 : {
1241 0 : throwInvalidColumnType( STR_INVALID_COLUMN_NAME_LENGTH, aName );
1242 : }
1243 :
1244 0 : (*m_pFileStream).WriteCharPtr( aCol.getStr() );
1245 0 : m_pFileStream->Write(aBuffer, 11 - aCol.getLength());
1246 :
1247 0 : sal_Int32 nPrecision = 0;
1248 0 : xCol->getPropertyValue(sPropPrec) >>= nPrecision;
1249 0 : sal_Int32 nScale = 0;
1250 0 : xCol->getPropertyValue(sPropScale) >>= nScale;
1251 :
1252 0 : bool bBinary = false;
1253 :
1254 0 : switch (getINT32(xCol->getPropertyValue(sPropType)))
1255 : {
1256 : case DataType::CHAR:
1257 : case DataType::VARCHAR:
1258 0 : cTyp = 'C';
1259 0 : break;
1260 : case DataType::DOUBLE:
1261 0 : if (getBOOL(xCol->getPropertyValue(OMetaConnection::getPropMap().getNameByIndex(PROPERTY_ID_ISCURRENCY)))) // Currency will be treated separately
1262 0 : cTyp = 'Y';
1263 : else
1264 0 : cTyp = 'B';
1265 0 : break;
1266 : case DataType::INTEGER:
1267 0 : cTyp = 'I';
1268 0 : break;
1269 : case DataType::TINYINT:
1270 : case DataType::SMALLINT:
1271 : case DataType::BIGINT:
1272 : case DataType::DECIMAL:
1273 : case DataType::NUMERIC:
1274 : case DataType::REAL:
1275 0 : cTyp = 'N'; // only dBase 3 format
1276 0 : break;
1277 : case DataType::TIMESTAMP:
1278 0 : cTyp = 'T';
1279 0 : break;
1280 : case DataType::DATE:
1281 0 : cTyp = 'D';
1282 0 : break;
1283 : case DataType::BIT:
1284 0 : cTyp = 'L';
1285 0 : break;
1286 : case DataType::LONGVARBINARY:
1287 0 : bBinary = true;
1288 : // run through
1289 : case DataType::LONGVARCHAR:
1290 0 : cTyp = 'M';
1291 0 : break;
1292 : default:
1293 : {
1294 0 : throwInvalidColumnType(STR_INVALID_COLUMN_TYPE, aName);
1295 : }
1296 : }
1297 :
1298 0 : (*m_pFileStream).WriteChar( cTyp );
1299 0 : if ( nDbaseType == VisualFoxPro )
1300 0 : (*m_pFileStream).WriteUInt32( sal_uInt32(nRecLength-1) );
1301 : else
1302 0 : m_pFileStream->Write(aBuffer, 4);
1303 :
1304 0 : switch(cTyp)
1305 : {
1306 : case 'C':
1307 : OSL_ENSURE(nPrecision < 255, "ODbaseTable::Create: Column zu lang!");
1308 0 : if (nPrecision > 254)
1309 : {
1310 0 : throwInvalidColumnType(STR_INVALID_COLUMN_PRECISION, aName);
1311 : }
1312 0 : (*m_pFileStream).WriteUChar( (sal_uInt8) std::min((unsigned)nPrecision, 255U) ); // field length
1313 0 : nRecLength = nRecLength + (sal_uInt16)::std::min((sal_uInt16)nPrecision, (sal_uInt16)255UL);
1314 0 : (*m_pFileStream).WriteUChar( (sal_uInt8)0 ); // decimals
1315 0 : break;
1316 : case 'F':
1317 : case 'N':
1318 : OSL_ENSURE(nPrecision >= nScale,
1319 : "ODbaseTable::Create: Feldlaenge muss groesser Nachkommastellen sein!");
1320 0 : if (nPrecision < nScale)
1321 : {
1322 0 : throwInvalidColumnType(STR_INVALID_PRECISION_SCALE, aName);
1323 : }
1324 0 : if (getBOOL(xCol->getPropertyValue(OMetaConnection::getPropMap().getNameByIndex(PROPERTY_ID_ISCURRENCY)))) // Currency will be treated separately
1325 : {
1326 0 : (*m_pFileStream).WriteUChar( (sal_uInt8)10 ); // standard length
1327 0 : (*m_pFileStream).WriteUChar( (sal_uInt8)4 );
1328 0 : nRecLength += 10;
1329 : }
1330 : else
1331 : {
1332 0 : sal_Int32 nPrec = SvDbaseConverter::ConvertPrecisionToDbase(nPrecision,nScale);
1333 :
1334 0 : (*m_pFileStream).WriteUChar( (sal_uInt8)( nPrec) );
1335 0 : (*m_pFileStream).WriteUChar( (sal_uInt8)nScale );
1336 0 : nRecLength += (sal_uInt16)nPrec;
1337 : }
1338 0 : break;
1339 : case 'L':
1340 0 : (*m_pFileStream).WriteUChar( (sal_uInt8)1 );
1341 0 : (*m_pFileStream).WriteUChar( (sal_uInt8)0 );
1342 0 : ++nRecLength;
1343 0 : break;
1344 : case 'I':
1345 0 : (*m_pFileStream).WriteUChar( (sal_uInt8)4 );
1346 0 : (*m_pFileStream).WriteUChar( (sal_uInt8)0 );
1347 0 : nRecLength += 4;
1348 0 : break;
1349 : case 'Y':
1350 : case 'B':
1351 : case 'T':
1352 : case 'D':
1353 0 : (*m_pFileStream).WriteUChar( (sal_uInt8)8 );
1354 0 : (*m_pFileStream).WriteUChar( (sal_uInt8)0 );
1355 0 : nRecLength += 8;
1356 0 : break;
1357 : case 'M':
1358 0 : bCreateMemo = sal_True;
1359 0 : (*m_pFileStream).WriteUChar( (sal_uInt8)10 );
1360 0 : (*m_pFileStream).WriteUChar( (sal_uInt8)0 );
1361 0 : nRecLength += 10;
1362 0 : if ( bBinary )
1363 0 : aBuffer[0] = 0x06;
1364 0 : break;
1365 : default:
1366 0 : throwInvalidColumnType(STR_INVALID_COLUMN_TYPE, aName);
1367 : }
1368 0 : m_pFileStream->Write(aBuffer, 14);
1369 0 : aBuffer[0] = 0x00;
1370 0 : }
1371 :
1372 0 : (*m_pFileStream).WriteUChar( (sal_uInt8)FIELD_DESCRIPTOR_TERMINATOR ); // end of header
1373 0 : (*m_pFileStream).WriteChar( (char)DBF_EOL );
1374 0 : m_pFileStream->Seek(10L);
1375 0 : (*m_pFileStream).WriteUInt16( nRecLength ); // set record length afterwards
1376 :
1377 0 : if (bCreateMemo)
1378 : {
1379 0 : m_pFileStream->Seek(0L);
1380 0 : if (nDbaseType == VisualFoxPro)
1381 0 : (*m_pFileStream).WriteUChar( (sal_uInt8) FoxProMemo );
1382 : else
1383 0 : (*m_pFileStream).WriteUChar( (sal_uInt8) dBaseIIIMemo );
1384 : } // if (bCreateMemo)
1385 : }
1386 0 : catch ( const Exception& e )
1387 : {
1388 : (void)e;
1389 :
1390 : try
1391 : {
1392 : // we have to drop the file because it is corrupted now
1393 0 : DropImpl();
1394 : }
1395 0 : catch(const Exception&) { }
1396 0 : throw;
1397 : }
1398 0 : return sal_True;
1399 : }
1400 :
1401 :
1402 : // creates in principle dBase III file format
1403 0 : sal_Bool ODbaseTable::CreateMemoFile(const INetURLObject& aFile)
1404 : {
1405 : SAL_INFO( "connectivity.drivers", "dbase Ocke.Janssen@sun.com ODbaseTable::CreateMemoFile" );
1406 : // filehandling macro for table creation
1407 0 : m_pMemoStream = createStream_simpleError( aFile.GetMainURL(INetURLObject::NO_DECODE),STREAM_READWRITE | STREAM_SHARE_DENYWRITE);
1408 :
1409 0 : if (!m_pMemoStream)
1410 0 : return sal_False;
1411 :
1412 0 : m_pMemoStream->SetStreamSize(512);
1413 :
1414 0 : m_pMemoStream->Seek(0L);
1415 0 : (*m_pMemoStream).WriteUInt32( sal_uInt32(1) ); // pointer to the first free block
1416 :
1417 0 : m_pMemoStream->Flush();
1418 0 : delete m_pMemoStream;
1419 0 : m_pMemoStream = NULL;
1420 0 : return sal_True;
1421 : }
1422 :
1423 0 : sal_Bool ODbaseTable::Drop_Static(const OUString& _sUrl,sal_Bool _bHasMemoFields,OCollection* _pIndexes )
1424 : {
1425 : SAL_INFO( "connectivity.drivers", "dbase Ocke.Janssen@sun.com ODbaseTable::Drop_Static" );
1426 0 : INetURLObject aURL;
1427 0 : aURL.SetURL(_sUrl);
1428 :
1429 0 : sal_Bool bDropped = ::utl::UCBContentHelper::Kill(aURL.GetMainURL(INetURLObject::NO_DECODE));
1430 :
1431 0 : if(bDropped)
1432 : {
1433 0 : if (_bHasMemoFields)
1434 : { // delete the memo fields
1435 0 : aURL.setExtension("dbt");
1436 0 : bDropped = ::utl::UCBContentHelper::Kill(aURL.GetMainURL(INetURLObject::NO_DECODE));
1437 : }
1438 :
1439 0 : if(bDropped)
1440 : {
1441 0 : if(_pIndexes)
1442 : {
1443 : try
1444 : {
1445 0 : sal_Int32 i = _pIndexes->getCount();
1446 0 : while (i)
1447 : {
1448 0 : _pIndexes->dropByIndex(--i);
1449 : }
1450 : }
1451 0 : catch(const SQLException&)
1452 : {
1453 : }
1454 : }
1455 0 : aURL.setExtension("inf");
1456 :
1457 : // as the inf file does not necessarily exist, we aren't allowed to use UCBContentHelper::Kill
1458 : try
1459 : {
1460 0 : ::ucbhelper::Content aDeleteContent( aURL.GetMainURL( INetURLObject::NO_DECODE ), Reference< XCommandEnvironment >(), comphelper::getProcessComponentContext() );
1461 0 : aDeleteContent.executeCommand( "delete", makeAny( sal_Bool( sal_True ) ) );
1462 : }
1463 0 : catch(const Exception&)
1464 : {
1465 : // silently ignore this ....
1466 : }
1467 : }
1468 : }
1469 0 : return bDropped;
1470 : }
1471 :
1472 0 : sal_Bool ODbaseTable::DropImpl()
1473 : {
1474 : SAL_INFO( "connectivity.drivers", "dbase Ocke.Janssen@sun.com ODbaseTable::DropImpl" );
1475 0 : FileClose();
1476 :
1477 0 : if(!m_pIndexes)
1478 0 : refreshIndexes(); // look for indexes which must be deleted as well
1479 :
1480 0 : sal_Bool bDropped = Drop_Static(getEntry(m_pConnection,m_Name),HasMemoFields(),m_pIndexes);
1481 0 : if(!bDropped)
1482 : {// we couldn't drop the table so we have to reopen it
1483 0 : construct();
1484 0 : if(m_pColumns)
1485 0 : m_pColumns->refresh();
1486 : }
1487 0 : return bDropped;
1488 : }
1489 :
1490 :
1491 1 : sal_Bool ODbaseTable::InsertRow(OValueRefVector& rRow, sal_Bool bFlush,const Reference<XIndexAccess>& _xCols)
1492 : {
1493 : SAL_INFO( "connectivity.drivers", "dbase Ocke.Janssen@sun.com ODbaseTable::InsertRow" );
1494 : // fill buffer with blanks
1495 1 : AllocBuffer();
1496 1 : memset(m_pBuffer, 0, m_aHeader.db_slng);
1497 1 : m_pBuffer[0] = ' ';
1498 :
1499 : // Copy new row completely:
1500 : // ... and add at the end as new Record:
1501 1 : sal_Size nTempPos = m_nFilePos;
1502 :
1503 1 : m_nFilePos = (sal_Size)m_aHeader.db_anz + 1;
1504 1 : sal_Bool bInsertRow = UpdateBuffer( rRow, NULL, _xCols, true );
1505 1 : if ( bInsertRow )
1506 : {
1507 1 : sal_Size nFileSize = 0, nMemoFileSize = 0;
1508 :
1509 1 : nFileSize = lcl_getFileSize(*m_pFileStream);
1510 :
1511 1 : if (HasMemoFields() && m_pMemoStream)
1512 : {
1513 1 : m_pMemoStream->Seek(STREAM_SEEK_TO_END);
1514 1 : nMemoFileSize = m_pMemoStream->Tell();
1515 : }
1516 :
1517 1 : if (!WriteBuffer())
1518 : {
1519 0 : m_pFileStream->SetStreamSize(nFileSize); // restore old size
1520 :
1521 0 : if (HasMemoFields() && m_pMemoStream)
1522 0 : m_pMemoStream->SetStreamSize(nMemoFileSize); // restore old size
1523 0 : m_nFilePos = nTempPos; // restore file position
1524 : }
1525 : else
1526 : {
1527 1 : (*m_pFileStream).WriteChar( (char)DBF_EOL ); // write EOL
1528 : // raise number of datasets in the header:
1529 1 : m_pFileStream->Seek( 4L );
1530 1 : (*m_pFileStream).WriteUInt32( m_aHeader.db_anz + 1 );
1531 :
1532 : // if AppendOnly no flush!
1533 1 : if (bFlush)
1534 1 : m_pFileStream->Flush();
1535 :
1536 : // raise number if successfully
1537 1 : m_aHeader.db_anz++;
1538 1 : *rRow.get()[0] = m_nFilePos; // set bookmark
1539 1 : m_nFilePos = nTempPos;
1540 : }
1541 : }
1542 : else
1543 0 : m_nFilePos = nTempPos;
1544 :
1545 1 : return bInsertRow;
1546 : }
1547 :
1548 :
1549 4 : sal_Bool ODbaseTable::UpdateRow(OValueRefVector& rRow, OValueRefRow& pOrgRow,const Reference<XIndexAccess>& _xCols)
1550 : {
1551 : SAL_INFO( "connectivity.drivers", "dbase Ocke.Janssen@sun.com ODbaseTable::UpdateRow" );
1552 : // fill buffer with blanks
1553 4 : AllocBuffer();
1554 :
1555 : // position on desired record:
1556 4 : sal_Size nPos = m_aHeader.db_kopf + (long)(m_nFilePos-1) * m_aHeader.db_slng;
1557 4 : m_pFileStream->Seek(nPos);
1558 4 : m_pFileStream->Read((char*)m_pBuffer, m_aHeader.db_slng);
1559 :
1560 4 : sal_Size nMemoFileSize( 0 );
1561 4 : if (HasMemoFields() && m_pMemoStream)
1562 : {
1563 0 : m_pMemoStream->Seek(STREAM_SEEK_TO_END);
1564 0 : nMemoFileSize = m_pMemoStream->Tell();
1565 : }
1566 4 : if (!UpdateBuffer(rRow, pOrgRow, _xCols, false) || !WriteBuffer())
1567 : {
1568 0 : if (HasMemoFields() && m_pMemoStream)
1569 0 : m_pMemoStream->SetStreamSize(nMemoFileSize); // restore old size
1570 : }
1571 : else
1572 : {
1573 4 : m_pFileStream->Flush();
1574 : }
1575 4 : return sal_True;
1576 : }
1577 :
1578 :
1579 1 : sal_Bool ODbaseTable::DeleteRow(const OSQLColumns& _rCols)
1580 : {
1581 : SAL_INFO( "connectivity.drivers", "dbase Ocke.Janssen@sun.com ODbaseTable::DeleteRow" );
1582 : // Set the Delete-Flag (be it set or not):
1583 : // Position on desired record:
1584 1 : sal_Size nFilePos = m_aHeader.db_kopf + (long)(m_nFilePos-1) * m_aHeader.db_slng;
1585 1 : m_pFileStream->Seek(nFilePos);
1586 :
1587 1 : OValueRefRow aRow = new OValueRefVector(_rCols.get().size());
1588 :
1589 1 : if (!fetchRow(aRow,_rCols,sal_True,sal_True))
1590 0 : return sal_False;
1591 :
1592 2 : Reference<XPropertySet> xCol;
1593 2 : OUString aColName;
1594 1 : ::comphelper::UStringMixEqual aCase(isCaseSensitive());
1595 32 : for (sal_uInt16 i = 0; i < m_pColumns->getCount(); i++)
1596 : {
1597 31 : Reference<XPropertySet> xIndex = isUniqueByColumnName(i);
1598 31 : if (xIndex.is())
1599 : {
1600 0 : xCol.set(m_pColumns->getByIndex(i), css::uno::UNO_QUERY);
1601 : OSL_ENSURE(xCol.is(),"ODbaseTable::DeleteRow column is null!");
1602 0 : if(xCol.is())
1603 : {
1604 0 : xCol->getPropertyValue(OMetaConnection::getPropMap().getNameByIndex(PROPERTY_ID_NAME)) >>= aColName;
1605 :
1606 0 : Reference<XUnoTunnel> xTunnel(xIndex,UNO_QUERY);
1607 : OSL_ENSURE(xTunnel.is(),"No TunnelImplementation!");
1608 0 : ODbaseIndex* pIndex = reinterpret_cast< ODbaseIndex* >( xTunnel->getSomething(ODbaseIndex::getUnoTunnelImplementationId()) );
1609 : OSL_ENSURE(pIndex,"ODbaseTable::DeleteRow: No Index returned!");
1610 :
1611 0 : OSQLColumns::Vector::const_iterator aIter = _rCols.get().begin();
1612 0 : sal_Int32 nPos = 1;
1613 0 : for(;aIter != _rCols.get().end();++aIter,++nPos)
1614 : {
1615 0 : if(aCase(getString((*aIter)->getPropertyValue(OMetaConnection::getPropMap().getNameByIndex(PROPERTY_ID_REALNAME))),aColName))
1616 0 : break;
1617 : }
1618 0 : if (aIter == _rCols.get().end())
1619 0 : continue;
1620 :
1621 0 : pIndex->Delete(m_nFilePos,*(aRow->get())[nPos]);
1622 : }
1623 : }
1624 31 : }
1625 :
1626 1 : m_pFileStream->Seek(nFilePos);
1627 1 : (*m_pFileStream).WriteUChar( (sal_uInt8)'*' ); // mark the row in the table as deleted
1628 1 : m_pFileStream->Flush();
1629 2 : return sal_True;
1630 : }
1631 :
1632 106 : Reference<XPropertySet> ODbaseTable::isUniqueByColumnName(sal_Int32 _nColumnPos)
1633 : {
1634 : SAL_INFO( "connectivity.drivers", "dbase Ocke.Janssen@sun.com ODbaseTable::isUniqueByColumnName" );
1635 106 : if(!m_pIndexes)
1636 0 : refreshIndexes();
1637 106 : if(m_pIndexes->hasElements())
1638 : {
1639 0 : Reference<XPropertySet> xCol;
1640 0 : m_pColumns->getByIndex(_nColumnPos) >>= xCol;
1641 : OSL_ENSURE(xCol.is(),"ODbaseTable::isUniqueByColumnName column is null!");
1642 0 : OUString sColName;
1643 0 : xCol->getPropertyValue(OMetaConnection::getPropMap().getNameByIndex(PROPERTY_ID_NAME)) >>= sColName;
1644 :
1645 0 : Reference<XPropertySet> xIndex;
1646 0 : for(sal_Int32 i=0;i<m_pIndexes->getCount();++i)
1647 : {
1648 0 : xIndex.set(m_pIndexes->getByIndex(i), css::uno::UNO_QUERY);
1649 0 : if(xIndex.is() && getBOOL(xIndex->getPropertyValue(OMetaConnection::getPropMap().getNameByIndex(PROPERTY_ID_ISUNIQUE))))
1650 : {
1651 0 : Reference<XNameAccess> xCols(Reference<XColumnsSupplier>(xIndex,UNO_QUERY)->getColumns());
1652 0 : if(xCols->hasByName(sColName))
1653 0 : return xIndex;
1654 :
1655 : }
1656 0 : }
1657 : }
1658 106 : return Reference<XPropertySet>();
1659 : }
1660 :
1661 0 : static double toDouble(const OString& rString)
1662 : {
1663 0 : return ::rtl::math::stringToDouble( rString, '.', ',', NULL, NULL );
1664 : }
1665 :
1666 :
1667 5 : sal_Bool ODbaseTable::UpdateBuffer(OValueRefVector& rRow, OValueRefRow pOrgRow, const Reference<XIndexAccess>& _xCols, const bool bForceAllFields)
1668 : {
1669 : SAL_INFO( "connectivity.drivers", "dbase Ocke.Janssen@sun.com ODbaseTable::UpdateBuffer" );
1670 : OSL_ENSURE(m_pBuffer,"Buffer is NULL!");
1671 5 : if ( !m_pBuffer )
1672 0 : return sal_False;
1673 5 : sal_Int32 nByteOffset = 1;
1674 :
1675 : // Update fields:
1676 5 : Reference<XPropertySet> xCol;
1677 10 : Reference<XPropertySet> xIndex;
1678 : sal_uInt16 i;
1679 10 : OUString aColName;
1680 5 : const sal_Int32 nColumnCount = m_pColumns->getCount();
1681 10 : ::std::vector< Reference<XPropertySet> > aIndexedCols(nColumnCount);
1682 :
1683 5 : ::comphelper::UStringMixEqual aCase(isCaseSensitive());
1684 :
1685 10 : Reference<XIndexAccess> xColumns = m_pColumns;
1686 : // first search a key that exist already in the table
1687 80 : for (i = 0; i < nColumnCount; ++i)
1688 : {
1689 75 : sal_Int32 nPos = i;
1690 75 : if(_xCols != xColumns)
1691 : {
1692 0 : m_pColumns->getByIndex(i) >>= xCol;
1693 : OSL_ENSURE(xCol.is(),"ODbaseTable::UpdateBuffer column is null!");
1694 0 : xCol->getPropertyValue(OMetaConnection::getPropMap().getNameByIndex(PROPERTY_ID_NAME)) >>= aColName;
1695 :
1696 0 : for(nPos = 0;nPos<_xCols->getCount();++nPos)
1697 : {
1698 : Reference<XPropertySet> xFindCol(
1699 0 : _xCols->getByIndex(nPos), css::uno::UNO_QUERY);
1700 : OSL_ENSURE(xFindCol.is(),"ODbaseTable::UpdateBuffer column is null!");
1701 0 : if(aCase(getString(xFindCol->getPropertyValue(OMetaConnection::getPropMap().getNameByIndex(PROPERTY_ID_NAME))),aColName))
1702 0 : break;
1703 0 : }
1704 0 : if (nPos >= _xCols->getCount())
1705 0 : continue;
1706 : }
1707 :
1708 75 : ++nPos;
1709 75 : xIndex = isUniqueByColumnName(i);
1710 75 : aIndexedCols[i] = xIndex;
1711 75 : if (xIndex.is())
1712 : {
1713 : // first check if the value is different to the old one and when if it conform to the index
1714 0 : if(pOrgRow.is() && (rRow.get()[nPos]->getValue().isNull() || rRow.get()[nPos] == (pOrgRow->get())[nPos]))
1715 0 : continue;
1716 : else
1717 : {
1718 0 : Reference<XUnoTunnel> xTunnel(xIndex,UNO_QUERY);
1719 : OSL_ENSURE(xTunnel.is(),"No TunnelImplementation!");
1720 0 : ODbaseIndex* pIndex = reinterpret_cast< ODbaseIndex* >( xTunnel->getSomething(ODbaseIndex::getUnoTunnelImplementationId()) );
1721 : OSL_ENSURE(pIndex,"ODbaseTable::UpdateBuffer: No Index returned!");
1722 :
1723 0 : if (pIndex->Find(0,*rRow.get()[nPos]))
1724 : {
1725 : // There is no unique value
1726 0 : if ( aColName.isEmpty() )
1727 : {
1728 0 : m_pColumns->getByIndex(i) >>= xCol;
1729 : OSL_ENSURE(xCol.is(),"ODbaseTable::UpdateBuffer column is null!");
1730 0 : xCol->getPropertyValue(OMetaConnection::getPropMap().getNameByIndex(PROPERTY_ID_NAME)) >>= aColName;
1731 0 : xCol.clear();
1732 : } // if ( !aColName.getLength() )
1733 0 : const OUString sError( getConnection()->getResources().getResourceStringWithSubstitution(
1734 : STR_DUPLICATE_VALUE_IN_COLUMN
1735 : ,"$columnname$", aColName
1736 0 : ) );
1737 0 : ::dbtools::throwGenericSQLException( sError, *this );
1738 0 : }
1739 : }
1740 : }
1741 : }
1742 :
1743 : // when we are here there is no double key in the table
1744 :
1745 80 : for (i = 0; i < nColumnCount && nByteOffset <= m_nBufferSize ; ++i)
1746 : {
1747 : // Lengths for each data type:
1748 : OSL_ENSURE(i < m_aPrecisions.size(),"Illegal index!");
1749 75 : sal_Int32 nLen = 0;
1750 75 : sal_Int32 nType = 0;
1751 75 : sal_Int32 nScale = 0;
1752 75 : if ( i < m_aPrecisions.size() )
1753 : {
1754 75 : nLen = m_aPrecisions[i];
1755 75 : nType = m_aTypes[i];
1756 75 : nScale = m_aScales[i];
1757 : }
1758 : else
1759 : {
1760 0 : m_pColumns->getByIndex(i) >>= xCol;
1761 0 : if ( xCol.is() )
1762 : {
1763 0 : xCol->getPropertyValue(OMetaConnection::getPropMap().getNameByIndex(PROPERTY_ID_PRECISION)) >>= nLen;
1764 0 : xCol->getPropertyValue(OMetaConnection::getPropMap().getNameByIndex(PROPERTY_ID_TYPE)) >>= nType;
1765 0 : xCol->getPropertyValue(OMetaConnection::getPropMap().getNameByIndex(PROPERTY_ID_SCALE)) >>= nScale;
1766 : }
1767 : }
1768 :
1769 75 : bool bSetZero = false;
1770 75 : switch (nType)
1771 : {
1772 : case DataType::INTEGER:
1773 : case DataType::DOUBLE:
1774 : case DataType::TIMESTAMP:
1775 0 : bSetZero = true;
1776 : case DataType::LONGVARBINARY:
1777 : case DataType::DATE:
1778 : case DataType::BIT:
1779 : case DataType::LONGVARCHAR:
1780 37 : nLen = m_aRealFieldLengths[i];
1781 37 : break;
1782 : case DataType::DECIMAL:
1783 20 : nLen = SvDbaseConverter::ConvertPrecisionToDbase(nLen,nScale);
1784 20 : break; // The sign and the comma
1785 : default:
1786 18 : break;
1787 :
1788 : } // switch (nType)
1789 :
1790 75 : sal_Int32 nPos = i;
1791 75 : if(_xCols != xColumns)
1792 : {
1793 0 : m_pColumns->getByIndex(i) >>= xCol;
1794 : OSL_ENSURE(xCol.is(),"ODbaseTable::UpdateBuffer column is null!");
1795 0 : xCol->getPropertyValue(OMetaConnection::getPropMap().getNameByIndex(PROPERTY_ID_NAME)) >>= aColName;
1796 0 : for(nPos = 0;nPos<_xCols->getCount();++nPos)
1797 : {
1798 : Reference<XPropertySet> xFindCol(
1799 0 : _xCols->getByIndex(nPos), css::uno::UNO_QUERY);
1800 0 : if(aCase(getString(xFindCol->getPropertyValue(OMetaConnection::getPropMap().getNameByIndex(PROPERTY_ID_NAME))),aColName))
1801 0 : break;
1802 0 : }
1803 0 : if (nPos >= _xCols->getCount())
1804 : {
1805 0 : nByteOffset += nLen;
1806 70 : continue;
1807 : }
1808 : }
1809 :
1810 :
1811 :
1812 75 : ++nPos; // the row values start at 1
1813 75 : const ORowSetValue &thisColVal = rRow.get()[nPos]->get();
1814 75 : const bool thisColIsBound = thisColVal.isBound();
1815 75 : const bool thisColIsNull = !thisColIsBound || thisColVal.isNull();
1816 : // don't overwrite non-bound columns
1817 75 : if ( ! (bForceAllFields || thisColIsBound) )
1818 : {
1819 : // No - don't overwrite this field, it has not changed.
1820 40 : nByteOffset += nLen;
1821 40 : continue;
1822 : }
1823 35 : if (aIndexedCols[i].is())
1824 : {
1825 0 : Reference<XUnoTunnel> xTunnel(aIndexedCols[i],UNO_QUERY);
1826 : OSL_ENSURE(xTunnel.is(),"No TunnelImplementation!");
1827 0 : ODbaseIndex* pIndex = reinterpret_cast< ODbaseIndex* >( xTunnel->getSomething(ODbaseIndex::getUnoTunnelImplementationId()) );
1828 : OSL_ENSURE(pIndex,"ODbaseTable::UpdateBuffer: No Index returned!");
1829 : // Update !!
1830 0 : if (pOrgRow.is() && !thisColIsNull)
1831 0 : pIndex->Update(m_nFilePos, *(pOrgRow->get())[nPos], thisColVal);
1832 : else
1833 0 : pIndex->Insert(m_nFilePos, thisColVal);
1834 : }
1835 :
1836 35 : char* pData = (char *)(m_pBuffer + nByteOffset);
1837 35 : if (thisColIsNull)
1838 : {
1839 30 : if ( bSetZero )
1840 0 : memset(pData,0,nLen); // Clear to NULL char ('\0')
1841 : else
1842 30 : memset(pData,' ',nLen); // Clear to space/blank ('\0x20')
1843 30 : nByteOffset += nLen;
1844 : OSL_ENSURE( nByteOffset <= m_nBufferSize ,"ByteOffset > m_nBufferSize!");
1845 30 : continue;
1846 : }
1847 :
1848 : try
1849 : {
1850 5 : switch (nType)
1851 : {
1852 : case DataType::TIMESTAMP:
1853 : {
1854 0 : sal_Int32 nJulianDate = 0, nJulianTime = 0;
1855 0 : lcl_CalcJulDate(nJulianDate,nJulianTime, thisColVal);
1856 : // Exactly 8 bytes to copy:
1857 0 : memcpy(pData,&nJulianDate,4);
1858 0 : memcpy(pData+4,&nJulianTime,4);
1859 : }
1860 0 : break;
1861 : case DataType::DATE:
1862 : {
1863 0 : ::com::sun::star::util::Date aDate;
1864 0 : if(thisColVal.getTypeKind() == DataType::DOUBLE)
1865 0 : aDate = ::dbtools::DBTypeConversion::toDate(thisColVal.getDouble());
1866 : else
1867 0 : aDate = thisColVal;
1868 : char s[9];
1869 : snprintf(s,
1870 : sizeof(s),
1871 : "%04d%02d%02d",
1872 : (int)aDate.Year,
1873 : (int)aDate.Month,
1874 0 : (int)aDate.Day);
1875 :
1876 : // Exactly 8 bytes to copy:
1877 0 : strncpy(pData,s,sizeof s - 1);
1878 0 : } break;
1879 : case DataType::INTEGER:
1880 : {
1881 0 : sal_Int32 nValue = thisColVal;
1882 0 : memcpy(pData,&nValue,nLen);
1883 : }
1884 0 : break;
1885 : case DataType::DOUBLE:
1886 : {
1887 0 : const double d = thisColVal;
1888 0 : m_pColumns->getByIndex(i) >>= xCol;
1889 :
1890 0 : if (getBOOL(xCol->getPropertyValue(OMetaConnection::getPropMap().getNameByIndex(PROPERTY_ID_ISCURRENCY)))) // Currency is treated separately
1891 : {
1892 0 : sal_Int64 nValue = 0;
1893 0 : if ( m_aScales[i] )
1894 0 : nValue = (sal_Int64)(d * pow(10.0,(int)m_aScales[i]));
1895 : else
1896 0 : nValue = (sal_Int64)(d);
1897 0 : memcpy(pData,&nValue,nLen);
1898 : } // if (getBOOL(xCol->getPropertyValue(OMetaConnection::getPropMap().getNameByIndex(PROPERTY_ID_ISCURRENCY)))) // Currency is treated separately
1899 : else
1900 0 : memcpy(pData,&d,nLen);
1901 : }
1902 0 : break;
1903 : case DataType::DECIMAL:
1904 : {
1905 0 : memset(pData,' ',nLen); // Clear to NULL
1906 :
1907 0 : const double n = thisColVal;
1908 :
1909 : // one, because const_cast GetFormatPrecision on SvNumberFormat is not constant,
1910 : // even though it really could and should be
1911 0 : const OString aDefaultValue( ::rtl::math::doubleToString( n, rtl_math_StringFormat_F, nScale, '.', NULL, 0));
1912 0 : const sal_Int32 nValueLen = aDefaultValue.getLength();
1913 0 : if ( nValueLen <= nLen )
1914 : {
1915 : // Write value right-justified, padded with blanks to the left.
1916 0 : memcpy(pData+nLen-nValueLen,aDefaultValue.getStr(),nValueLen);
1917 : // write the resulting double back
1918 0 : *rRow.get()[nPos] = toDouble(aDefaultValue);
1919 : }
1920 : else
1921 : {
1922 0 : m_pColumns->getByIndex(i) >>= xCol;
1923 : OSL_ENSURE(xCol.is(),"ODbaseTable::UpdateBuffer column is null!");
1924 0 : xCol->getPropertyValue(OMetaConnection::getPropMap().getNameByIndex(PROPERTY_ID_NAME)) >>= aColName;
1925 0 : ::std::list< ::std::pair<const sal_Char* , OUString > > aStringToSubstitutes;
1926 0 : aStringToSubstitutes.push_back(::std::pair<const sal_Char* , OUString >("$columnname$", aColName));
1927 0 : aStringToSubstitutes.push_back(::std::pair<const sal_Char* , OUString >("$precision$", OUString::number(nLen)));
1928 0 : aStringToSubstitutes.push_back(::std::pair<const sal_Char* , OUString >("$scale$", OUString::number(nScale)));
1929 0 : aStringToSubstitutes.push_back(::std::pair<const sal_Char* , OUString >("$value$", OStringToOUString(aDefaultValue,RTL_TEXTENCODING_UTF8)));
1930 :
1931 0 : const OUString sError( getConnection()->getResources().getResourceStringWithSubstitution(
1932 : STR_INVALID_COLUMN_DECIMAL_VALUE
1933 : ,aStringToSubstitutes
1934 0 : ) );
1935 0 : ::dbtools::throwGenericSQLException( sError, *this );
1936 0 : }
1937 0 : } break;
1938 : case DataType::BIT:
1939 0 : *pData = thisColVal.getBool() ? 'T' : 'F';
1940 0 : break;
1941 : case DataType::LONGVARBINARY:
1942 : case DataType::LONGVARCHAR:
1943 : {
1944 1 : char cNext = pData[nLen]; // Mark's scratch and replaced by 0
1945 1 : pData[nLen] = '\0'; // This is because the buffer is always a sign of greater ...
1946 :
1947 1 : sal_Size nBlockNo = strtol((const char *)pData,NULL,10); // Block number read
1948 :
1949 : // Next initial character restore again:
1950 1 : pData[nLen] = cNext;
1951 1 : if (!m_pMemoStream || !WriteMemo(thisColVal, nBlockNo))
1952 0 : break;
1953 :
1954 1 : OString aBlock(OString::number(nBlockNo));
1955 : //align aBlock at the right of a nLen sequence, fill to the left with '0'
1956 2 : OStringBuffer aStr;
1957 1 : comphelper::string::padToLength(aStr, nLen - aBlock.getLength(), '0');
1958 1 : aStr.append(aBlock);
1959 :
1960 : // Copy characters:
1961 2 : memcpy(pData, aStr.getStr(), nLen);
1962 1 : } break;
1963 : default:
1964 : {
1965 4 : memset(pData,' ',nLen); // Clear to NULL
1966 :
1967 4 : OUString sStringToWrite( thisColVal.getString() );
1968 :
1969 : // convert the string, using the connection's encoding
1970 8 : OString sEncoded;
1971 :
1972 4 : DBTypeConversion::convertUnicodeStringToLength( sStringToWrite, sEncoded, nLen, m_eEncoding );
1973 8 : memcpy( pData, sEncoded.getStr(), sEncoded.getLength() );
1974 :
1975 : }
1976 4 : break;
1977 : }
1978 : }
1979 0 : catch( const SQLException& )
1980 : {
1981 0 : throw;
1982 : }
1983 0 : catch ( const Exception& )
1984 : {
1985 0 : m_pColumns->getByIndex(i) >>= xCol;
1986 : OSL_ENSURE( xCol.is(), "ODbaseTable::UpdateBuffer column is null!" );
1987 0 : if ( xCol.is() )
1988 0 : xCol->getPropertyValue(OMetaConnection::getPropMap().getNameByIndex(PROPERTY_ID_NAME)) >>= aColName;
1989 :
1990 0 : const OUString sError( getConnection()->getResources().getResourceStringWithSubstitution(
1991 : STR_INVALID_COLUMN_VALUE,
1992 : "$columnname$", aColName
1993 0 : ) );
1994 0 : ::dbtools::throwGenericSQLException( sError, *this );
1995 : }
1996 : // And more ...
1997 5 : nByteOffset += nLen;
1998 : OSL_ENSURE( nByteOffset <= m_nBufferSize ,"ByteOffset > m_nBufferSize!");
1999 : }
2000 10 : return sal_True;
2001 : }
2002 :
2003 :
2004 1 : sal_Bool ODbaseTable::WriteMemo(const ORowSetValue& aVariable, sal_Size& rBlockNr)
2005 : {
2006 : SAL_INFO( "connectivity.drivers", "dbase Ocke.Janssen@sun.com ODbaseTable::WriteMemo" );
2007 : // if the BlockNo 0 is given, the block will be appended at the end
2008 1 : sal_Size nSize = 0;
2009 1 : OString aStr;
2010 2 : ::com::sun::star::uno::Sequence<sal_Int8> aValue;
2011 : sal_uInt8 nHeader[4];
2012 1 : const bool bBinary = aVariable.getTypeKind() == DataType::LONGVARBINARY && m_aMemoHeader.db_typ == MemoFoxPro;
2013 1 : if ( bBinary )
2014 : {
2015 0 : aValue = aVariable.getSequence();
2016 0 : nSize = aValue.getLength();
2017 : }
2018 : else
2019 : {
2020 1 : nSize = DBTypeConversion::convertUnicodeString( aVariable.getString(), aStr, m_eEncoding );
2021 : }
2022 :
2023 : // append or overwrite
2024 1 : sal_Bool bAppend = rBlockNr == 0;
2025 :
2026 1 : if (!bAppend)
2027 : {
2028 0 : switch (m_aMemoHeader.db_typ)
2029 : {
2030 : case MemodBaseIII: // dBase III-Memofield, ends with 2 * Ctrl-Z
2031 0 : bAppend = nSize > (512 - 2);
2032 0 : break;
2033 : case MemoFoxPro:
2034 : case MemodBaseIV: // dBase IV-Memofield with length
2035 : {
2036 : char sHeader[4];
2037 0 : m_pMemoStream->Seek(rBlockNr * m_aMemoHeader.db_size);
2038 0 : m_pMemoStream->SeekRel(4L);
2039 0 : m_pMemoStream->Read(sHeader,4);
2040 :
2041 : sal_Size nOldSize;
2042 0 : if (m_aMemoHeader.db_typ == MemoFoxPro)
2043 0 : nOldSize = ((((unsigned char)sHeader[0]) * 256 +
2044 0 : (unsigned char)sHeader[1]) * 256 +
2045 0 : (unsigned char)sHeader[2]) * 256 +
2046 0 : (unsigned char)sHeader[3];
2047 : else
2048 0 : nOldSize = ((((unsigned char)sHeader[3]) * 256 +
2049 0 : (unsigned char)sHeader[2]) * 256 +
2050 0 : (unsigned char)sHeader[1]) * 256 +
2051 0 : (unsigned char)sHeader[0] - 8;
2052 :
2053 : // fits the new length in the used blocks
2054 0 : sal_Size nUsedBlocks = ((nSize + 8) / m_aMemoHeader.db_size) + (((nSize + 8) % m_aMemoHeader.db_size > 0) ? 1 : 0),
2055 0 : nOldUsedBlocks = ((nOldSize + 8) / m_aMemoHeader.db_size) + (((nOldSize + 8) % m_aMemoHeader.db_size > 0) ? 1 : 0);
2056 0 : bAppend = nUsedBlocks > nOldUsedBlocks;
2057 : }
2058 : }
2059 : }
2060 :
2061 1 : if (bAppend)
2062 : {
2063 1 : sal_Size nStreamSize = m_pMemoStream->Seek(STREAM_SEEK_TO_END);
2064 : // fill last block
2065 1 : rBlockNr = (nStreamSize / m_aMemoHeader.db_size) + ((nStreamSize % m_aMemoHeader.db_size) > 0 ? 1 : 0);
2066 :
2067 1 : m_pMemoStream->SetStreamSize(rBlockNr * m_aMemoHeader.db_size);
2068 1 : m_pMemoStream->Seek(STREAM_SEEK_TO_END);
2069 : }
2070 : else
2071 : {
2072 0 : m_pMemoStream->Seek(rBlockNr * m_aMemoHeader.db_size);
2073 : }
2074 :
2075 1 : switch (m_aMemoHeader.db_typ)
2076 : {
2077 : case MemodBaseIII: // dBase III-Memofield, ends with Ctrl-Z
2078 : {
2079 1 : const char cEOF = (char) DBF_EOL;
2080 1 : nSize++;
2081 1 : m_pMemoStream->Write( aStr.getStr(), aStr.getLength() );
2082 1 : (*m_pMemoStream).WriteChar( cEOF ).WriteChar( cEOF );
2083 1 : } break;
2084 : case MemoFoxPro:
2085 : case MemodBaseIV: // dBase IV-Memofeld with length
2086 : {
2087 0 : if ( MemodBaseIV == m_aMemoHeader.db_typ )
2088 0 : (*m_pMemoStream).WriteUChar( (sal_uInt8)0xFF )
2089 0 : .WriteUChar( (sal_uInt8)0xFF )
2090 0 : .WriteUChar( (sal_uInt8)0x08 );
2091 : else
2092 0 : (*m_pMemoStream).WriteUChar( (sal_uInt8)0x00 )
2093 0 : .WriteUChar( (sal_uInt8)0x00 )
2094 0 : .WriteUChar( (sal_uInt8)0x00 );
2095 :
2096 0 : sal_uInt32 nWriteSize = nSize;
2097 0 : if (m_aMemoHeader.db_typ == MemoFoxPro)
2098 : {
2099 0 : if ( bBinary )
2100 0 : (*m_pMemoStream).WriteUChar( (sal_uInt8) 0x00 ); // Picture
2101 : else
2102 0 : (*m_pMemoStream).WriteUChar( (sal_uInt8) 0x01 ); // Memo
2103 0 : for (int i = 4; i > 0; nWriteSize >>= 8)
2104 0 : nHeader[--i] = (sal_uInt8) (nWriteSize % 256);
2105 : }
2106 : else
2107 : {
2108 0 : (*m_pMemoStream).WriteUChar( (sal_uInt8) 0x00 );
2109 0 : nWriteSize += 8;
2110 0 : for (int i = 0; i < 4; nWriteSize >>= 8)
2111 0 : nHeader[i++] = (sal_uInt8) (nWriteSize % 256);
2112 : }
2113 :
2114 0 : m_pMemoStream->Write(nHeader,4);
2115 0 : if ( bBinary )
2116 0 : m_pMemoStream->Write( aValue.getConstArray(), aValue.getLength() );
2117 : else
2118 0 : m_pMemoStream->Write( aStr.getStr(), aStr.getLength() );
2119 0 : m_pMemoStream->Flush();
2120 : }
2121 : }
2122 :
2123 :
2124 : // Write the new block number
2125 1 : if (bAppend)
2126 : {
2127 1 : sal_Size nStreamSize = m_pMemoStream->Seek(STREAM_SEEK_TO_END);
2128 1 : m_aMemoHeader.db_next = (nStreamSize / m_aMemoHeader.db_size) + ((nStreamSize % m_aMemoHeader.db_size) > 0 ? 1 : 0);
2129 :
2130 : // Write the new block number
2131 1 : m_pMemoStream->Seek(0L);
2132 1 : (*m_pMemoStream).WriteUInt32( m_aMemoHeader.db_next );
2133 1 : m_pMemoStream->Flush();
2134 : }
2135 2 : return sal_True;
2136 : }
2137 :
2138 :
2139 : // XAlterTable
2140 0 : void SAL_CALL ODbaseTable::alterColumnByName( const OUString& colName, const Reference< XPropertySet >& descriptor ) throw(SQLException, NoSuchElementException, RuntimeException, std::exception)
2141 : {
2142 : SAL_INFO( "connectivity.drivers", "dbase Ocke.Janssen@sun.com ODbaseTable::alterColumnByName" );
2143 0 : ::osl::MutexGuard aGuard(m_aMutex);
2144 0 : checkDisposed(OTableDescriptor_BASE::rBHelper.bDisposed);
2145 :
2146 :
2147 0 : Reference<XDataDescriptorFactory> xOldColumn;
2148 0 : m_pColumns->getByName(colName) >>= xOldColumn;
2149 :
2150 0 : alterColumn(m_pColumns->findColumn(colName)-1,descriptor,xOldColumn);
2151 0 : }
2152 :
2153 0 : void SAL_CALL ODbaseTable::alterColumnByIndex( sal_Int32 index, const Reference< XPropertySet >& descriptor ) throw(SQLException, ::com::sun::star::lang::IndexOutOfBoundsException, RuntimeException, std::exception)
2154 : {
2155 : SAL_INFO( "connectivity.drivers", "dbase Ocke.Janssen@sun.com ODbaseTable::alterColumnByIndex" );
2156 0 : ::osl::MutexGuard aGuard(m_aMutex);
2157 0 : checkDisposed(OTableDescriptor_BASE::rBHelper.bDisposed);
2158 :
2159 0 : if(index < 0 || index >= m_pColumns->getCount())
2160 0 : throw IndexOutOfBoundsException(OUString::number(index),*this);
2161 :
2162 0 : Reference<XDataDescriptorFactory> xOldColumn;
2163 0 : m_pColumns->getByIndex(index) >>= xOldColumn;
2164 0 : alterColumn(index,descriptor,xOldColumn);
2165 0 : }
2166 :
2167 0 : void ODbaseTable::alterColumn(sal_Int32 index,
2168 : const Reference< XPropertySet >& descriptor ,
2169 : const Reference< XDataDescriptorFactory >& xOldColumn )
2170 : {
2171 : SAL_INFO( "connectivity.drivers", "dbase Ocke.Janssen@sun.com ODbaseTable::alterColumn" );
2172 0 : if(index < 0 || index >= m_pColumns->getCount())
2173 0 : throw IndexOutOfBoundsException(OUString::number(index),*this);
2174 :
2175 0 : ODbaseTable* pNewTable = NULL;
2176 : try
2177 : {
2178 : OSL_ENSURE(descriptor.is(),"ODbaseTable::alterColumn: descriptor can not be null!");
2179 : // creates a copy of the original column and copy all properties from descriptor in xCopyColumn
2180 0 : Reference<XPropertySet> xCopyColumn;
2181 0 : if(xOldColumn.is())
2182 0 : xCopyColumn = xOldColumn->createDataDescriptor();
2183 : else
2184 0 : xCopyColumn = new OColumn(getConnection()->getMetaData()->supportsMixedCaseQuotedIdentifiers());
2185 :
2186 0 : ::comphelper::copyProperties(descriptor,xCopyColumn);
2187 :
2188 : // creates a temp file
2189 :
2190 0 : OUString sTempName = createTempFile();
2191 :
2192 0 : pNewTable = new ODbaseTable(m_pTables,static_cast<ODbaseConnection*>(m_pConnection));
2193 0 : Reference<XPropertySet> xHoldTable = pNewTable;
2194 0 : pNewTable->setPropertyValue(OMetaConnection::getPropMap().getNameByIndex(PROPERTY_ID_NAME),makeAny(sTempName));
2195 0 : Reference<XAppend> xAppend(pNewTable->getColumns(),UNO_QUERY);
2196 : OSL_ENSURE(xAppend.is(),"ODbaseTable::alterColumn: No XAppend interface!");
2197 :
2198 : // copy the structure
2199 0 : sal_Int32 i=0;
2200 0 : for(;i < index;++i)
2201 : {
2202 0 : Reference<XPropertySet> xProp;
2203 0 : m_pColumns->getByIndex(i) >>= xProp;
2204 0 : Reference<XDataDescriptorFactory> xColumn(xProp,UNO_QUERY);
2205 0 : Reference<XPropertySet> xCpy;
2206 0 : if(xColumn.is())
2207 0 : xCpy = xColumn->createDataDescriptor();
2208 : else
2209 0 : xCpy = new OColumn(getConnection()->getMetaData()->supportsMixedCaseQuotedIdentifiers());
2210 0 : ::comphelper::copyProperties(xProp,xCpy);
2211 0 : xAppend->appendByDescriptor(xCpy);
2212 0 : }
2213 0 : ++i; // now insert our new column
2214 0 : xAppend->appendByDescriptor(xCopyColumn);
2215 :
2216 0 : for(;i < m_pColumns->getCount();++i)
2217 : {
2218 0 : Reference<XPropertySet> xProp;
2219 0 : m_pColumns->getByIndex(i) >>= xProp;
2220 0 : Reference<XDataDescriptorFactory> xColumn(xProp,UNO_QUERY);
2221 0 : Reference<XPropertySet> xCpy;
2222 0 : if(xColumn.is())
2223 0 : xCpy = xColumn->createDataDescriptor();
2224 : else
2225 0 : xCpy = new OColumn(getConnection()->getMetaData()->supportsMixedCaseQuotedIdentifiers());
2226 0 : ::comphelper::copyProperties(xProp,xCpy);
2227 0 : xAppend->appendByDescriptor(xCpy);
2228 0 : }
2229 :
2230 : // construct the new table
2231 0 : if(!pNewTable->CreateImpl())
2232 : {
2233 0 : const OUString sError( getConnection()->getResources().getResourceStringWithSubstitution(
2234 : STR_COLUMN_NOT_ALTERABLE,
2235 0 : "$columnname$", ::comphelper::getString(descriptor->getPropertyValue(OMetaConnection::getPropMap().getNameByIndex(PROPERTY_ID_NAME)))
2236 0 : ) );
2237 0 : ::dbtools::throwGenericSQLException( sError, *this );
2238 : }
2239 :
2240 0 : pNewTable->construct();
2241 :
2242 : // copy the data
2243 0 : copyData(pNewTable,0);
2244 :
2245 : // now drop the old one
2246 0 : if( DropImpl() ) // we don't want to delete the memo columns too
2247 : {
2248 : // rename the new one to the old one
2249 0 : pNewTable->renameImpl(m_Name);
2250 : // release the temp file
2251 0 : pNewTable = NULL;
2252 0 : ::comphelper::disposeComponent(xHoldTable);
2253 : }
2254 : else
2255 : {
2256 0 : pNewTable = NULL;
2257 : }
2258 0 : FileClose();
2259 0 : construct();
2260 0 : if(m_pColumns)
2261 0 : m_pColumns->refresh();
2262 :
2263 : }
2264 0 : catch(const SQLException&)
2265 : {
2266 0 : throw;
2267 : }
2268 0 : catch(const Exception&)
2269 : {
2270 : SAL_WARN( "connectivity.drivers","ODbaseTable::alterColumn: Exception occurred!");
2271 0 : throw;
2272 : }
2273 0 : }
2274 :
2275 0 : Reference< XDatabaseMetaData> ODbaseTable::getMetaData() const
2276 : {
2277 : SAL_INFO( "connectivity.drivers", "dbase Ocke.Janssen@sun.com ODbaseTable::getMetaData" );
2278 0 : return getConnection()->getMetaData();
2279 : }
2280 :
2281 0 : void SAL_CALL ODbaseTable::rename( const OUString& newName ) throw(::com::sun::star::sdbc::SQLException, ::com::sun::star::container::ElementExistException, ::com::sun::star::uno::RuntimeException, std::exception)
2282 : {
2283 : SAL_INFO( "connectivity.drivers", "dbase Ocke.Janssen@sun.com ODbaseTable::rename" );
2284 0 : ::osl::MutexGuard aGuard(m_aMutex);
2285 0 : checkDisposed(OTableDescriptor_BASE::rBHelper.bDisposed);
2286 0 : if(m_pTables && m_pTables->hasByName(newName))
2287 0 : throw ElementExistException(newName,*this);
2288 :
2289 :
2290 0 : renameImpl(newName);
2291 :
2292 0 : ODbaseTable_BASE::rename(newName);
2293 :
2294 0 : construct();
2295 0 : if(m_pColumns)
2296 0 : m_pColumns->refresh();
2297 0 : }
2298 : namespace
2299 : {
2300 0 : void renameFile(OConnection* _pConenction,const OUString& oldName,
2301 : const OUString& newName,const OUString& _sExtension)
2302 : {
2303 0 : OUString aName = ODbaseTable::getEntry(_pConenction,oldName);
2304 0 : if(aName.isEmpty())
2305 : {
2306 0 : OUString aIdent = _pConenction->getContent()->getIdentifier()->getContentIdentifier();
2307 0 : if ( aIdent.lastIndexOf('/') != (aIdent.getLength()-1) )
2308 0 : aIdent += "/";
2309 0 : aIdent += oldName;
2310 0 : aName = aIdent;
2311 : }
2312 0 : INetURLObject aURL;
2313 0 : aURL.SetURL(aName);
2314 :
2315 0 : aURL.setExtension( _sExtension );
2316 0 : OUString sNewName(newName + "." + _sExtension);
2317 :
2318 : try
2319 : {
2320 0 : Content aContent(aURL.GetMainURL(INetURLObject::NO_DECODE),Reference<XCommandEnvironment>(), comphelper::getProcessComponentContext());
2321 :
2322 0 : Sequence< PropertyValue > aProps( 1 );
2323 0 : aProps[0].Name = "Title";
2324 0 : aProps[0].Handle = -1; // n/a
2325 0 : aProps[0].Value = makeAny( sNewName );
2326 0 : Sequence< Any > aValues;
2327 0 : aContent.executeCommand( "setPropertyValues",makeAny(aProps) ) >>= aValues;
2328 0 : if(aValues.getLength() && aValues[0].hasValue())
2329 0 : throw Exception();
2330 : }
2331 0 : catch(const Exception&)
2332 : {
2333 0 : throw ElementExistException(newName,NULL);
2334 0 : }
2335 0 : }
2336 : }
2337 :
2338 0 : void SAL_CALL ODbaseTable::renameImpl( const OUString& newName ) throw(::com::sun::star::sdbc::SQLException, ::com::sun::star::container::ElementExistException, ::com::sun::star::uno::RuntimeException)
2339 : {
2340 : SAL_INFO( "connectivity.drivers", "dbase Ocke.Janssen@sun.com ODbaseTable::getEntry" );
2341 0 : ::osl::MutexGuard aGuard(m_aMutex);
2342 :
2343 0 : FileClose();
2344 :
2345 :
2346 0 : renameFile(m_pConnection,m_Name,newName,m_pConnection->getExtension());
2347 0 : if ( HasMemoFields() )
2348 : { // delete the memo fields
2349 0 : OUString sExt("dbt");
2350 0 : renameFile(m_pConnection,m_Name,newName,sExt);
2351 0 : }
2352 0 : }
2353 :
2354 0 : void ODbaseTable::addColumn(const Reference< XPropertySet >& _xNewColumn)
2355 : {
2356 : SAL_INFO( "connectivity.drivers", "dbase Ocke.Janssen@sun.com ODbaseTable::addColumn" );
2357 0 : OUString sTempName = createTempFile();
2358 :
2359 0 : ODbaseTable* pNewTable = new ODbaseTable(m_pTables,static_cast<ODbaseConnection*>(m_pConnection));
2360 0 : Reference< XPropertySet > xHold = pNewTable;
2361 0 : pNewTable->setPropertyValue(OMetaConnection::getPropMap().getNameByIndex(PROPERTY_ID_NAME),makeAny(sTempName));
2362 : {
2363 0 : Reference<XAppend> xAppend(pNewTable->getColumns(),UNO_QUERY);
2364 0 : sal_Bool bCase = getConnection()->getMetaData()->supportsMixedCaseQuotedIdentifiers();
2365 : // copy the structure
2366 0 : for(sal_Int32 i=0;i < m_pColumns->getCount();++i)
2367 : {
2368 0 : Reference<XPropertySet> xProp;
2369 0 : m_pColumns->getByIndex(i) >>= xProp;
2370 0 : Reference<XDataDescriptorFactory> xColumn(xProp,UNO_QUERY);
2371 0 : Reference<XPropertySet> xCpy;
2372 0 : if(xColumn.is())
2373 0 : xCpy = xColumn->createDataDescriptor();
2374 : else
2375 : {
2376 0 : xCpy = new OColumn(bCase);
2377 0 : ::comphelper::copyProperties(xProp,xCpy);
2378 : }
2379 :
2380 0 : xAppend->appendByDescriptor(xCpy);
2381 0 : }
2382 0 : Reference<XPropertySet> xCpy = new OColumn(bCase);
2383 0 : ::comphelper::copyProperties(_xNewColumn,xCpy);
2384 0 : xAppend->appendByDescriptor(xCpy);
2385 : }
2386 :
2387 : // construct the new table
2388 0 : if(!pNewTable->CreateImpl())
2389 : {
2390 0 : const OUString sError( getConnection()->getResources().getResourceStringWithSubstitution(
2391 : STR_COLUMN_NOT_ADDABLE,
2392 0 : "$columnname$", ::comphelper::getString(_xNewColumn->getPropertyValue(OMetaConnection::getPropMap().getNameByIndex(PROPERTY_ID_NAME)))
2393 0 : ) );
2394 0 : ::dbtools::throwGenericSQLException( sError, *this );
2395 : }
2396 :
2397 0 : sal_Bool bAlreadyDroped = sal_False;
2398 : try
2399 : {
2400 0 : pNewTable->construct();
2401 : // copy the data
2402 0 : copyData(pNewTable,pNewTable->m_pColumns->getCount());
2403 : // drop the old table
2404 0 : if(DropImpl())
2405 : {
2406 0 : bAlreadyDroped = sal_True;
2407 0 : pNewTable->renameImpl(m_Name);
2408 : // release the temp file
2409 : }
2410 0 : xHold = pNewTable = NULL;
2411 :
2412 0 : FileClose();
2413 0 : construct();
2414 0 : if(m_pColumns)
2415 0 : m_pColumns->refresh();
2416 : }
2417 0 : catch(const SQLException&)
2418 : {
2419 : // here we know that the old table wasn't dropped before
2420 0 : if(!bAlreadyDroped)
2421 0 : xHold = pNewTable = NULL;
2422 :
2423 0 : throw;
2424 0 : }
2425 0 : }
2426 :
2427 0 : void ODbaseTable::dropColumn(sal_Int32 _nPos)
2428 : {
2429 : SAL_INFO( "connectivity.drivers", "dbase Ocke.Janssen@sun.com ODbaseTable::dropColumn" );
2430 0 : OUString sTempName = createTempFile();
2431 :
2432 0 : ODbaseTable* pNewTable = new ODbaseTable(m_pTables,static_cast<ODbaseConnection*>(m_pConnection));
2433 0 : Reference< XPropertySet > xHold = pNewTable;
2434 0 : pNewTable->setPropertyValue(OMetaConnection::getPropMap().getNameByIndex(PROPERTY_ID_NAME),makeAny(sTempName));
2435 : {
2436 0 : Reference<XAppend> xAppend(pNewTable->getColumns(),UNO_QUERY);
2437 0 : sal_Bool bCase = getConnection()->getMetaData()->supportsMixedCaseQuotedIdentifiers();
2438 : // copy the structure
2439 0 : for(sal_Int32 i=0;i < m_pColumns->getCount();++i)
2440 : {
2441 0 : if(_nPos != i)
2442 : {
2443 0 : Reference<XPropertySet> xProp;
2444 0 : m_pColumns->getByIndex(i) >>= xProp;
2445 0 : Reference<XDataDescriptorFactory> xColumn(xProp,UNO_QUERY);
2446 0 : Reference<XPropertySet> xCpy;
2447 0 : if(xColumn.is())
2448 0 : xCpy = xColumn->createDataDescriptor();
2449 : else
2450 : {
2451 0 : xCpy = new OColumn(bCase);
2452 0 : ::comphelper::copyProperties(xProp,xCpy);
2453 : }
2454 0 : xAppend->appendByDescriptor(xCpy);
2455 : }
2456 0 : }
2457 : }
2458 :
2459 : // construct the new table
2460 0 : if(!pNewTable->CreateImpl())
2461 : {
2462 0 : xHold = pNewTable = NULL;
2463 0 : const OUString sError( getConnection()->getResources().getResourceStringWithSubstitution(
2464 : STR_COLUMN_NOT_DROP,
2465 : "$position$", OUString::number(_nPos)
2466 0 : ) );
2467 0 : ::dbtools::throwGenericSQLException( sError, *this );
2468 : }
2469 0 : pNewTable->construct();
2470 : // copy the data
2471 0 : copyData(pNewTable,_nPos);
2472 : // drop the old table
2473 0 : if(DropImpl())
2474 0 : pNewTable->renameImpl(m_Name);
2475 : // release the temp file
2476 :
2477 0 : xHold = pNewTable = NULL;
2478 :
2479 0 : FileClose();
2480 0 : construct();
2481 0 : }
2482 :
2483 0 : OUString ODbaseTable::createTempFile()
2484 : {
2485 : SAL_INFO( "connectivity.drivers", "dbase Ocke.Janssen@sun.com ODbaseTable::createTempFile" );
2486 0 : OUString aIdent = m_pConnection->getContent()->getIdentifier()->getContentIdentifier();
2487 0 : if ( aIdent.lastIndexOf('/') != (aIdent.getLength()-1) )
2488 0 : aIdent += "/";
2489 :
2490 0 : OUString sTempName(aIdent);
2491 0 : OUString sExt(OUString(".") + m_pConnection->getExtension());
2492 0 : OUString sName(m_Name);
2493 0 : TempFile aTempFile(sName, &sExt, &sTempName);
2494 0 : if(!aTempFile.IsValid())
2495 0 : getConnection()->throwGenericSQLException(STR_COULD_NOT_ALTER_TABLE, *this);
2496 :
2497 0 : INetURLObject aURL;
2498 0 : aURL.SetSmartProtocol(INET_PROT_FILE);
2499 0 : aURL.SetURL(aTempFile.GetURL());
2500 :
2501 0 : OUString sNewName(aURL.getName().copy(0, aURL.getName().getLength() - sExt.getLength()));
2502 :
2503 0 : return sNewName;
2504 : }
2505 :
2506 0 : void ODbaseTable::copyData(ODbaseTable* _pNewTable,sal_Int32 _nPos)
2507 : {
2508 : SAL_INFO( "connectivity.drivers", "dbase Ocke.Janssen@sun.com ODbaseTable::copyData" );
2509 0 : sal_Int32 nPos = _nPos + 1; // +1 because we always have the bookmark clumn as well
2510 0 : OValueRefRow aRow = new OValueRefVector(m_pColumns->getCount());
2511 0 : OValueRefRow aInsertRow;
2512 0 : if(_nPos)
2513 : {
2514 0 : aInsertRow = new OValueRefVector(_pNewTable->m_pColumns->getCount());
2515 0 : ::std::for_each(aInsertRow->get().begin(),aInsertRow->get().end(),TSetRefBound(true));
2516 : }
2517 : else
2518 0 : aInsertRow = aRow;
2519 :
2520 : // we only have to bind the values which we need to copy into the new table
2521 0 : ::std::for_each(aRow->get().begin(),aRow->get().end(),TSetRefBound(true));
2522 0 : if(_nPos && (_nPos < (sal_Int32)aRow->get().size()))
2523 0 : (aRow->get())[nPos]->setBound(false);
2524 :
2525 :
2526 0 : sal_Bool bOk = sal_True;
2527 : sal_Int32 nCurPos;
2528 0 : OValueRefVector::Vector::iterator aIter;
2529 0 : for(sal_uInt32 nRowPos = 0; nRowPos < m_aHeader.db_anz;++nRowPos)
2530 : {
2531 0 : bOk = seekRow( IResultSetHelper::BOOKMARK, nRowPos+1, nCurPos );
2532 0 : if ( bOk )
2533 : {
2534 0 : bOk = fetchRow( aRow, *m_aColumns, sal_True, sal_True);
2535 0 : if ( bOk && !aRow->isDeleted() ) // copy only not deleted rows
2536 : {
2537 : // special handling when pos == 0 then we don't have to distinguish between the two rows
2538 0 : if(_nPos)
2539 : {
2540 0 : aIter = aRow->get().begin()+1;
2541 0 : sal_Int32 nCount = 1;
2542 0 : for(OValueRefVector::Vector::iterator aInsertIter = aInsertRow->get().begin()+1; aIter != aRow->get().end() && aInsertIter != aInsertRow->get().end();++aIter,++nCount)
2543 : {
2544 0 : if(nPos != nCount)
2545 : {
2546 0 : (*aInsertIter)->setValue( (*aIter)->getValue() );
2547 0 : ++aInsertIter;
2548 : }
2549 : }
2550 : }
2551 0 : bOk = _pNewTable->InsertRow(*aInsertRow,sal_True,_pNewTable->m_pColumns);
2552 : OSL_ENSURE(bOk,"Row could not be inserted!");
2553 : }
2554 : else
2555 : OSL_ENSURE(bOk,"Row could not be fetched!");
2556 : }
2557 : else
2558 : {
2559 : OSL_ASSERT(false);
2560 : }
2561 0 : } // for(sal_uInt32 nRowPos = 0; nRowPos < m_aHeader.db_anz;++nRowPos)
2562 0 : }
2563 :
2564 0 : void ODbaseTable::throwInvalidDbaseFormat()
2565 : {
2566 : SAL_INFO( "connectivity.drivers", "dbase Ocke.Janssen@sun.com ODbaseTable::throwInvalidDbaseFormat" );
2567 0 : FileClose();
2568 : // no dbase file
2569 :
2570 0 : const OUString sError( getConnection()->getResources().getResourceStringWithSubstitution(
2571 : STR_INVALID_DBASE_FILE,
2572 : "$filename$", getEntry(m_pConnection,m_Name)
2573 0 : ) );
2574 0 : ::dbtools::throwGenericSQLException( sError, *this );
2575 0 : }
2576 :
2577 21 : void ODbaseTable::refreshHeader()
2578 : {
2579 : SAL_INFO( "connectivity.drivers", "dbase Ocke.Janssen@sun.com ODbaseTable::refreshHeader" );
2580 21 : if ( m_aHeader.db_anz == 0 )
2581 0 : readHeader();
2582 21 : }
2583 :
2584 1720 : sal_Bool ODbaseTable::seekRow(IResultSetHelper::Movement eCursorPosition, sal_Int32 nOffset, sal_Int32& nCurPos)
2585 : {
2586 : SAL_INFO( "connectivity.drivers", "dbase Ocke.Janssen@sun.com ODbaseTable::seekRow" );
2587 :
2588 : // prepare positioning:
2589 : OSL_ENSURE(m_pFileStream,"ODbaseTable::seekRow: FileStream is NULL!");
2590 :
2591 1720 : sal_uInt32 nNumberOfRecords = (sal_uInt32)m_aHeader.db_anz;
2592 1720 : sal_uInt32 nTempPos = m_nFilePos;
2593 1720 : m_nFilePos = nCurPos;
2594 :
2595 1720 : switch(eCursorPosition)
2596 : {
2597 : case IResultSetHelper::NEXT:
2598 130 : ++m_nFilePos;
2599 130 : break;
2600 : case IResultSetHelper::PRIOR:
2601 0 : if (m_nFilePos > 0)
2602 0 : --m_nFilePos;
2603 0 : break;
2604 : case IResultSetHelper::FIRST:
2605 0 : m_nFilePos = 1;
2606 0 : break;
2607 : case IResultSetHelper::LAST:
2608 0 : m_nFilePos = nNumberOfRecords;
2609 0 : break;
2610 : case IResultSetHelper::RELATIVE:
2611 0 : m_nFilePos = (((sal_Int32)m_nFilePos) + nOffset < 0) ? 0L
2612 0 : : (sal_uInt32)(((sal_Int32)m_nFilePos) + nOffset);
2613 0 : break;
2614 : case IResultSetHelper::ABSOLUTE:
2615 : case IResultSetHelper::BOOKMARK:
2616 1590 : m_nFilePos = (sal_uInt32)nOffset;
2617 1590 : break;
2618 : }
2619 :
2620 1720 : if (m_nFilePos > (sal_Int32)nNumberOfRecords)
2621 0 : m_nFilePos = (sal_Int32)nNumberOfRecords + 1;
2622 :
2623 1720 : if (m_nFilePos == 0 || m_nFilePos == (sal_Int32)nNumberOfRecords + 1)
2624 : goto Error;
2625 : else
2626 : {
2627 1714 : sal_Size nEntryLen = m_aHeader.db_slng;
2628 :
2629 : OSL_ENSURE(m_nFilePos >= 1,"SdbDBFCursor::FileFetchRow: ungueltige Record-Position");
2630 1714 : sal_Size nPos = m_aHeader.db_kopf + (sal_Size)(m_nFilePos-1) * nEntryLen;
2631 :
2632 1714 : m_pFileStream->Seek(nPos);
2633 1714 : if (m_pFileStream->GetError() != ERRCODE_NONE)
2634 0 : goto Error;
2635 :
2636 1714 : m_pFileStream->Read((char*)m_pBuffer, nEntryLen);
2637 1714 : if (m_pFileStream->GetError() != ERRCODE_NONE)
2638 0 : goto Error;
2639 : }
2640 1714 : goto End;
2641 :
2642 : Error:
2643 6 : switch(eCursorPosition)
2644 : {
2645 : case IResultSetHelper::PRIOR:
2646 : case IResultSetHelper::FIRST:
2647 0 : m_nFilePos = 0;
2648 0 : break;
2649 : case IResultSetHelper::LAST:
2650 : case IResultSetHelper::NEXT:
2651 : case IResultSetHelper::ABSOLUTE:
2652 : case IResultSetHelper::RELATIVE:
2653 6 : if (nOffset > 0)
2654 0 : m_nFilePos = nNumberOfRecords + 1;
2655 6 : else if (nOffset < 0)
2656 0 : m_nFilePos = 0;
2657 6 : break;
2658 : case IResultSetHelper::BOOKMARK:
2659 0 : m_nFilePos = nTempPos; // last position
2660 : }
2661 6 : return sal_False;
2662 :
2663 : End:
2664 1714 : nCurPos = m_nFilePos;
2665 1714 : return sal_True;
2666 : }
2667 :
2668 9442 : sal_Bool ODbaseTable::ReadMemo(sal_Size nBlockNo, ORowSetValue& aVariable)
2669 : {
2670 : SAL_INFO( "connectivity.drivers", "dbase Ocke.Janssen@sun.com ODbaseTable::ReadMemo" );
2671 9442 : bool bIsText = true;
2672 :
2673 9442 : m_pMemoStream->Seek(nBlockNo * m_aMemoHeader.db_size);
2674 9442 : switch (m_aMemoHeader.db_typ)
2675 : {
2676 : case MemodBaseIII: // dBase III-Memofield, ends with Ctrl-Z
2677 : {
2678 9442 : const char cEOF = (char) DBF_EOL;
2679 9442 : OStringBuffer aBStr;
2680 : static char aBuf[514];
2681 9442 : aBuf[512] = 0; // avoid random value
2682 9442 : sal_Bool bReady = sal_False;
2683 :
2684 9442 : do
2685 : {
2686 9442 : m_pMemoStream->Read(&aBuf,512);
2687 :
2688 9442 : sal_uInt16 i = 0;
2689 9442 : while (aBuf[i] != cEOF && ++i < 512)
2690 : ;
2691 9442 : bReady = aBuf[i] == cEOF;
2692 :
2693 9442 : aBuf[i] = 0;
2694 9442 : aBStr.append(aBuf);
2695 :
2696 9442 : } while (!bReady && !m_pMemoStream->IsEof());
2697 :
2698 18884 : aVariable = OStringToOUString(aBStr.makeStringAndClear(),
2699 18884 : m_eEncoding);
2700 :
2701 9442 : } break;
2702 : case MemoFoxPro:
2703 : case MemodBaseIV: // dBase IV-Memofield with length
2704 : {
2705 : char sHeader[4];
2706 0 : m_pMemoStream->Read(sHeader,4);
2707 : // Foxpro stores text and binary data
2708 0 : if (m_aMemoHeader.db_typ == MemoFoxPro)
2709 : {
2710 0 : bIsText = sHeader[3] != 0;
2711 : }
2712 0 : else if (((sal_uInt8)sHeader[0]) != 0xFF || ((sal_uInt8)sHeader[1]) != 0xFF || ((sal_uInt8)sHeader[2]) != 0x08)
2713 : {
2714 0 : return sal_False;
2715 : }
2716 :
2717 0 : sal_uInt32 nLength(0);
2718 0 : (*m_pMemoStream).ReadUInt32( nLength );
2719 :
2720 0 : if (m_aMemoHeader.db_typ == MemodBaseIV)
2721 0 : nLength -= 8;
2722 :
2723 0 : if ( nLength )
2724 : {
2725 0 : if ( bIsText )
2726 : {
2727 0 : OStringBuffer aBuffer(read_uInt8s_ToOString(*m_pMemoStream, nLength));
2728 : //pad it out with ' ' to expected length on short read
2729 0 : sal_Int32 nRequested = sal::static_int_cast<sal_Int32>(nLength);
2730 0 : comphelper::string::padToLength(aBuffer, nRequested, ' ');
2731 0 : aVariable = OStringToOUString(aBuffer.makeStringAndClear(), m_eEncoding);
2732 : } // if ( bIsText )
2733 : else
2734 : {
2735 0 : ::com::sun::star::uno::Sequence< sal_Int8 > aData(nLength);
2736 0 : m_pMemoStream->Read(aData.getArray(),nLength);
2737 0 : aVariable = aData;
2738 : }
2739 : } // if ( nLength )
2740 : }
2741 : }
2742 9442 : return sal_True;
2743 : }
2744 :
2745 20 : void ODbaseTable::AllocBuffer()
2746 : {
2747 : SAL_INFO( "connectivity.drivers", "dbase Ocke.Janssen@sun.com ODbaseTable::AllocBuffer" );
2748 20 : sal_uInt16 nSize = m_aHeader.db_slng;
2749 : OSL_ENSURE(nSize > 0, "Size too small");
2750 :
2751 20 : if (m_nBufferSize != nSize)
2752 : {
2753 15 : delete m_pBuffer;
2754 15 : m_pBuffer = NULL;
2755 : }
2756 :
2757 : // if there is no buffer available: allocate:
2758 20 : if (m_pBuffer == NULL && nSize > 0)
2759 : {
2760 15 : m_nBufferSize = nSize;
2761 15 : m_pBuffer = new sal_uInt8[m_nBufferSize+1];
2762 : }
2763 20 : }
2764 :
2765 5 : sal_Bool ODbaseTable::WriteBuffer()
2766 : {
2767 : SAL_INFO( "connectivity.drivers", "dbase Ocke.Janssen@sun.com ODbaseTable::WriteBuffer" );
2768 : OSL_ENSURE(m_nFilePos >= 1,"SdbDBFCursor::FileFetchRow: ungueltige Record-Position");
2769 :
2770 : // postion on desired record:
2771 5 : sal_Size nPos = m_aHeader.db_kopf + (long)(m_nFilePos-1) * m_aHeader.db_slng;
2772 5 : m_pFileStream->Seek(nPos);
2773 5 : return m_pFileStream->Write((char*) m_pBuffer, m_aHeader.db_slng) > 0;
2774 : }
2775 :
2776 21 : sal_Int32 ODbaseTable::getCurrentLastPos() const
2777 : {
2778 : SAL_INFO( "connectivity.drivers", "dbase Ocke.Janssen@sun.com ODbaseTable::getCurrentLastPos" );
2779 21 : return m_aHeader.db_anz;
2780 : }
2781 :
2782 : /* vim:set shiftwidth=4 softtabstop=4 expandtab: */
|
