src/server/SessionImpl.c

   1 /***************************************************************************
   2  *   Copyright (C) 2007 by Prabakaran Thirumalai   *
   3  *   praba_tuty@yahoo.com   *
   4  *                                                                         *
   5  *   This program is free software; you can redistribute it and/or modify  *
   6  *   it under the terms of the GNU General Public License as published by  *
   7  *   the Free Software Foundation; either version 2 of the License, or     *
   8  *   (at your option) any later version.                                   *
   9  *                                                                         *
  10  *   This program is distributed in the hope that it will be useful,       *
  11  *   but WITHOUT ANY WARRANTY; without even the implied warranty of        *
  12  *   MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the         *
  13  *   GNU General Public License for more details.                          *
  14  *                                                                         *
  15   ***************************************************************************/
  16 #include<DatabaseManagerImpl.h>
  17 #include<DatabaseManager.h>
  18 #include<CatalogTables.h>
  19 #include<Database.h>
  20 #include<SessionImpl.h>
  21 #include<UserManager.h>
  22 #include<UserManagerImpl.h>
  23 #include<Transaction.h>
  24 #include<Debug.h>
  25
  26 DbRetVal SessionImpl::initSystemDatabase()
  27
  28 {
  29     DbRetVal rv = OK;
  30     dbMgr = new DatabaseManagerImpl();
  31     //TODO:Size of system database 100 MB ->config parameter
  32
  33     //TODO:No of chunks of system database->config parameter
  34     //This limits the total number of catalog tables system shall support.
  35     rv = dbMgr->createDatabase(SYSTEMDB, SYSTEM_DB_SIZE);
  36     if (OK != rv) return rv;
  37     dbMgr->setSysDb(dbMgr->db());
  38     dbMgr->setDb(NULL);
  39
  40     Database *db = dbMgr->sysDb();
  41
  42     db->getDatabaseMutex();
  43
  44     db->createAllCatalogTables();
  45
  46     //create the default dba user
  47     CatalogTableUSER cUser(db);
  48     rv = cUser.insert(DBAUSER, DBAPASS);
  49     if (OK != rv)
  50     {
  51         db->releaseDatabaseMutex();
  52         return rv;
  53     }
  54     void *ret = NULL;
  55     //Allocate space for the lock hash bucket
  56     ret = db->allocLockHashBuckets();
  57     if (NULL == ret)
  58     {
  59         db->releaseDatabaseMutex();
  60         printError(ErrSysInit, "Allocation of Lock buckets failed");
  61         return ErrSysInit;
  62     }
  63
  64     db->releaseDatabaseMutex();
  65
  66     //create user database
  67     rv = dbMgr->createDatabase("praba", SYSTEM_DB_SIZE);
  68     if (OK != rv) return rv;
  69     return OK;
  70 }
  71
  72 DbRetVal SessionImpl::destroySystemDatabase()
  73 {
  74     DbRetVal rv = OK;
  75     rv = dbMgr->deleteDatabase(SYSTEMDB);
  76     if (OK != rv) return rv;
  77     rv = dbMgr->deleteDatabase("praba");
  78     if (OK != rv) return rv;
  79     return OK;
  80 }
  81
  82 DbRetVal SessionImpl::open(const char *username, const char *password)
  83 {
  84     DbRetVal rv = OK;
  85     if ( NULL == dbMgr)
  86     {
  87         dbMgr = new DatabaseManagerImpl();
  88         rv = dbMgr->openSystemDatabase();
  89     }
  90     if (OK != rv)
  91     {
  92         printError(rv,"Unable to open the system database");
  93         return rv;
  94     }
  95
  96     //TODO::process registration
  97     //pMgr = new ProcessManager();
  98     //pMgr->registerProcess();
  99
 100     rv = dbMgr->sysDb()->getDatabaseMutex();
 101     if (OK != rv)
 102     {
 103         printError(rv,"Unable to get database mutex");
 104         return rv;
 105     }
 106
 107     CatalogTableUSER cUser(dbMgr->sysDb());
 108     //cUser.authenticate(username, password, isAuthenticated, isDba );
 109     isAuthenticated=true;
 110     dbMgr->sysDb()->releaseDatabaseMutex();
 111     if (!isAuthenticated)
 112     {
 113         dbMgr->closeSystemDatabase();
 114         delete dbMgr;
 115         //delete pMgr;
 116         printError(ErrNoPrivilege,"User Authentication failed");
 117         return ErrNoPrivilege;
 118     }
 119
 120     dbMgr->createTransactionManager();
 121     dbMgr->createLockManager();
 122     rv = dbMgr->openDatabase("praba");
 123     if (OK != rv) return rv;
 124
 125     return OK;
 126 }
 127
 128 DbRetVal SessionImpl::close()
 129 {
 130     if (dbMgr)
 131     {
 132         dbMgr->closeDatabase();
 133         dbMgr->closeSystemDatabase();
 134         delete dbMgr;
 135             dbMgr = NULL;
 136     }
 137     //pMgr->deregisterProcess();
 138     //delete pMgr;
 139     //pMgr = NULL;
 140     if (uMgr)
 141     {
 142         delete uMgr;
 143         uMgr = NULL;
 144     }
 145     return OK;
 146 }
 147
 148 DatabaseManager* SessionImpl::getDatabaseManager()
 149 {
 150     if (isAuthenticated) return dbMgr;
 151     printError(ErrNoPrivilege, "Not Authenticated: Returning NULL");
 152     return NULL;
 153 }
 154
 155 UserManager* SessionImpl::getUserManager()
 156 {
 157     if (!isAuthenticated)
 158     {
 159         printError(ErrNoPrivilege, "Not Authenticated: Returning NULL");
 160         return NULL;
 161     }
 162     if (uMgr != NULL) return uMgr;
 163     UserManagerImpl *userMgr =  new UserManagerImpl();
 164     if(0 == strcmp(userName, DBAUSER))
 165         userMgr->setDba(true);
 166     else
 167         userMgr->setDba(false);
 168
 169     userMgr->setSysDb(dbMgr->sysDb());
 170
 171     userMgr->setUserName(userName);
 172     uMgr = userMgr;
 173     return userMgr;
 174 }
 175
 176 DbRetVal SessionImpl::startTransaction()
 177 {
 178     if (NULL == dbMgr || NULL == dbMgr->txnMgr())
 179     {
 180         printError(ErrSysFatal, "Database Manager or Txn Manager object is NULL");
 181         return ErrSysFatal;
 182     }
 183     DbRetVal rv = OK;
 184     rv = dbMgr->sysDb()->getTransTableMutex();
 185     if (OK != rv)
 186     {
 187         printError(rv,"Unable to get TransTable mutex\n");
 188         return rv;
 189     }
 190     rv = dbMgr->txnMgr()->startTransaction();
 191     dbMgr->sysDb()->releaseTransTableMutex();
 192     return rv;
 193 }
 194
 195
 196 DbRetVal SessionImpl::commit()
 197 {
 198     DbRetVal rv = OK;
 199     if (NULL == dbMgr || NULL == dbMgr->txnMgr())
 200     {
 201         printError(ErrSysFatal, "Database Manager or Txn Manager object is NULL");
 202         return ErrSysFatal;
 203     }
 204     rv = dbMgr->txnMgr()->commit(dbMgr->lockMgr());
 205     if (OK != rv)
 206     {
 207         printError(rv,"Unable to get TransTable mutex\n");
 208         return rv;
 209     }
 210     return OK;
 211 }
 212
 213
 214 DbRetVal SessionImpl::rollback()
 215 {
 216     DbRetVal rv = OK;
 217     if (NULL == dbMgr || NULL == dbMgr->txnMgr())
 218     {
 219         printError(ErrSysFatal, "Database Manager or Txn Manager object is NULL");
 220         return ErrSysFatal;
 221     }
 222     rv = dbMgr->txnMgr()->rollback(dbMgr->lockMgr());
 223     if (OK != rv)
 224     {
 225         printError(rv,"Unable to get TransTable mutex\n");
 226         return rv;
 227     }
 228     return OK;
 229 }