src/server/SessionImpl.cxx

   1 /***************************************************************************
   2  *   Copyright (C) 2007 by www.databasecache.com                           *
   3  *   Contact: praba_tuty@databasecache.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 #include<Config.h>
  26 #include<Process.h>
  27
  28 //Before calling this method, application is required to call readConfigValues
  29 DbRetVal SessionImpl::initSystemDatabase()
  30
  31 {
  32     DbRetVal rv = OK;
  33     rv = readConfigFile();
  34     if (rv != OK)
  35     {
  36        printError(ErrSysInit, "Configuration file read failed\n");
  37        return ErrSysInit;
  38     }
  39     printf("ConfigValues\n");
  40     printf(" getPageSize %d\n", Conf::config.getPageSize());
  41     printf(" getMaxTrans %d\n", Conf::config.getMaxTrans());
  42     printf(" getMaxProcs %d\n", Conf::config.getMaxProcs());
  43     printf(" getMaxSysDbSize %ld\n", Conf::config.getMaxSysDbSize());
  44     printf(" getMaxDbSize %ld\n", Conf::config.getMaxDbSize());
  45     printf(" getSysDbKey %d\n", Conf::config.getSysDbKey());
  46     printf(" getUserDbKey %d\n", Conf::config.getUserDbKey());
  47     printf(" getLogFile %s\n", Conf::config.getLogFile());
  48     printf(" getMapAddress %ld\n", Conf::config.getMapAddress());
  49     printf(" getMutexSecs %d\n", Conf::config.getMutexSecs());
  50     printf(" getMutexUSecs %d\n", Conf::config.getMutexUSecs());
  51
  52
  53     dbMgr = new DatabaseManagerImpl();
  54
  55     rv = dbMgr->createDatabase(SYSTEMDB, Conf::config.getMaxSysDbSize());
  56     if (OK != rv) return rv;
  57     dbMgr->setSysDb(dbMgr->db());
  58     dbMgr->setDb(NULL);
  59
  60     Database *db = dbMgr->sysDb();
  61
  62     rv = db->getDatabaseMutex();
  63     if (OK != rv)
  64     {
  65         printError(ErrLockTimeOut, "Unable to get Database Mutex");
  66         return rv;
  67     }
  68
  69
  70     db->createAllCatalogTables();
  71
  72     //create the default dba user
  73     CatalogTableUSER cUser(db);
  74     rv = cUser.insert(DBAUSER, DBAPASS);
  75     if (OK != rv)
  76     {
  77         db->releaseDatabaseMutex();
  78         return rv;
  79     }
  80     void *ret = NULL;
  81     //Allocate space for the lock hash bucket
  82     ret = db->allocLockHashBuckets();
  83     if (NULL == ret)
  84     {
  85         db->releaseDatabaseMutex();
  86         printError(ErrSysInit, "Allocation of Lock buckets failed");
  87         return ErrSysInit;
  88     }
  89
  90     db->releaseDatabaseMutex();
  91
  92     //create user database
  93     rv = dbMgr->createDatabase("praba", Conf::config.getMaxDbSize());
  94     if (OK != rv) return rv;
  95     return OK;
  96 }
  97
  98 DbRetVal SessionImpl::destroySystemDatabase()
  99 {
 100     DbRetVal rv = OK;
 101     rv = dbMgr->deleteDatabase(SYSTEMDB);
 102     if (OK != rv) return rv;
 103     rv = dbMgr->deleteDatabase("praba");
 104     if (OK != rv) return rv;
 105     delete dbMgr;
 106     dbMgr = NULL;
 107     return OK;
 108 }
 109
 110 DbRetVal SessionImpl::open(const char *username, const char *password)
 111 {
 112     DbRetVal rv = OK;
 113     rv = readConfigFile();
 114     if (rv != OK)
 115     {
 116        printError(ErrSysFatal, "Configuration file read failed\n");
 117        return ErrSysFatal;
 118     }
 119
 120     if ( NULL == dbMgr)
 121     {
 122         dbMgr = new DatabaseManagerImpl();
 123         rv = dbMgr->openSystemDatabase();
 124     }
 125     if (OK != rv)
 126     {
 127         printError(rv,"Unable to open the system database");
 128         return rv;
 129     }
 130
 131     rv = dbMgr->sysDb()->getDatabaseMutex();
 132     if (OK != rv)
 133     {
 134         printError(rv,"Unable to get database mutex");
 135         return rv;
 136     }
 137
 138     CatalogTableUSER cUser(dbMgr->sysDb());
 139     cUser.authenticate(username, password, isAuthenticated, isDba);
 140     strcpy(userName, username);
 141     //isAuthenticated=true;
 142     dbMgr->sysDb()->releaseDatabaseMutex();
 143     if (!isAuthenticated)
 144     {
 145         dbMgr->closeSystemDatabase();
 146         delete dbMgr;
 147         dbMgr = NULL;
 148         printError(ErrNoPrivilege,"User Authentication failed");
 149         return ErrNoPrivilege;
 150     }
 151
 152     dbMgr->createTransactionManager();
 153     dbMgr->createLockManager();
 154         rv = dbMgr->openDatabase("praba");
 155     if (OK != rv) {
 156         return rv;
 157     }
 158
 159     rv = dbMgr->registerThread();
 160     if (OK != rv)
 161     {
 162         printError(rv,"Unable to register to csql server");
 163         return rv;
 164     }
 165     return OK;
 166 }
 167
 168 DbRetVal SessionImpl::close()
 169 {
 170     DbRetVal rv = OK;
 171     if (dbMgr)
 172     {
 173         rv = dbMgr->deregisterThread();
 174         if (rv != OK) {  return ErrBadCall;  }
 175         rv = dbMgr->closeDatabase();
 176         if (rv != OK) { return ErrBadCall;  }
 177         rv = dbMgr->closeSystemDatabase();
 178         if (rv != OK) { return ErrBadCall;  }
 179         delete dbMgr;
 180         dbMgr = NULL;
 181     }
 182     if (uMgr)
 183     {
 184         delete uMgr;
 185         uMgr = NULL;
 186     }
 187     return OK;
 188 }
 189
 190 DatabaseManager* SessionImpl::getDatabaseManager()
 191 {
 192     if (isAuthenticated) return dbMgr;
 193     printError(ErrNoPrivilege, "Not Authenticated: Returning NULL");
 194     return NULL;
 195 }
 196
 197 UserManager* SessionImpl::getUserManager()
 198 {
 199     if (!isAuthenticated)
 200     {
 201         printError(ErrNoPrivilege, "Not Authenticated: Returning NULL");
 202         return NULL;
 203     }
 204     if (uMgr != NULL) return uMgr;
 205     UserManagerImpl *userMgr =  new UserManagerImpl();
 206     if(0 == strcmp(userName, DBAUSER))
 207         userMgr->setDba(true);
 208     else
 209         userMgr->setDba(false);
 210
 211     userMgr->setSysDb(dbMgr->sysDb());
 212
 213     userMgr->setUserName(userName);
 214     uMgr = userMgr;
 215     return userMgr;
 216 }
 217
 218 DbRetVal SessionImpl::startTransaction(IsolationLevel level)
 219 {
 220     if (NULL == dbMgr || NULL == dbMgr->txnMgr())
 221     {
 222         printError(ErrSysFatal, "Database Manager or Txn Manager object is NULL");
 223         return ErrSysFatal;
 224     }
 225     DbRetVal rv = OK;
 226     rv = dbMgr->sysDb()->getTransTableMutex();
 227     if (OK != rv)
 228     {
 229         printError(rv,"Unable to get TransTable mutex\n");
 230         return rv;
 231     }
 232     rv = dbMgr->txnMgr()->startTransaction(level);
 233     dbMgr->sysDb()->releaseTransTableMutex();
 234     return rv;
 235 }
 236
 237
 238 DbRetVal SessionImpl::commit()
 239 {
 240     DbRetVal rv = OK;
 241     if (NULL == dbMgr || NULL == dbMgr->txnMgr())
 242     {
 243         printError(ErrSysFatal, "Database Manager or Txn Manager object is NULL");
 244         return ErrSysFatal;
 245     }
 246     rv = dbMgr->txnMgr()->commit(dbMgr->lockMgr());
 247     if (OK != rv)
 248     {
 249         printError(rv,"Unable to get TransTable mutex\n");
 250         return rv;
 251     }
 252     return OK;
 253 }
 254
 255
 256 DbRetVal SessionImpl::rollback()
 257 {
 258     DbRetVal rv = OK;
 259     if (NULL == dbMgr || NULL == dbMgr->txnMgr())
 260     {
 261         printError(ErrSysFatal, "Database Manager or Txn Manager object is NULL");
 262         return ErrSysFatal;
 263     }
 264     rv = dbMgr->txnMgr()->rollback(dbMgr->lockMgr());
 265     if (OK != rv)
 266     {
 267         printError(rv,"Unable to get TransTable mutex\n");
 268         return rv;
 269     }
 270     return OK;
 271 }
 272
 273 DbRetVal SessionImpl::readConfigFile()
 274 {
 275     // Check if env variable is set or not
 276     char *confFilename = os::getenv("CSQL_CONFIG_FILE");
 277     if (confFilename == NULL)
 278     {
 279         printError(ErrSysInit, "CSQL_CONFIG_FILE environment variable should be set.");
 280         return ErrSysInit;
 281     }
 282
 283     int  rv = Conf::config.readAllValues(confFilename);
 284     if (rv != 0) return ErrSysInit;
 285     return OK;
 286 }
 287