/afs/cs.wisc.edu/u/n/w/nwilliam/private/workspace/Quut/src/select.cpp

#include <cstring>
#include "catalog.h"
#include "query.h"
#include "index.h"
#include "exceptions/end_of_file_exception.h"
#include "exceptions/no_more_records_exception.h"
#include "utility.h"
#include "exceptions/end_of_file_exception.h"
#include "exceptions/bad_param_exception.h"
#include "exceptions/file_open_exception.h"
#include "buffer.h"
#include <cstdio>
#include <fcntl.h>
#include <string>

extern badgerdb::BufMgr *bufMgr;

namespace badgerdb
{
  void Operators::Select(const std::string & result,      // name of the output relation
       int projCnt,                     // number of attributes in the projection
       const attrInfo projNames[],      // the list of projection attributes
       const attrInfo *attr,            // attribute used inthe selection predicate 
       Operator op,                       // predicate operation
       const void *attrValue)             // literal value in the predicate
  {
   
    if((op == Operator(EQ))){ //NEED TO CHECK IF THERE IS AN INDEX ALSO
      //INDEX SELECT
      IndexSelect(result, projCnt, projNames, attr, op, attrValue);
    }else{
      //Scan select
      //printAttrInfo(&projNames[0]);
      //printAttrInfo(attr);
      ScanSelect(result, projCnt, projNames, attr, op, attrValue);
    }
    
    
  }
  void Operators::ScanSelect(const std::string & result, int projCnt, const attrInfo projNames[], const attrInfo *attr, Operator op, const void *attrValue){
    std::string relation = projNames[0].relName;
    //int size = sizeof projNames/sizeof(attrInfo);
    int i, j = 0;
    std::string s1, s2;
    RelDesc rd;
    AttrDesc *attrs;
    int attrCnt;

    relCat->getInfo(relation, rd);

    // get attribute data
    attrCat->getRelInfo(rd.relName, attrCnt, attrs);
    int projToAttrMap[projCnt];
    //Utilities::UT_computeWidth(attrCnt, attrs, attrWidth);
    
    for(i = 0; i < projCnt; i++){
      s1 = projNames[i].attrName;
      for(j = 0; j < attrCnt; j++){
  s2 = attrs[j].attrName;
  if(s1.compare(s2) == 0){
    projToAttrMap[i] =j;
    break;
  }
      }
    }
    

   


    // compute width of output columns

    //    UT_computeWidth(attrCnt, attrs, attrWidth);

    // open data file
    FileScan filescan(rd.relName, bufMgr);
    FileScan fscan(result, bufMgr);
    RecordId rid;
    int records = 0;
    while(1)
      {
  try
    {
      filescan.scanNext(rid);
      std::string recordStr = filescan.getRecord();
      std::string insertstr;
      
      if(DEBUG){
        std::cout<<"\nRecord String size: "<<recordStr.size()<<"\n"; 
        std::cout<<recordStr; 
      }
      fscan.insertRecord(recordStr, rid);
      records++;
    }
  catch(EndOfFileException &e)
    {
      break;
    }
      }
    fscan.flushFile();
  }
    
  void Operators::IndexSelect(const std::string & result, int projCnt, const attrInfo projNames[], const attrInfo *attr, Operator op, const void *attrValue){
  }
}