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 }
  34 void SqlStatement::setConnection(AbsSqlConnection *conn)
  35 {
  36     sqlCon = (SqlConnection*)conn;
  37     con = conn;
  38
  39 }
  40 void SqlStatement::setSqlConnection(SqlConnection *conn)
  41 {
  42     sqlCon = conn;
  43 }
  44
  45 DbRetVal SqlStatement::prepare(char *stmtstr)
  46 {
  47     DbRetVal rv = OK;
  48     lexInput = stmtstr;
  49     parsedData = &pData;
  50     yy_scan_string( stmtstr );
  51     int rc = yyparse();
  52     if (rc != 0)
  53     {
  54         free();
  55         parsedData = NULL;
  56         yyrestart(yyin);
  57         return ErrSyntaxError;
  58     }
  59     stmt = StatementFactory::getStatement(parsedData);
  60     stmt->setDbMgr(sqlCon->getConnObject().getDatabaseManager());
  61     rv = stmt->resolve();
  62     if (rv != OK)
  63     {
  64         free();
  65         parsedData = NULL;
  66         yyrestart(yyin);
  67         return rv;
  68     }
  69     parsedData = NULL;
  70     yyrestart(yyin);
  71     return OK;
  72 }
  73
  74 char*  SqlStatement::getTableName()
  75 {
  76     return pData.getTableName();
  77 }
  78
  79 bool SqlStatement::isSelect()
  80 {
  81     if (pData.getStmtType() == SelectStatement) return true;
  82     return false;
  83 }
  84
  85 DbRetVal SqlStatement::execute(int &rowsAffected)
  86 {
  87     DbRetVal rv = OK;
  88     rv = stmt->execute(rowsAffected);
  89     return rv;
  90 }
  91
  92 void* SqlStatement::fetch()
  93 {
  94     if (pData.getStmtType() != SelectStatement) return NULL;
  95     SelStatement *selStmt = (SelStatement*) stmt;
  96     return selStmt->fetch();
  97 }
  98
  99 void* SqlStatement::fetchAndPrint()
 100 {
 101     if (pData.getStmtType() != SelectStatement) return NULL;
 102     SelStatement *selStmt = (SelStatement*) stmt;
 103     return selStmt->fetchAndPrint();
 104 }
 105
 106 DbRetVal SqlStatement::bindParam(int pos, void* value)
 107 {
 108     DbRetVal rv = OK;
 109     rv = stmt->setParam(pos, value);
 110     return rv;
 111 }
 112
 113 DbRetVal SqlStatement::bindField(int pos, void* value)
 114 {
 115     DbRetVal rv = OK;
 116     if (pData.getStmtType() != SelectStatement) return ErrBadCall;
 117     SelStatement *selStmt = (SelStatement*) stmt;
 118     rv = selStmt->setBindField(pos, value);
 119     return rv;
 120 }
 121 void* SqlStatement::next()
 122 {
 123     if (pData.getStmtType() != SelectStatement) return 0;
 124     SelStatement *selStmt = (SelStatement*) stmt;
 125     return( (void*) selStmt->next() );
 126 }
 127
 128 DbRetVal SqlStatement::close()
 129 {
 130     if (pData.getStmtType() != SelectStatement) return OK;
 131     SelStatement *selStmt = (SelStatement*) stmt;
 132     return selStmt->close();
 133 }
 134
 135 void* SqlStatement::getFieldValuePtr( int pos )
 136 {
 137     if (pData.getStmtType() != SelectStatement) return 0;
 138     SelStatement *selStmt = (SelStatement*) stmt;
 139     return( (void*) selStmt->getFieldValuePtr( pos ) );
 140 }
 141
 142 int SqlStatement::noOfProjFields()
 143 {
 144     if (pData.getStmtType() != SelectStatement) return 0;
 145     SelStatement *selStmt = (SelStatement*) stmt;
 146     return selStmt->noOfProjFields();
 147 }
 148
 149 int SqlStatement::noOfParamFields()
 150 {
 151     return stmt->noOfParamFields();
 152 }
 153
 154 DbRetVal SqlStatement::getProjFldInfo (int projpos, FieldInfo *&fInfo)
 155 {
 156     DbRetVal rv = OK;
 157     if (pData.getStmtType() != SelectStatement) return ErrBadCall;
 158     SelStatement *selStmt = (SelStatement*) stmt;
 159     rv = selStmt->getProjFldInfo(projpos, fInfo);
 160     return rv;
 161 }
 162
 163 DbRetVal SqlStatement::getParamFldInfo (int parampos, FieldInfo *&fInfo)
 164 {
 165     DbRetVal rv = OK;
 166     if (pData.getStmtType() ==SelectStatement ||
 167         pData.getStmtType() ==InsertStatement ||
 168         pData.getStmtType() ==UpdateStatement ||
 169         pData.getStmtType() ==DeleteStatement)
 170     {
 171
 172         DmlStatement *dmlStmt = (DmlStatement*) stmt;
 173         rv = dmlStmt->getParamFldInfo(parampos, fInfo);
 174     }
 175     return rv;
 176 }
 177
 178 DbRetVal SqlStatement::free()
 179 {
 180     delete stmt;
 181     stmt = NULL;
 182     pData.reset();
 183 }
 184
 185 void SqlStatement::setShortParam(int paramPos, short value)
 186 {
 187     stmt->setShortParam(paramPos, value);
 188 }
 189 void SqlStatement::setIntParam(int paramPos, int value)
 190 {
 191     stmt->setIntParam(paramPos, value);
 192 }
 193 void SqlStatement::setLongParam(int paramPos, long value)
 194 {
 195     stmt->setLongParam(paramPos, value);
 196 }
 197 void SqlStatement::setLongLongParam(int paramPos, long long value)
 198 {
 199     stmt->setLongLongParam(paramPos, value);
 200 }
 201 void SqlStatement::setByteIntParam(int paramPos, ByteInt value)
 202 {
 203     stmt->setByteIntParam(paramPos, value);
 204 }
 205 void SqlStatement::setFloatParam(int paramPos, float value)
 206 {
 207     stmt->setFloatParam(paramPos, value);
 208 }
 209 void SqlStatement::setDoubleParam(int paramPos, double value)
 210 {
 211     stmt->setDoubleParam(paramPos, value);
 212 }
 213 void SqlStatement::setStringParam(int paramPos, char *value)
 214 {
 215     stmt->setStringParam(paramPos, value);
 216 }
 217 void SqlStatement::setDateParam(int paramPos, Date value)
 218 {
 219     stmt->setDateParam(paramPos, value);
 220 }
 221 void SqlStatement::setTimeParam(int paramPos, Time value)
 222 {
 223     stmt->setTimeParam(paramPos, value);
 224 }
 225 void SqlStatement::setTimeStampParam(int paramPos, TimeStamp value)
 226 {
 227     stmt->setTimeStampParam(paramPos, value);
 228 }
 229