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

 /* 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 "XbaseDriver.h"
 #include "XbaseCursor.h"
 #include "XbaseConnection.h"
 #include "XbaseConnection_p.h"
 #include "KDbError.h"
 
 xBaseConnection::xBaseConnection(KDbDriver *driver, KDbDriver* internalDriver, const KDbConnectionData& connData)
   : KDbConnection(driver, connData)
   , d(new xBaseConnectionInternal(this, internalDriver))
 {
 }
 
 xBaseConnection::~xBaseConnection() {
   destroy();
 }
 
 bool xBaseConnection::drv_connect(KDbServerVersionInfo* version)
 {
   Q_UNUSED(version);
   const bool ok = d->db_connect(*data());
   if (!ok)
     return false;
 
   //! @todo xBase version here
   //version.string = mysql_get_host_info(d->mysql);
 
   return true;
 }
 
 bool xBaseConnection::drv_disconnect() {
   return d->db_disconnect(*data());
 }
 
 KDbCursor* xBaseConnection::prepareQuery(const KDbEscapedString& sql, int cursor_options)
 {
   if ( !d->internalConn ) {
     return nullptr;
   }
   KDbCursor* internalCursor = d->internalConn->prepareQuery(sql,cursor_options);
   return new xBaseCursor( this, internalCursor, sql, cursor_options );
 }
 
 KDbCursor* xBaseConnection::prepareQuery(KDbQuerySchema* query, int cursor_options) {
   if ( !d->internalConn ) {
     return nullptr;
   }
   KDbCursor* internalCursor = d->internalConn->prepareQuery(query, cursor_options);
   return new xBaseCursor( this, internalCursor, query, cursor_options );
 }
 
 bool xBaseConnection::drv_getDatabasesList(QStringList* list)
 {
   //! @todo Check whether this is the right thing to do
   *list += QStringList( d->dbMap.keys() );
 //        list<<d->internalConn->databaseNames();
   return true;
 }
 
 bool xBaseConnection::drv_createDatabase( const QString &dbName) {
   //! @todo Check whether this function has any use.
   //xbaseDebug() << dbName;
 // return d->internalConn->createDatabase(d->dbMap[dbName]);
   return true;
 }
 
 bool xBaseConnection::drv_useDatabase(const QString &dbName, bool *cancelled, KDbMessageHandler* msgHandler)
 {
   Q_UNUSED(cancelled);
   Q_UNUSED(msgHandler);
 //! @todo is here escaping needed?
   return d->useDatabase(dbName);
 }
 
 bool xBaseConnection::drv_closeDatabase() {
   if (!d->internalConn || !d->internalConn->closeDatabase() ) {
     return false;
   }
   return true;
 }
 
 bool xBaseConnection::drv_dropDatabase(const QString &dbName) {
     Q_UNUSED(dbName);
 //! @todo is here escaping needed
   // Delete the directory ?
   return true;
 }
 
 bool xBaseConnection::drv_executeSql( const KDbEscapedString& sql ) {
   return d->executeSql(sql);
 }
 
 quint64 xBaseConnection::drv_lastInsertRecordId()
 {
   //! @todo
   quint64 rowID = -1;
   if (d->internalConn)
     d->internalConn->lastInsertedAutoIncValue(QString(), QString(), &rowID );
 
   return rowID;
 }
 
 int xBaseConnection::serverResult()
 {
   return d->res;
 }
 
 QString xBaseConnection::serverResultName() const
 {
   if (!d->internalConn) {
     return QString();
   }
   return d->internalConn->serverResultName();
 }
 
 /*void xBaseConnection::drv_clearServerResult()
 {
   if (!d || !d->internalConn)
     return;
   d->internalConn->clearError();
   d->res = 0;
 }*/
 
 QString xBaseConnection::serverErrorMsg()
 {
   return d->errmsg;
 }
 
 bool xBaseConnection::drv_containsTable( const QString &tableName )
 {
   return resultExists(KDbEscapedString("SHOW TABLES LIKE %1")
                       .arg(escapeString(tableName)));
 }
 
 bool xBaseConnection::drv_getTablesList(QStringList* list)
 {
   if ( !d->internalConn ) {
     return false;
   }
   *list += d->internalConn->tableNames();
   return true;
 }
 
 KDbPreparedStatementInterface* xBaseConnection::prepareStatementInternal()
 {
     if ( !d->internalConn )
         return nullptr;
 //! @todo   return new XBasePreparedStatement(*d);
         return nullptr;
 }