// InsertQuery_t.cxx

#include "dataset_sql/InsertQuery.h"
#include <string>
#include <iostream>

using std::string;
using std::cout;
using std::endl;
using dset::InsertQuery;

typedef InsertQuery::Row Row;

// Display messsage.
void msg(string txt) {
  cout << "--- " << txt << " ---" << endl;
}

int InsertQuery_t() {
  msg("BEGIN TESTING InsertQuery");
  Row row1;
  row1["id"] = "40";
  row1["name"] = "higgs.002505.h130_zz_4e_filt4e.recon";
  row1["vidh"] = "0";
  row1["vidl"] = "0";
  row1["amiextractime"] = "2003";
  row1["amiplanpartitions"] = "69878";
  row1["amiplannumevents"] = "0";
  row1["content"] = "cbnt";
  row1["includedpartitions"] = "656";
  row1["numevents"] = "83339";

  InsertQuery query(row1);
  
  msg("Testing is_valid");
  assert( query.is_valid() == true );

  msg("Testing get_row");
  Row Row3;
  Row3 = query.get_row();
  for( Row::const_iterator miter = Row3.begin();
         miter != Row3.end(); ++miter )
      cout << miter->first << " - " << miter->second << endl;

  msg("Testing set Sql query");
  Row row2;
  row2["id"] = "254";
  row2["name"] = "higgs.002505.h130_zz_4e.dc1.lumi10.recon.010";
  row2["vidh"] = "10003";
  row2["vidl"] = "10764";
  row2["aminame"] = "higgs.002505.h130_zz_4e.dc1.lumi10.recon.010";
  row2["amistate"] = "validated";
  row2["amiextractime"] = "2004";
  row2["amiplanpartitions"] = "60";
  row2["amiplannumevents"] = "10000";
  row2["content"] = "cbnt";
  row2["physicsprocess"] = "h130_zz_4e";
  row2["physworkgrp"] = "Higgs";
  row2["includedpartitions"] = "60";
  row2["numevents"] = "9570";
  query.set(row2);
  assert( (query.get_row()).size() == 14 );

  msg("End testing InsertQuery");
  return 0;
}

#ifdef CTEST_MAIN
int main() {
  return InsertQuery_t();
}
#endif