demo.cxx

Go to the documentation of this file.

//----------------------------------------------------------------------------------------------
//
// To run this demo:-
// 
// 1) Set up a database (say t2k_db) on a mysql server (say mysqlserver.t2k.com) 
//    with a write access account (say t2k_writer,t2k_writer_psw) using the 
//    following environmental variables:-
// 
//    export SK_TSQL_URL="mysql://neut12.triumf.ca/testskcalib"
//    export SK_TSQL_USER="skcaldb_writer"
//    export SK_TSQL_PSWD="sk222wrtr"
//    
//    You need to have added ROOT to your LD_LIBRARY_PATH as well
// 
//    There are scripts (setup_writer.*sh) that do this for you
//    
// 2) Prime it:-
//
//    app/database_updater.py apply_local_update demo/demo_db_table.update
// 
// 3) Run the demo:-
// 
//    linux/demo.exe 
//
//----------------------------------------------------------------------------------------------
#include "TVldTimeStamp.hxx"
#include "TDbi.hxx"

Int_t DateTimeToUnixTime(const std::string& dateTime) {
  return TDbi::MakeTimeStamp(dateTime).GetSec();
}

std::string UnixTimeToDateTime(Int_t unixSecs) {
  return TDbi::MakeDateTimeString(TVldTimeStamp(unixSecs,0));
}



#include "TSK_DBI_Context.hxx"
#include "TDemo_DB_Table.hxx"
#include "TResultSetHandle.hxx"

#include <iostream>
#include <string>

int main() {


  // Examine the Database table DEMO_DB_TABLE every 5 days between the start
  // and end date.

  std::string start_date_time = "2008-12-30 00:00:00";
  std::string end_date_time   = "2009-03-01 00:00:00";

  Int_t start_unix_time = DateTimeToUnixTime(start_date_time);
  Int_t end_unix_time   = DateTimeToUnixTime(end_date_time);

  UInt_t required_id      = 1;

  for (Int_t current_unix_time = start_unix_time; current_unix_time <= end_unix_time; current_unix_time += 5*24*60*60) {
    TSK_DBI_Context context;
    context.SetTimeStamp(current_unix_time);
    TResultSetHandle<TDemo_DB_Table> rs(context);
    SK_DBI_Log("_______________________________________________________________________________");
    Int_t numRows(rs.GetNumRows());
    if ( ! numRows )  SK_DBI_Log("Applying query at " << UnixTimeToDateTime(current_unix_time) << " ... failed to find any results.");
    else {
      SK_DBI_Log("Applying query at " << UnixTimeToDateTime(current_unix_time) << " ... result set contains " 
                                    << numRows << " rows as follows:-");
      for (Int_t irow = 0; irow<numRows; ++irow) rs.GetRow(irow)->Print();
      const TDemo_DB_Table* required_row = rs.GetRowByIndex(required_id);
      if ( required_row ) {
        SK_DBI_Log("  required row " << 1);
        required_row->Print();
      }
      else SK_DBI_Log("  cannot find required row " << 1);      
    }
  }

  return 0;
}