// ============================================================================= // ============================================================================= int createtables() { // // Create Tables // int tmpCounter = 0; pb = new ProgressBar('=', 80, arguments.pCreateCounter, "Create Tables/Views"); sw->start(); try { if ( (arguments.pCreateList.count("ALL") > 0) || (arguments.pCreateList.count("ALTRO") > 0) ) { if ( arguments.pTest == false ) { if ( !tableExists("ALTRO") ) db->executeUpdate(dbq->getSqlCreateTableALTRO()); } else { ofstream *seperateOutFile = new ofstream(); seperateOutFile->open("ALTRO.sql"); string query = dbq->getSqlCreateTableALTRO(); *seperateOutFile << query << ";" << endl; seperateOutFile->close(); delete seperateOutFile; } pb->print(tmpCounter++); } if ( (arguments.pCreateList.count("ALL") > 0) || (arguments.pCreateList.count("FEC") > 0) ) { if ( arguments.pTest == false ) { if ( !tableExists("FEC") ) db->executeUpdate(dbq->getSqlCreateTableFEC()); } else { ofstream *seperateOutFile = new ofstream(); seperateOutFile->open("FEC.sql"); string query = dbq->getSqlCreateTableFEC(); *seperateOutFile << query << ";" << endl; seperateOutFile->close(); delete seperateOutFile; } pb->print(tmpCounter++); } if ( (arguments.pCreateList.count("ALL") > 0) || (arguments.pCreateList.count("RCU") > 0) ) { if ( arguments.pTest == false ) { if ( !tableExists("RCU") ) db->executeUpdate(dbq->getSqlCreateTableRCU()); } else { ofstream *seperateOutFile = new ofstream(); seperateOutFile->open("RCU.sql"); string query = dbq->getSqlCreateTableRCU(); *seperateOutFile << query << ";" << endl; seperateOutFile->close(); delete seperateOutFile; } pb->print(tmpCounter++); } if ( (arguments.pCreateList.count("ALL") > 0) || (arguments.pCreateList.count("SECTOR") > 0) ) { if ( arguments.pTest == false ) { if ( !tableExists("SECTOR") ) db->executeUpdate(dbq->getSqlCreateTableSECTOR()); } else { ofstream *seperateOutFile = new ofstream(); seperateOutFile->open("SECTOR.sql"); string query = dbq->getSqlCreateTableSECTOR(); *seperateOutFile << query << ";" << endl; seperateOutFile->close(); delete seperateOutFile; } pb->print(tmpCounter++); } if ( (arguments.pCreateList.count("ALL") > 0) || (arguments.pCreateList.count("TPC") > 0) ) { if ( arguments.pTest == false ) { if ( !tableExists("TPC") ) db->executeUpdate(dbq->getSqlCreateTableTPC()); } else { ofstream *seperateOutFile = new ofstream(); seperateOutFile->open("TPC.sql"); string query = dbq->getSqlCreateTableTPC(); *seperateOutFile << query << ";" << endl; seperateOutFile->close(); delete seperateOutFile; } pb->print(tmpCounter++); } if ( (arguments.pCreateList.count("ALL") > 0) || (arguments.pCreateList.count("SECTOR_TPC") > 0) ) { if ( arguments.pTest == false ) { if ( !tableExists("SECTOR_TPC") ) db->executeUpdate(dbq->getSqlCreateTableSECTOR_TPC()); } else { ofstream *seperateOutFile = new ofstream(); seperateOutFile->open("SECTOR_TPC.sql"); string query = dbq->getSqlCreateTableSECTOR_TPC(); *seperateOutFile << query << ";" << endl; seperateOutFile->close(); delete seperateOutFile; } pb->print(tmpCounter++); } if ( (arguments.pCreateList.count("ALL") > 0) || (arguments.pCreateList.count("RCU_SECTOR") > 0) ) { if ( arguments.pTest == false ) { if ( !tableExists("RCU_SECTOR") ) db->executeUpdate(dbq->getSqlCreateTableRCU_SECTOR()); } else { ofstream *seperateOutFile = new ofstream(); seperateOutFile->open("RCU_SECTOR.sql"); string query = dbq->getSqlCreateTableRCU_SECTOR(); *seperateOutFile << query << ";" << endl; seperateOutFile->close(); delete seperateOutFile; } pb->print(tmpCounter++); } if ( (arguments.pCreateList.count("ALL") > 0) || (arguments.pCreateList.count("FEC_RCU") > 0) ) { if ( arguments.pTest == false ) { if ( !tableExists("FEC_RCU") ) db->executeUpdate(dbq->getSqlCreateTableFEC_RCU()); } else { ofstream *seperateOutFile = new ofstream(); seperateOutFile->open("FEC_RCU.sql"); string query = dbq->getSqlCreateTableFEC_RCU(); *seperateOutFile << query << ";" << endl; seperateOutFile->close(); delete seperateOutFile; } pb->print(tmpCounter++); } if ( (arguments.pCreateList.count("ALL") > 0) || (arguments.pCreateList.count("ALTRO_FEC") > 0) ) { if ( arguments.pTest == false ) { if ( !tableExists("ALTRO_FEC") ) db->executeUpdate(dbq->getSqlCreateTableALTRO_FEC()); } else { ofstream *seperateOutFile = new ofstream(); seperateOutFile->open("ALTRO_FEC.sql"); string query = dbq->getSqlCreateTableALTRO_FEC(); *seperateOutFile << query << ";" << endl; seperateOutFile->close(); delete seperateOutFile; } pb->print(tmpCounter++); } if ( (arguments.pCreateList.count("ALL") > 0) || (arguments.pCreateList.count("FEE_A") > 0) ) { if ( arguments.pTest == false ) { if ( !tableExists("FEE_A") ) db->executeUpdate(dbq->getSqlCreateTableFEE_A()); } else { ofstream *seperateOutFile = new ofstream(); seperateOutFile->open("FEE_A.sql"); string query = dbq->getSqlCreateTableFEE_A(); *seperateOutFile << query << ";" << endl; seperateOutFile->close(); delete seperateOutFile; } pb->print(tmpCounter++); } if ( (arguments.pCreateList.count("ALL") > 0) || (arguments.pCreateList.count("FEE_C") > 0) ) { if ( arguments.pTest == false ) { if ( !tableExists("FEE_C") ) db->executeUpdate(dbq->getSqlCreateTableFEE_C()); } else { ofstream *seperateOutFile = new ofstream(); seperateOutFile->open("FEE_C.sql"); string query = dbq->getSqlCreateTableFEE_C(); *seperateOutFile << query << ";" << endl; seperateOutFile->close(); delete seperateOutFile; } pb->print(tmpCounter++); } if ( (arguments.pCreateList.count("ALL") > 0) || (arguments.pCreateList.count("FEESERVICES_A") > 0) ) { if ( arguments.pTest == false ) { if ( !tableExists("FEESERVICES_A") ) db->executeUpdate(dbq->getSqlCreateTableFEESERVICES_A()); } else { ofstream *seperateOutFile = new ofstream(); seperateOutFile->open("FEESERVICES_A.sql"); string query = dbq->getSqlCreateTableFEESERVICES_A(); *seperateOutFile << query << ";" << endl; seperateOutFile->close(); delete seperateOutFile; } pb->print(tmpCounter++); } if ( (arguments.pCreateList.count("ALL") > 0) || (arguments.pCreateList.count("FEESERVICES_C") > 0) ) { if ( arguments.pTest == false ) { if ( !tableExists("FEESERVICES_C") ) db->executeUpdate(dbq->getSqlCreateTableFEESERVICES_C()); } else { ofstream *seperateOutFile = new ofstream(); seperateOutFile->open("FEESERVICES_C.sql"); string query = dbq->getSqlCreateTableFEESERVICES_C(); *seperateOutFile << query << ";" << endl; seperateOutFile->close(); delete seperateOutFile; } pb->print(tmpCounter++); } // Create Views FEE and FEESERVICES /* if ( arguments.pCreateList.count("FEE") > 0 ) { if ( arguments.pTest == false ) { db->executeUpdate(dbq->getSqlCreateViewFEE()); } else { ofstream *seperateOutFile = new ofstream(); seperateOutFile->open("FEE.sql"); string query = dbq->getSqlCreateViewFEE(); *seperateOutFile << query << ";" << endl; seperateOutFile->close(); delete seperateOutFile; } pb->print(tmpCounter++); } if ( arguments.pCreateList.count("FEESERVICES") > 0 ) { if ( arguments.pTest == false ) { if ( !tableExists("FEE") ) { cerr << "Error: FEE View does not yet exist. Create it first!" << endl; return 0; } db->executeUpdate(dbq->getSqlCreateViewFEESERVICES()); } else { ofstream *seperateOutFile = new ofstream(); seperateOutFile->open("FEESERVICES.sql"); string query = dbq->getSqlCreateViewFEESERVICES(); *seperateOutFile << query << ";" << endl; seperateOutFile->close(); delete seperateOutFile; } pb->print(tmpCounter++); } */ } catch(SQLException& ea) { cout << ea.what() << endl; } sw->stop(); delete pb; cout << "Create Tables | " << sw->formatRealTime() << " s, " << sw->formatSysTime() << "s" << endl; return 1; }