src/sql/SqlStatement.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 "Statement.h"
  21 #include <SqlStatement.h>
  22 #include <dmllex.h>
  23
  24 char *lexInput;
  25 extern ParsedData *parsedData;
  26
  27 int yyparse ();
  28
  29 SqlStatement::SqlStatement()
  30 {
  31     sqlCon = NULL;
  32     stmt = NULL;
  33     isPrepd = false;
  34 }
  35 void SqlStatement::setConnection(AbsSqlConnection *conn)
  36 {
  37     sqlCon = (SqlConnection*)conn;
  38     con = conn;
  39
  40 }
  41 void SqlStatement::setSqlConnection(SqlConnection *conn)
  42 {
  43     sqlCon = conn;
  44 }
  45
  46 DbRetVal SqlStatement::prepare(char *stmtstr)
  47 {
  48     DbRetVal rv = OK;
  49     if (! sqlCon->isConnectionOpen()) {
  50         printError(ErrNotOpen, "Connection not open");
  51         return ErrNotOpen;
  52     }
  53     if(isPrepared()) free();
  54     lexInput = stmtstr;
  55     parsedData = &pData;
  56     yy_scan_string( stmtstr );
  57     int rc = yyparse();
  58     if (rc != 0)
  59     {
  60         free();
  61         parsedData = NULL;
  62         yyrestart(yyin);
  63         return ErrSyntaxError;
  64     }
  65     stmt = StatementFactory::getStatement(parsedData);
  66     stmt->setDbMgr(sqlCon->getConnObject().getDatabaseManager());
  67     rv = stmt->resolve();
  68     if (rv != OK)
  69     {
  70         free();
  71         parsedData = NULL;
  72         yyrestart(yyin);
  73         return rv;
  74     }
  75     parsedData = NULL;
  76     yyrestart(yyin);
  77     isPrepd = true;
  78     return OK;
  79 }
  80
  81 char*  SqlStatement::getTableName()
  82 {
  83     return pData.getTableName();
  84 }
  85
  86 bool SqlStatement::isSelect()
  87 {
  88     if (pData.getStmtType() == SelectStatement) return true;
  89     return false;
  90 }
  91
  92 bool SqlStatement::isPrepared() { return isPrepd; }
  93
  94 DbRetVal SqlStatement::execute(int &rowsAffected)
  95 {
  96     DbRetVal rv = OK;
  97     if (! sqlCon->isConnectionOpen()) {
  98         printError(ErrNotOpen, "Connection not open");
  99         return ErrNotOpen;
 100     }
 101     if (! isPrepared()) {
 102         printError(ErrNotPrepared, "Statement Not Prepared");
 103         return ErrNotPrepared;
 104     }
 105     rv = stmt->execute(rowsAffected);
 106     return rv;
 107 }
 108
 109 void* SqlStatement::fetch()
 110 {
 111     if (! sqlCon->isConnectionOpen()) {
 112         printError(ErrNotOpen, "Connection not open");
 113         return NULL;
 114     }
 115     if (! isPrepared()) {
 116         printError(ErrNotPrepared, "Statement Not Prepared");
 117         return NULL;
 118     }
 119     if (pData.getStmtType() != SelectStatement) return NULL;
 120     SelStatement *selStmt = (SelStatement*) stmt;
 121     return selStmt->fetch();
 122 }
 123
 124 void* SqlStatement::fetch(DbRetVal &rv)
 125 {
 126     if (! sqlCon->isConnectionOpen()) {
 127         printError(ErrNotOpen, "Connection not open");
 128         return NULL;
 129     }
 130     if (! isPrepared()) {
 131         printError(ErrNotPrepared, "Statement Not Prepared");
 132         return NULL;
 133     }
 134     if (pData.getStmtType() != SelectStatement) return NULL;
 135     SelStatement *selStmt = (SelStatement*) stmt;
 136     return selStmt->fetch(rv);
 137 }
 138
 139 void* SqlStatement::fetchAndPrint(bool SQL)
 140 {
 141     if (! sqlCon->isConnectionOpen()) {
 142         printError(ErrNotOpen, "Connection not open");
 143         return NULL;
 144     }
 145     if (! isPrepared()) {
 146         printError(ErrNotPrepared, "Statement Not Prepared");
 147         return NULL;
 148     }
 149     if (pData.getStmtType() != SelectStatement) return NULL;
 150     SelStatement *selStmt = (SelStatement*) stmt;
 151     return selStmt->fetchAndPrint(SQL);
 152 }
 153
 154 DbRetVal SqlStatement::bindParam(int pos, void* value)
 155 {
 156     DbRetVal rv = OK;
 157     rv = stmt->setParam(pos, value);
 158     return rv;
 159 }
 160
 161 DbRetVal SqlStatement::bindField(int pos, void* value)
 162 {
 163     DbRetVal rv = OK;
 164     if (pData.getStmtType() != SelectStatement) return ErrBadCall;
 165     SelStatement *selStmt = (SelStatement*) stmt;
 166     rv = selStmt->setBindField(pos, value);
 167     return rv;
 168 }
 169 void* SqlStatement::next()
 170 {
 171     if (pData.getStmtType() != SelectStatement) return 0;
 172     SelStatement *selStmt = (SelStatement*) stmt;
 173     return( (void*) selStmt->next() );
 174 }
 175
 176 bool SqlStatement::isFldNull(int pos)
 177 {
 178     if (pData.getStmtType() != SelectStatement) return 0;
 179     SelStatement *selStmt = (SelStatement*) stmt;
 180     return (selStmt->isFldNull(pos));
 181 }
 182 DbRetVal SqlStatement::close()
 183 {
 184     if (pData.getStmtType() != SelectStatement) return OK;
 185     SelStatement *selStmt = (SelStatement*) stmt;
 186     return selStmt->close();
 187 }
 188
 189 void* SqlStatement::getParamValuePtr( int pos )
 190 {
 191     //if (pData.getStmtType() != SelectStatement) return 0;
 192     DmlStatement *dmlStmt = (DmlStatement*) stmt;
 193     return( (void*) dmlStmt->getParamValuePtr( pos ) );
 194 }
 195
 196 char* SqlStatement::getFieldName( int pos )
 197 {
 198     if (pData.getStmtType() != SelectStatement) return 0;
 199     SelStatement *selStmt = (SelStatement*) stmt;
 200     return( (char*) selStmt->getFieldName( pos ) );
 201 }
 202
 203 DataType SqlStatement::getFieldType( int pos )
 204 {
 205     if (pData.getStmtType() != SelectStatement) return typeUnknown;
 206     SelStatement *selStmt = (SelStatement*) stmt;
 207     return( (DataType) selStmt->getFieldType( pos ) );
 208 }
 209 int SqlStatement::getFieldLength( int pos )
 210 {
 211     if (pData.getStmtType() != SelectStatement) return 0;
 212     SelStatement *selStmt = (SelStatement*) stmt;
 213     return( (int) selStmt->getFieldLength( pos ) );
 214 }
 215
 216 void* SqlStatement::getFieldValuePtr( int pos )
 217 {
 218     if (pData.getStmtType() != SelectStatement) return 0;
 219     SelStatement *selStmt = (SelStatement*) stmt;
 220     return( (void*) selStmt->getFieldValuePtr( pos ) );
 221 }
 222
 223 int SqlStatement::noOfProjFields()
 224 {
 225     if (pData.getStmtType() != SelectStatement) return 0;
 226     SelStatement *selStmt = (SelStatement*) stmt;
 227     return selStmt->noOfProjFields();
 228 }
 229
 230 int SqlStatement::noOfParamFields()
 231 {
 232     return stmt->noOfParamFields();
 233 }
 234
 235 DbRetVal SqlStatement::getProjFldInfo (int projpos, FieldInfo *&fInfo)
 236 {
 237     DbRetVal rv = OK;
 238     if (pData.getStmtType() != SelectStatement) return ErrBadCall;
 239     SelStatement *selStmt = (SelStatement*) stmt;
 240     rv = selStmt->getProjFldInfo(projpos, fInfo);
 241     return rv;
 242 }
 243
 244 DbRetVal SqlStatement::getParamFldInfo (int parampos, FieldInfo *&fInfo)
 245 {
 246     DbRetVal rv = OK;
 247     if (pData.getStmtType() ==SelectStatement ||
 248         pData.getStmtType() ==InsertStatement ||
 249         pData.getStmtType() ==UpdateStatement ||
 250         pData.getStmtType() ==DeleteStatement)
 251     {
 252
 253         DmlStatement *dmlStmt = (DmlStatement*) stmt;
 254         rv = dmlStmt->getParamFldInfo(parampos, fInfo);
 255     }
 256     return rv;
 257 }
 258
 259 DbRetVal SqlStatement::free()
 260 {
 261     delete stmt;
 262     stmt = NULL;
 263     pData.reset();
 264     isPrepd = false;
 265     return OK;
 266 }
 267
 268 void SqlStatement::setNull(int pos)
 269 {
 270     stmt->setNull(pos);
 271 }
 272 void SqlStatement::setShortParam(int paramPos, short value)
 273 {
 274     stmt->setShortParam(paramPos, value);
 275 }
 276 void SqlStatement::setIntParam(int paramPos, int value)
 277 {
 278     stmt->setIntParam(paramPos, value);
 279 }
 280 void SqlStatement::setLongParam(int paramPos, long value)
 281 {
 282     stmt->setLongParam(paramPos, value);
 283 }
 284 void SqlStatement::setLongLongParam(int paramPos, long long value)
 285 {
 286     stmt->setLongLongParam(paramPos, value);
 287 }
 288 void SqlStatement::setByteIntParam(int paramPos, ByteInt value)
 289 {
 290     stmt->setByteIntParam(paramPos, value);
 291 }
 292 void SqlStatement::setFloatParam(int paramPos, float value)
 293 {
 294     stmt->setFloatParam(paramPos, value);
 295 }
 296 void SqlStatement::setDoubleParam(int paramPos, double value)
 297 {
 298     stmt->setDoubleParam(paramPos, value);
 299 }
 300 void SqlStatement::setStringParam(int paramPos, char *value)
 301 {
 302     stmt->setStringParam(paramPos, value);
 303 }
 304 void SqlStatement::setDateParam(int paramPos, Date value)
 305 {
 306     stmt->setDateParam(paramPos, value);
 307 }
 308 void SqlStatement::setTimeParam(int paramPos, Time value)
 309 {
 310     stmt->setTimeParam(paramPos, value);
 311 }
 312 void SqlStatement::setTimeStampParam(int paramPos, TimeStamp value)
 313 {
 314     stmt->setTimeStampParam(paramPos, value);
 315 }
 316 void SqlStatement::setBinaryParam(int paramPos, void *value)
 317 {
 318     stmt->setBinaryParam(paramPos, value);
 319 }
 320 int SqlStatement::getFldPos(char *name)
 321 {
 322     return stmt->getFldPos(name);
 323 }
 324 List SqlStatement::getAllTableNames()
 325 {
 326     DatabaseManager *dbMgr = sqlCon->getConnObject().getDatabaseManager();
 327     return dbMgr->getAllTableNames();
 328 }
 329