include/SqlLogConnection.h

   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  *   You should have received a copy of the GNU General Public License     *
  16  *   along with this program; if not, write to the                         *
  17  *   Free Software Foundation, Inc.,                                       *
  18  *   59 Temple Place - Suite 330, Boston, MA  02111-1307, USA.             *
  19  ***************************************************************************/
  20 #ifndef SQLLOGCONNECTION_H
  21 #define SQLLOGCONNECTION_H
  22 #include<CSql.h>
  23 #include<SqlFactory.h>
  24 #include<Util.h>
  25 #include<Network.h>
  26
  27 /*
  28 *
  29 * @class SqlLogConnection
  30 *
  31 */
  32
  33 typedef struct my_msgbuffer {
  34     long mtype;
  35     void *data;
  36 } Message;
  37
  38 class DllExport AbsSqlLogSend
  39 {
  40     public:
  41     virtual DbRetVal prepare(int tId, int sId, int len, char *st, char *tn,
  42                              bool hasParam)=0;
  43     virtual DbRetVal commit(int len, void *data)=0;
  44     virtual DbRetVal free(int txnId, int stmtId, bool hasParam)=0;
  45 };
  46
  47 class DllExport MsgQueueSend : public AbsSqlLogSend
  48 {
  49     int msgQId;
  50     public:
  51     MsgQueueSend() { msgQId = os::msgget(Conf::config.getMsgKey(), 0666); }
  52     DbRetVal prepare(int tId, int sId, int len, char *stmt, char *tn,
  53                      bool hasParam);
  54     DbRetVal commit(int len, void *data);
  55     DbRetVal free(int txnId, int stmtId, bool hasParam);
  56 };
  57
  58 class DllExport FileSend : public AbsSqlLogSend
  59 {
  60     int fdRedoLog;
  61     int fdStmtLog;
  62     public:
  63     FileSend();
  64     ~FileSend();
  65     DbRetVal openRedoFile();
  66     DbRetVal prepare(int txnId, int stmtId, int len, char *stmt, char*tn,
  67                      bool hasParam);
  68     DbRetVal commit(int len, void *data);
  69     DbRetVal free(int txnId, int stmtId, bool hasParam);
  70 };
  71
  72
  73 class DllExport OfflineLog : public AbsSqlLogSend
  74 {
  75     int fdOfflineLog;
  76     void *metadata;
  77     int fileSize;
  78     DbRetVal createMetadataFile();
  79     void *openMetadataFile();
  80     public:
  81     OfflineLog();
  82     ~OfflineLog();
  83     DbRetVal openOfflineLogFile();
  84     DbRetVal prepare(int txnId, int stmtId, int len, char *stmt, char*tn,
  85                      bool hasParam);
  86     DbRetVal commit(int len, void *data);
  87     DbRetVal free(int txnId, int stmtId, bool hasParam);
  88 };
  89
  90
  91 enum ExecType
  92 {
  93     EXECONLY = 0,
  94     SETPARAM
  95 };
  96
  97 class ExecLogInfo
  98 {
  99     public:
 100     ExecLogInfo() : pos(0), len(0), isNull(0) {}
 101     int stmtId;
 102     ExecType type;
 103     int pos;
 104     int isNull;
 105     DataType dataType;
 106     int len;
 107     void *value; //Extendible value as per parameter type size
 108 };
 109
 110 class DllExport SqlLogConnection : public AbsSqlConnection
 111 {
 112     Connection dummyConn;
 113
 114     List execLogStore;
 115     int execLogStoreSize;
 116
 117     //sync mode of the current transaction
 118     TransSyncMode syncMode;
 119
 120     AbsSqlLogSend *msgQSend;
 121     AbsSqlLogSend *fileSend;
 122     AbsSqlLogSend *offlineLog;
 123
 124     GlobalUniqueID txnUID;
 125     static List cacheList;
 126     int txnID;
 127     DbRetVal populateCachedTableList();
 128     public:
 129     bool noMsgLog;
 130     bool noOfflineLog;
 131
 132     SqlLogConnection() {
 133         innerConn = NULL; syncMode = ASYNC;
 134         msgQSend = NULL; fileSend = NULL; offlineLog = NULL;
 135 #ifndef MMDB
 136         if (Conf::config.useCache() && Conf::config.getCacheMode()==ASYNC_MODE)
 137             msgQSend = new MsgQueueSend();
 138         if (Conf::config.useCache() &&
 139                                    Conf::config.getCacheMode() == OFFLINE_MODE)
 140             offlineLog = new OfflineLog;
 141 #endif
 142         if (Conf::config.useDurability()) { fileSend = new FileSend(); }
 143         txnUID.open();
 144         execLogStoreSize =0;
 145         noMsgLog = false;
 146         noOfflineLog = false;
 147         txnID = 0;
 148     }
 149     ~SqlLogConnection();
 150     bool isTableCached(char *name);
 151
 152     inline bool isNoLogRequired()
 153     {
 154         if (!msgQSend && !fileSend && !offlineLog) return true;
 155         else return false;
 156     }
 157     inline bool isMsgQReqd()
 158     {
 159         if (msgQSend) return true; else return false;
 160     }
 161     inline bool isFileLogReqd()
 162     {
 163         if (fileSend) return true; else return false;
 164     }
 165     inline bool isOfflineLogReqd()
 166     {
 167         if (offlineLog) return true; else return false;
 168     }
 169     //Note::forced to implement this as it is pure virtual in base class
 170     Connection& getConnObject(){  return dummyConn; }
 171
 172     DbRetVal connect (char *user, char * pass);
 173
 174     DbRetVal disconnect();
 175
 176     DbRetVal commit();
 177
 178     DbRetVal rollback();
 179
 180     DbRetVal beginTrans (IsolationLevel isoLevel, TransSyncMode mode);
 181
 182     DbRetVal msgPrepare(int tId, int sId, int len, char *stmt, char *tname,
 183                         bool hasParam)
 184     {
 185         return msgQSend->prepare(tId, sId, len, stmt, tname, hasParam);
 186     }
 187     DbRetVal fileLogPrepare(int tId, int sId, int len, char *stmt, char *tname,
 188                             bool hasParam)
 189     {
 190         return fileSend->prepare(tId, sId, len, stmt, tname, hasParam);
 191     }
 192     DbRetVal offlineLogPrepare(int tId, int sId, int len, char *stmt,
 193                                char *tname, bool hasParam)
 194     {
 195         return offlineLog->prepare(tId, sId, len, stmt, tname, hasParam);
 196     }
 197     DbRetVal commitLogs(int logSize, void *data)
 198     {
 199         int txnId = getTxnID();
 200         if (msgQSend && !noMsgLog) msgQSend->commit(logSize, data);
 201         if (fileSend) fileSend->commit(logSize, data);
 202         if (offlineLog && !noOfflineLog) offlineLog->commit(logSize, data);
 203         return OK;
 204     }
 205     DbRetVal freeLogs(int stmtId, bool hasParam)
 206     {
 207         int txnId = getTxnID();
 208         if (msgQSend && !noMsgLog) msgQSend->free(txnId, stmtId, hasParam);
 209         if (fileSend) fileSend->free(txnId, stmtId, hasParam);
 210         if (offlineLog && !noOfflineLog)
 211             offlineLog->free(txnId, stmtId, hasParam);
 212         return OK;
 213     }
 214
 215     inline void addExecLog(ExecLogInfo *info) { execLogStore.append(info); }
 216     inline void addToExecLogSize(int size) { execLogStoreSize += size; }
 217     inline int getExecLogStoreSize() { return execLogStoreSize; }
 218     List getExecLogList() { return execLogStore; }
 219
 220     DbRetVal setSyncMode(TransSyncMode mode);
 221     inline void setNoMsgLog(bool nmlog) { noMsgLog = nmlog; }
 222     inline void setNoOfflineLog(bool nolog) { noOfflineLog = nolog; }
 223     inline TransSyncMode getSyncMode() { return syncMode; }
 224     inline int getTxnID() { return txnID; }
 225     friend class SqlFactory;
 226 };
 227
 228 #endif