1 /**************************************************************************
2 * Copyright(c) 1998-1999, ALICE Experiment at CERN, All rights reserved. *
4 * Author: The ALICE Off-line Project. *
5 * Contributors are mentioned in the code where appropriate. *
7 * Permission to use, copy, modify and distribute this software and its *
8 * documentation strictly for non-commercial purposes is hereby granted *
9 * without fee, provided that the above copyright notice appears in all *
10 * copies and that both the copyright notice and this permission notice *
11 * appear in the supporting documentation. The authors make no claims *
12 * about the suitability of this software for any purpose. It is *
13 * provided "as is" without express or implied warranty. *
14 **************************************************************************/
16 /////////////////////////////////////////////////////////////////////////////////////////////////
19 // access class to a DataBase in an AliEn storage //
21 /////////////////////////////////////////////////////////////////////////////////////////////////
25 #include <TGridResult.h>
29 //#include <TSystem.h>
30 #include <TObjArray.h>
31 #include <TObjString.h>
35 #include "AliCDBEntry.h"
36 #include "AliCDBGrid.h"
41 //_____________________________________________________________________________
42 AliCDBGrid::AliCDBGrid(const char *gridUrl, const char *user, const char *dbFolder, const char *se) :
51 // if the same Grid is alreay active, skip connection
52 if (!gGrid || fGridUrl != gGrid->GridUrl()
53 || (( fUser != "" ) && ( fUser != gGrid->GetUser() )) ) {
54 // connection to the Grid
55 AliInfo("Connection to the Grid...");
57 AliInfo(Form("gGrid = %x; fGridUrl = %s; gGrid->GridUrl() = %s",gGrid,fGridUrl.Data(), gGrid->GridUrl()));
58 AliInfo(Form("fUser = %s; gGrid->GetUser() = %s",fUser.Data(), gGrid->GetUser()));
60 TGrid::Connect(fGridUrl.Data(),fUser.Data());
64 AliError("Connection failed!");
68 TString initDir(gGrid->Pwd(0));
69 if (fDBFolder[0] != '/') {
70 fDBFolder.Prepend(initDir);
73 // check DBFolder: trying to cd to DBFolder; if it does not exist, create it
74 if(!gGrid->Cd(fDBFolder.Data(),0)){
75 AliDebug(2,Form("Creating new folder <%s> ...",fDBFolder.Data()));
76 if(!gGrid->Mkdir(fDBFolder.Data(),"",0)){
77 AliError(Form("Cannot create folder <%s> !",fDBFolder.Data()));
80 AliDebug(2,Form("Folder <%s> found",fDBFolder.Data()));
83 // removes any '/' at the end of path, then append one '/'
84 while(fDBFolder.EndsWith("/")) fDBFolder.Remove(fDBFolder.Last('/'));
88 fBaseFolder = fDBFolder;
90 // return to the initial directory
91 gGrid->Cd(initDir.Data(),0);
94 //_____________________________________________________________________________
95 AliCDBGrid::~AliCDBGrid()
98 delete gGrid; gGrid=0;
102 //_____________________________________________________________________________
103 Bool_t AliCDBGrid::FilenameToId(TString& filename, AliCDBId& id) {
104 // build AliCDBId from full path filename (fDBFolder/path/Run#x_#y_v#z_s0.root)
106 if(filename.Contains(fDBFolder)){
107 filename = filename(fDBFolder.Length(),filename.Length()-fDBFolder.Length());
110 TString idPath = filename(0,filename.Last('/'));
112 if(!id.IsValid()) return kFALSE;
114 filename=filename(idPath.Length()+1,filename.Length()-idPath.Length());
117 // valid filename: Run#firstRun_#lastRun_v#version_s0.root
118 TRegexp keyPattern("^Run[0-9]+_[0-9]+_v[0-9]+_s0.root$");
119 keyPattern.Index(filename, &mSize);
122 // TODO backward compatibility ... maybe remove later!
124 TRegexp oldKeyPattern("^Run[0-9]+_[0-9]+_v[0-9]+.root$");
125 oldKeyPattern.Index(filename, &oldmSize);
127 AliDebug(2,Form("Bad filename <%s>.", filename.Data()));
130 AliDebug(2,Form("Old filename format <%s>.", filename.Data()));
131 id.SetSubVersion(-11); // TODO trick to ensure backward compatibility
135 id.SetSubVersion(-1); // TODO trick to ensure backward compatibility
138 filename.Resize(filename.Length() - sizeof(".root") + 1);
140 TObjArray* strArray = (TObjArray*) filename.Tokenize("_");
142 TString firstRunString(((TObjString*) strArray->At(0))->GetString());
143 id.SetFirstRun(atoi(firstRunString.Data() + 3));
144 id.SetLastRun(atoi(((TObjString*) strArray->At(1))->GetString()));
146 TString verString(((TObjString*) strArray->At(2))->GetString());
147 id.SetVersion(atoi(verString.Data() + 1));
154 //_____________________________________________________________________________
155 Bool_t AliCDBGrid::IdToFilename(const AliCDBId& id, TString& filename) const {
156 // build file name from AliCDBId (path, run range, version) and fDBFolder
158 if (!id.GetAliCDBRunRange().IsValid()) {
159 AliDebug(2,Form("Invalid run range <%d, %d>.",
160 id.GetFirstRun(), id.GetLastRun()));
164 if (id.GetVersion() < 0) {
165 AliDebug(2,Form("Invalid version <%d>.", id.GetVersion()));
169 filename = Form("Run%d_%d_v%d",
174 if (id.GetSubVersion() != -11) filename += "_s0"; // TODO to ensure backward compatibility
177 filename.Prepend(fDBFolder + id.GetPath() + '/');
182 //_____________________________________________________________________________
183 Bool_t AliCDBGrid::PrepareId(AliCDBId& id) {
184 // prepare id (version) of the object that will be stored (called by PutEntry)
186 TString initDir(gGrid->Pwd(0));
187 TString pathName= id.GetPath();
189 TString dirName(fDBFolder);
191 Bool_t dirExist=kFALSE;
193 // go to the path; if directory does not exist, create it
194 TObjArray *arrName=pathName.Tokenize("/");
195 for(int i=0;i<arrName->GetEntries();i++){
196 TString buffer((arrName->At(i))->GetName());
197 dirName+=buffer; dirName+="/";
198 dirExist=gGrid->Cd(dirName,0);
200 AliDebug(2,Form("Creating new folder <%s> ...",dirName.Data()));
201 if(!gGrid->Mkdir(dirName,"",0)){
202 AliError(Form("Cannot create directory <%s> !",dirName.Data()));
203 gGrid->Cd(initDir.Data());
209 gGrid->Cd(initDir,0);
212 AliCDBId anId; // the id got from filename
213 AliCDBRunRange lastRunRange(-1,-1); // highest runRange found
214 Int_t lastVersion=0; // highest version found
216 TGridResult *res = gGrid->Ls(dirName);
218 //loop on the files in the directory, look for highest version
219 for(int i=0; i < res->GetEntries(); i++){
220 filename=res->GetFileNamePath(i);
221 if (!FilenameToId(filename, anId)) continue;
222 if (anId.GetAliCDBRunRange().Overlaps(id.GetAliCDBRunRange()) && anId.GetVersion() > lastVersion) {
223 lastVersion = anId.GetVersion();
224 lastRunRange = anId.GetAliCDBRunRange();
230 id.SetVersion(lastVersion + 1);
233 TString lastStorage = id.GetLastStorage();
234 if(lastStorage.Contains(TString("new"), TString::kIgnoreCase) && id.GetVersion() > 1 ){
235 AliDebug(2, Form("A NEW object is being stored with version %d",
237 AliDebug(2, Form("and it will hide previously stored object with version %d!",
241 if(!lastRunRange.IsAnyRange() && !(lastRunRange.IsEqual(&id.GetAliCDBRunRange())))
242 AliWarning(Form("Run range modified w.r.t. previous version (Run%d_%d_v%d)",
243 lastRunRange.GetFirstRun(), lastRunRange.GetLastRun(), id.GetVersion()));
248 //_____________________________________________________________________________
249 AliCDBId* AliCDBGrid::GetId(const TObjArray& validFileIds, const AliCDBId& query) {
250 // look for the Id that matches query's requests (highest or exact version)
252 if(validFileIds.GetEntriesFast() < 1) {
254 } else if (validFileIds.GetEntriesFast() == 1) {
255 return dynamic_cast<AliCDBId*> (validFileIds.At(0));
258 TIter iter(&validFileIds);
263 while((anIdPtr = dynamic_cast<AliCDBId*> (iter.Next()))){
264 if(anIdPtr->GetPath() != query.GetPath()) continue;
266 //if(!CheckVersion(query, anIdPtr, result)) return NULL;
268 if (!query.HasVersion()){ // look for highest version
269 if(result && result->GetVersion() > anIdPtr->GetVersion()) continue;
270 if(result && result->GetVersion() == anIdPtr->GetVersion()) {
271 AliDebug(2,Form("More than one object valid for run %d, version %d!",
272 query.GetFirstRun(), anIdPtr->GetVersion()));
276 } else { // look for specified version
277 if(query.GetVersion() != anIdPtr->GetVersion()) continue;
278 if(result && result->GetVersion() == anIdPtr->GetVersion()){
279 AliDebug(2,Form("More than one object valid for run %d, version %d!",
280 query.GetFirstRun(), anIdPtr->GetVersion()));
292 //_____________________________________________________________________________
293 AliCDBEntry* AliCDBGrid::GetEntry(const AliCDBId& queryId) {
294 // get AliCDBEntry from the database
298 AliCDBId selectedId(queryId);
299 if (!selectedId.HasVersion()) {
300 // if version is not specified, first check the selection criteria list
301 GetSelection(&selectedId);
304 TObjArray validFileIds;
305 validFileIds.SetOwner(1);
307 // look for file matching query requests (path, runRange, version)
308 if(selectedId.GetFirstRun() == fRun &&
309 fPathFilter.Comprises(selectedId.GetAliCDBPath()) && fVersion < 0 && !fMetaDataFilter){
310 // look into list of valid files previously loaded with AliCDBStorage::FillValidFileIds()
311 AliDebug(2, Form("List of files valid for run %d and for path %s was loaded. Looking there!",
312 selectedId.GetFirstRun(), selectedId.GetPath().Data()));
313 dataId = GetId(fValidFileIds, selectedId);
316 // List of files valid for reqested run was not loaded. Looking directly into CDB
317 AliDebug(2, Form("List of files valid for run %d and for path %s was not loaded. Looking directly into CDB!",
318 selectedId.GetFirstRun(), selectedId.GetPath().Data()));
321 MakeQueryFilter(selectedId.GetFirstRun(), selectedId.GetLastRun(), 0, filter);
323 TString pattern = Form("%s/Run*", selectedId.GetPath().Data());
324 if(selectedId.GetVersion() >= 0) pattern += Form("_v%d*",selectedId.GetVersion());
326 AliDebug(2,Form("pattern: %s", pattern.Data()));
328 TGridResult *res = gGrid->Query(fDBFolder, pattern, filter, "");
329 AliCDBId validFileId;
330 for(int i=0; i<res->GetEntries(); i++){
331 TString filename = res->GetKey(i, "lfn");
332 if(filename == "") continue;
333 if(FilenameToId(filename, validFileId))
334 validFileIds.AddLast(validFileId.Clone());
337 dataId = GetId(validFileIds, selectedId);
340 if (!dataId) return NULL;
343 if (!IdToFilename(*dataId, filename)) {
344 AliDebug(2,Form("Bad data ID encountered! Subnormal error!"));
348 AliCDBEntry* anEntry = GetEntryFromFile(filename, dataId);
353 //_____________________________________________________________________________
354 AliCDBEntry* AliCDBGrid::GetEntryFromFile(TString& filename, AliCDBId* dataId){
355 // Get AliCBEntry object from file "filename"
357 AliDebug(2,Form("Opening file: %s",filename.Data()));
359 filename.Prepend("/alien");
360 TFile *file = TFile::Open(filename);
362 AliDebug(2,Form("Can't open file <%s>!", filename.Data()));
366 // get the only AliCDBEntry object from the file
367 // the object in the file is an AliCDBEntry entry named "AliCDBEntry"
369 AliCDBEntry* anEntry = dynamic_cast<AliCDBEntry*> (file->Get("AliCDBEntry"));
372 AliDebug(2,Form("Bad storage data: file does not contain an AliCDBEntry object!"));
377 // The object's Id is not reset during storage
378 // If object's Id runRange or version do not match with filename,
379 // it means that someone renamed file by hand. In this case a warning msg is issued.
382 AliCDBId entryId = anEntry->GetId();
383 Int_t tmpSubVersion = dataId->GetSubVersion();
384 dataId->SetSubVersion(entryId.GetSubVersion()); // otherwise filename and id may mismatch
385 if(!entryId.IsEqual(dataId)){
386 AliWarning(Form("Mismatch between file name and object's Id!"));
387 AliWarning(Form("File name: %s", dataId->ToString().Data()));
388 AliWarning(Form("Object's Id: %s", entryId.ToString().Data()));
390 dataId->SetSubVersion(tmpSubVersion);
393 anEntry->SetLastStorage("grid");
395 // Check whether entry contains a TTree. In case load the tree in memory!
396 LoadTreeFromFile(anEntry);
398 // close file, return retieved entry
399 file->Close(); delete file; file=0;
404 //_____________________________________________________________________________
405 TList* AliCDBGrid::GetEntries(const AliCDBId& queryId) {
406 // multiple request (AliCDBStorage::GetAll)
408 TList* result = new TList();
411 TObjArray validFileIds;
412 validFileIds.SetOwner(1);
414 Bool_t alreadyLoaded = kFALSE;
416 // look for file matching query requests (path, runRange)
417 if(queryId.GetFirstRun() == fRun &&
418 fPathFilter.Comprises(queryId.GetAliCDBPath()) && fVersion < 0 && !fMetaDataFilter){
419 // look into list of valid files previously loaded with AliCDBStorage::FillValidFileIds()
420 AliDebug(2,Form("List of files valid for run %d and for path %s was loaded. Looking there!",
421 queryId.GetFirstRun(), queryId.GetPath().Data()));
423 alreadyLoaded = kTRUE;
426 // List of files valid for reqested run was not loaded. Looking directly into CDB
427 AliDebug(2,Form("List of files valid for run %d and for path %s was not loaded. Looking directly into CDB!",
428 queryId.GetFirstRun(), queryId.GetPath().Data()));
431 MakeQueryFilter(queryId.GetFirstRun(), queryId.GetLastRun(), 0, filter);
433 TString pattern = Form("%s/Run*.root", queryId.GetPath().Data());
434 AliDebug(2,Form("pattern: %s", pattern.Data()));
436 TGridResult *res = gGrid->Query(fDBFolder, pattern, filter, "");
438 AliCDBId validFileId;
439 for(int i=0; i<res->GetEntries(); i++){
440 TString filename = res->GetKey(i, "lfn");
441 if(filename == "") continue;
442 if(FilenameToId(filename, validFileId))
443 validFileIds.AddLast(validFileId.Clone());
450 iter = new TIter(&fValidFileIds);
452 iter = new TIter(&validFileIds);
455 TObjArray selectedIds;
456 selectedIds.SetOwner(1);
458 // loop on list of valid Ids to select the right version to get.
459 // According to query and to the selection criteria list, version can be the highest or exact
463 AliCDBPath queryPath = queryId.GetAliCDBPath();
464 while((anIdPtr = dynamic_cast<AliCDBId*> (iter->Next()))){
465 AliCDBPath thisCDBPath = anIdPtr->GetAliCDBPath();
466 if(!(queryPath.Comprises(thisCDBPath)) || pathCopy.GetPath() == thisCDBPath.GetPath()) continue;
467 pathCopy = thisCDBPath;
469 // check the selection criteria list for this query
470 AliCDBId thisId(*anIdPtr);
471 thisId.SetVersion(queryId.GetVersion());
472 if(!thisId.HasVersion()) GetSelection(&thisId);
475 dataId = GetId(fValidFileIds, thisId);
477 dataId = GetId(validFileIds, thisId);
479 if(dataId) selectedIds.Add(dataId->Clone());
484 // selectedIds contains the Ids of the files matching all requests of query!
485 // All the objects are now ready to be retrieved
486 iter = new TIter(&selectedIds);
487 while((anIdPtr = dynamic_cast<AliCDBId*> (iter->Next()))){
489 if (!IdToFilename(*anIdPtr, filename)) {
490 AliDebug(2,Form("Bad data ID encountered! Subnormal error!"));
494 AliCDBEntry* anEntry = GetEntryFromFile(filename, anIdPtr);
496 if(anEntry) result->Add(anEntry);
504 //_____________________________________________________________________________
505 Bool_t AliCDBGrid::PutEntry(AliCDBEntry* entry) {
506 // put an AliCDBEntry object into the database
508 AliCDBId& id = entry->GetId();
510 // set version for the entry to be stored
511 if (!PrepareId(id)) return kFALSE;
513 // build filename from entry's id
515 if (!IdToFilename(id, filename)) {
516 AliError("Bad ID encountered! Subnormal error!");
520 TString folderToTag = Form("%s%s",
522 id.GetPath().Data());
524 // add CDB and CDB_MD tag to folder
525 // TODO how to check that folder has already tags?
526 AddTag(folderToTag,"CDB");
527 AddTag(folderToTag,"CDB_MD");
529 TDirectory* saveDir = gDirectory;
531 TString fullFilename = Form("/alien%s", filename.Data());
532 // specify SE to filename
533 if (fSE != "default") fullFilename += Form("?se=%s",fSE.Data());
536 TFile *file = TFile::Open(fullFilename,"CREATE");
537 if(!file || !file->IsWritable()){
538 AliError(Form("Can't open file <%s>!", filename.Data()));
539 if(file && !file->IsWritable()) file->Close(); delete file; file=0;
545 //SetTreeToFile(entry, file);
547 entry->SetVersion(id.GetVersion());
549 // write object (key name: "AliCDBEntry")
550 Bool_t result = (file->WriteTObject(entry, "AliCDBEntry") != 0);
551 if (!result) AliError(Form("Can't write entry to file <%s>!", filename.Data()));
554 if (saveDir) saveDir->cd(); else gROOT->cd();
555 file->Close(); delete file; file=0;
558 AliInfo(Form("CDB object stored into file %s", filename.Data()));
559 AliInfo(Form("using S.E.: %s", fSE.Data()));
561 if(!TagFileId(filename, &id)){
562 AliInfo(Form("CDB tagging failed. Deleting file %s!",filename.Data()));
563 if(!gGrid->Rm(filename.Data()))
564 AliError("Can't delete file!");
568 TagFileMetaData(filename, entry->GetMetaData());
573 //_____________________________________________________________________________
574 Bool_t AliCDBGrid::AddTag(TString& folderToTag, const char* tagname){
575 // add "tagname" tag (CDB or CDB_MD) to folder where object will be stored
577 Bool_t result = kTRUE;
578 AliDebug(2, Form("adding %s tag to folder %s", tagname, folderToTag.Data()));
579 TString addTag = Form("addTag %s %s", folderToTag.Data(), tagname);
580 TGridResult *gridres = gGrid->Command(addTag.Data());
581 const char* resCode = gridres->GetKey(0,"__result__"); // '1' if success
582 if(resCode[0] != '1') {
583 AliError(Form("Couldn't add %s tags to folder %s !",
584 tagname, folderToTag.Data()));
591 //_____________________________________________________________________________
592 Bool_t AliCDBGrid::TagFileId(TString& filename, const AliCDBId* id){
593 // tag stored object in CDB table using object Id's parameters
595 TString addTagValue1 = Form("addTagValue %s CDB ", filename.Data());
596 TString addTagValue2 = Form("first_run=%d last_run=%d version=%d ",
600 TString addTagValue3 = Form("path_level_0=\"%s\" path_level_1=\"%s\" path_level_2=\"%s\"",
601 id->GetLevel0().Data(),
602 id->GetLevel1().Data(),
603 id->GetLevel2().Data());
604 TString addTagValue = Form("%s%s%s",
607 addTagValue3.Data());
609 Bool_t result = kFALSE;
610 AliDebug(2, Form("Tagging file. Tag command: %s", addTagValue.Data()));
611 TGridResult* res = gGrid->Command(addTagValue.Data());
612 const char* resCode = res->GetKey(0,"__result__"); // '1' if success
613 if(resCode[0] != '1') {
614 AliError(Form("Couldn't add CDB tag value to file %s !",
618 AliInfo("Object successfully tagged.");
626 //_____________________________________________________________________________
627 Bool_t AliCDBGrid::TagFileMetaData(TString& filename, const AliCDBMetaData* md){
628 // tag stored object in CDB table using object Id's parameters
630 TString addTagValue1 = Form("addTagValue %s CDB_MD ", filename.Data());
631 TString addTagValue2 = Form("object_classname=\"%s\" responsible=\"%s\" beam_period=%d ",
632 md->GetObjectClassName(),
633 md->GetResponsible(),
634 md->GetBeamPeriod());
635 TString addTagValue3 = Form("aliroot_version=\"%s\" comment=\"%s\"",
636 md->GetAliRootVersion(),
638 TString addTagValue = Form("%s%s%s",
641 addTagValue3.Data());
643 Bool_t result = kFALSE;
644 AliDebug(2, Form("Tagging file. Tag command: %s", addTagValue.Data()));
645 TGridResult* res = gGrid->Command(addTagValue.Data());
646 const char* resCode = res->GetKey(0,"__result__"); // '1' if success
647 if(resCode[0] != '1') {
648 AliWarning(Form("Couldn't add CDB_MD tag value to file %s !",
652 AliInfo("Object successfully tagged.");
658 //_____________________________________________________________________________
659 TList* AliCDBGrid::GetIdListFromFile(const char* fileName){
661 TString turl(fileName);
662 turl.Prepend("/alien" + fDBFolder);
663 turl += "?se="; turl += fSE.Data();
664 TFile *file = TFile::Open(turl);
666 AliError(Form("Can't open selection file <%s>!", turl.Data()));
670 TList *list = new TList();
678 keycycle = "AliCDBId;";
681 id = (AliCDBId*) file->Get(keycycle);
685 file->Close(); delete file; file=0;
692 //_____________________________________________________________________________
693 Bool_t AliCDBGrid::Contains(const char* path) const{
694 // check for path in storage's DBFolder
696 TString initDir(gGrid->Pwd(0));
697 TString dirName(fDBFolder);
698 dirName += path; // dirName = fDBFolder/path
699 Bool_t result=kFALSE;
700 if (gGrid->Cd(dirName,0)) result=kTRUE;
701 gGrid->Cd(initDir.Data(),0);
705 //_____________________________________________________________________________
706 void AliCDBGrid::QueryValidFiles()
708 // Query the CDB for files valid for AliCDBStorage::fRun
709 // fills list fValidFileIds with AliCDBId objects created from file name
712 MakeQueryFilter(fRun, fRun, fMetaDataFilter, filter);
714 TString pattern = Form("%s/Run*", fPathFilter.GetPath().Data());
715 if(fVersion >= 0) pattern += Form("_v%d*", fVersion);
717 AliDebug(2,Form("pattern: %s", pattern.Data()));
719 TGridResult *res = gGrid->Query(fDBFolder, pattern, filter, "");
721 AliCDBId validFileId;
722 for(int i=0; i<res->GetEntries(); i++){
723 TString filename = res->GetKey(i, "lfn");
724 if(filename == "") continue;
725 AliDebug(2,Form("Found valid file: %s", filename.Data()));
726 Bool_t result = FilenameToId(filename, validFileId);
728 fValidFileIds.AddLast(validFileId.Clone());
735 //_____________________________________________________________________________
736 void AliCDBGrid::MakeQueryFilter(Int_t firstRun, Int_t lastRun,
737 const AliCDBMetaData* md, TString& result) const
739 // create filter for file query
741 result = Form("CDB:first_run<=%d and CDB:last_run>=%d", firstRun, lastRun);
743 // if(version >= 0) {
744 // result += Form(" and CDB:version=%d", version);
746 // if(pathFilter.GetLevel0() != "*") {
747 // result += Form(" and CDB:path_level_0=\"%s\"", pathFilter.GetLevel0().Data());
749 // if(pathFilter.GetLevel1() != "*") {
750 // result += Form(" and CDB:path_level_1=\"%s\"", pathFilter.GetLevel1().Data());
752 // if(pathFilter.GetLevel2() != "*") {
753 // result += Form(" and CDB:path_level_2=\"%s\"", pathFilter.GetLevel2().Data());
757 if(md->GetObjectClassName()[0] != '\0') {
758 result += Form(" and CDB_MD:object_classname=\"%s\"", md->GetObjectClassName());
760 if(md->GetResponsible()[0] != '\0') {
761 result += Form(" and CDB_MD:responsible=\"%s\"", md->GetResponsible());
763 if(md->GetBeamPeriod() != 0) {
764 result += Form(" and CDB_MD:beam_period=%d", md->GetBeamPeriod());
766 if(md->GetAliRootVersion()[0] != '\0') {
767 result += Form(" and CDB_MD:aliroot_version=\"%s\"", md->GetAliRootVersion());
769 if(md->GetComment()[0] != '\0') {
770 result += Form(" and CDB_MD:comment=\"%s\"", md->GetComment());
773 AliDebug(2, Form("filter: %s",result.Data()));
777 //_____________________________________________________________________________
778 Int_t AliCDBGrid::GetLatestVersion(const char* path, Int_t run){
779 // get last version found in the database valid for run and path
781 TObjArray validFileIds;
782 validFileIds.SetOwner(1);
784 AliCDBPath aCDBPath(path);
785 if(!aCDBPath.IsValid() || aCDBPath.IsWildcard()) {
786 AliError(Form("Invalid path in request: %s", path));
789 AliCDBId query(path, run, run, -1, -1);
790 AliCDBId* dataId = 0;
792 // look for file matching query requests (path, runRange, version)
793 if(run == fRun && fPathFilter.Comprises(aCDBPath) && fVersion < 0){
794 // look into list of valid files previously loaded with AliCDBStorage::FillValidFileIds()
795 AliDebug(2, Form("List of files valid for run %d and for path %s was loaded. Looking there!",
797 dataId = GetId(fValidFileIds, query);
798 if (!dataId) return -1;
799 return dataId->GetVersion();
802 // List of files valid for reqested run was not loaded. Looking directly into CDB
803 AliDebug(2, Form("List of files valid for run %d and for path %s was not loaded. Looking directly into CDB!",
807 MakeQueryFilter(run, run, 0, filter);
809 TString pattern = Form("%s/Run*.root", path);
810 AliDebug(2,Form("pattern: %s", pattern.Data()));
812 TGridResult *res = gGrid->Query(fDBFolder, pattern, filter, "");
813 AliCDBId validFileId;
814 for(int i=0; i<res->GetEntries(); i++){
815 TString filename = res->GetKey(i, "lfn");
816 if(filename == "") continue;
817 if(FilenameToId(filename, validFileId))
818 validFileIds.AddLast(validFileId.Clone());
822 dataId = GetId(validFileIds, query);
823 if (!dataId) return -1;
825 return dataId->GetVersion();
829 //_____________________________________________________________________________
830 Int_t AliCDBGrid::GetLatestSubVersion(const char* /*path*/, Int_t /*run*/, Int_t /*version*/){
831 // get last subversion found in the database valid for run and path
832 AliError("Objects in GRID storage have no sub version!");
837 /////////////////////////////////////////////////////////////////////////////////////////////////
839 // AliCDBGrid factory //
841 /////////////////////////////////////////////////////////////////////////////////////////////////
843 ClassImp(AliCDBGridFactory)
845 //_____________________________________________________________________________
846 Bool_t AliCDBGridFactory::Validate(const char* gridString) {
847 // check if the string is valid Grid URI
849 // pattern: alien://hostName:Port;user;dbPath;SE
850 // example of a valid pattern:
851 // "alien://aliendb4.cern.ch:9000;colla;DBTest;ALICE::CERN::Server"
852 // TRegexp gridPattern("^alien://.+:[0-9]+;[a-zA-Z0-9_-.]+;.+;.+$");
853 TRegexp gridPattern("^alien://.+$");
855 return TString(gridString).Contains(gridPattern);
858 //_____________________________________________________________________________
859 AliCDBParam* AliCDBGridFactory::CreateParameter(const char* gridString) {
860 // create AliCDBGridParam class from the URI string
862 if (!Validate(gridString)) {
865 //TString buffer(gridString + sizeof("alien://") - 1);
866 TString buffer(gridString);
868 TString gridUrl = "alien://";
870 TString dbFolder = "DBGrid";
871 TString se = "default";
873 TObjArray *arr = buffer.Tokenize('?');
877 while((str = (TObjString*) iter.Next())){
878 TString entry(str->String());
879 Int_t indeq = entry.Index('=');
881 if(entry.BeginsWith("alien://")) { // maybe it's a gridUrl!
885 AliError(Form("Invalid entry! %s",entry.Data()));
890 TString key = entry(0,indeq);
891 TString value = entry(indeq+1,entry.Length()-indeq);
893 if(key.Contains("grid",TString::kIgnoreCase)) {
896 else if (key.Contains("user",TString::kIgnoreCase)){
899 else if (key.Contains("folder",TString::kIgnoreCase)){
902 else if (key.Contains("se",TString::kIgnoreCase)){
906 AliError(Form("Invalid entry! %s",entry.Data()));
911 AliDebug(2, Form("gridUrl: %s",gridUrl.Data()));
912 AliDebug(2, Form("user: %s",user.Data()));
913 AliDebug(2, Form("dbFolder: %s",dbFolder.Data()));
914 AliDebug(2, Form("s.e.: %s",se.Data()));
916 return new AliCDBGridParam(gridUrl.Data(), user.Data(), dbFolder.Data(), se.Data());
919 //_____________________________________________________________________________
920 AliCDBStorage* AliCDBGridFactory::Create(const AliCDBParam* param) {
921 // create AliCDBGrid storage instance from parameters
923 AliCDBGrid *grid = 0;
924 if (AliCDBGridParam::Class() == param->IsA()) {
926 const AliCDBGridParam* gridParam = (const AliCDBGridParam*) param;
927 grid = new AliCDBGrid(gridParam->GridUrl().Data(),
928 gridParam->GetUser().Data(),
929 gridParam->GetDBFolder().Data(),
930 gridParam->GetSE().Data());
941 /////////////////////////////////////////////////////////////////////////////////////////////////
943 // AliCDBGrid Parameter class // //
945 /////////////////////////////////////////////////////////////////////////////////////////////////
947 ClassImp(AliCDBGridParam)
949 //_____________________________________________________________________________
950 AliCDBGridParam::AliCDBGridParam():
957 // default constructor
961 //_____________________________________________________________________________
962 AliCDBGridParam::AliCDBGridParam(const char* gridUrl,
964 const char* dbFolder,
976 TString uri = Form("%s?User=%s?DBFolder=%s?SE=%s",
977 fGridUrl.Data(), fUser.Data(),
978 fDBFolder.Data(), fSE.Data());
983 //_____________________________________________________________________________
984 AliCDBGridParam::~AliCDBGridParam() {
989 //_____________________________________________________________________________
990 AliCDBParam* AliCDBGridParam::CloneParam() const {
993 return new AliCDBGridParam(fGridUrl.Data(), fUser.Data(),
994 fDBFolder.Data(), fSE.Data());
997 //_____________________________________________________________________________
998 ULong_t AliCDBGridParam::Hash() const {
999 // return Hash function
1001 return fGridUrl.Hash()+fUser.Hash()+fDBFolder.Hash()+fSE.Hash();
1004 //_____________________________________________________________________________
1005 Bool_t AliCDBGridParam::IsEqual(const TObject* obj) const {
1006 // check if this object is equal to AliCDBParam obj
1012 if (AliCDBGridParam::Class() != obj->IsA()) {
1016 AliCDBGridParam* other = (AliCDBGridParam*) obj;
1018 if(fGridUrl != other->fGridUrl) return kFALSE;
1019 if(fUser != other->fUser) return kFALSE;
1020 if(fDBFolder != other->fDBFolder) return kFALSE;
1021 if(fSE != other->fSE) return kFALSE;