XbaseCursor.cpp

/* This file is part of the KDE project
   Copyright (C) 2008 Sharan Rao <[email protected]>
 
   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();
}