TOracleServer Class Reference

#include <TOracleServer.h>

Inheritance diagram for TOracleServer:

Collaboration diagram for TOracleServer:

Public Member Functions
void	Close (Option_t *opt="")
Int_t	CreateDataBase (const char *dbname)
Int_t	DropDataBase (const char *dbname)
TSQLResult *	GetColumns (const char *dbname, const char *table, const char *wild=0)
TSQLResult *	GetDataBases (const char *wild=0)
TSQLResult *	GetTables (const char *dbname, const char *wild=0)
Int_t	PrintResult ()
Int_t	PrintResultStr (TString &result)
TSQLResult *	Query (const char *sql)
Int_t	QueryTree (char *query, TTree *tree, char *leafs=0)
Int_t	Reload ()
Int_t	SelectDataBase (const char *dbname)
const char *	ServerInfo ()
Int_t	Shutdown ()
	TOracleServer (const char *db, const char *uid, const char *pw)
	~TOracleServer ()

Private Attributes
Connection *	fConn
Environment *	fEnv
oracle::occi::Statement *	fStmt

Friends
class	TOracleServerE
class	TOracleServerE2
class	TOracleServerE2W
class	TOracleServerE2WFB
class	TOracleServerE2WX

Constructor & Destructor Documentation

TOracleServer()

TOracleServer::TOracleServer	(	const char *	db,
		const char *	uid,
		const char *	pw
	)

~TOracleServer()

TOracleServer::~TOracleServer

(

)

{
   // Close connection to Oracle DB server.
 
   if (IsConnected())
      Close();
}

Member Function Documentation

Close()

void TOracleServer::Close

(

Option_t *

opt = ""

)

{
   // Close connection to Oracle DB server.
 
   try {
      if (fStmt)
         fConn->terminateStatement(fStmt);
      if (fConn)
         fEnv->terminateConnection(fConn);
      if (fEnv)
         Environment::terminateEnvironment(fEnv);
   } catch (SQLException &oraex)  {
      Error("TOracleServer", "close connection failed: (error: %s)", (oraex.getMessage()).c_str());
      //MakeZombie();
   }
 
   fPort = -1;
}

CreateDataBase()

Int_t TOracleServer::CreateDataBase

(

const char *

dbname

)

{
   // Create a database. Returns 0 if successful, non-zero otherwise.
   // NOT IMPLEMENTED.
 
   if (!IsConnected()) {
      Error("CreateDataBase", "not connected");
      return -1;
   }
   return -1;
}

DropDataBase()

Int_t TOracleServer::DropDataBase

(

const char *

dbname

)

{
   // Drop (i.e. delete) a database. Returns 0 if successful, non-zero
   // otherwise.
   // NOT IMPLEMENTED.
 
   if (!IsConnected()) {
      Error("DropDataBase", "not connected");
      return -1;
   }
 
   return -1;
}

GetColumns()

TSQLResult * TOracleServer::GetColumns	(	const char *	dbname,
		const char *	table,
		const char *	wild = 0
	)

{
   // List all columns in specified table in the specified database.
   // Wild is for wildcarding "t%" list all columns starting with "t".
   // Returns a pointer to a TSQLResult object if successful, 0 otherwise.
   // The result object must be deleted by the user.
 
   if (!IsConnected()) {
      Error("GetColumns", "not connected");
      return 0;
   }
 
   if (SelectDataBase(dbname) != 0) {
      Error("GetColumns", "no such database %s", dbname);
      return 0;
   }
   return new TOracleResult(fConn, table);
}

GetDataBases()

TSQLResult * TOracleServer::GetDataBases

(

const char *

wild = 0

)

{
   // List all available databases. Wild is for wildcarding "t%" list all
   // databases starting with "t".
   // Returns a pointer to a TSQLResult object if successful, 0 otherwise.
   // The result object must be deleted by the user.
   // NOT IMPLEMENTED.
 
   if (!IsConnected()) {
      Error("GetDataBases", "not connected");
      return 0;
   }
 
   return 0;
}

GetTables()

TSQLResult * TOracleServer::GetTables	(	const char *	dbname,
		const char *	wild = 0
	)

{
   // List all tables in the specified database. Wild is for wildcarding
   // "t%" list all tables starting with "t".
   // Returns a pointer to a TSQLResult object if successful, 0 otherwise.
   // The result object must be deleted by the user.
 
   // In Oracle 9 and above, table is accessed in schema.table format.
   // GetTables returns tables in all schemas accessible for the user.
   // Assumption: table ALL_OBJECTS is accessible for the user, which is true in Oracle 10g
   // The returned TSQLResult has two columns: schema_name, table_name
   // "dbname": if specified, return table list of this schema, or return all tables
   // "wild" is not used in this implementation
 
   if (!IsConnected()) {
      Error("GetTables", "not connected");
      return 0;
   }
 
   TString sqlstr("SELECT owner, object_name FROM ALL_OBJECTS WHERE object_type='TABLE'");
   if (dbname)
      sqlstr = sqlstr + " AND owner='" + dbname + "'";
   TSQLResult *tabRs;
   tabRs = Query(sqlstr.Data());
   return tabRs;
}

PrintResult()

Int_t TOracleServer::PrintResult

(

)

{
  if (!fStmt) printf("statement is not defined!\n");
  else {
    ResultSet *rset = fStmt->getResultSet();
    vector<MetaData> cmd = rset->getColumnListMetaData();
    const int  nlmax=cmd.size();
    printf("TOracleServer::PrintResult: %d columns\n", nlmax);
    if(nlmax<1) return 0;
    
    TString leaflist(nlmax*64);
    
    for (int i = 0; i < nlmax; i++) {
      string s = cmd[i].getString(MetaData::ATTR_NAME);
      if (i > 0) leaflist+=" : ";
      leaflist+= s.c_str();
    }
    
    printf("\n     #: %s\n", leaflist.Data());
    
    int line=0;
    while (rset->next())
    {
      printf("%6d: ",++line);
      for (int i = 1; i <= nlmax; i++) 
      {
        string fruit = rset->getString(i);
        printf("%s ", rset->getString(i).c_str() );
      }
      printf("\n");
    }
    
    delete rset;
  }
  return 0;
}

PrintResultStr()

Int_t TOracleServer::PrintResultStr

(

TString &

result

)

{
  int nlines=0;
  if (!fStmt) Log(1,"TOracleServer::PrintResultStr","ERROR: statement is not defined!");
  else {
    ResultSet *rset = fStmt->getResultSet();
    vector<MetaData> cmd = rset->getColumnListMetaData();
    const int  nlmax=cmd.size();
    Log(2,"TOracleServer::PrintResult","%d columns", nlmax);
    if(nlmax<1) return nlines;
 
    TString leaflist(nlmax*64);
 
    for (int i = 0; i < nlmax; i++) {
      string s = cmd[i].getString(MetaData::ATTR_NAME);
      if (i > 0) leaflist+=" : ";
      leaflist+= s.c_str();
    }
 
    result += Form("     #: %s\n", leaflist.Data());
 
    int line=0;
    while (rset->next())
    {
      result += Form("%6d: ",++line);
      for (int i = 1; i <= nlmax; i++) 
      {
        result += Form("%s ", rset->getString(i).c_str() );
      }
      result += Form("\n");
      nlines++;
    }
 
    delete rset;
  }
  return nlines;
}

Query()

TSQLResult * TOracleServer::Query

(

const char *

sql

)

{
   // Execute SQL command. Result object must be deleted by the user.
   // Returns a pointer to a TSQLResult object if successful, 0 otherwise.
   // The result object must be deleted by the user.
 
   if (!IsConnected()) {
      Error("Query", "not connected");
      return 0;
   }
 
   try {
      if (!fStmt)
         fStmt = fConn->createStatement();
 
      // count the number of rows of the resultset of this select
      // NOTE: Oracle doesn't provide a way through OCI or OCCI to count
      //       the number of rows. The reason is the memory concern of client
      //       application. Consider a select statment with 1 million rows
      //       returned. In Oracle, user can set prefetch size to repeatedly
      //       retrieve all rows by calling next(#rows_to_fetch). By default,
      //       prefetch size is set to 1, meaning client only fetch 1 row each
      //       time it contacts db server.
      // The best-so-far way to count the number of rows is to traverse the
      // resultset (count(query)). This method is neither efficient, fast
      // nor 100% accurate. Please see OCI/OCCI discussion forum for details
      // So the only purpose to count rows is follow TSQL specification.
 
      // TODO: We should change TSQL spec on GetRowCount(). Not every db server
      // provides natural way to do so like mysql. User can loop over resultset
      // and get the count after the last next() unless he must know the count
      // before next()
 
      // NOTE: sql should not end with ";" !!!
      int row_count = -1;
      //char sql_chars[strlen(sql)+1],*str;
      char* sql_chars = new char[strlen(sql)+1];
      char* str;
      strcpy(sql_chars, sql);
      str = sql_chars;
      // skip space and newline chars
      while ( *str == '\n' || *str == '\t' || *str == ' ' || *str == '\r' )
         str ++;
      string sql_string = sql;
      if (strncasecmp(str, "SELECT",6)==0) {
         string count_sql = "select COUNT(*) from ( " + sql_string + " )";
         fStmt->setSQL(count_sql.c_str());
         fStmt->execute();
 
         if (fStmt->status() == Statement::RESULT_SET_AVAILABLE) {
            ResultSet *count_rs = fStmt->getResultSet();
            if (count_rs->next())
               row_count = count_rs->getInt(1);
            fStmt->closeResultSet(count_rs);
         }
      }
      // NOTE: between above and below execute(), if there is any DDL operated
      // on target tables, the row_count may not be accurate
      fStmt->setSQL(sql);
      fStmt->execute();
 
      TOracleResult *res = new TOracleResult(fStmt, row_count);
      return res;
   } catch (SQLException &oraex)  {
      Error("TOracleServer", "query failed: (error: %s)", (oraex.getMessage()).c_str());
   }
 
   return 0;
}

QueryTree()

Int_t TOracleServer::QueryTree	(	char *	query,
		TTree *	tree,
		char *	leafs = 0
	)

{
  // read from database the given query and fill the tree with the results
  // example: db->QueryTree("select * from tb_plates",t);
  // VT(2004)
 
  if (!IsConnected()) {
    Error("QueryTree", "not connected");
    return 0;
  }
  if (!tree) {
    Error("QueryTree", "tree is not valid");
    return 0;
  }
 
  try {
    if (!fStmt)
      fStmt = fConn->createStatement();
    fStmt->setSQL(query);
    fStmt->setPrefetchRowCount(2000);
    printf("\nexecute sql query: %s ...\n",query);
    fStmt->execute();
    
    ResultSet *rset = fStmt->getResultSet();
    vector<MetaData> cmd = rset->getColumnListMetaData();
    const int  nlmax=cmd.size();
    printf("Number of metadata fields: %d\n", nlmax);
    if(nlmax<1) return 0;
    
    TString leaflist(nlmax*64);
    int ind=0;
    int *ifields = new int[nlmax];
    int dtype=0;
     
    for (int i = 0; i < nlmax; i++) {
      dtype = cmd[i].getInt(MetaData::ATTR_DATA_TYPE);
      printf("\nocci field type: %d \t",dtype);
      string s = cmd[i].getString(MetaData::ATTR_NAME);
      if (dtype == OCCI_SQLT_NUM )
    {
      ifields[ind++] = i + 1;
      if (ind > 1) leaflist+=":";
      leaflist+= s.c_str();
      leaflist+="/F";
      printf("%s added", s.c_str());
    } else printf("%s skipped", s.c_str());
    }
    
    leaflist.ToLower();
    printf("\n\nleaflist=%s\n", leaflist.Data());
    if(leafs) {
      leaflist=leafs;
      printf("\n\nleaflist=%s\n", leaflist.Data());
    }
    Float_t *data = new Float_t[ind];
    tree->Branch("query", data, leaflist.Data() );
    
    while (rset->next() == 1)
      {
    for (int i = 0; i < ind; i++)
      data[i] = rset->getFloat(ifields[i]);
    tree->Fill();
      }
    
    delete rset;
    delete[] ifields;
    delete[] data;
    return tree->GetEntries();
  } catch (SQLException &oraex)  {
    Error("TOracleServer", "QueryTree failed: (error: %s)", (oraex.getMessage()).c_str());
  }
  return 0;
}

Reload()

Int_t TOracleServer::Reload

(

)

{
   // Reload permission tables. Returns 0 if successful, non-zero
   // otherwise. User must have reload permissions.
   // NOT IMPLEMENTED.
 
   if (!IsConnected()) {
      Error("Reload", "not connected");
      return -1;
   }
   return -1;
}

SelectDataBase()

Int_t TOracleServer::SelectDataBase

(

const char *

dbname

)

{
   // Select a database. Returns 0 if successful, non-zero otherwise.
   // NOT IMPLEMENTED.
 
   if (!IsConnected()) {
      Error("SelectDataBase", "not connected");
      return -1;
   }
 
   // do nothing and return success code
   return 0;
}

ServerInfo()

const char * TOracleServer::ServerInfo

(

)

{
   // Return server info.
   // NOT IMPLEMENTED.
 
   if (!IsConnected()) {
      Error("ServerInfo", "not connected");
      return 0;
   }
   return "Oracle";
}

Shutdown()

Int_t TOracleServer::Shutdown

(

)

{
   // Shutdown the database server. Returns 0 if successful, non-zero
   // otherwise. User must have shutdown permissions.
   // NOT IMPLEMENTED.
 
   if (!IsConnected()) {
      Error("Shutdown", "not connected");
      return -1;
   }
   return -1;
}

Friends And Related Function Documentation

TOracleServerE

friend class TOracleServerE

friend

TOracleServerE2

friend class TOracleServerE2

friend

TOracleServerE2W

friend class TOracleServerE2W

friend

TOracleServerE2WFB

friend class TOracleServerE2WFB

friend

TOracleServerE2WX

friend class TOracleServerE2WX

friend

Member Data Documentation

fConn

Connection* TOracleServer::fConn

private

fEnv

Environment* TOracleServer::fEnv

private

fStmt

oracle::occi::Statement* TOracleServer::fStmt

private

---

The documentation for this class was generated from the following files:

• src/libEOracle/TOracleServer.h
• src/libEOracle/TOracleServer.cxx