// ============================================================================= // ============================================================================= int createfillqueries() { // // Create the queries to fill the tables. // altroQuerys.clear(); fecQuerys.clear(); rcuQuerys.clear(); sectorQuerys.clear(); tpcQuerys.clear(); altro_fecQuerys.clear(); fec_rcuQuerys.clear(); rcu_sectorQuerys.clear(); sector_tpcQuerys.clear(); tpcQueryCount = arguments.pSelectTagList.size(); altroQueryCount = ciAltros*cifecPerSector*ciSectors*ciSides*tpcQueryCount; fecQueryCount = cifecPerSector*ciSectors*ciSides*tpcQueryCount; rcuQueryCount = ciRCUs*ciSectors*ciSides*tpcQueryCount; sectorQueryCount = ciSectors*ciSides*tpcQueryCount; pb = new ProgressBar('=', 80, fecQueryCount, "Create Querys "); sw->start(); for ( uint32_t tagCounter = 0; tagCounter < arguments.pSelectTagList.size(); tagCounter++ ) { tpcQuerys.push_back(dbq->getSqlInsertTPC(arguments.pSelectTagList.at(tagCounter), arguments.pFillComment.at(tagCounter))); tpcQueryIndex++; for(int32_t sideCounter = 0; sideCounter < ciSides; sideCounter++) { for(int32_t sectorCounter = 0; sectorCounter < ciSectors; sectorCounter++) { sectorQuerys.push_back(dbq->getSqlInsertSECTOR(sectorIndex, sectorCounter, sideCounter)); sectorQueryIndex++; sector_tpcQuerys.push_back(dbq->getSqlInsertSECTOR_TPC(sectorIndex, arguments.pSelectTagList.at(tagCounter))); sector_tpcQueryIndex++; for(int32_t rcuCounter = 0; rcuCounter < ciRCUs; rcuCounter++) { rcuQuerys.push_back(dbq->getSqlInsertRCU(rcuIndex, get_eqid(sideCounter, sectorCounter, rcuCounter), sideCounter, sectorCounter, rcuCounter, arguments.pSelectTagList.at(tagCounter))); rcuQueryIndex++; rcu_sectorQuerys.push_back(dbq->getSqlInsertRCU_SECTOR(rcuIndex, sectorIndex)); rcu_sectorQueryIndex++; for(int32_t branchCounter = 0; branchCounter < 2; branchCounter++) { for(int32_t fecCounter = 0; fecCounter < fecPerRCUBranch[rcuCounter][branchCounter]; fecCounter++) { fecQuerys.push_back(dbq->getSqlInsertFEC(fecIndex, sideCounter, sectorCounter, rcuCounter, branchCounter, fecCounter, arguments.pSelectTagList.at(tagCounter))); fecQueryIndex++; fec_rcuQuerys.push_back(dbq->getSqlInsertFEC_RCU(fecIndex, rcuIndex)); fec_rcuQueryIndex++; for(int32_t altroCounter = 0; altroCounter < ciAltros; altroCounter++) { // ALTRO table altroQuerys.push_back(dbq->getSqlInsertALTRO(altroIndex, sideCounter, sectorCounter, rcuCounter, branchCounter, fecCounter, altroCounter, arguments.pSelectTagList.at(tagCounter))); altroQueryIndex++; // ALTRO_FEC table altro_fecQuerys.push_back(dbq->getSqlInsertALTRO_FEC(altroIndex,fecIndex)); altro_fecQueryIndex++; altroIndex++; } pb->print(fecIndex); fecIndex++; } // end FEC loop } // end BRANCH loop rcuIndex++; //feeIndex++; /* cout << "altroIndex : " << altroIndex << ", fecIndex " << fecIndex << ", rcuIndex " << rcuIndex << ", sectorIndex " << sectorIndex << ", arguments.pSelectTagList.at(tagCounter) " << arguments.pSelectTagList.at(tagCounter) << endl; cout << "altroQueryCount : " << altroQueryCount << ", fecQueryCount " << fecQueryCount << ", rcuQueryCount " << rcuQueryCount << ", sectorQueryCount " << sectorQueryCount << ", tpcQueryCount " << tpcQueryCount << endl; */ } // end RCU Loop sectorIndex++; } // end SECTOR Loop } // end SIDE Loop } // end Tag Loop delete pb; sw->stop(); cout << "created Querys | " << sw->formatRealTime() << " s, " << sw->formatSysTime() << "s" << endl; return 1; } // ============================================================================= // ============================================================================= int32_t getquerysizes() { // // Check size of queries. // int32_t lengthofQueries = 0; int32_t totalLengthofQuerys = 0; for ( int32_t i = 0; i < altroQueryCount; i++ ) lengthofQueries += altroQuerys[i].length(); totalLengthofQuerys += lengthofQueries; cout << endl << setw(40) << "Altro Querys Length: " << setw(11) << lengthofQueries << " Byte, " << setw(8) << (lengthofQueries/1024) << " kByte " << setw(5) << (lengthofQueries/1024/1024) << " MByte" << endl; lengthofQueries = 0; for(int32_t i = 0; i < fecQueryCount; i++) lengthofQueries += fecQuerys[i].length(); totalLengthofQuerys += lengthofQueries; cout << setw(40) << "FEC Querys Length: " << setw(11) << lengthofQueries << " Byte, " << setw(8) << (lengthofQueries/1024) << " kByte " << setw(5) << (lengthofQueries/1024/1024) << " MByte" << endl; lengthofQueries = 0; for(int32_t i = 0; i < rcuQueryCount; i++) lengthofQueries += rcuQuerys[i].length(); totalLengthofQuerys += lengthofQueries; cout << setw(40) << "RCU Querys Length: " << setw(11) << lengthofQueries << " Byte, " << setw(8) << (lengthofQueries/1024) << " kByte " << setw(5) << (lengthofQueries/1024/1024) << " MByte" << endl; lengthofQueries = 0; for(int32_t i = 0; i < sectorQueryCount; i++) lengthofQueries += sectorQuerys[i].length(); totalLengthofQuerys += lengthofQueries; cout << setw(40) << "Sector Querys Length: " << setw(11) << lengthofQueries << " Byte, " << setw(8) << (lengthofQueries/1024) << " kByte " << setw(5) << (lengthofQueries/1024/1024) << " MByte" << endl; lengthofQueries = 0; for(int32_t i = 0; i < altroQueryCount; i++) lengthofQueries += altro_fecQuerys[i].length(); totalLengthofQuerys += lengthofQueries; cout << setw(40) << "ALTRO & FEC Link Querys Length: " << setw(11) << lengthofQueries << " Byte, " << setw(8) << (lengthofQueries/1024) << " kByte " << setw(5) << (lengthofQueries/1024/1024) << " MByte" << endl; lengthofQueries = 0; for(int32_t i = 0; i < fecQueryCount; i++) lengthofQueries += fec_rcuQuerys[i].length(); totalLengthofQuerys += lengthofQueries; cout << setw(40) << "FEC & RCU Link Querys Length: " << setw(11) << lengthofQueries << " Byte, " << setw(8) << (lengthofQueries/1024) << " kByte " << setw(5) << (lengthofQueries/1024/1024) << " MByte" << endl; lengthofQueries = 0; for(int32_t i = 0; i < rcuQueryCount; i++) lengthofQueries += rcu_sectorQuerys[i].length(); totalLengthofQuerys += lengthofQueries; cout << setw(40) << "RCU & SECTOR Link Querys Length: " << setw(11) << lengthofQueries << " Byte, " << setw(8) << (lengthofQueries/1024) << " kByte " << setw(5) << (lengthofQueries/1024/1024) << " MByte" << endl; lengthofQueries = 0; for(int32_t i = 0; i < sectorQueryCount; i++) lengthofQueries += sector_tpcQuerys[i].length(); totalLengthofQuerys += lengthofQueries; cout << setw(40) << "SECTOR & TPC Link Querys Length: " << setw(11) << lengthofQueries << " Byte, " << setw(8) << (lengthofQueries/1024) << " kByte " << setw(5) << (lengthofQueries/1024/1024) << " MByte" << endl; cout << setw(40) << "TPC Querys Length: " << setw(11) << lengthofQueries << " Byte, " << setw(8) << (lengthofQueries/1024) << " kByte " << setw(5) << (lengthofQueries/1024/1024) << " MByte" << endl; cout << "--------------------------------------------------------------------------------------------------" << endl; cout << setw(40) << "Total Querys Length: " << setw(11) << totalLengthofQuerys << " Byte, " << setw(8) << (totalLengthofQuerys/1024) << " kByte " << setw(5) << (totalLengthofQuerys/1024/1024) << " MByte" << endl << endl; return 1; } // ============================================================================= // ============================================================================= int32_t filltables() { // // Fill Tables with standard values (a few different basic configurations are // available, see for example Config/AltroConfig.C). // // // 1) Find the max id's in the tables. The new data will be appended // at the end of each table. // if ( !findmaxids() ) { cerr << "*Error: Could not find max id's!" << endl; return 0; } // // 2) Check if config(s) exist(s). If yes, skip it. // if ( !checkbeforefillconfigexists() ) { // Check if config exists. cerr << "*Nothing to be done!" << endl; return 0; } // // 3) Create the queries. // if ( !createfillqueries() ) { cerr << "*Error: Could not create queries!" << endl; return 0; } // // 4) Test output (size of queries), no DB activity. // if ( (arguments.pTest == true) && !getquerysizes() ) { cerr << "*Error: Could not get size of queries!" << endl; return 0; } // // 5) Fill tables (or print32_t queries to file) // sw->start(); try { pb = new ProgressBar('=',80,altroQueryCount ,"Insert Altros "); if (arguments.pTest == false) { for(int32_t i = 0; i < altroQueryCount; i++) { db->executeUpdate(altroQuerys[i]); pb->print(i); } } else { ofstream *seperateOutFile = new ofstream(); seperateOutFile->open("ALTRO.sql"); for(int32_t i = 0; i < altroQueryCount; i++) { *seperateOutFile << altroQuerys[i] << ";" << endl; pb->print(i); } seperateOutFile->close(); delete seperateOutFile; } delete pb; sw->stop(); pb = new ProgressBar('=',80,fecQueryCount ,"Insert FECs "); if (arguments.pTest == false) { for(int32_t i = 0; i < fecQueryCount; i++) { db->executeUpdate(fecQuerys[i]); pb->print(i); } } else { ofstream *seperateOutFile = new ofstream(); seperateOutFile->open("FEC.sql"); for(int32_t i = 0; i < fecQueryCount; i++) { *seperateOutFile << fecQuerys[i] << ";" << endl; pb->print(i); } seperateOutFile->close(); delete seperateOutFile; } delete pb; pb = new ProgressBar('=',80,rcuQueryCount ,"Insert RCUs "); if (arguments.pTest == false) { for(int32_t i = 0; i < rcuQueryCount; i++) { db->executeUpdate(rcuQuerys[i]); pb->print(i); } } else { ofstream *seperateOutFile = new ofstream(); seperateOutFile->open("RCU.sql"); for(int32_t i = 0; i < rcuQueryCount; i++) { *seperateOutFile << rcuQuerys[i] << ";" << endl; pb->print(i); } seperateOutFile->close(); delete seperateOutFile; } delete pb; pb = new ProgressBar('=',80,sectorQueryCount,"Insert Sectors "); if (arguments.pTest == false) { for(int32_t i = 0; i < sectorQueryCount; i++) { db->executeUpdate(sectorQuerys[i]); pb->print(i); } } else { ofstream *seperateOutFile = new ofstream(); seperateOutFile->open("SECTOR.sql"); for(int32_t i = 0; i < sectorQueryCount; i++) { *seperateOutFile << sectorQuerys[i] << ";" << endl; pb->print(i); } seperateOutFile->close(); delete seperateOutFile; } delete pb; pb = new ProgressBar('=',80,tpcQueryCount ,"Insert TPCs "); if (arguments.pTest == false) { for(int32_t i = 0; i < tpcQueryCount; i++) { db->executeUpdate(tpcQuerys[i]); pb->print(i); } } else { ofstream *seperateOutFile = new ofstream(); seperateOutFile->open("TPC.sql"); for(int32_t i = 0; i < tpcQueryCount; i++) { *seperateOutFile << tpcQuerys[i] << ";" << endl; pb->print(i); } seperateOutFile->close(); delete seperateOutFile; } delete pb; sw->stop(); pb = new ProgressBar('=',80,altroQueryCount ,"Insert AF Link "); if (arguments.pTest == false) { for(int32_t i = 0; i < altroQueryCount; i++) { db->executeUpdate(altro_fecQuerys[i]); pb->print(i); } } else { ofstream *seperateOutFile = new ofstream(); seperateOutFile->open("ALTRO_FEC.sql"); for(int32_t i = 0; i < altroQueryCount; i++) { *seperateOutFile << altro_fecQuerys[i] << ";" << endl; pb->print(i); } seperateOutFile->close(); delete seperateOutFile; } delete pb; sw->stop(); pb = new ProgressBar('=',80,fecQueryCount ,"Insert FR Link "); if (arguments.pTest == false) { for(int32_t i = 0; i < fecQueryCount; i++) { db->executeUpdate(fec_rcuQuerys[i]); pb->print(i); } } else { ofstream *seperateOutFile = new ofstream(); seperateOutFile->open("FEC_RCU.sql"); for(int32_t i = 0; i < fecQueryCount; i++) { *seperateOutFile << fec_rcuQuerys[i] << ";" << endl; pb->print(i); } seperateOutFile->close(); delete seperateOutFile; } delete pb; sw->stop(); pb = new ProgressBar('=',80,rcuQueryCount ,"Insert RS Link "); if (arguments.pTest == false) { for(int32_t i = 0; i < rcuQueryCount; i++) { db->executeUpdate(rcu_sectorQuerys[i]); pb->print(i); } } else { ofstream *seperateOutFile = new ofstream(); seperateOutFile->open("RCU_SECTOR.sql"); for(int32_t i = 0; i < rcuQueryCount; i++) { *seperateOutFile << rcu_sectorQuerys[i] << ";" << endl; pb->print(i); } seperateOutFile->close(); delete seperateOutFile; } delete pb; sw->stop(); pb = new ProgressBar('=',80,sectorQueryCount ,"Insert ST Link "); if (arguments.pTest == false) { for(int32_t i = 0; i < sectorQueryCount; i++) { db->executeUpdate(sector_tpcQuerys[i]); pb->print(i); } } else { ofstream *seperateOutFile = new ofstream(); seperateOutFile->open("SECTOR_TPC.sql"); for(int32_t i = 0; i < sectorQueryCount; i++) { *seperateOutFile << sector_tpcQuerys[i] << ";" << endl; pb->print(i); } seperateOutFile->close(); delete seperateOutFile; } delete pb; sw->stop(); } catch(SQLException& ea) { cout << ea.what() << endl; return 0; } cout << "created a TPC | " << sw->formatRealTime() << " s, " << sw->formatSysTime() << "s" << endl; return 1; } // ============================================================================= // ============================================================================= int32_t fillicl() { // // Fill FEE and FEESERVICES tables // // // 1) Check if tables are empty. If not, abort. // // Check if tables are empty. if (arguments.pTest == false) { if ( !tableEmpty("FEE_A") ) { cerr << "*FEE_A Table is not empty!" << endl; return 0; } if ( !tableEmpty("FEE_C") ) { cerr << "*FEE_C Table is not empty!" << endl; return 0; } if ( !tableEmpty("FEESERVICES_A") ) { cerr << "*FEESERVICES_A Table is not empty!" << endl; return 0; } if ( !tableEmpty("FEESERVICES_C") ) { cerr << "*FEESERVICES_C Table is not empty!" << endl; return 0; } } // // 2) create queries: // feeQuerys.clear(); feeservicesQuerys.clear(); feeQueryCount = ciRCUs*ciSectors*ciSides; // feeservicesQueryCount = cifecPerSector*ciSectors*ciSides*6 + feeQueryCount*48; // 6 per FEC plus 48 per RCU fecIndex = 0; fecQueryCount = cifecPerSector*ciSectors*ciSides; pb = new ProgressBar('=', 80, fecQueryCount, "Create Querys "); sw->start(); for(int32_t sideCounter = 0; sideCounter < ciSides; sideCounter++) { for(int32_t sectorCounter = 0; sectorCounter < ciSectors; sectorCounter++) { for(int32_t rcuCounter = 0; rcuCounter < ciRCUs; rcuCounter++) { feeQuerys.push_back(dbq->getSqlInsertFEE(sideCounter, sectorCounter, rcuCounter)); feeQueryIndex++; feeservicesQuerys.push_back(dbq->getSqlInsertFEESERVICES(sideCounter, sectorCounter, rcuCounter, "MAIN_STATE", "float")); feeservicesQueryIndex++; feeservicesQuerys.push_back(dbq->getSqlInsertFEESERVICES(sideCounter, sectorCounter, rcuCounter, "ACTEL_STATE", "float")); feeservicesQueryIndex++; feeservicesQuerys.push_back(dbq->getSqlInsertFEESERVICES(sideCounter, sectorCounter, rcuCounter, "ACTEL_STATENAME", "char")); feeservicesQueryIndex++; feeservicesQuerys.push_back(dbq->getSqlInsertFEESERVICES(sideCounter, sectorCounter, rcuCounter, "ACTEL_CYCLES", "int")); feeservicesQueryIndex++; feeservicesQuerys.push_back(dbq->getSqlInsertFEESERVICES(sideCounter, sectorCounter, rcuCounter, "ACTEL_FRAMEERR", "int")); feeservicesQueryIndex++; feeservicesQuerys.push_back(dbq->getSqlInsertFEESERVICES(sideCounter, sectorCounter, rcuCounter, "ACTEL_FWVERSION", "int")); feeservicesQueryIndex++; feeservicesQuerys.push_back(dbq->getSqlInsertFEESERVICES(sideCounter, sectorCounter, rcuCounter, "ACTEL_ERROR", "int")); feeservicesQueryIndex++; feeservicesQuerys.push_back(dbq->getSqlInsertFEESERVICES(sideCounter, sectorCounter, rcuCounter, "ACTEL_STATUS", "int")); feeservicesQueryIndex++; feeservicesQuerys.push_back(dbq->getSqlInsertFEESERVICES(sideCounter, sectorCounter, rcuCounter, "ACTEL_LASTFRAME", "int")); feeservicesQueryIndex++; feeservicesQuerys.push_back(dbq->getSqlInsertFEESERVICES(sideCounter, sectorCounter, rcuCounter, "ACTEL_NOFSEU", "int")); feeservicesQueryIndex++; feeservicesQuerys.push_back(dbq->getSqlInsertFEESERVICES(sideCounter, sectorCounter, rcuCounter, "RCU_AFL", "int")); feeservicesQueryIndex++; feeservicesQuerys.push_back(dbq->getSqlInsertFEESERVICES(sideCounter, sectorCounter, rcuCounter, "RCU_FWVERSION", "int")); feeservicesQueryIndex++; feeservicesQuerys.push_back(dbq->getSqlInsertFEESERVICES(sideCounter, sectorCounter, rcuCounter, "RCU_SLC_STATUS", "int")); feeservicesQueryIndex++; feeservicesQuerys.push_back(dbq->getSqlInsertFEESERVICES(sideCounter, sectorCounter, rcuCounter, "RCU_FECERR_A", "int")); feeservicesQueryIndex++; feeservicesQuerys.push_back(dbq->getSqlInsertFEESERVICES(sideCounter, sectorCounter, rcuCounter, "RCU_FECERR_B", "int")); feeservicesQueryIndex++; feeservicesQuerys.push_back(dbq->getSqlInsertFEESERVICES(sideCounter, sectorCounter, rcuCounter, "RCU_TEMP1", "float")); feeservicesQueryIndex++; feeservicesQuerys.push_back(dbq->getSqlInsertFEESERVICES(sideCounter, sectorCounter, rcuCounter, "RCU_TEMP2", "float")); feeservicesQueryIndex++; feeservicesQuerys.push_back(dbq->getSqlInsertFEESERVICES(sideCounter, sectorCounter, rcuCounter, "RCU_DCS_FWVERSION", "int")); feeservicesQueryIndex++; feeservicesQuerys.push_back(dbq->getSqlInsertFEESERVICES(sideCounter, sectorCounter, rcuCounter, "RCU_DCS_OLDMODE", "int")); feeservicesQueryIndex++; feeservicesQuerys.push_back(dbq->getSqlInsertFEESERVICES(sideCounter, sectorCounter, rcuCounter, "CEDBG_EN_SERVICE_UPDATE", "int")); feeservicesQueryIndex++; feeservicesQuerys.push_back(dbq->getSqlInsertFEESERVICES(sideCounter, sectorCounter, rcuCounter, "START_TIME_NAME", "char")); feeservicesQueryIndex++; feeservicesQuerys.push_back(dbq->getSqlInsertFEESERVICES(sideCounter, sectorCounter, rcuCounter, "UPDATE_TIME_NAME", "char")); feeservicesQueryIndex++; feeservicesQuerys.push_back(dbq->getSqlInsertFEESERVICES(sideCounter, sectorCounter, rcuCounter, "UPDATE_COUNTER", "int")); feeservicesQueryIndex++; // Add RCU2 registers (Jan 2016) feeservicesQuerys.push_back(dbq->getSqlInsertFEESERVICES(sideCounter, sectorCounter, rcuCounter, "RCU_FECERR_AI", "int")); feeservicesQueryIndex++; feeservicesQuerys.push_back(dbq->getSqlInsertFEESERVICES(sideCounter, sectorCounter, rcuCounter, "RCU_FECERR_AO", "int")); feeservicesQueryIndex++; feeservicesQuerys.push_back(dbq->getSqlInsertFEESERVICES(sideCounter, sectorCounter, rcuCounter, "RCU_FECERR_BI", "int")); feeservicesQueryIndex++; feeservicesQuerys.push_back(dbq->getSqlInsertFEESERVICES(sideCounter, sectorCounter, rcuCounter, "RCU_FECERR_BO", "int")); feeservicesQueryIndex++; feeservicesQuerys.push_back(dbq->getSqlInsertFEESERVICES(sideCounter, sectorCounter, rcuCounter, "RCU_RADMON1", "float")); feeservicesQueryIndex++; feeservicesQuerys.push_back(dbq->getSqlInsertFEESERVICES(sideCounter, sectorCounter, rcuCounter, "RCU_RADMON2", "int")); feeservicesQueryIndex++; feeservicesQuerys.push_back(dbq->getSqlInsertFEESERVICES(sideCounter, sectorCounter, rcuCounter, "RADMON_CONTROL", "int")); feeservicesQueryIndex++; feeservicesQuerys.push_back(dbq->getSqlInsertFEESERVICES(sideCounter, sectorCounter, rcuCounter, "RADMON_Current", "float")); feeservicesQueryIndex++; feeservicesQuerys.push_back(dbq->getSqlInsertFEESERVICES(sideCounter, sectorCounter, rcuCounter, "RADMON_FWVERSION", "int")); feeservicesQueryIndex++; feeservicesQuerys.push_back(dbq->getSqlInsertFEESERVICES(sideCounter, sectorCounter, rcuCounter, "RADMON_MBU1", "int")); feeservicesQueryIndex++; feeservicesQuerys.push_back(dbq->getSqlInsertFEESERVICES(sideCounter, sectorCounter, rcuCounter, "RADMON_MBU2", "int")); feeservicesQueryIndex++; feeservicesQuerys.push_back(dbq->getSqlInsertFEESERVICES(sideCounter, sectorCounter, rcuCounter, "RADMON_MBU3", "int")); feeservicesQueryIndex++; feeservicesQuerys.push_back(dbq->getSqlInsertFEESERVICES(sideCounter, sectorCounter, rcuCounter, "RADMON_MBU4", "int")); feeservicesQueryIndex++; feeservicesQuerys.push_back(dbq->getSqlInsertFEESERVICES(sideCounter, sectorCounter, rcuCounter, "RADMON_SEU1", "int")); feeservicesQueryIndex++; feeservicesQuerys.push_back(dbq->getSqlInsertFEESERVICES(sideCounter, sectorCounter, rcuCounter, "RADMON_SEU2", "int")); feeservicesQueryIndex++; feeservicesQuerys.push_back(dbq->getSqlInsertFEESERVICES(sideCounter, sectorCounter, rcuCounter, "RADMON_SEU3", "int")); feeservicesQueryIndex++; feeservicesQuerys.push_back(dbq->getSqlInsertFEESERVICES(sideCounter, sectorCounter, rcuCounter, "RADMON_SEU4", "int")); feeservicesQueryIndex++; feeservicesQuerys.push_back(dbq->getSqlInsertFEESERVICES(sideCounter, sectorCounter, rcuCounter, "RADMON_STATE", "float")); feeservicesQueryIndex++; feeservicesQuerys.push_back(dbq->getSqlInsertFEESERVICES(sideCounter, sectorCounter, rcuCounter, "RADMON_STATENAME", "char")); feeservicesQueryIndex++; feeservicesQuerys.push_back(dbq->getSqlInsertFEESERVICES(sideCounter, sectorCounter, rcuCounter, "RADMON_STATUS", "int")); feeservicesQueryIndex++; feeservicesQuerys.push_back(dbq->getSqlInsertFEESERVICES(sideCounter, sectorCounter, rcuCounter, "RADMON_TEMP", "float")); feeservicesQueryIndex++; feeservicesQuerys.push_back(dbq->getSqlInsertFEESERVICES(sideCounter, sectorCounter, rcuCounter, "RADMON_VCC1", "float")); feeservicesQueryIndex++; feeservicesQuerys.push_back(dbq->getSqlInsertFEESERVICES(sideCounter, sectorCounter, rcuCounter, "RADMON_VCC2", "float")); feeservicesQueryIndex++; feeservicesQuerys.push_back(dbq->getSqlInsertFEESERVICES(sideCounter, sectorCounter, rcuCounter, "RCU_DDL2_XOFF_STATUS", "int")); feeservicesQueryIndex++; feeservicesQuerys.push_back(dbq->getSqlInsertFEESERVICES(sideCounter, sectorCounter, rcuCounter, "RCU_DDL2_XOFF_COUNTER", "int")); feeservicesQueryIndex++; for(int32_t branchCounter = 0; branchCounter < 2; branchCounter++) { for(int32_t fecCounter = 0; fecCounter < fecPerRCUBranch[rcuCounter][branchCounter]; fecCounter++) { feeservicesQuerys.push_back(dbq->getSqlInsertFEESERVICES(sideCounter, sectorCounter, rcuCounter, HwToOffline(sideCounter, rcuCounter, branchCounter, fecCounter), "STATE", "float")); feeservicesQueryIndex++; feeservicesQuerys.push_back(dbq->getSqlInsertFEESERVICES(sideCounter, sectorCounter, rcuCounter, HwToOffline(sideCounter, rcuCounter, branchCounter, fecCounter), "AV", "float")); feeservicesQueryIndex++; feeservicesQuerys.push_back(dbq->getSqlInsertFEESERVICES(sideCounter, sectorCounter, rcuCounter, HwToOffline(sideCounter, rcuCounter, branchCounter, fecCounter), "DV", "float")); feeservicesQueryIndex++; feeservicesQuerys.push_back(dbq->getSqlInsertFEESERVICES(sideCounter, sectorCounter, rcuCounter, HwToOffline(sideCounter, rcuCounter, branchCounter, fecCounter), "AC", "float")); feeservicesQueryIndex++; feeservicesQuerys.push_back(dbq->getSqlInsertFEESERVICES(sideCounter, sectorCounter, rcuCounter, HwToOffline(sideCounter, rcuCounter, branchCounter, fecCounter), "DC", "float")); feeservicesQueryIndex++; feeservicesQuerys.push_back(dbq->getSqlInsertFEESERVICES(sideCounter, sectorCounter, rcuCounter, HwToOffline(sideCounter, rcuCounter, branchCounter, fecCounter), "TEMP", "float")); feeservicesQueryIndex++; fecIndex++; pb->print(fecIndex); } } } } } delete pb; sw->stop(); cout << "created Querys | " << sw->formatRealTime() << " s, " << sw->formatSysTime() << "s" << endl; // // 3) Fill tables (or print32_t queries to file) // try { sw->start(); pb = new ProgressBar('=', 80, feeQueryCount, "Insert FEE_A/C "); if (arguments.pTest == false) { for(int32_t i = 0; i < feeQueryCount; i++) { db->executeUpdate(feeQuerys[i]); pb->print(i); } } else { ofstream *seperateOutFile = new ofstream(); seperateOutFile->open("FEE.sql"); for(int32_t i = 0; i < feeQueryCount; i++) { *seperateOutFile << feeQuerys[i] << ";" << endl; pb->print(i); } seperateOutFile->close(); delete seperateOutFile; } delete pb; sw->stop(); pb = new ProgressBar('=', 80, feeservicesQueryCount, "Insert FEESERVICES_A/C"); if (arguments.pTest == false) { for(int32_t i = 0; i < feeservicesQueryCount; i++) { db->executeUpdate(feeservicesQuerys[i]); pb->print(i); } } else { ofstream *seperateOutFile = new ofstream(); seperateOutFile->open("FEESERVICES.sql"); for(int32_t i = 0; i < feeservicesQueryCount; i++) { *seperateOutFile << feeservicesQuerys[i] << ";" << endl; pb->print(i); } seperateOutFile->close(); delete seperateOutFile; } delete pb; sw->stop(); } catch(SQLException& ea) { cout << ea.what() << endl; return 0; } cout << "Filled ICL Tables | " << sw->formatRealTime() << " s, " << sw->formatSysTime() << "s" << endl; return 1; }