Index: unk/MagicSoft/Mars/datacenter/macros/getdolist.C =================================================================== --- /trunk/MagicSoft/Mars/datacenter/macros/getdolist.C (revision 9050) +++ (revision ) @@ -1,221 +1,0 @@ -/* ======================================================================== *\ -! -! * -! * This file is part of MARS, the MAGIC Analysis and Reconstruction -! * Software. It is distributed to you in the hope that it can be a useful -! * and timesaving tool in analysing Data of imaging Cerenkov telescopes. -! * It is distributed WITHOUT ANY WARRANTY. -! * -! * Permission to use, copy, modify and distribute this software and its -! * documentation for any purpose is hereby granted without fee, -! * provided that the above copyright notice appear in all copies and -! * that both that copyright notice and this permission notice appear -! * in supporting documentation. It is provided "as is" without express -! * or implied warranty. -! * -! -! -! Author(s): Daniela Dorner, 01/2005 -! -! Copyright: MAGIC Software Development, 2000-2006 -! -! -\* ======================================================================== */ - -///////////////////////////////////////////////////////////////////////////// -// -// getdolist.C -// =========== -// -// This macro is a key part of the automation concept. -// It queries from the database, for which dates/runs/sequences/datasets a -// certain step has to be done and writes the todo-files. -// -// Usage: -// .x getdolist.C+("table", "column", "date", "listpath") -// The first and second argument give the table and column in the database -// and specify like this the primary (date/run/sequenc/dataset) and the -// step. -// The third argument specifies the date, for which the macro has to be -// executed. This is currently not used in the automatic analysis. It was -// forseen to give the possibility to process the data night by night. By -// giving date='NULL' the macro is executed for all dates. -// The forth argument gives the path, where teh todo-file is stored. -// -// The macro needs apart from sql.rc the resource file steps.rc -// In this files the interdependencies of the analysis steps are given: To -// execute a certain step other steps have to be executed first and each -// step also influences othere steps - this information is stored in steps.rc -// example: -// To execute the calibration, all files have to be available on disk (needs). -// And if the calibration is done, fillcallisto and star can be executed -// (influences). -// -// Make sure, that database and password are corretly set in a resource -// file called sql.rc and the resource file is found. -// -// Returns 0 in case of failure and 1 in case of success. -// -///////////////////////////////////////////////////////////////////////////// - -#include -#include -#include - -#include -#include -#include -#include - -#include -#include - -#include "MSQLServer.h" - -using namespace std; - - -int getdolist(TString table, TString column, TString date, TString listpath) -{ - MSQLServer serv("sql.rc"); - if (!serv.IsConnected()) - { - cout << "ERROR - Connection to database failed." << endl; - return 0; - } - cout << "getstatus" << endl; - cout << "---------" << endl; - cout << endl; - cout << "Connected to " << serv.GetName() << endl; - cout << endl; - - TEnv rc("steps.rc"); - - //read in needs - TString needs = rc.GetValue(table+"."+column+".Needs", ""); - cout << "Needs: " << needs << endl; - - TList l; - while (!needs.IsNull()) - { - needs = needs.Strip(TString::kBoth); - - Int_t idx = needs.First(' '); - if (idx<0) - idx = needs.Length(); - - TString need = needs(0, idx); - needs.Remove(0, idx); - l.Add(new TObjString(need)); - } - - //build query - // this forms a query like e.g. - //SELECT SequenceProcessStatus.fSequenceFirst FROM SequenceProcessStatus - // WHERE ISNULL(fCallisto) - // AND NOT ISNULL(fAllFilesAvail) AND NOT ISNULL(fSequenceFileWritten) - //which would query all sequences for which Callisto has to be done. - TString query(Form("SELECT %s.%s FROM %s", - table.Data(), rc.GetValue(table+".Primary", ""), - table.Data())); - - //get joins - //if a date is given, the tables, which contain the information about the - // date (given in step.rc as TimerTable), have to be joined - if (date!="NULL" && rc.GetValue(table+".TimerTable", "")!="") - query+=Form(" left join %s on %s.%s=%s.%s ", - rc.GetValue(table+".TimerTable", ""), table.Data(), - rc.GetValue(table+".Primary", ""), - rc.GetValue(table+".TimerTable", ""), - rc.GetValue(table+".Primary", "")); - query+=Form(" WHERE ISNULL(%s) AND ISNULL(fReturnCode) AND ISNULL(fFailedCode) AND ISNULL(fFailedCodeAdd) AND ISNULL(fStartTime) AND ISNULL(fFailedTime) ", column.Data()); - - TIter Next(&l); - TObject *o=0; - while ((o=Next())) - query+=Form(" AND NOT ISNULL(%s)", o->GetName()); - - //if a date is given another condition is added to the query - if (date!="NULL") - { - if (rc.GetValue(table+".TimerTable", "")!="") - { - TString day=date+" 13:00:00"; - query+=Form(" AND (fRunStart>ADDDATE(\"%s\", INTERVAL -1 DAY) AND fRunStart<\"%s\")", - day.Data(), day.Data()); - } - else - query+=Form(" AND %s=%s ", rc.GetValue(table+".Primary", ""), date.Data()); - } - - //to process the newest data first, the results are ordered descending by the primary - query+=Form(" ORDER BY %s.%s DESC ", table.Data(), rc.GetValue(table+".Primary", "")); - - //this part of the query is needed, if there are more than 512 results and single - //todo files are written, as shell scripts have a limitation for arrays - if ((table=="SequenceProcessStatus" && column=="fCallisto") || - (table=="SequenceProcessStatus" && column=="fStar") || - (table=="RunProcessStatus" && column=="fDataCheckDone")) - query+="LIMIT 0, 500"; - - cout << "query: " << query << endl; - - TSQLResult *res = serv.Query(query); - if (!res) - { - cout << "ERROR - Query failed: " << query << endl; - return 0; - } - - - //write todo-file - //depending on the kind of step and primary, this looks different - //for steps, which do not take much time and can thus be executed - // for all data at once (e.g. buildsequenceentries) only one todo - // file is written - //for steps, which take quite long for one primary (e.g. calibration) - // or of which a large number has to be executed (e.g. datacheck) - // one todo-file per primary is written - TString filename; - TSQLRow *row=0; - - if ((table=="SequenceProcessStatus" && column=="fCallisto") || - (table=="SequenceProcessStatus" && column=="fStar") || - (table=="RunProcessStatus" && column=="fDataCheckDone") || - (table=="DataSetProcessStatus" && column=="fGanymed")) - { - while ((row = res->Next())) - { - filename=Form("%s/ToDo-%s-%s-%s.txt", listpath.Data(), table.Data(), column.Data(), (*row)[0]); - //remove file, if it is already existing - // this is needed, that the same step is not executed several times - gSystem->Unlink(filename); - ofstream fout(filename, ios::app); - if (!fout) - { - cout << "ERROR - Cannot open file " << filename << endl; - return 0; - } - fout << (*row)[0] << endl; - } - } - else - { - filename=Form("%s/ToDo-%s-%s.txt", listpath.Data(), table.Data(), column.Data()); - ofstream fout(filename, ios::app); - if (!fout) - { - cout << "ERROR - Cannot open file " << filename << endl; - return 0; - } - - while ((row = res->Next())) - fout << (*row)[0] << endl; - } - - delete res; - - return 1; -} - - Index: unk/MagicSoft/Mars/datacenter/macros/setstatus.C =================================================================== --- /trunk/MagicSoft/Mars/datacenter/macros/setstatus.C (revision 9050) +++ (revision ) @@ -1,185 +1,0 @@ -/* ======================================================================== *\ -! -! * -! * This file is part of MARS, the MAGIC Analysis and Reconstruction -! * Software. It is distributed to you in the hope that it can be a useful -! * and timesaving tool in analysing Data of imaging Cerenkov telescopes. -! * It is distributed WITHOUT ANY WARRANTY. -! * -! * Permission to use, copy, modify and distribute this software and its -! * documentation for any purpose is hereby granted without fee, -! * provided that the above copyright notice appear in all copies and -! * that both that copyright notice and this permission notice appear -! * in supporting documentation. It is provided "as is" without express -! * or implied warranty. -! * -! -! -! Author(s): Daniela Dorner, 01/2005 -! -! Copyright: MAGIC Software Development, 2000-2008 -! -! -\* ======================================================================== */ - -///////////////////////////////////////////////////////////////////////////// -// -// setstatus.C -// =========== -// -// This macro is a key part of the automation concept. -// It sets the status for dates/runs/sequences/datasets in the database, if a -// certain step has been done. -// -// Usage: -// .x setstatus.C+("primary","table","column","statustime","returncode","failedcode","failedcodeadd","starttime","failedtime",kTRUE) -// The first argument is the primary (date/run/sequence/dataset), the second -// and third argument give the table and column of the step. The fourth -// column is giving the statustime, to which the column has to be set. The -// fifth argument is giving the error code (in case of failure), the sixth -// an error comment, the seventh the starttime and the eigth the stoptime -// (only in case of failure). -// The last argument is indicating if the columns of all influenced steps -// shall be reset to NULL. The default is kTRUE, which means, that the -// columns are reset. -// -// Make sure, that database and password are corretly set in a resource -// file called sql.rc and the resource file is found. -// -// Returns 0 in case of failure and 1 in case of success. -// -///////////////////////////////////////////////////////////////////////////// -#include -#include -#include - -#include -#include -#include - -#include "MTime.h" -#include "MSQLServer.h" - -using namespace std; - - -Bool_t CheckReset(TEnv &rc, TString table, TString column, TString statustime) -{ - if (statustime!="NULL") - { - cout << "everything ok - no reset needed" << endl; - return kTRUE; - } - - //some columns can't be reseted, this is given in steps.rc - TString reset=rc.GetValue(table+"."+column+".Reset", "no"); - if (reset.Contains("no")) - { - cout << "you can't reset " << column << "." << endl; - return kFALSE; - } - - cout << "reset is possible" << endl; - return kTRUE; -} - -TString CheckDefault(MSQLServer &serv, TEnv &rc, TString primary, TString table, TString influence) -{ - //check if the value in the database is the default - TString query(Form("SELECT %s FROM %s WHERE %s=%s", - influence.Data(), table.Data(), - rc.GetValue(table+".Primary", ""), primary.Data())); - - TSQLResult *res = serv.Query(query); - if (!res) - cout << "Error - no run to check" << endl; - - MTime t, t0; - //set time t to 'no-version-value', - //which is in this case equivalent to NULL - t.Set(1970,1,1,0,0,0); - t0.Set(1970,1,1,0,0,0); - - TSQLRow *row=0; - while ((row = res->Next())) - { - if (row && (*row)[0]) - t.SetSqlDateTime((*row)[0]); - - cout << "t : " << t << endl; - cout << "t0: " << t0 << endl; - - return t()-t0()>0 ? "no" : "yes"; - } -} - -Int_t SetInfluences(MSQLServer &serv, TEnv &rc, TString primary, TString table, TString column, TString statustime, TString returncode, TString failedcode, TString failedcodeadd, TString starttime, TString failedtime, Bool_t resetall) -{ - cout << "set influences for " << table << "." << column << endl; - - //build query and set step and influences for the step - TString influences = rc.GetValue(table+"."+column+".Influences", ""); - - TString query(Form("UPDATE %s SET %s=%s, fReturnCode=%s, fFailedCode=%s, fFailedCodeAdd=%s, fFailedTime=%s ", - table.Data(), column.Data(), statustime.Data(), returncode.Data(), failedcode.Data(), - failedcodeadd.Data(), failedtime.Data())); - if (starttime.CompareTo("noreset")) - query += Form(", fStartTime=%s", starttime.Data()); - - while (!influences.IsNull() && resetall) - { - influences = influences.Strip(TString::kBoth); - - Int_t idx = influences.First(' '); - if (idx<0) - idx = influences.Length(); - - TString influence = influences(0, idx); - influences.Remove(0, idx); - - TString deflt = rc.GetValue(influence+".Default", ""); - - //for some columns there may be a different default - // in the file steps.rc they are marked with Default: check - // in this case, the value in the database has to be checked - if (deflt=="check") - deflt=CheckDefault(serv, rc, primary, table, influence); - //if it is the default value (1970-01-01 00:00:00), nothing is inserted into the database - if (deflt=="yes") - continue; - - query+=Form(", %s=NULL", influence.Data()); - } - - query+=Form(" WHERE %s='%s'", rc.GetValue(table+".Primary", ""), primary.Data()); - - TSQLResult *res = serv.Query(query); - if (!res) - return 0; - - return 1; -} - -int setstatus(TString primary, TString table, TString column, TString statustime, TString returncode, TString failedcode, TString failedcodeadd, TString starttime, TString failedtime, Bool_t resetall=kTRUE) -{ - TEnv env("sql.rc"); - - MSQLServer serv(env); - if (!serv.IsConnected()) - { - cout << "ERROR - Connection to database failed." << endl; - return 0; - } - cout << "setstatus" << endl; - cout << "---------" << endl; - cout << endl; - cout << "Connected to " << serv.GetName() << endl; - cout << endl; - - TEnv rc("steps.rc"); - - //if reset is needed and/or can be done, set new values - return !CheckReset(rc, table, column, statustime) ? 0 : SetInfluences(serv, rc, primary, table, column, statustime, returncode, failedcode, failedcodeadd, starttime, failedtime, resetall); - -} - Index: unk/MagicSoft/Mars/datacenter/macros/setupdb.C =================================================================== --- /trunk/MagicSoft/Mars/datacenter/macros/setupdb.C (revision 9050) +++ (revision ) @@ -1,960 +1,0 @@ -// This macro is a macro to create the Magic Database. -// It is kept up to date, if any changes in the database are made. - -#include -/* -Statements - -SELECT [ DISTINCT ] * | LIST OF COLUMNS, FUNCTIONS, CONSTANTS - FROM LIST OF TABLES OR VIEWS - [ WHERE CONDITION(S) ] - [ ORDER BY ORDERING COLUMN(S) [ ASC | DESC ] ] - [ GROUP BY GROUPING COLUMN(S) ] - [ HAVING CONDITION(S) ] - -DELETE FROM TABLE NAME - [ WHERE CONDITION(S) ] - -INSERT INTO TABLE NAME - [ (COLUMN LIST) ] - VALUES (VALUE LIST) - -UPDATE TABLE NAME - SET COLUMN NAME = VALUE - [ WHERE CONDITION ] - -Functions - -Function Purpose -SUM Total of the values in a field. -AVG Average of the values in a field. -MIN Lowest value in a field. -MAX Highest value in a field. -COUNT Number of values in a field, not counting Null (blank) values. - -Predicates - -Predicate Description -BETWEEN ... AND Compares a value to a range formed by two values. -IN Determines whether a value exists in a list of values or a table. -LIKE Compares, in part or in whole, one value with another. -JOIN Joins two tables. - -Data Definition - -CREATE TABLE TABLE_NAME - ( COLUMN_NAME DATA_TYPE [(SIZE)] COLUMN_CONSTRAINT, - [, other column definitions,...] - [, primary key constraint] - ) - -ALTER TABLE TABLE_NAME ADD | DROP | MODIFY - ( COLUMN_NAME DATA_TYPE [(SIZE)] COLUMN_CONSTRAINT, - [, other column definitions,...] - ) - -DROP TABLE TABLE_NAME - -CREATE [UNIQUE] [ASC | DESC] INDEX INDEX_NAME - ON TABLE_NAME ( COLUMN_LIST ) - -DROP INDEX INDEX_NAME ON TABLE_NAME - -CREATE VIEW VIEW_NAME AS QUERY_NAME - -CONSTRAINT CONSTRAINT_NAME - {PRIMARY KEY | UNIQUE | NOT NULL | - REFERENCES FOREIGN_TABLE [(FIELD_LIST)]} - - */ - -void Line(const TArrayI &max) -{ - cout << "+" << setfill('-'); - for (int i=0; iGetFieldCount(); - - TArrayI max(n); - - for (int i=0; iGetFieldName(i)); - - TSQLRow *row; - - TList rows; - while (row=res->Next()) - { - for (int i=0; iGetFieldLength(i)); - rows.Add(row); - } - - Line(max); - - cout << "|" << setfill(' '); - for (int i=0; iGetFieldName(i) << " |"; - cout << endl; - - Line(max); - - cout << setfill(' '); - TIter Next(&rows); - while (row=(TSQLRow*)Next()) - { - cout << "|"; - for (int i=0; iGetColumns(db, table); - if (!res) - return ""; - - TString fields; - - TList rows; - while (row=res->Next()) - rows.Add(row); - - TIter Next(&rows); - while (row=(TSQLRow*)Next()) - { - fields += (*row)[0]; - if (row!=rows.Last()) - fields += ", "; - } - - delete res; - - return fields; -} - -void PrintContents(TSQLServer *serv, const char *db, const char *table) -{ - TString fields=GetFields(serv, db, table); - - TSQLResult *res = serv->Query(Form("SELECT %s FROM %s", fields.Data(), table)); - if (res) - { - Print(res); - delete res; - } -} - -/* - GetTables(db): - \u "db" - SHOW TABLES; - - GetDataBases(); - SHOW DATABASES; - - GetColumns(db, table); - EXPLAIN table; - DESCRIBE table; - - SHOW VARIABLES; - - PRIMARY_KEY impliziert NOT NULL - - */ - -void CreatePrimaryEntries() -{ - TList list; - list.SetOwner(); - - // Trigger tables - list.Add(new TObjString( - "INSERT MyMagic.L1TriggerTable (fL1TriggerTableKEY, fL1TriggerTableName, fL1TriggerTable) VALUES " - " (1, 'n/a', 'Not available')")); - - list.Add(new TObjString( - "INSERT MyMagic.L2TriggerTable (fL2TriggerTableKEY, fL2TriggerTableName, fL2TriggerTable) VALUES " - " (1, 'n/a', 'Not available')")); - - // File path - list.Add(new TObjString( - "INSERT MyMagic.FilePath (fFilePathName, fFilePath) VALUES " - " ('n/a', 'Not available in the Data Center')")); - - // Magic number - list.Add(new TObjString( - "INSERT MyMagic.MagicNumber (fMagicNumber, fMagicNumberName) VALUES " - " (0x0001, 'Not available')," //1 - " (0xc0c0, 'Ok')," //45344 - " (0xc0c1, 'Not closed')," //45345 - " (0x0000, 'Wrong')")); //0 - - // Run type - list.Add(new TObjString( - "INSERT MyMagic.RunType (fRunType, fRunTypeName) VALUES " - " (0xffff, 'Not available')," - " (0x0000, 'Data')," - " (0x0001, 'Pedestal')," - " (0x0002, 'Calibration')," - " (0x0007, 'Point Run')," - " (0x0100, 'Monte Carlo')")); - - // HvSettings - list.Add(new TObjString( - "INSERT MyMagic.HvSettings (fHvSettingsKEY, fHvSettingsName, fHvSettings) VALUES " - " (1, 'n/a', 'Not available')")); - - //Excluded From DataAnalysis - list.Add(new TObjString( - "INSERT MyMagic.ExcludedFDA (fExcludedFDAKEY, fExcludedFDAName, fExcludedFDA) VALUES " - " (1, \"Not excluded\", \"Not excluded from Data Analysis\")")); - - //Manually Changed - list.Add(new TObjString( - "INSERT MyMagic.ManuallyChanged (fManuallyChangedKEY, fManuallyChangedName, fManuallyChanged) VALUES " - " (1, \"Automatic\", \"This entry was created automatically without user intervention\")"); - - // Source type - list.Add(new TObjString( - "INSERT MyMagic.SourceType (fSourceTypeName) VALUES ('Unknown')")); - - // LightConditions - list.Add(new TObjString( - "INSERT MyMagic.LightConditions (fLightConditionsKEY, fLightConditionsName, fLightConditions) VALUES " - " (1, 'n/a', 'Light conditions are not available')")); - - // Testflag - list.Add(new TObjString( - "INSERT MyMagic.TestFlag (fTestFlagKEY, fTestFlagName, fTestFlag) VALUES " - " (1, 'n/a', 'Testflag is not available')")); - - // Trigger delay table - list.Add(new TObjString( - "INSERT MyMagic.TriggerDelayTable (fTriggerDelayTableKEY, fTriggerDelayTableName, fTriggerDelayTable) VALUES " - " (1, 'n/a', 'Trigger delay table is not available')")); - - // Calibration script - list.Add(new TObjString( - "INSERT MyMagic.CalibrationScript (fCalibrationScriptKEY, fCalibrationScriptName, fCalibrationScript) VALUES " - " (1, 'n/a', 'Calibration script is not available')")); - - // discriminator threshold table - list.Add(new TObjString( - "INSERT MyMagic.DiscriminatorThresholdTable (fDiscriminatorThresholdTableKEY, fDiscriminatorThresholdTableName, fDiscriminatorThresholdTable) VALUES " - " (1, 'n/a', 'Discriminator threshold table is not available')")); - - // Observation Mode - list.Add(new TObjString( - "INSERT MyMagic.ObservationMode (fObservationModeKEY, fObservationModeName, fObservationMode) VALUES " - " (1, 'n/a', 'Not available')")); - - - TSQLServer *serv = TSQLServer::Connect("mysql://localhost:3306", "hercules", "d99swMT!"); - if (!serv) - return; - - TIter Next(&list); - TObjString *str; - - cout << "Filling tables..." << endl; - - while ((str=(TObjString*)Next())) - { - TString q(str->GetString()); - - Int_t f = q.First('('); - TString out = q(0, f); - cout << " - " << out << "... " << flush; - TSQLResult *res = serv->Query(q); - cout << (res==0 ? "ERROR!" : "Ok.") << endl; - if (res) - delete res; - } - - serv->Close(); - delete serv; -} - -TObjString *CreateKeyTable(TString name) -{ - return new TObjString(Form( - "CREATE TABLE MyMagic.%s (" - " f%sKEY SMALLINT UNSIGNED AUTO_INCREMENT PRIMARY KEY," - " f%sName VARCHAR(255) NOT NULL UNIQUE," - " f%s VARCHAR(255) NULL" - ") MAX_ROWS=65536", name.Data(), name.Data(), name.Data(), name.Data())); -} - -void CreateMagicDataBase() -{ - TList list; - list.SetOwner(); - - TString query = - "CREATE TABLE MyMagic.RunData" - "(" - " fRunDataKEY INT UNSIGNED PRIMARY KEY AUTO_INCREMENT,"// COMMENT('The unique key for each run-file'),"; - " fRunNumber INT UNSIGNED NOT NULL UNIQUE," // PACK_KEYS=1,";// COMMENT('Run number'),"; - " fMagicNumberKEY TINYINT UNSIGNED NOT NULL," // PACK_KEYS=1,";// COMMENT('The MAGIC Key (first two bytes of a raw data file)'),"; - " fFormatVersion SMALLINT UNSIGNED NOT NULL," // PACK_KEYS=1,";// COMMENT('File format version of the raw data file)'),"; - " fRunTypeKEY TINYINT UNSIGNED NOT NULL," // PACK_KEYS=1,";// COMMENT('Run type'),"; - " fProjectKEY SMALLINT UNSIGNED NOT NULL," // PACK_KEYS=1,";// COMMENT('Name of the project (assigned by the physics comittee)'),"; - " fSourceKEY SMALLINT UNSIGNED NOT NULL," // PACK_KEYS=1,";// COMMENT('Name of the source observed'),"; - " fNumEvents MEDIUMINT UNSIGNED NOT NULL," // COMMENT('Number of events in this run-file'),"; - " fRunStart DATETIME NOT NULL," // COMMENT('Time when the run was started'),"; - " fRunStop DATETIME NULL,"; // COMMENT('Time when the run has stopped')"; - query += - " fZenithDistance TINYINT NULL," // COMMENT('Time of last change'),"; - " fAzimuth SMALLINT NULL," // COMMENT('Time of last change'),"; - " fL1TriggerTableKEY SMALLINT UNSIGNED NOT NULL," // COMMENT('Time of last change'),"; - " fL2TriggerTableKEY SMALLINT UNSIGNED NOT NULL," // COMMENT('Time of last change'),"; - " fHvSettingsKEY SMALLINT UNSIGNED NOT NULL," // COMMENT('Time of last change'),"; - " fDaqStoreRate SMALLINT UNSIGNED NULL," // COMMENT('Time of last change'),"; - " fDaqTriggerRate SMALLINT UNSIGNED NULL," // COMMENT('Time of last change'),"; - " fMeanTriggerRate SMALLINT UNSIGNED NULL," // COMMENT('Time of last change'),"; - " fL2RatePresc SMALLINT UNSIGNED NULL," // COMMENT('Time of last change'),"; - " fL2RateUnpresc SMALLINT UNSIGNED NULL," // COMMENT('Time of last change'),"; - " fExcludedFDAKEY SMALLINT UNSIGNED NOT NULL," - " fSequenceFirst INT UNSIGNED NOT NULL,"; - query += - " fLastUpdate TIMESTAMP" // COMMENT('Time of last change'),"; - " fTestFlagKEY SMALLINT UNSIGNED NOT NULL," - " fLightConditionsKEY SMALLINT UNSIGNED NOT NULL," - " fCalibrationScriptKEY SMALLINT UNSIGNED NOT NULL," - " fDiscriminatorThresholdTableKEY SMALLINT UNSIGNED NOT NULL," - " fTriggerDelayTableKEY SMALLINT UNSIGNED NOT NULL," - " fObservationModeKEY SMALLINT UNSIGNED NOT NULL," - ")"; - - list.Add(new TObjString(query)); - - list.Add(new TObjString( - "CREATE TABLE MyMagic.RunType (" - " fRunTypeKEY TINYINT UNSIGNED AUTO_INCREMENT PRIMARY KEY," - " fRunType SMALLINT UNSIGNED NOT NULL UNIQUE," - " fRunTypeName VARCHAR(255) NOT NULL UNIQUE," - ") MAX_ROWS=256")); - - list.Add(new TObjString( - "CREATE TABLE MyMagic.MagicNumber (" - " fMagicNumberKEY TINYINT UNSIGNED AUTO_INCREMENT PRIMARY KEY," - " fMagicNumber SMALLINT UNSIGNED NOT NULL UNIQUE," - " fMagicNumberName VARCHAR(255) NOT NULL UNIQUE" - ") MAX_ROWS=256")); - - list.Add(new TObjString( - "CREATE TABLE MyMagic.Project (" - " fProjectKEY SMALLINT UNSIGNED AUTO_INCREMENT PRIMARY KEY," - " fProjectName CHAR(100) NOT NULL UNIQUE," - " fProject VARCHAR(255) NOT NULL" - ") MAX_ROWS=65536")); - - list.Add(new TObjString( - "CREATE TABLE MyMagic.Source (" - " fSourceKEY SMALLINT UNSIGNED AUTO_INCREMENT PRIMARY KEY," - " fSourceName CHAR(80) NOT NULL UNIQUE," - " fSourceTypeKEY SMALLINT UNSIGNED NULL," - " fRightAscension DOUBLE NULL," - " fDeclination DOUBLE NULL," - " fEpochChar CHAR NULL,"// DEFAULT='J' - " fEpochDate SMALLINT(4) UNSIGNED NULL,"// DEFAULT=2000 - " fMagnitude SMALLINT NULL," // 82=8.2 - " fTest ENUM(\"no\",\"yes\") NOT NULL" //default no - ") MAX_ROWS=65536")); - - list.Add(new TObjString( - "CREATE TABLE MyMagic.SourceType (" - " fSourceTypeKEY SMALLINT UNSIGNED AUTO_INCREMENT PRIMARY KEY," - " fSourceTypeName VARCHAR(255) NOT NULL UNIQUE" - ") MAX_ROWS=65536")); - - list.Add(new TObjString( - "CREATE TABLE MyMagic.Files (" - " fRawFileKEY INT UNSIGNED NOT NULL PRIMARY KEY," - " fRepFileKEY INT UNSIGNED NULL UNIQUE," - " fDccFileKEY INT UNSIGNED NULL UNIQUE" - ")")); - - list.Add(new TObjString( - "CREATE TABLE MyMagic.RawFile (" - " fRawFileKEY INT UNSIGNED PRIMARY KEY," - " fRawFileName VARCHAR(64) NOT NULL UNIQUE," // NULL means - Not in Wuerzburg! - " fFilePathKEY SMALLINT UNSIGNED NOT NULL" - ")")); - - list.Add(new TObjString( - "CREATE TABLE MyMagic.RepFile (" - " fRepFileKEY INT UNSIGNED AUTO_INCREMENT PRIMARY KEY," - " fRepFileName VARCHAR(64) NOT NULL UNIQUE," // NULL means - Not in Wuerzburg! - " fFilePathKEY SMALLINT UNSIGNED NOT NULL" - ")")); - - list.Add(new TObjString( - "CREATE TABLE MyMagic.DccFile (" - " fDccFileKEY INT UNSIGNED AUTO_INCREMENT PRIMARY KEY," - " fDccFileName VARCHAR(64) NOT NULL UNIQUE," // NULL means - Not in Wuerzburg! - " fFilePathKEY SMALLINT UNSIGNED NOT NULL" - ")")); - - list.Add(new TObjString( - "CREATE TABLE MyMagic.FilePath (" - " fFilePathKEY SMALLINT UNSIGNED AUTO_INCREMENT PRIMARY KEY," - " fFilePathName VARCHAR(255) NOT NULL UNIQUE," - " fFilePath VARCHAR(255) NOT NULL UNIQUE" - ") MAX_ROWS=65536")); - - list.Add(CreateKeyTable("L1TriggerTable")); - list.Add(CreateKeyTable("L2TriggerTable")); - list.Add(CreateKeyTable("HvSettings")); -// list.Add(CreateKeyTable("ExcludedFDA")); - list.Add(CreateKeyTable("ManuallyChanged")); - list.Add(CreateKeyTable("TestFlag")); - list.Add(CreateKeyTable("LightConditions")); - list.Add(CreateKeyTable("CalibrationScript")); - list.Add(CreateKeyTable("DiscriminatorThresholdTable")); - list.Add(CreateKeyTable("TriggerDelayTable")); - list.Add(CreateKeyTable("ObservationMode")); - - list.Add(new TObjString( - "CREATE TABLE MyMagic.ExcludedFDA (" - " fExcludedFDAKEY SMALLINT UNSIGNED AUTO_INCREMENT PRIMARY KEY," - " fExcludedFDAImportance SMALLINT UNSIGNED NULL," - " fExcludedFDAAutomatic ENUM(\"yes\",\"no\") NULL," - " fExcludedFDAName VARCHAR(255) NOT NULL UNIQUE," - " fExcludedFDA VARCHAR(255) NULL" - ") MAX_ROWS=65536")); - - - list.Add(new TObjString( - "CREATE TABLE MyMagic.DataCheck (" - " fRunNumber INT UNSIGNED PRIMARY KEY," - " fEvents INT UNSIGNED NULL," - " fPositionSignal TINYINT UNSIGNED NULL," - " fPositionFWHM TINYINT UNSIGNED NULL," - " fHeightSignal SMALLINT UNSIGNED NULL," - " fHeightFWHM SMALLINT UNSIGNED NULL," - " fHasSignal ENUM(\"yes\",\"no\") NULL," - " fHasPedestal ENUM(\"yes\",\"no\") NULL," - " fPositionAsym ENUM(\"yes\",\"no\") NULL," - " fHeightAsym ENUM(\"yes\",\"no\") NULL," - " fEventsInterlaced INT UNSIGNED NULL," - " fPositionSignalInterlaced TINYINT UNSIGNED NULL," - " fPositionFWHMInterlaced TINYINT UNSIGNED NULL," - " fHeightSignalInterlaced SMALLINT UNSIGNED NULL," - " fHeightFWHMInterlaced SMALLINT UNSIGNED NULL," - " fHasSignalInterlaced ENUM(\"yes\",\"no\") NULL," - " fHasPedestalInterlaced ENUM(\"yes\",\"no\") NULL," - " fPositionAsymInterlaced ENUM(\"yes\",\"no\") NULL," - " fHeightAsymInterlaced ENUM(\"yes\",\"no\") NULL" - ")")); - - -/* - list.Add(new TObjString( - "CREATE TABLE MyMagic.TriggerTable (" - " fTriggerTableKEY SMALLINT UNSIGNED AUTO_INCREMENT PRIMARY KEY," - " fTriggerTableName VARCHAR(255) NOT NULL UNIQUE," - " fTriggerTable VARCHAR(255) NULL" - ") MAX_ROWS=65536")); - - list.Add(new TObjString( - "CREATE TABLE MyMagic.HvSettings (" - " fHvSettingsKEY SMALLINT UNSIGNED AUTO_INCREMENT PRIMARY KEY," - " fHvSettingsName VARCHAR(255) NOT NULL UNIQUE," - " fHvSettings VARCHAR(255) NULL" - ") MAX_ROWS=65536")); - - list.Add(new TObjString( - "CREATE TABLE MyMagic.ExcludedFDA (" - " fExcludedFDAKEY SMALLINT UNSIGNED AUTO_INCREMENT PRIMARY KEY," - " fExcludedFDAName VARCHAR(255) NOT NULL UNIQUE," - " fExcludedFDA VARCHAR(255) NULL" - ") MAX_ROWS=65536")); - - list.Add(new TObjString( - "CREATE TABLE MyMagic.ManuallyChanged (" - " fManuallyChangedKEY SMALLINT UNSIGNED AUTO_INCREMENT PRIMARY KEY," - " fManuallyChangedName VARCHAR(255) NOT NULL UNIQUE," - " fManuallyChanged VARCHAR(255) NULL" - ") MAX_ROWS=65536")); - */ - list.Add(new TObjString( - "CREATE TABLE MyMagic.Changes (" - " fChangesKEY INT UNSIGNED AUTO_INCREMENT PRIMARY KEY," - " fTimeStamp TIMESTAMP," - " fTableName VARCHAR(64) NOT NULL," - " fRowKEY INT UNSIGNED NOT NULL," - " fColumnName VARCHAR(64) NOT NULL," - " fDescription VARCHAR(255) NOT NULL" - ")")); - - list.Add(new TObjString( - "CREATE TABLE MyMagic.Comments (" - " fCommentsKEY INT UNSIGNED AUTO_INCREMENT PRIMARY KEY," - " fCommentsName VARCHAR(255) NOT NULL,", - " fRunDataKEY INT UNSIGNED NOT NULL" - ")")); - - list.Add(new TObjString( - "CREATE TABLE MyMagic.RunBook (" - " fRunBookKEY INT UNSIGNED AUTO_INCREMENT PRIMARY KEY," - " fRunBookDate DATETIME NOT NULL,", - " fRunBookText TEXT NOT NULL" - ")")); - - list.Add(new TObjString( - "CREATE TABLE MyMagic.Sequences (" - " fSequenceFirst INT UNSIGNED PRIMARY KEY, " - " fSequenceLast INT UNSIGNED NOT NULL UNIQUE, " - " fProjectKEY SMALLINT UNSIGNED NOT NULL," - " fSourceKEY SMALLINT UNSIGNED NOT NULL," - " fNumEvents MEDIUMINT UNSIGNED NOT NULL," - " fRunTime SMALLINT UNSIGNED NOT NULL," - " fRunStart DATETIME NOT NULL," - " fRunStop DATETIME NOT NULL," - " fZenithDistanceMin TINYINT NULL," - " fZenithDistanceMax TINYINT NULL," - " fAzimuthMin SMALLINT NULL," - " fAzimuthMax SMALLINT NULL," - " fL1TriggerTableKEY SMALLINT UNSIGNED NOT NULL,"; - query += - " fL2TriggerTableKEY SMALLINT UNSIGNED NOT NULL," - " fHvSettingsKEY SMALLINT UNSIGNED NOT NULL," - " fManuallyChanged SMALLINT UNSIGNED NOT NULL," - " fLastUpdate TIMESTAMP" // COMMENT('Time of last change'),"; - " fTestFlagKEY SMALLINT UNSIGNED NOT NULL," - " fLightConditionsKEY SMALLINT UNSIGNED NOT NULL," - " fDiscriminatorThresholdTableKEY SMALLINT UNSIGNED NOT NULL," - " fTriggerDelayTableKEY SMALLINT UNSIGNED NOT NULL," - " fObservationModeKEY SMALLINT UNSIGNED NOT NULL," - ")"; - - list.Add(new TObjString( - "CREATE TABLE MyMagic.Calibration (" - " fSequenceFirst INT UNSIGNED PRIMARY KEY, " - " fUnsuitableInner SMALLINT UNSIGNED NOT NULL, " - " fUnsuitableOuter SMALLINT UNSIGNED NOT NULL, " - " fUnreliableInner SMALLINT UNSIGNED NOT NULL," - " fUnreliableOuter SMALLINT UNSIGNED NOT NULL," - " fIsolatedInner SMALLINT UNSIGNED NOT NULL," - " fIsolatedOuter SMALLINT UNSIGNED NOT NULL," - " fIsolatedMaxCluster SMALLINT UNSIGNED NOT NULL," - " fMeanPedRmsInner FLOAT(6,2) NOT NULL," - " fMeanPedRmsOuter FLOAT(6,2) NOT NULL," - " fMeanSignalInner FLOAT(6,2) NOT NULL," - " fMeanSignalOuter FLOAT(6,2) NOT NULL," - " fArrTimeMeanInner FLOAT(5,1) NOT NULL," - " fArrTimeRmsInner FLOAT(6,2) NOT NULL," - " fArrTimeMeanOuter FLOAT(5,1) NOT NULL," - " fArrTimeRmsOuter FLOAT(6,2) NOT NULL," - " fConvFactorInner FLOAT(6,3) NOT NULL," - " fConvFactorOuter FLOAT(6,3) NOT NULL," - " fPulsePosMean FLOAT(6,2) NOT NULL," - " fPulsePosRms FLOAT(6,2) NOT NULL," - " fPulsePosCheckMean FLOAT(6,2) NULL," - " fPulsePosCheckRms FLOAT(6,2) NULL," - " fPulsePosOffMed FLOAT(7,4) NULL," - " fPulsePosOffDev FLOAT(7,4) NULL," - " fHiLoGainRatioMed FLOAT(6,2) NULL," - " fHiLoGainRatioDev FLOAT(6,2) NULL," - " fLastUpdate TIMESTAMP" - ")")); - - list.Add(new TObjString( - "CREATE TABLE MyMagic.Star (" - " fSequenceFirst INT UNSIGNED PRIMARY KEY, " - " fMeanNumberIslands FLOAT(6,2) NOT NULL," - " fPSF FLOAT(5,1) NOT NULL," - " fRatio FLOAT(5,1) NOT NULL," - " fMuonRate FLOAT(6,2) NOT NULL," - " fMuonNumber INT UNSIGNED NOT NULL," - " fEffOnTime INT UNSIGNED NOT NULL," - " fDataRate INT UNSIGNED NOT NULL," - " fMaxHumidity FLOAT(6,1) NOT NULL," - " fInhomogeneity FLOAT(5,1) NOT NULL," - " fNumStarsMed FLOAT(5,1) NOT NULL," - " fNumStarsRMS FLOAT(5,1) NOT NULL," - " fNumStarsCorMed FLOAT(5,1) NOT NULL," - " fNumStarsCorRMS FLOAT(5,1) NOT NULL," - " fBrightnessMed FLOAT(5,1) NOT NULL," - " fBrightnessRMS FLOAT(5,1) NOT NULL," - " fLastUpdate TIMESTAMP" - ")")); - - list.Add(new TObjString( - "CREATE TABLE MyMagic.DataSets (" - " fDataSetNumber INT UNSIGNED PRIMARY KEY, " - " fSourceKEY SMALLINT UNSIGNED NOT NULL," - " fWobble ENUM('Y','N') NULL," - " fComment VARCHAR(255) NULL," - " fLastUpdate TIMESTAMP" - ")")); - - list.Add(new TObjString( - "CREATE TABLE MyMagic.Ganymed (" - " fDataSetNumber INT UNSIGNED PRIMARY KEY, " - " fExcessEvents INT UNSIGNED NOT NULL," - " fBackgroundEvents INT UNSIGNED NOT NULL," - " fSignalEvents INT UNSIGNED NOT NULL," - " fEffOnTime INT UNSIGNED NOT NULL," - " fSignificance FLOAT(5,1) NOT NULL," - " fScaleFactor FLOAT(5,2) NOT NULL," - " fStandard ENUM(\"no\",\"yes\") NOT NULL," //default no - " fLastUpdate TIMESTAMP" - ")")); - - list.Add(new TObjString( - "CREATE TABLE MyMagic.DataSetProcessStatus (" - " fDataSetNumber INT UNSIGNED PRIMARY KEY, " - " fDataSetInserted DATETIME NULL," - " fStarFilesAvail DATETIME NULL," - " fGanymed DATETIME NULL," - " fFillGanymed DATETIME NULL," - " fStartTime DATETIME NULL," - " fFailedTime DATETIME NULL," - " fFailedCode SMALLINT UNSIGNED NULL," - " fReturnCode SMALLINT UNSIGNED NULL," - " fFailedCodeAdd INT UNSIGNED NULL" - ")"; - - list.Add(new TObjString( - "CREATE TABLE MyMagic.SequenceBuildStatus (" - " fDate DATE PRIMARY KEY, " - " fCCFilled DATETIME NULL," - " fExclusionsDone DATETIME NULL," - " fSequenceEntriesBuilt DATETIME NULL," - " fStartTime DATETIME NULL," - " fFailedTime DATETIME NULL," - " fFailedCode SMALLINT UNSIGNED NULL," - " fReturnCode SMALLINT UNSIGNED NULL," - " fFailedCodeAdd INT UNSIGNED NULL" - ")"; - - list.Add(new TObjString( - "CREATE TABLE MyMagic.RunProcessStatus (" - " fRunNumber INT UNSIGNED PRIMARY KEY, " - " fCCFileAvail DATETIME NULL," - " fCaCoFileAvail DATETIME NULL," - " fCaCoFileFound INT UNSIGNED NULL," - " fRawFileAvail DATETIME NULL," - " fDataCheckDone DATETIME NULL," - " fTimingCorrection DATETIME NULL," - " fMerpp DATETIME NULL," - " fMerppCCUpdate DATETIME NULL," - " fMerppCaCoUpdate DATETIME NULL," - " fStartTime DATETIME NULL," - " fFailedTime DATETIME NULL," - " fFailedCode SMALLINT UNSIGNED NULL," - " fReturnCode SMALLINT UNSIGNED NULL," - " fFailedCodeAdd INT UNSIGNED NULL" - ")"; - - list.Add(new TObjString( - "CREATE TABLE MyMagic.SequenceProcessStatus (" - " fSequenceFirst INT UNSIGNED PRIMARY KEY, " - " fSequenceFileWritten DATETIME NULL," - " fAllFilesAvail DATETIME NULL," - " fCallisto DATETIME NULL," - " fFillCallisto DATETIME NULL," - " fStar DATETIME NULL," - " fFillStar DATETIME NULL," - " fStartTime DATETIME NULL," - " fFailedTime DATETIME NULL," - " fFailedCode SMALLINT UNSIGNED NULL," - " fReturnCode SMALLINT UNSIGNED NULL," - " fFailedCodeAdd INT UNSIGNED NULL" - ")"; - - list.Add(new TObjString( - "CREATE TABLE MyMagic.MarsVersion (" - " fMarsVersion SMALLINT UNSIGNED AUTO_INCREMENT PRIMARY KEY," - " fStartDate DATETIME NULL ," - " fMarsVersionName VARCHAR(12) NOT NULL UNIQUE" - ") MAX_ROWS=256")); - - list.Add(new TObjString( - "CREATE TABLE `OpticalData` (" - " `fOpticalDataKEY` int(11) NOT NULL auto_increment," - " `fTimestamp` datetime NOT NULL default '0000-00-00 00:00:00'," - " `fExposure` smallint(5) unsigned NOT NULL default '0'," - " `fFitsFileKEY` smallint(5) unsigned NOT NULL default '0'," - " `fObjectKEY` smallint(5) unsigned NOT NULL default '0'," - " `fSkyLevel` float(6,1) default NULL," - " `fFWHM` float(4,2) default NULL," - " `fApertureRadius` float(3,1) default NULL," - " `fInstrumentalMag` float(7,4) default NULL," - " `fInstrumentalMagErr` float(6,4) default NULL," - " `fStatusKEY` smallint(5) unsigned NOT NULL default '0'," - " `fZenithDistance` float(4,1) default NULL," - " `fBandKEY` smallint(5) unsigned NOT NULL default '0'," - " `fFilterKEY` smallint(5) unsigned NOT NULL default '0'," - " `fTelescopeKEY` smallint(5) unsigned NOT NULL default '0'," - " `fCCDKEY` smallint(5) unsigned NOT NULL default '0'," - " PRIMARY KEY (`fOpticalDataKEY`)")); - - TSQLResult *res; - - TSQLServer *serv = TSQLServer::Connect("mysql://localhost:3306", "hercules", "d99swMT!"); - if (!serv) - return; - - res = serv->DropDataBase("MyMagic"); - res = serv->CreateDataBase("MyMagic"); - if (res) - { - cout << "Error creating Data Base!" << endl; - return; - } - - TIter Next(&list); - TObjString *str; - - cout << "Creating tables..." << endl; - - while ((str=(TObjString*)Next())) - { - TString q(str->GetString()); - - Int_t f = q.First('('); - TString out = q(0, f); - cout << " - " << out << "... " << flush; - res = serv->Query(q); - cout << (res==0 ? "ERROR!" : "Ok.") << endl; - if (res) - delete res; - } - - serv->Close(); - delete serv; -} - -void DisplayMagicDataBase() -{ - TSQLServer *serv = TSQLServer::Connect("mysql://localhost:3306", "hercules", "d99swMT!"); - if (!serv) - return; - - res = serv->GetColumns("MyMagic", "RunData"); - if (res) - Print(res); - res = serv->GetColumns("MyMagic", "RunType"); - if (res) - Print(res); - res = serv->GetColumns("MyMagic", "MagicNumber"); - if (res) - Print(res); - res = serv->GetColumns("MyMagic", "Project"); - if (res) - Print(res); - res = serv->GetColumns("MyMagic", "Source"); - if (res) - Print(res); - res = serv->GetColumns("MyMagic", "TriggerTable"); - if (res) - Print(res); - res = serv->GetColumns("MyMagic", "HvSettings"); - if (res) - Print(res); - - serv->Close(); -} - -Bool_t ExistStr(TSQLServer *serv, const char *column, const char *table, const char *test) -{ - TString query(Form("SELECT %s FROM %s WHERE %s='%s'", column, table, column, test)); - TSQLResult *res = serv->Query(query); - if (!res) - return kFALSE; - delete res; - - TSQLRow *row; - - while (row=res->Next()) - { - if ((*row)[0]) - return kTRUE; - } - - return kFALSE; -} -/* -void LoadSourceNames(const char *fname) -{ - TSQLServer *serv = TSQLServer::Connect("mysql://localhost:3306", "hercules", "d99swMT!"); - if (!serv) - return; - - ifstream fin(fname); - if (!fin) - { - cout << "Cannot open " << fname << endl; - return; - } - - while (1) - { - TString query, name; - - name.ReadLine(fin); - if (!fin) - break; - - if (ExistStr(serv, "fSourceName", "MyMagic.Source", name)) - { - cout << "Entry " << name << " exists." << endl; - continue; - } - - query = "INSERT MyMagic.Source SET "; - query += " fSourceName='"; - query += name; - query += "', fSourceTypeKEY=1"; - if (!serv->Query(query)) - { - cout << query << " - FAILED!" << endl; - return; - } - } - - serv->Close(); -} - -void LoadProjectNames(const char *fname) -{ - TSQLServer *serv = TSQLServer::Connect("mysql://localhost:3306", "hercules", "d99swMT!"); - if (!serv) - return; - - ifstream fin(fname); - if (!fin) - { - cout << "Cannot open " << fname << endl; - return; - } - - while (1) - { - TString query, name; - - name.ReadLine(fin); - if (!fin) - break; - - if (ExistStr(serv, "fProjectName", "MyMagic.Project", name)) - { - cout << "Entry " << name << " exists." << endl; - continue; - } - - query = "INSERT MyMagic.Project SET "; - query += " fProjectName='"; - query += name; - query += "', fProject='AUTO: "; - query += name; - query += "'"; - if (!serv->Query(query)) - { - cout << query << " - FAILED!" << endl; - return; - } - } - - serv->Close(); -} - -void LoadTriggerTableNames(const char *fname) -{ - TSQLServer *serv = TSQLServer::Connect("mysql://localhost:3306", "hercules", "d99swMT!"); - if (!serv) - return; - - ifstream fin(fname); - if (!fin) - { - cout << "Cannot open " << fname << endl; - return; - } - - while (1) - { - TString query, name; - - name.ReadLine(fin); - if (!fin) - break; - - if (ExistStr(serv, "fTriggerTableName", "MyMagic.TriggerTable", name)) - { - cout << "Entry " << name << " exists." << endl; - continue; - } - - query = "INSERT MyMagic.TriggerTable SET "; - query += " fTriggerTableName='"; - query += name; - query += "'"; - if (!serv->Query(query)) - { - cout << query << " - FAILED!" << endl; - return; - } - } - - serv->Close(); -} -*/ -void setupdb() -{ - CreateMagicDataBase(); - CreatePrimaryEntries(); - //LoadSourceNames("sourcenames.txt"); - //LoadProjectNames("projectnames.txt"); - //LoadTriggerTableNames("triggertablenames.txt"); - - - return; - - //TSQLServer *serv = TSQLServer::Connect("mysql://magic:3306", "root", "marWin"); - //TSQLServer *serv = TSQLServer::Connect("mysql://localhost:3306", "database", "ImM9G1CD8"); - TSQLServer *serv = TSQLServer::Connect("mysql://localhost:3306", "hercules", "d99swMT!"); - if (!serv) - return; - - cout << "ServerInfo: " << serv->ServerInfo() << endl; - cout << "DBMS: " << serv->GetDBMS() << endl; - cout << "Host: " << serv->GetHost() << endl; - cout << "Port: " << serv->GetPort() << endl; - - TSQLResult *res; - - cout << endl; - - res = serv->GetDataBases(); - if (res) - Print(res); - - serv->Close(); - /* - TList list; - if (!list.FindObject(triggertablename)) - { - TNamed *name = new TNamed(triggertablename, ""); - list.Add(name); - } - - list.Print(); - */ -} Index: /trunk/MagicSoft/Mars/resources/steps.rc =================================================================== --- /trunk/MagicSoft/Mars/resources/steps.rc (revision 9050) +++ /trunk/MagicSoft/Mars/resources/steps.rc (revision 9051) @@ -1,7 +1,7 @@ #primaries: -SequenceBuildStatus.Primary: fDate -RunProcessStatus.Primary: fRunNumber -SequenceProcessStatus.Primary: fSequenceFirst -DataSetProcessStatus.Primary: fDataSetNumber +SequenceBuildStatus.Primary: fDate fTelescopeNumber +RunProcessStatus.Primary: fRunNumber fTelescopeNumber fFileNumber +SequenceProcessStatus.Primary: fSequenceFirst fTelescopeNumber +DataSetProcessStatus.Primary: fDataSetNumber fTelescopeNumber #-------------------------------------------------------------------- Index: unk/MagicSoft/Mars/steps.rc =================================================================== --- /trunk/MagicSoft/Mars/steps.rc (revision 9050) +++ (revision ) @@ -1,266 +1,0 @@ -#primaries: -SequenceBuildStatus.Primary: fDate -RunProcessStatus.Primary: fRunNumber -SequenceProcessStatus.Primary: fSequenceFirst -DataSetProcessStatus.Primary: fDataSetNumber - -#-------------------------------------------------------------------- - - -#SequenceBuildStatus.fDate: -SequenceBuildStatus.fDate.Default: yes -#SequenceBuildStatus.fDate.Needs: - -SequenceBuildStatus.fDate.Influences: SequenceBuildStatus.fExclusionsDone SequenceBuildStatus.fSequenceEntriesBuilt -SequenceBuildStatus.fDate.Reset: yes - - -#SequenceBuildStatus.fCCFilled: -SequenceBuildStatus.fCCFilled.Default: no -SequenceBuildStatus.fCCFilled.Needs: SequenceBuildStatus.fDate -SequenceBuildStatus.fCCFilled.Influences: SequenceBuildStatus.fExclusionsDone SequenceBuildStatus.fSequenceEntriesBuilt -SequenceBuildStatus.fCCFilled.Reset: yes - - -#SequenceBuildStatus.fExclusionsDone: -SequenceBuildStatus.fExclusionsDone.Default: no -SequenceBuildStatus.fExclusionsDone.Needs: SequenceBuildStatus.fCCFilled -SequenceBuildStatus.fExclusionsDone.Influences: SequenceBuildStatus.fSequenceEntriesBuilt -SequenceBuildStatus.fExclusionsDone.Reset: yes - - -#SequenceBuildStatus.fSequenceEntriesBuilt: -SequenceBuildStatus.fSequenceEntriesBuilt.Default: no -SequenceBuildStatus.fSequenceEntriesBuilt.Needs: SequenceBuildStatus.fCCFilled SequenceBuildStatus.fExclusionsDone -#SequenceBuildStatus.fSequenceEntriesBuilt.Influences: -SequenceBuildStatus.fSequenceEntriesBuilt.Reset: yes - - -#-------------------------------------------------------------------- - - -#RunProcessStatus.fRunNumber: -RunProcessStatus.fRunNumber.Default: yes -#RunProcessStatus.fRunNumber.Needs: - -RunProcessStatus.fRunNumber.Influences: RunProcessStatus.fCCFileAvail RunProcessStatus.fCaCoFileAvail RunProcessStatus.fCaCoFileFound RunProcessStatus.fRawFileAvail RunProcessStatus.fMerpp RunProcessStatus.fMerppCCUpdate RunProcessStatus.fMerppCaCoUpdate -RunProcessStatus.fRunNumber.Reset: yes - - -#RunProcessStatus.fRawFileAvail: -RunProcessStatus.fRawFileAvail.Default: no -#RunProcessStatus.fRawFileAvail.Needs: - -#RunProcessStatus.fRawFileAvail.Influences: RunProcessStatus.fTimingCorrection RunProcessStatus.fDataCheckDone RunProcessStatus.fMerpp RunProcessStatus.fMerppCCUpdate RunProcessStatus.fMerppCaCoUpdate -RunProcessStatus.fRawFileAvail.Reset: yes - - -#RunProcessStatus.fCCFileAvail: -RunProcessStatus.fCCFileAvail.Default: no -#RunProcessStatus.fCCFileAvail.Needs: - -#RunProcessStatus.fCCFileAvail.Influences: RunProcessStatus.fMerppCCUpdate RunProcessStatus.fMerppCaCoUpdate -RunProcessStatus.fCCFileAvail.Reset: yes - - -#RunProcessStatus.fCaCoFileAvail: -RunProcessStatus.fCaCoFileAvail.Default: no -#RunProcessStatus.fCaCoFileAvail.Needs: - -#RunProcessStatus.fCaCoFileAvail.Influences: RunProcessStatus.fMerppCaCoUpdate -RunProcessStatus.fCaCoFileAvail.Reset: yes - - -#RunProcessStatus.fCaCoFileFound: -RunProcessStatus.fCaCoFileFound.Default: no -#RunProcessStatus.fCaCoFileFound.Needs: - -#RunProcessStatus.fCaCoFileFound.Influences: RunProcessStatus.fMerppCaCoUpdate -RunProcessStatus.fCaCoFileFound.Reset: yes - - -#RunProcessStatus.fDataCheckDone: -RunProcessStatus.fDataCheckDone.Default: no -RunProcessStatus.fDataCheckDone.Needs: RunProcessStatus.fRawFileAvail -#RunProcessStatus.fDataCheckDone.Influences: - -RunProcessStatus.fDataCheckDone.Reset: yes - - -#RunProcessStatus.fTimingCorrection: -RunProcessStatus.fTimingCorrection.Default: check -RunProcessStatus.fTimingCorrection.Needs: RunProcessStatus.fRawFileAvail -RunProcessStatus.fTimingCorrection.Influences: RunProcessStatus.fMerpp RunProcessStatus.fMerppCCUpdate RunProcessStatus.fMerppCaCoUpdate -RunProcessStatus.fTimingCorrection.Reset: yes - - -#RunProcessStatus.fCompmux: -RunProcessStatus.fCompmux.Default: check -RunProcessStatus.fCompmux.Needs: RunProcessStatus.fRawFileAvail -RunProcessStatus.fCompmux.Influences: RunProcessStatus.fMerpp RunProcessStatus.fMerppCCUpdate RunProcessStatus.fMerppCaCoUpdate -RunProcessStatus.fCompmux.Reset: yes - - -#RunProcessStatus.fMerpp: -RunProcessStatus.fMerpp.Default: no -RunProcessStatus.fMerpp.Needs: RunProcessStatus.fRawFileAvail RunProcessStatus.fTimingCorrection -RunProcessStatus.fMerpp.Influences: RunProcessStatus.fMerppCCUpdate RunProcessStatus.fMerppCaCoUpdate -RunProcessStatus.fMerpp.Reset: yes - - -#RunProcessStatus.fMerppCCUpdate: -RunProcessStatus.fMerppCCUpdate.Default: no -RunProcessStatus.fMerppCCUpdate.Needs: RunProcessStatus.fRawFileAvail RunProcessStatus.fMerpp RunProcessStatus.fTimingCorrection RunProcessStatus.fCCFileAvail -RunProcessStatus.fMerppCCUpdate.Influences: RunProcessStatus.fMerppCaCoUpdate -RunProcessStatus.fMerppCCUpdate.Reset: no - - -#RunProcessStatus.fMerppCaCoUpdate: -RunProcessStatus.fMerppCaCoUpdate.Default: no -RunProcessStatus.fMerppCaCoUpdate.Needs: RunProcessStatus.fRawFileAvail RunProcessStatus.fMerpp RunProcessStatus.fTimingCorrection RunProcessStatus.fCCFileAvail RunProcessStatus.fMerppCCUpdate RunProcessStatus.fCaCoFileFound -#RunProcessStatus.fMerppCaCoUpdate.Influences: - -RunProcessStatus.fMerppCaCoUpdate.Reset: no - - -#-------------------------------------------------------------------- - - -#SequenceProcessStatus.fSequenceFirst: -SequenceProcessStatus.fSequenceFirst.Default: yes -#SequenceProcessStatus.fSequenceFirst.Needs: - -SequenceProcessStatus.fSequenceFirst.Influences: SequenceProcessStatus.fSequenceFileWritten SequenceProcessStatus.fAllFilesAvail SequenceProcessStatus.fCallisto SequenceProcessStatus.fFillCallisto SequenceProcessStatus.fStar SequenceProcessStatus.fFillStar -SequenceProcessStatus.fSequenceFirst.Reset: yes - - -#SequenceProcessStatus.fSequenceFileWritten: -SequenceProcessStatus.fSequenceFileWritten.Default: check -SequenceProcessStatus.fSequenceFileWritten.Needs: SequenceProcessStatus.fSequenceFirst -SequenceProcessStatus.fSequenceFileWritten.Influences: SequenceProcessStatus.fCallisto SequenceProcessStatus.fFillCallisto SequenceProcessStatus.fStar SequenceProcessStatus.fFillStar -SequenceProcessStatus.fSequenceFileWritten.Reset: yes - - -#SequenceProcessStatus.fAllFilesAvail: -SequenceProcessStatus.fAllFilesAvail.Default: no -SequenceProcessStatus.fAllFilesAvail.Needs: SequenceProcessStatus.fSequenceFileWritten -SequenceProcessStatus.fAllFilesAvail.Influences: SequenceProcessStatus.fCallisto SequenceProcessStatus.fFillCallisto SequenceProcessStatus.fStar SequenceProcessStatus.fFillStar -SequenceProcessStatus.fAllFilesAvail.Reset: yes - - -#SequenceProcessStatus.fCallisto: -SequenceProcessStatus.fCallisto.Default: no -SequenceProcessStatus.fCallisto.Needs: SequenceProcessStatus.fSequenceFileWritten SequenceProcessStatus.fAllFilesAvail SequenceProcessStatus.fNotZipping -SequenceProcessStatus.fCallisto.Influences: SequenceProcessStatus.fFillCallisto SequenceProcessStatus.fStar SequenceProcessStatus.fFillStar -SequenceProcessStatus.fCallisto.Reset: yes - - -#SequenceProcessStatus.fFillCallisto: -SequenceProcessStatus.fFillCallisto.Default: no -SequenceProcessStatus.fFillCallisto.Needs: SequenceProcessStatus.fSequenceFileWritten SequenceProcessStatus.fAllFilesAvail SequenceProcessStatus.fCallisto -#SequenceProcessStatus.fFillCallisto.Influences: - -SequenceProcessStatus.fFillCallisto.Reset: yes - - -#SequenceProcessStatus.fStar: -SequenceProcessStatus.fStar.Default: no -SequenceProcessStatus.fStar.Needs: SequenceProcessStatus.fSequenceFileWritten SequenceProcessStatus.fAllFilesAvail SequenceProcessStatus.fCallisto -SequenceProcessStatus.fStar.Influences: SequenceProcessStatus.fFillStar -SequenceProcessStatus.fStar.Reset: yes - - -#SequenceProcessStatus.fFillStar: -SequenceProcessStatus.fFillStar.Default: no -SequenceProcessStatus.fFillStar.Needs: SequenceProcessStatus.fSequenceFileWritten SequenceProcessStatus.fAllFilesAvail SequenceProcessStatus.fCallisto SequenceProcessStatus.fStar -#SequenceProcessStatus.fFillStar.Influences: - -SequenceProcessStatus.fFillStar.Reset: yes - - -#-------------------------------------------------------------------- - - -#DataSetProcessStatus.fDataSetNumber: -DataSetProcessStatus.fDataSetNumber.Default: yes -#DataSetProcessStatus.fDataSetNumber.Needs: - -DataSetProcessStatus.fDataSetNumber.Influences: DataSetProcessStatus.fStarFilesAvail DataSetProcessStatus.fGanymed -DataSetProcessStatus.fDataSetNumber.Reset: yes - - -#DataSetProcessStatus.fDataSetInserted: -DataSetProcessStatus.fDataSetInserted.Default: no -DataSetProcessStatus.fDataSetInserted.Needs: DataSetProcessStatus.fDataSetNumber -DataSetProcessStatus.fDataSetInserted.Influences: DataSetProcessStatus.fDataSetFileWritten DataSetProcessStatus.fStarFilesAvail DataSetProcessStatus.fGanymed DataSetProcessStatus.fFillGanymed -DataSetProcessStatus.fDataSetInserted.Reset: yes - - -#DataSetProcessStatus.fDataSetFileWritten: -DataSetProcessStatus.fDataSetFileWritten.Default: no -DataSetProcessStatus.fDataSetFileWritten.Needs: DataSetProcessStatus.fDataSetNumber DataSetProcessStatus.fDataSetInserted -DataSetProcessStatus.fDataSetFileWritten.Influences: DataSetProcessStatus.fStarFilesAvail DataSetProcessStatus.fGanymed -DataSetProcessStatus.fDataSetFileWritten.Reset: yes - - -#DataSetProcessStatus.fStarFilesAvail: -DataSetProcessStatus.fStarFilesAvail.Default: no -DataSetProcessStatus.fStarFilesAvail.Needs: DataSetProcessStatus.fDataSetInserted DataSetProcessStatus.fDataSetFileWritten -DataSetProcessStatus.fStarFilesAvail.Influences: DataSetProcessStatus.fGanymed -DataSetProcessStatus.fStarFilesAvail.Reset: yes - - -#DataSetProcessStatus.fGanymed: -DataSetProcessStatus.fGanymed.Default: no -DataSetProcessStatus.fGanymed.Needs: DataSetProcessStatus.fDataSetInserted DataSetProcessStatus.fDataSetFileWritten DataSetProcessStatus.fStarFilesAvail -DataSetProcessStatus.fGanymed.Influences: DataSetProcessStatus.fFillGanymed -DataSetProcessStatus.fGanymed.Reset: yes - - -#DataSetProcessStatus.fFillGanymed: -DataSetProcessStatus.fFillGanymed.Default: no -DataSetProcessStatus.fFillGanymed.Needs: DataSetProcessStatus.fDataSetInserted DataSetProcessStatus.fDataSetFileWritten DataSetProcessStatus.fStarFilesAvail DataSetProcessStatus.fGanymed -#DataSetProcessStatus.fFillGanymed.Influences: -DataSetProcessStatus.fFillGanymed.Reset: yes - - -#-------------------------------------------------------------------- - - -#MCRunProcessStatus.fMCRunNumber: -MCRunProcessStatus.fMCRunNumber.Default: yes -#MCRunProcessStatus.fMCRunNumber.Needs: - -MCRunProcessStatus.fMCRunNumber.Influences: MCRunProcessStatus.fCameraInputCreated -MCRunProcessStatus.fMCRunNumber.Reset: yes - - -#MCRunProcessStatus.fCameraInputCreated: -MCRunProcessStatus.fCameraInputCreated.Default: no -MCRunProcessStatus.fCameraInputCreated.Needs: MCRunProcessStatus.fMCRunNumber -MCRunProcessStatus.fCameraInputCreated.Influences: MCRunProcessStatus.fReflectorInputCreated -MCRunProcessStatus.fCameraInputCreated.Reset: yes - - -#MCRunProcessStatus.fReflectorInputCreated: -MCRunProcessStatus.fReflectorInputCreated.Default: no -MCRunProcessStatus.fReflectorInputCreated.Needs: MCRunProcessStatus.fCameraInputCreated -MCRunProcessStatus.fReflectorInputCreated.Influences: MCRunProcessStatus.fCorsikaInputCreated -MCRunProcessStatus.fReflectorInputCreated.Reset: yes - - -#MCRunProcessStatus.fCorsikaInputCreated: -MCRunProcessStatus.fCorsikaInputCreated.Default: no -MCRunProcessStatus.fCorsikaInputCreated.Needs: MCRunProcessStatus.fReflectorInputCreated -MCRunProcessStatus.fCorsikaInputCreated.Influences: MCRunProcessStatus.fCorsikaFileAvail -MCRunProcessStatus.fCorsikaInputCreated.Reset: yes - - -#MCRunProcessStatus.fCorsikaFileAvail: -MCRunProcessStatus.fCorsikaFileAvail.Default: no -MCRunProcessStatus.fCorsikaFileAvail.Needs: MCRunProcessStatus.fCorsikaInputCreated -MCRunProcessStatus.fCorsikaFileAvail.Influences: MCRunProcessStatus.fReflectorFileAvail MCRunProcessStatus.fCameraFileAvail -MCRunProcessStatus.fCorsikaFileAvail.Reset: yes - - -#MCRunProcessStatus.fReflectorFileAvail: -MCRunProcessStatus.fReflectorFileAvail.Default: no -MCRunProcessStatus.fReflectorFileAvail.Needs: MCRunProcessStatus.fCorsikaFileAvail -MCRunProcessStatus.fReflectorFileAvail.Influences: MCRunProcessStatus.fCameraFileAvail -MCRunProcessStatus.fReflectorFileAvail.Reset: yes - - -#MCRunProcessStatus.fCameraFileAvail: -MCRunProcessStatus.fCameraFileAvail.Default: no -MCRunProcessStatus.fCameraFileAvail.Needs: MCRunProcessStatus.fReflectorFileAvail -#MCRunProcessStatus.fCameraFileAvail.Influences: -MCRunProcessStatus.fCameraFileAvail.Reset: yes - -