File indexing completed on 2024-04-21 15:29:53

 /* This file is part of the KDE project
    Copyright (C) 2008 Sharan Rao <sharanrao@gmail.com>
 
    This program is free software; you can redistribute it and/or
    modify it under the terms of the GNU Library General Public
    License as published by the Free Software Foundation; either
    version 2 of the License, or (at your option) any later version.
 
    This program is distributed in the hope that it will be useful,
    but WITHOUT ANY WARRANTY; without even the implied warranty of
    MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
    Library General Public License for more details.
 
    You should have received a copy of the GNU Library General Public License
    along with this program; see the file COPYING.  If not, write to
    the Free Software Foundation, Inc., 51 Franklin Street, Fifth Floor,
  * Boston, MA 02110-1301, USA.
 */
 
 #include "XbaseCursor.h"
 #include "XbaseConnection.h"
 
 #include "KDbError.h"
 #include "KDb.h"
 
 #include <limits.h>
 
 class KDbxBaseCursorData {
   public:
     explicit xBaseCursorData(KDbCursor* cursor = nullptr)
       : internalCursor(cursor)
     {
     }
 
     KDbCursor* internalCursor;
 
 };
 
 xBaseCursor::xBaseCursor(KDbConnection* conn, KDbCursor* internalCursor, const KDbEscapedString& sql, int cursor_options)
   : KDbCursor(conn,sql,cursor_options)
   , d( new xBaseCursorData(internalCursor) )
 {
   init();
 }
 
 xBaseCursor::xBaseCursor(KDbConnection* conn, KDbCursor* internalCursor, KDbQuerySchema* query, int options)
   : KDbCursor( conn, query, options )
   , d( new xBaseCursorData(internalCursor) )
 {
   init();
 }
 
 xBaseCursor::~xBaseCursor() {
   close();
 }
 
 void xBaseCursor::init() {
 
   if (d->internalCursor) {
     m_options |= d->internalCursor->options();
   }
   // SQLite does buffering. So all calls to moving the cursor to SQLite will read from the buffer
   // ( if the rows are already buffered ) inside. Any point in double buffering ?
   setBuffered(false);
 }
 
 bool xBaseCursor::drv_open(const KDbEscapedString& sql)
 {
 // xbaseDebug() << m_sql;
   if (!d->internalCursor) {
     return false;
   }
   return d->internalCursor->open();
 }
 
 bool xBaseCursor::drv_close() {
   if (!d->internalCursor) {
     return false;
   }
   m_opened = false;
   KDbConnection* internalConn = d->internalCursor->connection();
   internalConn->deleteCursor( d->internalCursor );
   return true;
 }
 
 void xBaseCursor::drv_getNextRecord() {
   if (!d->internalCursor) {
     m_fetchResult = FetchResult::Error;
     return;
   }
 
   if ( !d->internalCursor->moveNext() ) {
     if ( d->internalCursor->eof() )
       m_fetchResult = FetchResult::End;
     else
       m_fetchResult = FetchResult::Error;
   } else {
     m_fetchResult = FetchResult::Ok;
     m_fieldCount = d->internalCursor->fieldCount();
     m_fieldsToStoreInRecord = m_fieldCount;
   }
 }
 
 QVariant xBaseCursor::value(int pos) {
   if (!d->internalCursor) {
     // Construct an invalid QVariant
     return QVariant();
   }
   return d->internalCursor->value(pos);
 }
 
 
 bool xBaseCursor::drv_storeCurrentRecord(KDbRecordData* data) const
 {
   if (!d->internalCursor) {
     return false;
   }
 
   KDbRecordData* rData = d->internalCursor->storeCurrentRecord();
   if (!rData) {
     return false;
   }
   *data = *rData;
   return true;
 }
 
 void xBaseCursor::drv_appendCurrentRecordToBuffer() {
 }
 
 
 void xBaseCursor::drv_bufferMovePointerNext() {
 }
 
 void xBaseCursor::drv_bufferMovePointerPrev() {
 }
 
 
 void xBaseCursor::drv_bufferMovePointerTo(qint64 to) {
   Q_UNUSED(to);
 }
 
 const char** xBaseCursor::recordData() const {
   if (!d->internalCursor) {
     return nullptr;
   }
   return d->internalCursor->recordData();
 }
 
 int xBaseCursor::serverResult()
 {
   if (!d->internalCursor) {
     // Any better value to return ?
     return -1;
   }
   return d->internalCursor->serverResult();
 }
 
 QString xBaseCursor::serverResultName() const
 {
   if (!d->internalCursor) {
     return QString();
   }
   return d->internalCursor->serverResultName();
 }
 
 //! @todo xBaseCursor::drv_clearServerResult()
 /*void xBaseCursor::drv_clearServerResult()
 {
 }*/
 
 QString xBaseCursor::serverErrorMsg()
 {
   if (!d->internalCursor) {
     return QString();
   }
   return d->internalCursor->serverErrorMsg();
 }