src/gateway/SqlGwStatement.cxx

   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 #include <SqlGwStatement.h>
  21 #include <SqlLogStatement.h>
  22 #include <CacheTableLoader.h>
  23 DbRetVal SqlGwStatement::prepare(char *stmtstr)
  24 {
  25     DbRetVal rv = OK,ret=OK;
  26     SqlGwConnection *conn = (SqlGwConnection*) con;
  27     //conn->connectCSqlIfNotConnected();
  28     //conn->connectAdapterIfNotConnected();
  29     stmtHdlr = NoHandler;
  30     if (innerStmt) rv = innerStmt->prepare(stmtstr);
  31     SqlLogStatement *stmt = (SqlLogStatement*) innerStmt;
  32     bool isAllcachedTable = true;
  33     int noOfTable = 0;
  34     ListIterator titer =(stmt->getInnerStatement())->getTableNameList().getIterator();
  35     while (titer.hasElement())
  36     {
  37         TableName *t  = (TableName*)titer.nextElement();
  38         ret = CacheTableLoader::isTableCached(t->tblName);
  39         if(ret!=OK) isAllcachedTable=false;
  40         noOfTable++;
  41     }
  42     if(noOfTable == 1){ isAllcachedTable = true;}
  43     mode =CacheTableLoader::getTableMode((stmt->getInnerStatement())->getTableName());
  44     if ((rv == OK)&& ((mode!=5 && mode!=6)||innerStmt->isSelect()) && isAllcachedTable) {
  45         if (!stmt->isCached) {
  46             stmtHdlr = CSqlHandler;
  47             return rv;
  48         }else {
  49             if (stmt->mode != TABLE_OSYNC) {
  50                 stmtHdlr = CSqlHandler;
  51                 return rv;
  52             }else {
  53                 stmtHdlr = CSqlAndAdapterHandler;
  54             }
  55         }
  56     }
  57
  58     //TODO::add procedures also in the below checking
  59     if (!strncasecmp(stmtstr,"INSERT", 6) == 0 &&
  60         !strncasecmp(stmtstr, "UPDATE", 6) ==0 &&
  61         !strncasecmp(stmtstr, "SELECT", 6) ==0 &&
  62         !strncasecmp(stmtstr, "DELETE", 6) ==0) return rv;
  63
  64     //prepare failed. means table not there in csql->uncached table
  65     //or sql statement is complex and csql parser failed
  66     if (adapter) rv = adapter->prepare(stmtstr);
  67     if (rv == OK) {
  68         printDebug(DM_Gateway, "Handled by csql %d\n", shouldCSqlHandle());
  69         if (!shouldCSqlHandle()) stmtHdlr = AdapterHandler;
  70         else stmtHdlr = CSqlAndAdapterHandler;
  71         printDebug(DM_Gateway, "Handled  %d\n", stmtHdlr);
  72     }
  73     else
  74         printError(ErrSysInit, "Both csql and adapter could not prepare\n");
  75     return rv;
  76 }
  77 bool SqlGwStatement::shouldAdapterHandle()
  78 {
  79     if (stmtHdlr == AdapterHandler ||
  80         stmtHdlr == CSqlAndAdapterHandler) return true;
  81     return false;
  82 }
  83 bool SqlGwStatement::shouldCSqlHandle()
  84 {
  85     SqlGwConnection *conn = (SqlGwConnection*) con;
  86     if (stmtHdlr == CSqlHandler ||
  87         stmtHdlr == CSqlAndAdapterHandler) return true;
  88     return false;
  89 }
  90 bool SqlGwStatement::isSelect()
  91 {
  92     bool retValue;
  93     if (adapter && shouldAdapterHandle()) retValue =  adapter->isSelect();
  94     if (innerStmt && shouldCSqlHandle()) retValue =  innerStmt->isSelect();
  95     return retValue;
  96 }
  97
  98 DbRetVal SqlGwStatement::execute(int &rowsAffected)
  99 {
 100     DbRetVal rv = OK;
 101     SqlGwConnection *conn = (SqlGwConnection*) con;
 102     if (adapter && shouldAdapterHandle()) rv = adapter->execute(rowsAffected);
 103     if (rv != OK) return rv;
 104     if (shouldAdapterHandle())
 105     {
 106         GwHandler hdlr = conn->getTxnHandler();
 107         if (hdlr == NoHandler) conn->setTxnHandler(AdapterHandler);
 108         if (hdlr == CSqlHandler) conn->setTxnHandler(CSqlAndAdapterHandler);
 109     }
 110     if (innerStmt && shouldCSqlHandle()) rv = innerStmt->execute(rowsAffected);
 111     if (shouldCSqlHandle())
 112     {
 113         GwHandler hdlr = conn->getTxnHandler();
 114         if (hdlr == NoHandler) conn->setTxnHandler(CSqlHandler);
 115         if (hdlr == AdapterHandler) conn->setTxnHandler(CSqlAndAdapterHandler);
 116     }
 117     return rv;
 118 }
 119
 120 DbRetVal SqlGwStatement::bindParam(int pos, void* value)
 121 {
 122     DbRetVal rv = OK;
 123     printError(ErrWarning, "Deprecated and does not replicate or cache");
 124     return rv;
 125 }
 126
 127 DbRetVal SqlGwStatement::bindField(int pos, void* value)
 128 {
 129     DbRetVal rv = OK;
 130     //TODO::this will never be handled by both. check the flag for this
 131     if (adapter && shouldAdapterHandle()) rv = adapter->bindField(pos, value);
 132     if (rv != OK) return rv;
 133     if (innerStmt && shouldCSqlHandle()) rv = innerStmt->bindField(pos,value);
 134     return rv;
 135 }
 136
 137 void* SqlGwStatement::fetch()
 138 {
 139     //TODO::this will never be handled by both. check the flag for this
 140     if (adapter && shouldAdapterHandle()) return adapter->fetch();
 141     if (innerStmt && shouldCSqlHandle()) return innerStmt->fetch();
 142     return NULL;
 143 }
 144
 145 void* SqlGwStatement::fetch(DbRetVal &rv)
 146 {
 147     //TODO::this will never be handled by both. check the flag for this
 148     if (adapter && shouldAdapterHandle()) return adapter->fetch(rv);
 149     if (innerStmt && shouldCSqlHandle()) return innerStmt->fetch(rv);
 150     return NULL;
 151 }
 152
 153 void* SqlGwStatement::fetchAndPrint(bool SQL)
 154 {
 155     //TODO::this will never be handled by both. check the flag for this
 156     if (adapter && shouldAdapterHandle()) return adapter->fetchAndPrint(SQL);
 157     if (innerStmt && shouldCSqlHandle()) return innerStmt->fetchAndPrint(SQL);
 158     return NULL;
 159 }
 160
 161 void* SqlGwStatement::next()
 162 {
 163     //TODO::this will never be handled by both. check the flag for this
 164     if (adapter && shouldAdapterHandle()) return adapter->next();
 165     if (innerStmt && shouldCSqlHandle()) return innerStmt->next();
 166     return NULL;
 167 }
 168
 169 DbRetVal SqlGwStatement::close()
 170 {
 171     //TODO::this will never be handled by both. check the flag for this
 172     if (adapter && shouldAdapterHandle()) return adapter->close();
 173     if (innerStmt && shouldCSqlHandle()) return innerStmt->close();
 174     return OK;
 175 }
 176
 177 void* SqlGwStatement::getFieldValuePtr( int pos )
 178 {
 179     //TODO::this will never be handled by both. check the flag for this
 180     if (adapter && shouldAdapterHandle()) return adapter->getFieldValuePtr(pos);
 181     if (innerStmt && shouldCSqlHandle()) return innerStmt->getFieldValuePtr(pos);
 182     return NULL;
 183 }
 184
 185 int SqlGwStatement::noOfProjFields()
 186 {
 187     //TODO::this will never be handled by both. check the flag for this
 188     if (innerStmt && shouldCSqlHandle()) return innerStmt->noOfProjFields();
 189     if (adapter && shouldAdapterHandle()) return adapter->noOfProjFields();
 190     return 0;
 191 }
 192
 193 int SqlGwStatement::noOfParamFields()
 194 {
 195     if (innerStmt && shouldCSqlHandle()) return innerStmt->noOfParamFields();
 196     if (adapter && shouldAdapterHandle()) return adapter->noOfParamFields();
 197     return 0;
 198 }
 199
 200 DbRetVal SqlGwStatement::getProjFldInfo (int projpos, FieldInfo *&fInfo)
 201 {
 202     if (innerStmt && shouldCSqlHandle()) return innerStmt->getProjFldInfo(projpos, fInfo);
 203     if (adapter && shouldAdapterHandle()) return adapter->getProjFldInfo(projpos, fInfo);
 204     return OK;
 205 }
 206
 207 DbRetVal SqlGwStatement::getParamFldInfo (int parampos, FieldInfo *&fInfo)
 208 {
 209     if (innerStmt && shouldCSqlHandle()) return innerStmt->getParamFldInfo(parampos, fInfo);
 210     if (adapter && shouldAdapterHandle()) return adapter->getParamFldInfo(parampos, fInfo);
 211     return OK;
 212 }
 213
 214 DbRetVal SqlGwStatement::free()
 215 {
 216     DbRetVal rv = OK;
 217     if (adapter && shouldAdapterHandle()) rv = adapter->free();
 218     if (innerStmt && shouldCSqlHandle()) rv = innerStmt->free();
 219     return rv;
 220 }
 221 void SqlGwStatement::setShortParam(int paramPos, short value)
 222 {
 223     if (adapter && shouldAdapterHandle()) adapter->setShortParam(paramPos, value);
 224     if (innerStmt && shouldCSqlHandle()) innerStmt->setShortParam(paramPos,value);
 225     return;
 226 }
 227 void SqlGwStatement::setIntParam(int paramPos, int value)
 228 {
 229     if (adapter && shouldAdapterHandle()) adapter->setIntParam(paramPos, value);
 230     if (innerStmt && shouldCSqlHandle()) innerStmt->setIntParam(paramPos,value);
 231     return;
 232
 233 }
 234 void SqlGwStatement::setLongParam(int paramPos, long value)
 235 {
 236     if (adapter && shouldAdapterHandle()) adapter->setLongParam(paramPos, value);
 237     if (innerStmt && shouldCSqlHandle()) innerStmt->setLongParam(paramPos,value);
 238     return;
 239
 240 }
 241 void SqlGwStatement::setLongLongParam(int paramPos, long long value)
 242 {
 243     if (adapter && shouldAdapterHandle()) adapter->setLongLongParam(paramPos, value);
 244     if (innerStmt && shouldCSqlHandle()) innerStmt->setLongLongParam(paramPos,value);
 245     return;
 246 }
 247 void SqlGwStatement::setByteIntParam(int paramPos, ByteInt value)
 248 {
 249     if (adapter && shouldAdapterHandle()) adapter->setByteIntParam(paramPos, value);
 250     if (innerStmt && shouldCSqlHandle()) innerStmt->setByteIntParam(paramPos,value);
 251     return;
 252 }
 253 void SqlGwStatement::setFloatParam(int paramPos, float value)
 254 {
 255     if (adapter && shouldAdapterHandle()) adapter->setFloatParam(paramPos, value);
 256     if (innerStmt && shouldCSqlHandle()) innerStmt->setFloatParam(paramPos,value);
 257     return;
 258 }
 259 void SqlGwStatement::setDoubleParam(int paramPos, double value)
 260 {
 261     if (adapter && shouldAdapterHandle()) adapter->setDoubleParam(paramPos, value);
 262     if (innerStmt && shouldCSqlHandle()) innerStmt->setDoubleParam(paramPos,value);
 263     return;
 264
 265 }
 266 void SqlGwStatement::setStringParam(int paramPos, char *value)
 267 {
 268     if (adapter && shouldAdapterHandle()) adapter->setStringParam(paramPos, value);
 269     if (innerStmt && shouldCSqlHandle()) innerStmt->setStringParam(paramPos,value);
 270     return;
 271 }
 272 void SqlGwStatement::setDateParam(int paramPos, Date value)
 273 {
 274     if (adapter && shouldAdapterHandle()) adapter->setDateParam(paramPos, value);
 275     if (innerStmt && shouldCSqlHandle()) innerStmt->setDateParam(paramPos,value);
 276     return;
 277 }
 278 void SqlGwStatement::setTimeParam(int paramPos, Time value)
 279 {
 280     if (adapter && shouldAdapterHandle()) adapter->setTimeParam(paramPos, value);
 281     if (innerStmt && shouldCSqlHandle()) innerStmt->setTimeParam(paramPos,value);
 282     return;
 283 }
 284 void SqlGwStatement::setTimeStampParam(int paramPos, TimeStamp value)
 285 {
 286     if (adapter && shouldAdapterHandle()) adapter->setTimeStampParam(paramPos, value);
 287     if (innerStmt && shouldCSqlHandle()) innerStmt->setTimeStampParam(paramPos,value);
 288     return;
 289 }
 290 void SqlGwStatement::setBinaryParam(int paramPos, void *value, int length)
 291 {
 292     if (adapter && shouldAdapterHandle()) adapter->setBinaryParam(paramPos, value, length);
 293     if (innerStmt && shouldCSqlHandle()) innerStmt->setBinaryParam(paramPos,value, length);
 294 }
 295 bool SqlGwStatement::isFldNull(int pos)
 296 {
 297     if (adapter && shouldAdapterHandle()) return adapter->isFldNull(pos);
 298     if (innerStmt && shouldCSqlHandle()) return innerStmt->isFldNull(pos);
 299
 300 }
 301 bool SqlGwStatement::isFldNull(char *name)
 302 {
 303     if (adapter && shouldAdapterHandle()) return adapter->isFldNull(name);
 304     if (innerStmt && shouldCSqlHandle()) return innerStmt->isFldNull(name);
 305
 306 }
 307 void SqlGwStatement::setNull(int pos)
 308 {
 309     if (adapter && shouldAdapterHandle()) adapter->setNull(pos);
 310     if (innerStmt && shouldCSqlHandle()) innerStmt-> setNull(pos);
 311 }
 312 List SqlGwStatement::getAllTableNames(DbRetVal &ret)
 313 {
 314     printf("in csql\n"); if (innerStmt) return innerStmt->getAllTableNames(ret);
 315     printf("in Target Db\n"); if (adapter) adapter->getAllTableNames(ret);
 316 }
 317