src/sql/DdlStatement.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   ***************************************************************************/
  16 #include "Statement.h"
  17 #include <Info.h>
  18 CreateTblStatement::CreateTblStatement()
  19 {
  20     parsedData = NULL;
  21     dbMgr = NULL;
  22 }
  23
  24 CreateTblStatement::~CreateTblStatement()
  25 {
  26     tblDef.reset();
  27 }
  28 DbRetVal CreateTblStatement::execute(int &rowsAffected)
  29 {
  30     DbRetVal rv = OK;
  31     rv = dbMgr->createTable(tblName, tblDef);
  32     if (rv != OK) return rv;
  33     if (parsedData->getFieldNameList().size() > 0)
  34     {
  35         HashIndexInitInfo *idxInfo = new HashIndexInitInfo();
  36         strcpy(idxInfo->tableName, tblName);
  37         ListIterator iter = parsedData->getFieldNameList().getIterator();
  38         FieldName *name = NULL;
  39         while (iter.hasElement())
  40         {
  41             name = (FieldName*)iter.nextElement();
  42             idxInfo->list.append(name->fldName);
  43         }
  44         idxInfo->indType = hashIndex;
  45         idxInfo->isPrimary = true;
  46         idxInfo->isUnique = true;
  47
  48         char indName[IDENTIFIER_LENGTH];
  49         sprintf(indName, "%s_idx1_Primary", tblName);
  50         rv = dbMgr->createIndex(indName, idxInfo);
  51         delete idxInfo;
  52     }
  53     return rv;
  54 }
  55
  56 DbRetVal CreateTblStatement::resolve()
  57 {
  58     DbRetVal rv = OK;
  59     strcpy(tblName, parsedData->getTableName());
  60     FieldIterator iter = parsedData->getCreFldList().getIterator();
  61     FieldDef fDef;
  62
  63     int i = 0;
  64     FieldName *name = NULL;
  65     ListIterator nIter = parsedData->getFieldNameList().getIterator();
  66     while (iter.hasElement())
  67     {
  68         fDef = iter.nextElement();
  69         nIter.reset();
  70         while (nIter.hasElement())
  71         {
  72             name = (FieldName*)nIter.nextElement();
  73             if (strcmp(name->fldName, fDef.fldName_) == 0) fDef.isNull_ = true;
  74         }
  75
  76
  77        //TODO : need a new addField function which can take FieldDef as parameter.
  78        if (!fDef.isDefault_)  {
  79            i = tblDef.addField(fDef.fldName_, fDef.type_, fDef.length_,
  80                         NULL,fDef.isNull_);
  81        } else {
  82            i = tblDef.addField(fDef.fldName_, fDef.type_, fDef.length_,
  83                         fDef.defaultValueBuf_,fDef.isNull_);
  84        }
  85        if( 0 != i )
  86        {
  87           printError(ErrUnknown, "Error while adding field");
  88           rv = ErrUnknown;
  89           break;
  90        }
  91     }
  92     return rv;
  93 }
  94
  95 ///////////////////////////////////////
  96 CreateIdxStatement::CreateIdxStatement()
  97 {
  98     parsedData = NULL;
  99     dbMgr = NULL;
 100 }
 101
 102 CreateIdxStatement::~CreateIdxStatement()
 103 {
 104
 105 }
 106
 107 DbRetVal CreateIdxStatement::execute(int &rowsAffected)
 108 {
 109     DbRetVal rv = OK;
 110     if (parsedData->getFieldNameList().size() > 0)
 111     {
 112         HashIndexInitInfo *idxInfo = new HashIndexInitInfo();
 113         strcpy(idxInfo->tableName, parsedData->getTableName());
 114         ListIterator iter = parsedData->getFieldNameList().getIterator();
 115         FieldName *name = NULL;
 116         while (iter.hasElement())
 117         {
 118             name = (FieldName*)iter.nextElement();
 119             idxInfo->list.append(name->fldName);
 120         }
 121         idxInfo->indType = parsedData->getIndexType();
 122         idxInfo->isPrimary = parsedData->getPrimary();
 123         idxInfo->isUnique = parsedData->getUnique();
 124         rv = dbMgr->createIndex(parsedData->getIndexName(), idxInfo);
 125         delete idxInfo;
 126     }
 127     return rv;
 128 }
 129
 130 DbRetVal DropTblStatement::execute(int &rowsAffected)
 131 {
 132     DbRetVal rv = OK;
 133     rv = dbMgr->dropTable(parsedData->getTableName());
 134     return rv;
 135 }
 136
 137 DbRetVal DropIdxStatement::execute(int &rowsAffected)
 138 {
 139     DbRetVal rv = OK;
 140     rv = dbMgr->dropIndex(parsedData->getIndexName());
 141     return rv;
 142 }
 143