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