Back to home page

Project CMSSW displayed by LXR

 
 

    


File indexing completed on 2021-02-14 12:50:25

0001 #include "FWCore/PluginManager/interface/PluginManager.h"
0002 #include "FWCore/PluginManager/interface/standard.h"
0003 #include "FWCore/PluginManager/interface/SharedLibrary.h"
0004 #include "FWCore/ParameterSet/interface/ParameterSet.h"
0005 #include "FWCore/ServiceRegistry/interface/ServiceRegistry.h"
0006 //
0007 #include "CondCore/CondDB/interface/ConnectionPool.h"
0008 //
0009 #include "MyTestData.h"
0010 //
0011 #include <fstream>
0012 #include <iomanip>
0013 #include <cstdlib>
0014 #include <iostream>
0015 
0016 using namespace cond::persistency;
0017 
0018 int run(const std::string& connectionString) {
0019   try {
0020     //*************
0021     std::cout << "> Connecting with db in " << connectionString << std::endl;
0022     ConnectionPool connPool;
0023     connPool.setMessageVerbosity(coral::Debug);
0024     Session session = connPool.createSession(connectionString, true);
0025     session.transaction().start(false);
0026     MyTestData d0(17);
0027     MyTestData d1(999);
0028     std::cout << "> Storing payload ptr=" << &d0 << std::endl;
0029     cond::Hash p0 = session.storePayload(d0, boost::posix_time::microsec_clock::universal_time());
0030     cond::Hash p1 = session.storePayload(d1, boost::posix_time::microsec_clock::universal_time());
0031     std::string d("abcd1234");
0032     cond::Hash p3 = session.storePayload(d, boost::posix_time::microsec_clock::universal_time());
0033 
0034     IOVEditor editor;
0035     if (!session.existsIov("MyNewIOV")) {
0036       editor = session.createIov<MyTestData>("MyNewIOV", cond::runnumber, cond::SYNCH_OFFLINE);
0037       editor.setDescription("Test with MyTestData class");
0038       editor.insert(1, p0);
0039       editor.insert(100, p1);
0040       std::cout << "> inserted 2 iovs..." << std::endl;
0041       editor.flush();
0042       std::cout << "> iov changes flushed..." << std::endl;
0043     }
0044 
0045     if (!session.existsIov("StringData")) {
0046       editor = session.createIov<std::string>("StringData", cond::timestamp);
0047       editor.setDescription("Test with std::string class");
0048       editor.insert(1000000, p3);
0049       editor.insert(2000000, p3);
0050       editor.flush();
0051     }
0052 
0053     session.transaction().commit();
0054     std::cout << "> iov changes committed!..." << std::endl;
0055 
0056     session.transaction().start(false);
0057     std::cout << "## now trying to insert in the past..." << std::endl;
0058     try {
0059       editor = session.editIov("MyNewIOV");
0060       editor.insert(200, p1);
0061       editor.insert(300, p1);
0062       editor.insert(50, p1);
0063       editor.flush();
0064       std::cout << "ERROR: forbidden insertion." << std::endl;
0065       session.transaction().commit();
0066     } catch (const cond::persistency::Exception& e) {
0067       std::cout << "Expected error: " << e.what() << std::endl;
0068       session.transaction().rollback();
0069     }
0070     session.transaction().start(false);
0071     editor = session.editIov("StringData");
0072     editor.insert(3000000, p3);
0073     editor.insert(4000000, p3);
0074     editor.insert(1500000, p3);
0075     editor.flush();
0076     std::cout << "Insertion in the past completed." << std::endl;
0077     session.transaction().commit();
0078 
0079     ::sleep(2);
0080     session.transaction().start();
0081 
0082     IOVProxy proxy = session.readIov("MyNewIOV");
0083     std::cout << "> iov loaded size=" << proxy.loadedSize() << std::endl;
0084     std::cout << "> iov sequence size=" << proxy.sequenceSize() << std::endl;
0085     IOVArray iovs = proxy.selectAll();
0086     IOVArray::Iterator iovIt = iovs.find(57);
0087     if (iovIt == iovs.end()) {
0088       std::cout << ">[0] not found!" << std::endl;
0089     } else {
0090       cond::Iov_t val = *iovIt;
0091       std::cout << "#[0] iov since=" << val.since << " till=" << val.till << " pid=" << val.payloadId << std::endl;
0092       std::shared_ptr<MyTestData> pay0 = session.fetchPayload<MyTestData>(val.payloadId);
0093       pay0->print();
0094       iovIt++;
0095     }
0096     if (iovIt == iovs.end()) {
0097       std::cout << "#[1] not found!" << std::endl;
0098     } else {
0099       cond::Iov_t val = *iovIt;
0100       std::cout << "#[1] iov since=" << val.since << " till=" << val.till << " pid=" << val.payloadId << std::endl;
0101       std::shared_ptr<MyTestData> pay1 = session.fetchPayload<MyTestData>(val.payloadId);
0102       pay1->print();
0103     }
0104     iovIt = iovs.find(176);
0105     if (iovIt == iovs.end()) {
0106       std::cout << "#[2] not found!" << std::endl;
0107     } else {
0108       cond::Iov_t val = *iovIt;
0109       std::cout << "#[2] iov since=" << val.since << " till=" << val.till << " pid=" << val.payloadId << std::endl;
0110       std::shared_ptr<MyTestData> pay2 = session.fetchPayload<MyTestData>(val.payloadId);
0111       pay2->print();
0112       iovIt++;
0113     }
0114     if (iovIt == iovs.end()) {
0115       std::cout << "#[3] not found!" << std::endl;
0116     } else {
0117       cond::Iov_t val = *iovIt;
0118       std::cout << "#[3] iov since=" << val.since << " till=" << val.till << " pid=" << val.payloadId << std::endl;
0119       std::shared_ptr<MyTestData> pay3 = session.fetchPayload<MyTestData>(val.payloadId);
0120       pay3->print();
0121     }
0122 
0123     proxy = session.readIov("StringData");
0124     iovs = proxy.selectAll();
0125     auto iov2It = iovs.find(1000022);
0126     if (iov2It == iovs.end()) {
0127       std::cout << "#[4] not found!" << std::endl;
0128     } else {
0129       cond::Iov_t val = *iov2It;
0130       std::cout << "#[4] iov since=" << val.since << " till=" << val.till << " pid=" << val.payloadId << std::endl;
0131       std::shared_ptr<std::string> pay4 = session.fetchPayload<std::string>(val.payloadId);
0132       std::cout << "#pay4=" << *pay4 << std::endl;
0133     }
0134     session.transaction().commit();
0135   } catch (const std::exception& e) {
0136     std::cout << "ERROR: " << e.what() << std::endl;
0137     return -1;
0138   } catch (...) {
0139     std::cout << "UNEXPECTED FAILURE." << std::endl;
0140     return -1;
0141   }
0142   std::cout << "## Run successfully completed." << std::endl;
0143   return 0;
0144 }
0145 
0146 int main(int argc, char** argv) {
0147   int ret = 0;
0148   edmplugin::PluginManager::Config config;
0149   edmplugin::PluginManager::configure(edmplugin::standard::config());
0150   std::string connectionString0("sqlite_file:cms_conditions_0.db");
0151   ret = run(connectionString0);
0152   return ret;
0153 }