harpodbtest.cxx

Go to the documentation of this file.

//
// Demo code for harpo database manipulation
// Write access to harpo database was required !!!
// Can be run on harpo servers ONLY !!!
//

#include "HarpoDB.h"
#include "TString.h"
#include <iostream>
#include <stdlib.h>
#include <unistd.h>


int main(int argc, char **argv)
{
  HarpoDB *db;
  Long_t run = 0;
  if (argc == 2) {
    // Lookup for given run
    run = atol(argv[1]);
    //    char *pw = getpass("Enter Password: ");
  }
  db = new HarpoDB;
  db->SetUser("harpo","harpo");
  if ( ! db->Open() ) return 1;
  db->list();

  // Clenup test table
  db->ExecQuery("DELETE FROM `runtest`;");

  if ( run < 0 ) return run;

  HarpoDBTable *t0 = new HarpoDBTable();
  HarpoDBTable *t1 = new HarpoDBTable();
  
  db->GetTable("runconfig",t0);
  db->GetTable("runtest",t1);

  t0->list();
  t1->list();

  // copy runs 1675 - 1680

  HarpoDBRow runinfo;
  Bool_t ok;
  for (Long_t i=1675;i<=1680;i++) {
   ok = t0->GetRunRow(i,runinfo);
   if (ok) {
     runinfo.list();
     t1->InsertRunRow(runinfo);
   }
  }

  t0->DeleteRun(1676);

  // Insert with some row exist
  for (Long_t i=1678;i<=1682;i++) {
   ok = t0->GetRunRow(i,runinfo);
   if (ok) {
     runinfo.list();
     t1->InsertRunRow(runinfo);
   }
  }

  
  // Narrow query to "intresting" fileds
  dbFields fields = t0->GetFiledsTypes();
  for (dbFields::iterator it=fields.begin(); it!=fields.end(); ++it) {
    if (!( it->first.Contains("run") || it->first.Contains("Duration")
           || it->first.Contains("TriggerType")) )
      { // Other, we not need
        t0->Erase(it->first);
      } 
  }
  
  // 3 field query for runs
  for (Long_t i=2000;i<=2010;i++) {
    ok = t0->GetRunRow(i,runinfo);
    if (ok) {
      //   runinfo.list();
      t1->InsertRunRow(runinfo);
    }
  }
  
  // Update Duration to 2 hour
   
  Long_t duration = 200;
  for (Long_t i=2005;i<=2010;i++) {
    ok = t1->GetRunRow(i,runinfo);
    if (ok) {
      runinfo.SetVal("Duration",duration);
      t1->UpdateRunRow(runinfo);
    }
  }

  delete t1;
  delete t0;
  db->Close();
  delete db;
  return 0;
}