diff options
Diffstat (limited to 'reladminif/databaseifcommon.cc')
| -rw-r--r-- | reladminif/databaseifcommon.cc | 242 |
1 files changed, 242 insertions, 0 deletions
diff --git a/reladminif/databaseifcommon.cc b/reladminif/databaseifcommon.cc new file mode 100644 index 0000000..b3e3097 --- /dev/null +++ b/reladminif/databaseifcommon.cc @@ -0,0 +1,242 @@ +/* +* This file is part of rasdaman community. +* +* Rasdaman community is free software: you can redistribute it and/or modify +* it under the terms of the GNU General Public License as published by +* the Free Software Foundation, either version 3 of the License, or +* (at your option) any later version. +* +* Rasdaman community 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 General Public License for more details. +* +* You should have received a copy of the GNU General Public License +* along with rasdaman community. If not, see <http://www.gnu.org/licenses/>. +* +* Copyright 2003, 2004, 2005, 2006, 2007, 2008, 2009 Peter Baumann / +rasdaman GmbH. +* +* For more information please see <http://www.rasdaman.org> +* or contact Peter Baumann via <baumann@rasdaman.com>. +*/ +// This is -*- C++ -*- +/************************************************************************* + * + * + * PURPOSE: + * Contains all code that is shared by the database interface implementations + * + * + * COMMENTS: + * - schema version depending on release doesn't make sense; rather change + * it when the schema _really_ changes! + * + ***********************************************************************/ + + +#include <string.h> +#include <malloc.h> + +#include "globals.hh" // DEFAULT_DBNAME + +#include "databaseif.hh" +#include "adminif.hh" +#include "raslib/rminit.hh" +#include "raslib/rmdebug.hh" +#include "externs.h" +#include "sqlerror.hh" +#include "raslib/error.hh" +#include "relcatalogif/alltypes.hh" + +// defined in rasserver.cc +extern char globalConnectId[256]; + +const char* DatabaseIf::DefaultDatabaseName = DEFAULT_DBNAME; + +DatabaseIf::~DatabaseIf() +{ + RMDBGENTER(4, RMDebug::module_adminif, "DatabaseIf", "~DatabaseIf()"); + if (isConnected()) + { + baseDBMSClose(); + } + if (myName) + { + free(myName); + myName = NULL; + } + + connected = false; + opened = false; + RMDBGEXIT(4, RMDebug::module_adminif, "DatabaseIf", "~DatabaseIf()"); +} + +bool +DatabaseIf::isConnected() const +{ + RMDBGONCE(4, RMDebug::module_adminif, "DatabaseIf", "isConnected() " << connected); + return connected; +} + +bool +DatabaseIf::isOpen() const +{ + RMDBGONCE(4, RMDebug::module_adminif, "DatabaseIf", "isOpen() " << opened); + return opened; +} + +void +DatabaseIf::open(const char* dbName) throw(r_Error) +{ + RMDBGENTER(4, RMDebug::module_adminif, "DatabaseIf", "open(" << dbName << ")"); + + if (opened) + { + RMDBGMIDDLE(4, RMDebug::module_adminif, "DatabaseIf", "another database is already open"); + throw r_Error(r_Error::r_Error_DatabaseOpen); + } + else + { + //cannot do any further error checking + if ( 0 ) // we allow any other database name -- strcmp(dbName, DefaultDatabaseName)) + { + RMDBGMIDDLE(4, RMDebug::module_adminif, "DatabaseIf", "database name unknown"); + RMInit::logOut << "b_DatabaseIf::open(" << dbName << ") dbName=" << dbName << std::endl; + throw r_Error(r_Error::r_Error_DatabaseUnknown); + } + else + { + opened = true; + myName = strdup(dbName); + } + } + RMDBGEXIT(4, RMDebug::module_adminif, "DatabaseIf", "open(" << dbName << ")"); +} + +void +DatabaseIf::baseDBMSOpen() throw (r_Error) +{ + RMDBGENTER(4, RMDebug::module_adminif, "DatabaseIf", "baseDBMSOpen() " << ((myName)? myName:"NULL")); + if (connected) + { + RMDBGMIDDLE(4, RMDebug::module_adminif, "DatabaseIf", "databasename is already connected"); + throw r_Error(r_Error::r_Error_TransactionOpen); + } +#ifdef RMANDEBUG + if (AdminIf::getCurrentDatabaseIf()) + { + RMDBGMIDDLE(0, RMDebug::module_adminif, "DatabaseIf", "baseDBMSOpen() CurrentDatabaseIf != 0"); + RMInit::logOut << "Transaction begin:" << std::endl \ + << "There seems to be another database connection active (Internal State 1)." << std::endl \ + << "Please contact Customer support." << std::endl; + throw r_Error(DATABASE_OPEN); + } +#endif + AdminIf::setCurrentDatabaseIf(this); + connect(); + connected = true; + +#ifdef DBMS_PGSQL // cannot have this check in PostgreSQL -- PB 2005-jan-09 + if (!databaseExists(myName)) + { + RMInit::logOut << "Database " << ((myName)? myName: "NULL") << " unknown" << std::endl; + throw r_Error(r_Error::r_Error_DatabaseUnknown); + } +#endif // DBMS_PGSQL + +#ifndef FASTCONNECT + checkCompatibility(); + if (!isConsistent()) + { + RMInit::logOut << "Database " << ((myName)? myName: "NULL") << " inconsistent" << std::endl; + throw r_Error(DATABASE_INCONSISTENT); + } +#endif + RMDBGEXIT(4, RMDebug::module_adminif, "DatabaseIf", "baseDBMSOpen()"); +} + +void +DatabaseIf::close() +{ + RMDBGENTER(4, RMDebug::module_adminif, "DatabaseIf", "close()"); + opened = false; + if (myName) + { + free(myName); + myName = NULL; + } + if (connected) + { + disconnect(); + connected = false; + } + RMDBGEXIT(4, RMDebug::module_adminif, "DatabaseIf", "close()"); +} + +void +DatabaseIf::baseDBMSClose() +{ + RMDBGENTER(4, RMDebug::module_adminif, "DatabaseIf", "baseDBMSClose()"); +#ifdef RMANDEBUG + if (AdminIf::getCurrentDatabaseIf() == this) + { +#endif + AdminIf::setCurrentDatabaseIf(0); +#ifdef RMANDEBUG + } + else + { + //this happens when a transaction is killed by the server + RMDBGONCE(0, RMDebug::module_adminif, "DatabaseIf", "baseDBMSClose() current DatabaseIf != this"); + } +#endif + disconnect(); + connected = false; + RMDBGEXIT(4, RMDebug::module_adminif, "DatabaseIf", "baseDBMSClose()"); +} + +DatabaseIf::DatabaseIf() + : opened(false), + connected(false), + myName(NULL) +{ + RMDBGONCE(4, RMDebug::module_adminif, "DatabaseIf", "DatabaseIf()"); +} + +const char* +DatabaseIf::getName() const +{ + RMDBGONCE(4, RMDebug::module_adminif, "DatabaseIf", "getName() " << ((myName)? myName:"NULL")); + return myName; +} + +ostream& +operator << (ostream& stream, DatabaseIf& db) +{ + stream << "DatabaseIf" << std::endl; + stream << "\tConnected To\t: " << ((db.getName())? db.getName():" ") << std::endl; + if (db.opened) + { + if (db.connected) + { + stream << "\tDatabase is really ONLINE" << std::endl; + } + else + { + stream << "\tDatabase is only FAKE ONLINE" << std::endl; + } + } + else + { + stream << "\tDatabase is OFFLINE" << std::endl; + } + return stream; +} + +void +DatabaseIf::garbage( ) +{ + RMDBGONCE(0, RMDebug::module_adminif, "DatabaseIf", "garbage() NOT IMPLEMENTED"); +} + |