| 1 |
#include <iostream>
|
| 2 |
#include "DBSClient.hpp"
|
| 3 |
#include <exception>
|
| 4 |
#include "ClientAPIData.hpp"
|
| 5 |
using namespace std;
|
| 6 |
|
| 7 |
int main() {
|
| 8 |
DBSClient* dbsclient = new DBSClient();
|
| 9 |
vector<Evcollview_ClientAPIData*>
|
| 10 |
Evcollview_ClientAPIData::Evcollview_ClientAPIData(){
|
| 11 |
|
| 12 |
Schema.insert(Entry("status", "INTEGER"));
|
| 13 |
Schema.insert(Entry("validation_status", "INTEGER"));
|
| 14 |
Schema.insert(Entry("modified_by", "INTEGER"));
|
| 15 |
Schema.insert(Entry("name", "STRING"));
|
| 16 |
Schema.insert(Entry("processed_dataset", "INTEGER"));
|
| 17 |
Schema.insert(Entry("created_at", "FLOAT"));
|
| 18 |
Schema.insert(Entry("modified_at", "FLOAT"));
|
| 19 |
Schema.insert(Entry("created_by", "INTEGER"));
|
| 20 |
Schema.insert(Entry("events", "INTEGER"));
|
| 21 |
Schema.insert(Entry("collection_index", "INTEGER"));
|
| 22 |
Schema.insert(Entry("event_collection", "INTEGER"));
|
| 23 |
Schema.insert(Entry("id", "INTEGER"));
|
| 24 |
Schema.insert(Entry("estimated_luminosity", "STRING"));
|
| 25 |
|
| 26 |
}
|
| 27 |
|
| 28 |
int main() {
|
| 29 |
DBSClient* dbsclient = new DBSClient();
|
| 30 |
vector<Primarydataset_ClientAPIData*> primaryDatasetInfo;
|
| 31 |
typedef vector<Primarydataset_ClientAPIData*>::iterator PrimaryDatasetInfoIter;
|
| 32 |
try {
|
| 33 |
dbsclient->readPrimaryDataset(primaryDatasetInfo);
|
| 34 |
} catch (exception &ex) {
|
| 35 |
cout << ex.what() << endl;
|
| 36 |
}
|
| 37 |
delete dbsclient;
|
| 38 |
cout<<"Total number of structs returned "<<primaryDatasetInfo.size()<<endl;
|
| 39 |
for(PrimaryDatasetInfoIter i = primaryDatasetInfo.begin(); i != primaryDatasetInfo.end(); ++i) {
|
| 40 |
cout<<"\n********************************************************************************"<<endl;
|
| 41 |
cout<<"mcchanneldescription "<<(*i)->mcchanneldescription.getValue()<<endl;
|
| 42 |
cout<<"abstractdatasetannotation "<<(*i)->abstractdatasetannotation.getValue()<<endl;
|
| 43 |
cout<<"triggerdescriptionid "<<(*i)->triggerdescriptionid.getValue()<<endl;
|
| 44 |
cout<<"mcproduction "<<(*i)->mcproduction.getValue()<<endl;
|
| 45 |
cout<<"abstractdatasetdescriptionid "<<(*i)->abstractdatasetdescriptionid.getValue()<<endl;
|
| 46 |
cout<<"streamid "<<(*i)->streamid.getValue()<<endl;
|
| 47 |
cout<<"triggerpathdescriptionid "<<(*i)->triggerpathdescriptionid.getValue()<<endl;
|
| 48 |
//cout<<"startdate "<<(*i)->startdate.getValue()<<endl;
|
| 49 |
cout<<"mcdescriptionid "<<(*i)->mcdescriptionid.getValue()<<endl;
|
| 50 |
cout<<"cobradatasetname "<<(*i)->cobradatasetname.getValue()<<endl;
|
| 51 |
cout<<"mcchanneldescriptionid "<<(*i)->mcchanneldescriptionid.getValue()<<endl;
|
| 52 |
cout<<"mcdecaychain "<<(*i)->mcdecaychain.getValue()<<endl;
|
| 53 |
cout<<"streamannotation "<<(*i)->streamannotation.getValue()<<endl;
|
| 54 |
cout<<"primarydatasetid "<<(*i)->primarydatasetid.getValue()<<endl;
|
| 55 |
//cout<<"physicsgroupconvener "<<(*i)->physicsgroupconvener.getValue()<<endl;
|
| 56 |
cout<<"physicsgroupid "<<(*i)->physicsgroupid.getValue()<<endl;
|
| 57 |
cout<<"openforwriting "<<(*i)->openforwriting.getValue()<<endl;
|
| 58 |
cout<<"triggerpathdescription "<<(*i)->triggerpathdescription.getValue()<<endl;
|
| 59 |
//cout<<"enddate "<<(*i)->enddate.getValue()<<endl;
|
| 60 |
cout<<"streamname "<<(*i)->streamname.getValue()<<endl;
|
| 61 |
cout<<"mcdataset "<<(*i)->mcdataset.getValue()<<endl;
|
| 62 |
cout<<"physicsgroupname "<<(*i)->physicsgroupname.getValue()<<endl;
|
| 63 |
cout<<"abstractdatasetname "<<(*i)->abstractdatasetname.getValue()<<endl;
|
| 64 |
cout<<"********************************************************************************\n"<<endl;
|
| 65 |
delete *i;
|
| 66 |
}
|
| 67 |
|
| 68 |
|
| 69 |
}
|
| 70 |
|
| 71 |
|
| 72 |
int maina() {
|
| 73 |
|
| 74 |
cout << "Client test" << endl;
|
| 75 |
DBSClient* dbsclient = new DBSClient();
|
| 76 |
Primarydataset_ClientAPIData primaryDatasetInfo;
|
| 77 |
|
| 78 |
|
| 79 |
primaryDatasetInfo.mcchanneldescription = (string)"Some Description pata nahee";
|
| 80 |
primaryDatasetInfo.mcdecaychain = (string)"Some Decay pata nahee";
|
| 81 |
primaryDatasetInfo.mcproduction = (string)"Who knows pata nahee";
|
| 82 |
primaryDatasetInfo.triggerpathdescription = (string)"kia aur kioun pata nahee";
|
| 83 |
primaryDatasetInfo.streamannotation = (string)"No comments please pata nahee";
|
| 84 |
primaryDatasetInfo.cobradatasetname = (string)"AnacondaPataNahee";
|
| 85 |
primaryDatasetInfo.abstractdatasetannotation = (string)"Annotation what ? Pata Nahee";
|
| 86 |
primaryDatasetInfo.physicsgroupname = (string)"GroupOfItsOwnPataNahee";
|
| 87 |
primaryDatasetInfo.streamname = (string)"StreamingLivePataNahee";
|
| 88 |
primaryDatasetInfo.abstractdatasetname = (string)"MyFirstPrimaryDatasetPataNahee";
|
| 89 |
primaryDatasetInfo.mcdataset = 'y';
|
| 90 |
|
| 91 |
try {
|
| 92 |
dbsclient->createPrimaryDataset((string)"MyFirstPrimaryDatasetPataNahee", primaryDatasetInfo);
|
| 93 |
} catch (exception &ex) {
|
| 94 |
cout << ex.what() << endl;
|
| 95 |
}
|
| 96 |
delete dbsclient;
|
| 97 |
|
| 98 |
|
| 99 |
}
|
