DbiDBProxy.cxx

Go to the documentation of this file.

#include <memory>
#include <cassert>

#include "TCollection.h"
#include "TList.h"
#include "TSQLColumnInfo.h"
#include "TSQLStatement.h"
#include "TSQLServer.h"
#include "TSQLTableInfo.h"
#include "TString.h"

#include "Conventions/Detector.h"
#include "Conventions/SimFlag.h"
#include "DatabaseInterface/DbiDBProxy.h"
#include "DatabaseInterface/DbiCascader.h"
#include "DatabaseInterface/DbiFieldType.h"
#include "DatabaseInterface/DbiResultSet.h"
#include "DatabaseInterface/DbiServices.h"
#include "DatabaseInterface/DbiString.h"
#include "DatabaseInterface/DbiStatement.h"
#include "DatabaseInterface/DbiTableMetaData.h"
#include "DatabaseInterface/DbiTimerManager.h"
#include "LeakChecker/Lea.h"
#include "MessageService/MsgService.h"
#include "Validity/VldContext.h"

#include "Util/UtilString.h"

ClassImp(DbiDBProxy)

//   Typedefs
//   ********

//   Definition of static data members
//   *********************************

CVSID("$Id: DbiDBProxy.cxx,v 1.82 2009/01/30 09:52:57 nwest Exp $");

//    Definition of all member functions (static or otherwise)
//    *******************************************************
//
//    -  ordered: ctors, dtor, operators then in alphabetical order.


//.....................................................................

DbiDBProxy::DbiDBProxy(DbiCascader& cascader,
                       const string& tableName,
                       const DbiTableMetaData* metaData,
                       const DbiTableMetaData* metaValid,
                       const DbiTableProxy* tableProxy) :
fCascader(cascader),
fMetaData(metaData),
fMetaValid(metaValid),
fTableName(tableName),
fTableNameUc(UtilString::ToUpper(tableName)),
fTableProxy(tableProxy),
fVldSuffix("VLD")
{
//
//
//  Purpose:  Constructor
//
//  Arguments:   
//  cascader   in   Reference to one and only cascader
//  tableName  in   Table name.
//  metaData   in   Meta data for main table.
//  metaValid  in   Meta data for validity.
//  tableProxy in   Owning DbiTableProxy.
//

  LEA_CTOR    //Leak Checker
    
// If table name in mixed case, then use old suffix.
  if ( fTableName != fTableNameUc ) fVldSuffix = "Validity";

}

//.....................................................................

DbiDBProxy::~DbiDBProxy() {
//
//
//  Purpose: Destructor

  LEA_DTOR    //Leak Checker

  MSG("Dbi", Msg::kVerbose) << "Destroying DbiDBProxy " 
                          << fTableName << " at " << this
                          << endl;

}
//.....................................................................

void DbiDBProxy::FindTimeBoundaries(const VldContext& vc, 
                                    const Dbi::Task& task,
                                    UInt_t dbNo,
                                    VldTimeStamp earliestCreate,
                                    VldTimeStamp& start,
                                    VldTimeStamp& end) const {
//
//
//  Purpose: Find next time boundaries beyond standard time gate. 
//
//  Arguments: 
//    vc             in    The Validity Context for the query.
//    task           in    The task of the query.
//    dbNo           in    Database number in cascade (starting at 0).
//    earliestCreate in    Earliest creation date of data in the time gate
//    start          out   Lower time boundary or VldTimeStamp(0,0) if none
//    end            out   Upper time boundary or VldTimeStamp(0x7FFFFFFF,0) if none
//
//  Specification:-
//  =============
//
//  o Find the next time boundary (either TIMESTART or TIMEEND)
//    outside the current time gate with a creation date >= earliestCreate.

  MSG("Dbi",Msg::kSynopsis) << "FindTimeBoundaries for table " <<  fTableName
                            << " context " << vc 
                            << " task " << task 
                            << " Earliest creation date " <<  earliestCreate
                            << " database " << dbNo << endl;

//  Set the limits wide open
  start = VldTimeStamp(0,0);
  end   = VldTimeStamp(0x7FFFFFFF,0);
 
//  Construct a Time Gate on the current date.

  const VldTimeStamp curVTS = vc.GetTimeStamp();
  Int_t timeGate = Dbi::GetTimeGate(this->GetTableName());
  time_t vcSec = curVTS.GetSec() - timeGate;
  VldTimeStamp startGate(vcSec,0);
  vcSec += 2*timeGate;
  VldTimeStamp endGate(vcSec,0);
  string earliestCreateString(Dbi::MakeDateTimeString(earliestCreate));
  string startGateString(Dbi::MakeDateTimeString(startGate));
  string endGateString(Dbi::MakeDateTimeString(endGate));

// Extract information for VldContext.

  Detector::Detector_t    detType(vc.GetDetector());
  SimFlag::SimFlag_t       simFlg(vc.GetSimFlag());

// Use an auto_ptr to manage ownership of DbiStatement and TSQLStatement
  auto_ptr<DbiStatement> stmtDb(fCascader.CreateStatement(dbNo));

  for (int i_limit =1; i_limit <= 4; ++i_limit ) {
    DbiString sql("select ");
    if ( i_limit == 1 ) sql  << "min(TIMESTART) from " << fTableName
                             << "VLD where TIMESTART > '" << endGateString << "' ";
    if ( i_limit == 2 ) sql  << "min(TIMEEND) from " << fTableName
                             << "VLD where TIMEEND > '" << endGateString  << "' ";
    if ( i_limit == 3 ) sql  << "max(TIMESTART) from " << fTableName
                             << "VLD where TIMESTART < '" << startGateString << "' ";
    if ( i_limit == 4 ) sql  << "max(TIMEEND) from " << fTableName
                             << "VLD where TIMEEND < '" << startGateString  << "' ";
    sql << " and DetectorMask & " << static_cast<unsigned int>(detType) 
        << " and SimMask & " << static_cast<unsigned int>(simFlg)
        << " and CREATIONDATE >= '" << earliestCreateString << "'"
        << " and  Task = " << task;
    MSG("Dbi",Msg::kSynopsis) << "  FindTimeBoundaries query no. " << i_limit 
                          << " SQL:" <<sql.c_str() << endl;

    auto_ptr<TSQLStatement> stmt(stmtDb->ExecuteQuery(sql.c_str()));
    stmtDb->PrintExceptions(Msg::kDebug);

//  If the query returns data, convert to a time stamp and trim the limits
    TString date;
    if ( ! stmt.get() || ! stmt->NextResultRow() || stmt->IsNull(0) ) continue;
    date = stmt->GetString(0);
    if ( date.IsNull() ) continue;
    VldTimeStamp ts(Dbi::MakeTimeStamp(date.Data()));
    MSG("Dbi",Msg::kSynopsis) << "  FindTimeBoundaries query result: " << ts << endl;
    if ( i_limit <= 2 && ts < end   ) end   = ts;
    if ( i_limit >= 3 && ts > start ) start = ts;

  }

  MSG("Dbi",Msg::kSynopsis) << "FindTimeBoundaries for table " <<  fTableName
                        << " found " << start << " .. " << end << endl;

}
//.....................................................................

UInt_t DbiDBProxy::GetNumDb() const {
//
//
//  Purpose:  Return the number of databases in the cascade.

  return fCascader.GetNumDb();

}

//.....................................................................

DbiResultSet*  DbiDBProxy::QueryAllValidities (UInt_t dbNo,UInt_t seqNo) const {
//
//
//  Purpose:  Apply all validities query to database..
//
//  Arguments: 
//    dbNo         in    Database number in cascade (starting at 0).
//    seqNo        in    Just this SEQNO if >0 or all if 0 [default: 0]
//
//  Return:    New DbiResult object.
//             NB  Caller is responsible for deleting..
//
//  Contact:   N. West
//
//  Specification:-
//  =============
//
//  o Ask for every row in associated validity range table and return 
//    query results qualifying selection by fSqlCondition if defined.

//  Program Notes:-
//  =============

//  This function is provided to support database maintenance
//  rather than standard Dbi related I/O


// Generate SQL for validity table.

  DbiString sql;

  sql << "select * from " << fTableName << fVldSuffix;
  if ( fSqlCondition != "" ) sql << " where " << fSqlCondition;
  if ( seqNo > 0 ) {
    if ( fSqlCondition == "" ) sql << " where ";
    else                       sql << " and ";         
    sql << "seqno = " << seqNo;
  }
  sql  << ";" << '\0';

  MSG("Dbi",Msg::kSynopsis) << "Database: " << dbNo
                         << " query: " << sql.GetString() << endl;

//  Apply query and return result..

  DbiStatement* stmtDb = fCascader.CreateStatement(dbNo);
  return new DbiResultSet(stmtDb,sql,fMetaValid,fTableProxy,dbNo);

}



//.....................................................................

DbiResultSet*  DbiDBProxy::QuerySeqNo(UInt_t seqNo, UInt_t dbNo) const {
//
//
//  Purpose:  Apply sequence query to database..
//
//  Arguments: 
//    seqNo        in    The sequence number for the query.
//    dbNo         in    Database number in cascade (starting at 0).
//
//  Return:    New DbiResult object.
//             NB  Caller is responsible for deleting..
//
//  Contact:   N. West
//
//  Specification:-
//  =============
//
//  o Apply sequence query to table and return query results

//  Program Notes:-
//  =============

//  None..

// Generate SQL.

  DbiTimerManager::gTimerManager.RecMainQuery();
  DbiString sql;
  sql << "select * from " << fTableName << " where " 
      << "    SEQNO= " << seqNo;

  if ( DbiServices::OrderContextQuery() && fMetaData->HasRowCounter() )
    sql << " order by ROW_COUNTER";

  MSG("Dbi",Msg::kSynopsis) << "Database: " << dbNo
                         << " SeqNo query: " << sql.c_str() << endl;
  
//  Apply query and return result..

  DbiStatement* stmtDb = fCascader.CreateStatement(dbNo);
  return new DbiResultSet(stmtDb,sql,fMetaData,fTableProxy,dbNo);

}

//.....................................................................

DbiResultSet*  DbiDBProxy::QuerySeqNos(SeqList_t& seqNos,
                                       UInt_t dbNo,
                                       const string& sqlData,
                                       const string& fillOpts) const {
//
//
//  Purpose:  Apply query for a list of sequence numbers to database..
//
//  Arguments: 
//    seqNos       in    The vector of sequence numbers for the query.
//                       Should be in acsending order, see Program Notes
//    dbNo         in    Database number in cascade (starting at 0).
//    sqlData      in    Optional SQL extension to secondary query.
//    fillOpts     in    Optional fill options (available to DbiTableRow
//                       objects when filling.
//
//  Return:    New DbiResult object.
//             NB  Caller is responsible for deleting..
//
//  Contact:   N. West
//
//  Specification:-
//  =============
//
//  o Apply sequence query to table and return query results

//  Program Notes:-
//  =============

//  Where possible the SQL query is kept to a minimm by using
//  `BETWEEN' comparison to bracket ranges of numbers.

// Generate SQL.

  if ( seqNos.size() == 0 ) return 0;

  DbiTimerManager::gTimerManager.RecMainQuery();
  DbiString sql;
  sql << "select * from " << fTableName << " where ";

  if ( sqlData != "" ) sql << "( ";
  Bool_t first = kTRUE;
  SeqList_t::const_iterator itr1 = seqNos.begin();

  while ( itr1 != seqNos.end() ) {
    UInt_t seq1 = *itr1;
    UInt_t seq2 = seq1;
    SeqList_t::const_iterator itr2 = itr1;
    while ( itr2 != seqNos.end() && seq2 == *itr2 ) {
      ++itr2;
      ++seq2;
    }
    if ( first ) {
      first = kFALSE;
    }
    else {      
      sql << "or ";
    }
    if ( seq2 > seq1 + 1) {
      sql << "SEQNO between " << seq1 << " and " << seq2-1 << ' ';
      itr1 = itr2;
    }
    else {
      sql << "SEQNO = " << seq1 << ' ';
      ++itr1;
    }
  }
    
  if ( sqlData != "" ) sql << ")  and " << "(" << sqlData << ")" << " ";

  sql << "order by SEQNO";

  if ( DbiServices::OrderContextQuery() && fMetaData->HasRowCounter() )
    sql << ",ROW_COUNTER";

  MSG("Dbi",Msg::kSynopsis) << "Database: " << dbNo
                         << " SeqNos query: " << sql.c_str() << endl;
  
//  Apply query and return result..

  DbiStatement* stmtDb = fCascader.CreateStatement(dbNo);
  return new DbiResultSet(stmtDb,sql,fMetaData,fTableProxy,dbNo,fillOpts);

}

//.....................................................................

DbiResultSet*  DbiDBProxy::QueryValidity (const VldContext& vc,
                                          const Dbi::Task& task,
                                          UInt_t dbNo) const {
//
//
//  Purpose:  Apply validity query to database..
//
//  Arguments: 
//    vc           in    The Validity Context for the query.
//    task         in    The task of the query.
//    dbNo         in    Database number in cascade (starting at 0).
//
//  Return:    New DbiResult object.
//             NB  Caller is responsible for deleting..
//
//  Contact:   N. West
//
//  Specification:-
//  =============
//
//  o Apply query to associated validity range table and return query
//    results qualifying selection by fSqlCondition if defined.

//  Program Notes:-
//  =============

//  Rather than search over the full table this function places
//  a time gate round the context time and then trims any validity
//  range returned to this gate.  See FindTimeBoundaries to get a
//  more accurate validity range.

//  Construct a search window on the current date.

  const VldTimeStamp curVTS = vc.GetTimeStamp();
  Int_t timeGate = Dbi::GetTimeGate(this->GetTableName());
  time_t vcSec = curVTS.GetSec() - timeGate;
  VldTimeStamp startGate(vcSec,0);
  vcSec += 2*timeGate;
  VldTimeStamp endGate(vcSec,0);

// Extract information for VldContext.

  string startGateString(Dbi::MakeDateTimeString(startGate));
  string endGateString(Dbi::MakeDateTimeString(endGate));
  Detector::Detector_t    detType(vc.GetDetector());
  SimFlag::SimFlag_t       simFlg(vc.GetSimFlag());

// Generate SQL for context.

  DbiString context;
  context << "    TimeStart <= '" << endGateString << "' "
          << "and TimeEnd    > '" << startGateString << "' "
          << "and DetectorMask & " << static_cast<unsigned int>(detType) 
          << " and SimMask & " << static_cast<unsigned int>(simFlg);

//  Apply query and return result..

  return this->QueryValidity(context.GetString(),task,dbNo);

}
//.....................................................................

DbiResultSet*  DbiDBProxy::QueryValidity (const string& context, 
                                          const Dbi::Task& task,
                                          UInt_t dbNo) const {
//
//
//  Purpose:  Apply validity query to database..
//
//  Arguments: 
//    context      in    The Validity Context (see DbiSqlContext)
//    task         in    The task of the query.
//    dbNo         in    Database number in cascade (starting at 0).
//
//  Return:    New DbiResult object.
//             NB  Caller is responsible for deleting..
//
//  Contact:   N. West
//
//  Specification:-
//  =============
//
//  o Apply query to associated validity range table and return query
//    results qualifying selection by fSqlCondition if defined.


// Generate SQL for validity table.

  DbiString sql;

// Queries are normally ordered by creation date (the later the better)
// but make an exception for DBUSUBRUNSUMMARY which has open-ended
// end date and an unreliable creation date so the latest start date is 
// best.
// Same for DBURUNSUMMARY.  Bogus entries with wrong validity are stomping 
// real values for the same reason.  These should be cleaned +up in the DB 
// but TIMESTART should be always more valid than CREATIONDATE for such info
  string orderByName("CREATIONDATE");
  if ((fTableName == "DBUSUBRUNSUMMARY") || (fTableName == "DBURUNSUMMARY"))
      orderByName = "TIMESTART";
  sql << "select * from " << fTableName << fVldSuffix 
      << " where " ;
  if ( fSqlCondition != "" 
      ) sql << fSqlCondition << " and ";
  sql << context;
  if ( task != Dbi::kAnyTask
       ) sql << " and  Task = " << task
             << " order by " << orderByName << " desc;" << '\0';

  MSG("Dbi",Msg::kSynopsis) << "Database: " << dbNo
                         << " query: " << sql.c_str() << endl;

//  Apply query and return result..

  DbiStatement* stmtDb = fCascader.CreateStatement(dbNo);
  return new DbiResultSet(stmtDb,sql,fMetaValid,fTableProxy,dbNo);

}
//.....................................................................

DbiResultSet*  DbiDBProxy::QueryValidity (UInt_t seqNo,
                                          UInt_t dbNo) const {
//
//
//  Purpose:  Apply validity query to database..
//
//  Arguments: 
//    seqNo        in    The SEQNO of the validity rec.
//
//  Return:    New DbiResult object.
//             NB  Caller is responsible for deleting..
//
//  Contact:   N. West
//
//  Specification:-
//  =============
//
//  o Apply query to associated validity range table and return query
//    results qualifying selection by fSqlCondition if defined.


// Generate SQL for validity table.

  DbiString sql;
  sql << "select * from " << fTableName << fVldSuffix << " where ";
  if ( fSqlCondition != "" ) sql << fSqlCondition << " and ";
  sql << "SEQNO = " << seqNo << ";";

  MSG("Dbi",Msg::kSynopsis) << "Database: " << dbNo
                         << " SEQNO query: " << sql.c_str() << endl;

//  Apply query and return result..

  DbiStatement* stmtDb = fCascader.CreateStatement(dbNo);
  return new DbiResultSet(stmtDb,sql,fMetaValid,fTableProxy,dbNo);

}

//.....................................................................

Bool_t DbiDBProxy::RemoveSeqNo(UInt_t seqNo,
                               UInt_t dbNo) const {
//
//
//  Purpose:  Remove sequence number in main and auxiliary tables.
//
//  Arguments: 
//    seqNo        in    The sequence number to be removed.
//    dbNo         in    Database number in cascade (starting at 0). 
//
//  Return:    kTRUE if output successful,otherwise kFALSE.
//
//  Contact:   N. West
//
//  Specification:-
//  =============
//
//  o Remove sequence number in main and auxiliary tables.

//  Program Notes:-
//  =============

//  None.


// Generate SQL to remove SeqNo in main table.
  DbiString sql;
  sql  << "delete from  " << fTableName 
       << " where SEQNO = " << seqNo << ";"
       << '\0';

  MSG("Dbi",Msg::kSynopsis) << "Database: " << dbNo
                        << " RemoveSeqNo SQL: " << sql.c_str() << endl;

//  Apply query.
  auto_ptr<DbiStatement> stmtDb(fCascader.CreateStatement(dbNo));
  if ( ! stmtDb.get() ) return false;
  if ( ! stmtDb->ExecuteUpdate(sql.c_str()) || stmtDb->PrintExceptions() ) {
    MAXMSG("Dbi",Msg::kError,20) << "SQL: " << sql.c_str()
                           << " Failed. " << endl;
    return false;
  }

// Generate SQL to remove SeqNo in validity table.
  sql.GetString().erase();
  sql << "delete from  " << fTableName << fVldSuffix
      << " where SEQNO = " << seqNo << ";"
      << '\0';

  MSG("Dbi",Msg::kSynopsis) << "Database: " << dbNo
                        << " RemoveSeqNo SQL: " << sql.c_str() << endl;

//  Apply query.
  if (  ! stmtDb->ExecuteUpdate(sql.c_str()) ||  stmtDb->PrintExceptions() ) {
    MAXMSG("Dbi",Msg::kError,20) << "SQL: " << sql.c_str()
                           << " Failed. " << endl;
    return false;
  }

  return true;

}

//.....................................................................

Bool_t DbiDBProxy::ReplaceInsertDate(const VldTimeStamp& ts,
                                     UInt_t SeqNo,
                                     UInt_t dbNo) const{
//
//
//  Purpose:  Replace insertion date for row in auxiliary table.
//
//  Arguments: 
//    ts           in    Time stamp for new insertion date.
//    SeqNo        in    The sequence number of the row to be replaced.
//    dbNo         in    Database number in cascade (starting at 0). 
//
//  Return:    kTRUE if output successful,otherwise kFALSE.
//
//  Contact:   N. West


// Generate SQL.
  DbiString sql;
  sql << "update  " << fTableName << fVldSuffix
      << " set INSERTDATE = \'" << ts.AsString("s")
      << "\' where SEQNO = " << SeqNo << ";"
      << '\0';

  MSG("Dbi",Msg::kSynopsis) << "Database: " << dbNo
                        << " ReplaceInsertDate SQL: " 
                        << sql.c_str() << endl;

//  Apply query.
  auto_ptr<DbiStatement> stmtDb(fCascader.CreateStatement(dbNo));
  if ( ! stmtDb.get() ) return false;
  if (! stmtDb->ExecuteUpdate(sql.c_str()) || stmtDb->PrintExceptions() ) {
    MAXMSG("Dbi",Msg::kError,20) << "SQL: " << sql.c_str()
                           << " Failed. " << endl;
    return false;
  }

  return true;

}
//.....................................................................

Bool_t DbiDBProxy::ReplaceSeqNo(UInt_t oldSeqNo,
                                UInt_t newSeqNo,
                                UInt_t dbNo) const {
//
//
//  Purpose:  Replace sequence number in main and auxiliary tables.
//
//  Arguments: 
//    oldSeqNo     in    The old sequence number.
//    nwSeqNo      in    The new sequence number.
//    dbNo         in    Database number in cascade (starting at 0). 
//
//  Return:    kTRUE if output successful,otherwise kFALSE.
//
//  Contact:   N. West
//
//  Specification:-
//  =============
//
//  o Replace sequence number in main and auxiliary tables.

//  Program Notes:-
//  =============

//  None.

  if ( ! fCascader.GetConnection(dbNo) ) {
    MSG("Dbi",Msg::kWarning)
       << "Cannot renumber " << oldSeqNo
       << " no connection to cascade entry " << dbNo << endl;
    return false;
  }
// Deal with Oracle separately - it's best.
  if ( fCascader.GetConnection(dbNo)->GetDbType () == Dbi::kOracle )
    return this->ReplaceSeqNoOracle(oldSeqNo,newSeqNo,dbNo);

// Generate SQL to replace SeqNo in validity table.
  DbiString sql;
  sql << "update  " << fTableName << fVldSuffix
      << " set SEQNO = " << newSeqNo 
      << " where SEQNO = " << oldSeqNo << ";"
      << '\0';

  MSG("Dbi",Msg::kSynopsis) << "Database: " << dbNo
                        << " ReplaceSeqNo SQL: " << sql.c_str() << endl;

//  Apply query.
  auto_ptr<DbiStatement> stmtDb(fCascader.CreateStatement(dbNo));
  if ( ! stmtDb.get() ) return false;
  if ( ! stmtDb->ExecuteUpdate(sql.c_str()) || stmtDb->PrintExceptions() ) {
    MAXMSG("Dbi",Msg::kError,20) << "SQL: " << sql.c_str()
                           << " Failed. " << endl;
    return false;
  }

// Generate SQL to replace SeqNo in main table.
  sql.GetString().erase();
  sql  << "update  " << fTableName 
       << " set SEQNO = " << newSeqNo 
       << " where SEQNO = " << oldSeqNo << ";"
       << '\0';

  MSG("Dbi",Msg::kSynopsis) << "Database: " << dbNo
                        << " ReplaceSeqNo SQL: " << sql.c_str() << endl;

//  Apply query.
  if ( ! stmtDb->ExecuteUpdate(sql.c_str()) || stmtDb->PrintExceptions() ) {
    MAXMSG("Dbi",Msg::kError,20) << "SQL: " << sql.c_str()
                           << " Failed. " << endl;
    return false;
  }

  return true;

}
//.....................................................................

Bool_t DbiDBProxy::ReplaceSeqNoOracle(UInt_t oldSeqNo,
                                      UInt_t newSeqNo,
                                      UInt_t dbNo) const {
//
//
//  Purpose:  Replace sequence number in main and auxiliary tables.  Oracle version
//
//  Arguments: 
//    oldSeqNo     in    The old sequence number.
//    nwSeqNo      in    The new sequence number.
//    dbNo         in    Database number in cascade (starting at 0). 
//
//  Return:    kTRUE if output successful,otherwise kFALSE.
//
//  Contact:   N. West
//
//  Specification:-
//  =============
//
//  o Replace sequence number in main and auxiliary tables.

//  Program Notes:-
//  =============

//  Constraints between the main and VLD tables means that neither can simple get
//  updated without violating the constraint, so it's necessary to duplicate the
//  VLD entry, move the main entry and finally delete the old entry.

// Check that old VLD entry exists.

  DbiResultSet* rsOld = QueryValidity(oldSeqNo,dbNo);
  if ( rsOld && rsOld->IsBeforeFirst() ) rsOld->FetchRow();
  if ( ! rsOld || rsOld->IsExhausted() ) {
    MSG("Dbi",Msg::kWarning) << "Cannot renumber " << oldSeqNo
                           << " it does not exist" << endl;
    delete rsOld;
    return false;
  }

// Generate SQL to add new SeqNo in validity vable.

  DbiString sql;
  sql << "insert into " << fTableName << fVldSuffix
      << " values (" << newSeqNo;

  rsOld->IncrementCurCol();
  UInt_t numCols =rsOld->NumCols();
  for (UInt_t iCol = 2; iCol <= numCols; ++iCol) {
    UInt_t concept = rsOld->CurColFieldType().GetConcept();
    string delim = "";
    if (    concept == Dbi::kString 
         || concept == Dbi::kDate 
         || concept == Dbi::kChar ) delim = "\'";  
    sql << "," << delim << rsOld->CurColValue() << delim ;
    rsOld->IncrementCurCol();
  }
  sql << ")";   
  MSG("Dbi",Msg::kSynopsis) << "Database: " << dbNo
                        << " ReplaceSeqNo SQL (insert new VLD): " << sql.c_str() << endl;
  delete rsOld;

//  Apply query.
  auto_ptr<DbiStatement> stmtDb(fCascader.CreateStatement(dbNo));
  if ( ! stmtDb.get() ) return false;
  if ( ! stmtDb->ExecuteUpdate(sql.c_str()) || stmtDb->PrintExceptions() ) {
    MAXMSG("Dbi",Msg::kError,20) << "SQL: " << sql.c_str()
                           << " Failed. " << endl;
    return false;
  }

// Generate SQL to replace SeqNo in main table.
  sql.GetString().erase();
  sql  << "update  " << fTableName 
       << " set SEQNO = " << newSeqNo 
       << " where SEQNO = " << oldSeqNo << ";";

  MSG("Dbi",Msg::kSynopsis) << "Database: " << dbNo
                        << " ReplaceSeqNo SQL (rename main entry): " << sql.c_str() << endl;

//  Apply query.
  if ( ! stmtDb->ExecuteUpdate(sql.c_str()) || stmtDb->PrintExceptions() ) {
    MAXMSG("Dbi",Msg::kError,20) << "SQL: " << sql.c_str()
                           << " Failed. " << endl;
    return false;
  }

// Generate SQL to remove old SeqNo in validity table.
  sql.GetString().erase();
  sql  << "delete from  " << fTableName << fVldSuffix
       << " where SEQNO = " << oldSeqNo << ";";

  MSG("Dbi",Msg::kSynopsis) << "Database: " << dbNo
                        << " ReplaceSeqNo SQL (delete old VLD): " << sql.c_str() << endl;

//  Apply query.
  if ( ! stmtDb->ExecuteUpdate(sql.c_str()) || stmtDb->PrintExceptions() ) {
    MAXMSG("Dbi",Msg::kError,20) << "SQL: " << sql.c_str()
                           << " Failed. " << endl;
    return false;
  }

  return true;


}
//.....................................................................

void  DbiDBProxy::StoreMetaData(DbiTableMetaData& metaData) const {
//
//
//  Purpose:  Store table meta data.
//
//  Arguments: 
//    metaData   in    Empty DbiTableMetaData object apart from table name.



  const char* tableName = metaData.TableName().c_str(); 
  MSG("Dbi",Msg::kSynopsis) << "Get meta-data for table: " << tableName << endl;
  
//  Check each Db in turn until table found and store table meta data.

  for ( UInt_t dbNo = 0; dbNo < fCascader.GetNumDb(); dbNo++ ) {
    DbiConnection* connection = fCascader.GetConnection(dbNo); 
    TSQLServer* server = connection->GetServer();
    if ( ! server ) continue;
    connection->Connect();
    TSQLTableInfo* meta = server->GetTableInfo(tableName);
    if ( ! meta ) {
      connection->DisConnect();
      continue;
    }
    MSG("Dbi",Msg::kSynopsis) << "Meta-data query succeeded on cascade entry " << dbNo << endl;

    // Clear out any existing data, although there should not be any.
    metaData.Clear();

    const TList* cols =  meta->GetColumns();
    TIter colItr(cols);
    int col = 0;
    while ( TSQLColumnInfo* colInfo = dynamic_cast<TSQLColumnInfo*>(colItr.Next()) ) {

      ++col;
      string name(colInfo->GetName());
      name = UtilString::ToUpper(name);
      metaData.SetColName(name,col);

      DbiFieldType fldType(colInfo->GetSQLType(),
                           colInfo->GetLength(),
                           colInfo->GetTypeName());

      // For now continue to check for unsigned (even though not supported)
      if ( !colInfo->IsSigned() ) fldType.SetUnsigned();
      metaData.SetColFieldType(fldType,col);

      metaData.SetColIsNullable(col,colInfo->IsNullable());

      MSG("Dbi",Msg::kSynopsis) 
           << "Column "         << col << " " << name
           << " SQL type "      << colInfo->GetSQLType()
           << " SQL type name " << colInfo->GetTypeName()
           << " DBI type "      << fldType.AsString() 
           << " data size: "    << fldType.GetSize()
           << " col size: "     << colInfo->GetLength() << endl;

    }
    delete meta;
    connection->DisConnect();
    return;
  }
}

//.....................................................................

Bool_t DbiDBProxy::TableExists(Int_t selectDbNo) const {
//
//
//  Purpose:  Return true if table exists on selected cascade entry
//            or any entry if selectDbNo=-1 (default)


  return fCascader.TableExists(fTableName,selectDbNo);

}

---