---

SQLtoSQLQuerier.cpp

                              /* SQLtoSQLQuerier.cpp */

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

using namespace std;
using namespace LcgInfo;

typedef vector<vector<string> >::iterator matrStrIt;
typedef vector<string>::iterator vecStrIt;
typedef string::size_type strPos;

/*****************   EXTERN SYMBOLS FOR GENERIC CLASS  ****************/
extern "C" {
   Querier* SQLtoSQLQuerier_create(){
      return new SQLtoSQLQuerier();
   }
}

extern "C" {
   void SQLtoSQLQuerier_destroy(Querier *p){
      delete p;
   }
}

/******************  methods for class SQLtoSQLQuerier  ********************/

SQLtoSQLQuerier::SQLtoSQLQuerier()
   :mConf(0),mTranslator(0),mSql(0){
}

SQLtoSQLQuerier::~SQLtoSQLQuerier(){
}

void SQLtoSQLQuerier::setConfig(LcgConfigBuffer::ConfigBuffer & pConf){
   mConf=&pConf;
   mSql=new InfoFromLDAP();
   mSql->setConfig(pConf);
   mMap=new LcgConfigBuffer::ConfigBuffer();
   //it may throw a ConfigBufferexception if no attribute found, or 
   //a querytranslationexception if the mapping file is not proper
   try{
      string mappingfile=mConf->get_attribute_value("SCHEMA_MAPPING_FILE");
      mMap->populate_from_config(mappingfile);
   }catch(LcgConfigBuffer::CBException& e){
       string msg="No valid mapping file. aborting.";
       msg += "\nUnderlying CBException message: " + e.what() + " +line: ";
       msg += int2str(e.get_line()) + " +file: " + e.get_file();
       throw QueryTranslationException(msg,__FILE__,__LINE__);
    }
   mTranslator=new SQLtoSQLQueryTranslator(*mMap);
}

vector<vector<string> > SQLtoSQLQuerier::query(string const & pcanonical){

 vector<vector<string> > results;
 
 try{
   string input=pcanonical;
   vector<string> translation=mTranslator->translateQuery(input);
      
         // perform the SQL search and store the results
//debug
cout << "asking: " << translation.front() << endl;
//end debug

//this is just fake...
  string filter=translation.front();
  vector<string> attribs;
  attribs.push_back("glueceuniqueid");
  attribs.push_back("gluecename");
  try{
     results=mSql->query(filter,attribs);//can return several values, for several attr
  }catch(LcgConfigBuffer::CBException e){
      string msg="Error while querying the ldap interface. aborting.";
      msg += "\nUnderlying CBException message: " + e.what() + " +line: ";
      msg += int2str(e.get_line()) + " +file: " + e.get_file();
      throw LcgInfoException(msg,__FILE__,__LINE__);
   }
//... until a real SQL interface exists

         
//debug
cout << "Getting: ";
 for(matrStrIt r=results.begin(); r!=results.end(); r++){
   cout << "\n              ";
   for(vecStrIt k=(*r).begin(); k!=(*r).end(); k++)
      cout << *k << " ";
}
   cout << endl;
   cout << " ##############################################          ";
//end of debug

   return results;

 }catch(QueryTranslationException &e){
    cerr << e.what() << " +line: " << e.get_line() << " +file: " << e.get_file() << endl;;
    return results;
  }

}//end of query()

---