---

SQLtoLDAPQueryTranslator.cpp

                              /* SQLtoLDAPQueryTranslator.cpp */

/*
 *  Implementation of SQLtoLDAPQueryTranslator.h
 */
#include "SQLtoLDAPQueryTranslator.h"

using namespace LcgInfo;
using namespace std;

/******************  METHODS FOR CLASS SQLtoLDAPQueryTranslator  ********************/

const std::string SQLtoLDAPQueryTranslator::CHARS_TO_DIVIDE_LDAP_WORDS=" \t=><()!";

SQLtoLDAPQueryTranslator::SQLtoLDAPQueryTranslator()
: SQLQueryTranslator(){
}

SQLtoLDAPQueryTranslator::SQLtoLDAPQueryTranslator(string const & pMapFile)
: SQLQueryTranslator(pMapFile){
}

SQLtoLDAPQueryTranslator::SQLtoLDAPQueryTranslator(LcgConfigBuffer::ConfigBuffer & pMap)
: SQLQueryTranslator(pMap){
}

SQLtoLDAPQueryTranslator::~SQLtoLDAPQueryTranslator(){
}

vector<string> SQLtoLDAPQueryTranslator::translateQuery(string const & pQueryCanonical){
   // Define the necessary variables
   SQLPredicateTree * pred=new SQLtoLDAPPredicateTree();
   vector<string> rows;
   set<string> tables;
   string translated;
   vector<string> result;
   vector<string> newResults;

   // Let our parent's translateSemantic() method do the job
   translateSemantic(pQueryCanonical, *pred, rows, tables);

   // Build the subqueries and the predicate of the last query to return
   result.clear();
   if(!pred->empty())
      translated = pred->evaluate(result);  //where clause (may throw QueryTranslationException)

   //Now, add the rows to return to the query that corresponds to it
   vector<string> tokens;
   vector<short int> indices;
   string subqueryTable, askedTable, attrib, listOfResults;
   string::size_type pos, queryNum;
   bool included=false;
   for(vector<string>::iterator i=rows.begin(); i!=rows.end(); i++){
      askedTable=extractTable(*i);   //table of the current element in the row list
      included=false;
      queryNum=result.size()-1;
      for(vector<string>::reverse_iterator j=result.rbegin(); j!=result.rend(); j++, queryNum--){
         tokenizeStrWithIndices(*j, tokens, indices);
         subqueryTable=extractTable(tokens.back()); //table of the table.row asked in subquery
         if(i==rows.begin()){  //first time
            //copy the line (without the table names or =... parts)            
            attrib=extractRow(tokens.back());            
            pos=attrib.find_last_of('=',attrib.size()-1);
            if(pos!=string::npos) attrib=attrib.substr(0,pos);
            pos = indices.back();
            string aux=(*j).substr(0,pos) + attrib;
            newResults.insert(newResults.begin(), aux); 
            //add the objectclass filter 
            if(pos>0){//if there was already something
               newResults.front().insert(pos-1, ")");
               newResults.front().insert(0, "(&(objectclass=" + subqueryTable + ")"); 
            }
            else{//if there was nothing
               newResults.front().insert(0, "(objectclass=" + subqueryTable + ") "); 
            }
         }
         if(askedTable==subqueryTable){  //asking the same table ==> add the row, if...
            if(tokens.back()!=(*i)){  //...if the asked attribute is not already there
               listOfResults+=int2str(queryNum)+"-1,";
               attrib=extractRow(*i);            
               pos=attrib.find_last_of('=',attrib.size()-1);
               if(pos!=string::npos) attrib=attrib.substr(0,pos);
               if(newResults.size()>queryNum)
                  newResults.at(queryNum) +=  " " + attrib;
               else
                  newResults.back() += " " + attrib;
            }
            else{                        //otherwise, warn that the attr has to be returned 
               listOfResults+=int2str(queryNum)+"-0,";
            }
            included=true;
         }
      }
      if(!included){     //if not in a subquery, add to the last
         //but first, eliminate trailing =xxxx
         attrib=extractRow(*i);            
         pos=attrib.find_last_of('=',attrib.size()-1);
         if(pos!=string::npos) attrib=attrib.substr(0,pos);
         //and add the objectclass filter (only once)
         if(i==rows.begin()){
            listOfResults+=int2str(result.size())+"-0,";
            subqueryTable=extractTable(*i);   //table of the table.row asked in subquery
            if(translated.size()>0){//if there was something already
               translated.insert(translated.size(), ")");
               translated.insert(0, "(&(objectclass=" + subqueryTable + ")");
            }
            else{
               listOfResults+=int2str(result.size())+"-1,";
               translated.insert(0, "(objectclass=" + subqueryTable + ")");
            }
         }
         //now add the row to return 
         translated += " " + attrib;
      }  
   }
   newResults.push_back(translated);

   //Last element, the list of rows to return
   newResults.push_back(listOfResults);

   delete pred;  
   return newResults;
   
}//end of translateQuery()

---