4 |
|
use Mysql; |
5 |
|
use Getopt::Long; |
6 |
|
use File::Copy; |
7 |
+ |
use Term::ANSIColor; |
8 |
|
|
9 |
|
sub getDataset; |
10 |
|
sub dbUpdate; |
15 |
|
sub uploadRelease; |
16 |
|
sub downloadRelease; |
17 |
|
sub datasetExists; |
18 |
+ |
sub uploadConfig; |
19 |
+ |
sub locationExists; |
20 |
+ |
sub getLocation; |
21 |
|
|
22 |
|
our $db = Mysql->connect ("cmshead.mps.ohio-state.edu", "ntuple", "osuT3User") or die "Failed to connect to Tier 3, stopped"; |
23 |
|
|
24 |
|
my %opt; |
25 |
|
Getopt::Long::Configure ("bundling"); |
26 |
< |
GetOptions (\%opt, "comment|c=s", "format|f=s", "pyConfig|p=s", "crabCfg|b=s", "jsonFile|j=s", "lumiSummary|s=s", "location|l=s", "fileList|t=s", "release|r=s", "other|o", "recipe|e=s", "help|h"); |
26 |
> |
GetOptions (\%opt, "comment|c=s", "format|f=s", "pyConfig|p=s", "crabCfg|b=s", "jsonFile|j=s", "lumiSummary|s=s", "location|l=s", "name|n=s", "fileList|t=s", "release|r=s", "other|o", "recipe|e=s", "globalTag|g=s", "configName|i=s", "xSection|x=s", "higherOrderXSec|y=s", "help|h"); |
27 |
|
my $argc = @ARGV; |
28 |
|
|
29 |
|
printHelp ($ARGV[0]) if $opt{"help"}; |
30 |
|
printHelp () if $argc != 2 && $ARGV[0] ne "createOther"; |
31 |
< |
printHelp () if $ARGV[0] ne "create" && $ARGV[0] ne "createOther" && $ARGV[0] ne "update" && $ARGV[0] ne "finish" && $ARGV[0] ne "deprecate" && $ARGV[0] ne "uploadRelease" && $ARGV[0] ne "downloadRelease" && $ARGV[0] ne "deleteEntry"; |
31 |
> |
printHelp () if $ARGV[0] ne "create" && $ARGV[0] ne "createOther" && $ARGV[0] ne "update" && $ARGV[0] ne "finish" && $ARGV[0] ne "deprecate" && $ARGV[0] ne "uploadRelease" && $ARGV[0] ne "downloadRelease" && $ARGV[0] ne "deleteEntry" && $ARGV[0] ne "uploadConfig"; |
32 |
|
if (($ARGV[0] eq "create" || $ARGV[0] eq "finish") && !$opt{"location"}) |
33 |
|
{ |
34 |
|
print "The directory containing the ntuples must be given!\n"; |
39 |
|
print "The Python config, CMSSW release directory, and recipe file must be given!\n"; |
40 |
|
exit; |
41 |
|
} |
42 |
+ |
if ($ARGV[0] eq "uploadConfig" && (!$opt{"pyConfig"} || !$opt{"release"})) |
43 |
+ |
{ |
44 |
+ |
print "The Python config and ntuple release must be given!\n"; |
45 |
+ |
exit; |
46 |
+ |
} |
47 |
|
if ($ARGV[0] eq "uploadRelease") |
48 |
|
{ |
49 |
|
my $parentDir = "./$opt{'release'}"; |
59 |
|
{ |
60 |
|
downloadRelease ($ARGV[1], $opt{"pyConfig"}); |
61 |
|
} |
62 |
+ |
elsif ($ARGV[0] eq "uploadConfig") |
63 |
+ |
{ |
64 |
+ |
uploadConfig ($ARGV[1], $ENV{"USER"}, $opt{"pyConfig"}, $opt{"release"}, $opt{"comment"}); |
65 |
+ |
} |
66 |
|
elsif ($ARGV[0] eq "createOther") |
67 |
|
{ |
68 |
|
my @listOfFiles = @ARGV; |
69 |
|
@listOfFiles = reverse (@listOfFiles); |
70 |
|
pop (@listOfFiles); |
71 |
|
@listOfFiles = reverse (@listOfFiles); |
72 |
< |
dbOtherCreate ("$ENV{'USER'}", \@listOfFiles, $opt{"comment"}); |
72 |
> |
dbOtherCreate ("$ENV{'USER'}\@$ENV{'HOSTNAME'}", \@listOfFiles, $opt{"comment"}); |
73 |
|
} |
74 |
|
else |
75 |
|
{ |
83 |
|
$status = "" if $ARGV[0] eq "update"; |
84 |
|
$status = "deprecated" if $ARGV[0] eq "deprecate"; |
85 |
|
$opt{"format"} = "BEAN" if $ARGV[0] eq "create" && !$opt{"format"}; |
86 |
< |
dbUpdate ($id, $fullDataset, "$ENV{'USER'}\@$ENV{'HOSTNAME'}", $opt{"format"}, $opt{"location"}, $opt{"fileList"}, $status, $opt{"comment"}, $opt{"pyConfig"}, $opt{"crabCfg"}, $opt{"jsonFile"}, $opt{"lumiSummary"}, $opt{"release"}) if !$opt{"other"}; |
87 |
< |
dbUpdateOther ($id, $opt{"comment"}, "$ENV{'USER'}\@$ENV{'HOSTNAME'}") if $opt{"other"}; |
86 |
> |
if ($opt{"location"} && locationExists ($id, $opt{"location"})) |
87 |
> |
{ |
88 |
> |
print "This location is already registered in the database!\n"; |
89 |
> |
exit; |
90 |
> |
} |
91 |
> |
dbUpdate ($id, $fullDataset, "$ENV{'USER'}\@$ENV{'HOSTNAME'}", $opt{"format"}, $opt{"location"}, $opt{"name"}, $opt{"fileList"}, $status, $opt{"comment"}, $opt{"pyConfig"}, $opt{"crabCfg"}, $opt{"jsonFile"}, $opt{"lumiSummary"}, $opt{"release"}, $opt{"globalTag"}, $opt{"configName"}, $opt{"xSection"}, $opt{"higherOrderXSec"}) if $ARGV[0] ne "deleteEntry" && !$opt{"other"}; |
92 |
> |
dbUpdateOther ($id, $opt{"comment"}, "$ENV{'USER'}\@$ENV{'HOSTNAME'}") if $ARGV[0] ne "deleteEntry" && $opt{"other"}; |
93 |
|
dbDelete ($id) if $ARGV[0] eq "deleteEntry" && !$opt{"other"}; |
94 |
|
dbDeleteOther ($id) if $ARGV[0] eq "deleteEntry" && $opt{"other"}; |
95 |
|
} |
117 |
|
my $queryDataset = $dataset; |
118 |
|
$queryDataset =~ s/\*/%/g; |
119 |
|
$queryDataset =~ s/(.*)/%$1%/g; |
120 |
< |
my $query = "select id,dataset,user,creationTime from ntuple where dataset like '$queryDataset' order by creationTime"; |
120 |
> |
my $query = "select id,dataset,user,creationTime,status from ntuple where dataset like '$queryDataset' order by creationTime"; |
121 |
|
$db->selectdb ("ntuple"); |
122 |
|
$results = $db->query ($query); |
123 |
|
if ($results->numrows () == 1) |
150 |
|
for (my $i = 1; $i <= $results->numrows (); $i++) |
151 |
|
{ |
152 |
|
my @row = $results->fetchrow (); |
153 |
+ |
$row[3] =~ s/([^ ]*) [^ ]*/$1/g; |
154 |
|
$id{"$i"} = $row[0]; |
155 |
|
$fullDataset{"$i"} = $row[1]; |
156 |
|
printf "(%2d) $row[1]\n", $i; |
157 |
< |
print " created by $row[2] on $row[3]\n"; |
157 |
> |
print " ("; |
158 |
> |
print color "green" if $row[4] eq "present"; |
159 |
> |
print color "bold yellow" if $row[4] eq "submitted"; |
160 |
> |
print color "bold red" if $row[4] eq "created" or $row[4] eq "cancelled" or $row[4] eq "deprecated"; |
161 |
> |
print $row[4]; |
162 |
> |
print color "reset"; |
163 |
> |
print ") created by $row[2] on $row[3]\n"; |
164 |
|
} |
165 |
|
print "\nWhich entry would you like to modify?"; |
166 |
|
if ($command ne "deleteEntry" && $command ne "deprecate") |
188 |
|
{ |
189 |
|
my $id = shift; |
190 |
|
my $dataset = shift; |
191 |
< |
my $user = shift; |
191 |
> |
my $userAndHost = shift; |
192 |
|
my $format = shift; |
193 |
|
my $location = shift; |
194 |
+ |
my $name = shift; |
195 |
|
my $fileListName = shift; |
196 |
|
my $status = shift; |
197 |
|
my $comment = shift; |
200 |
|
my $jsonFileName = shift; |
201 |
|
my $lumiSummaryName = shift; |
202 |
|
my $release = shift; |
203 |
+ |
my $globalTag = shift; |
204 |
+ |
my $configName = shift; |
205 |
+ |
my $xSection = shift; |
206 |
+ |
my $ySection = shift; |
207 |
+ |
|
208 |
+ |
$location = getLocation ($id) if $id > 0 |
209 |
+ |
&& !$crabCfgName |
210 |
+ |
&& !$comment |
211 |
+ |
&& !$format |
212 |
+ |
&& !$globalTag |
213 |
+ |
&& !$configName |
214 |
+ |
&& !$jsonFileName |
215 |
+ |
&& !$location |
216 |
+ |
&& !$name |
217 |
+ |
&& !$psetName |
218 |
+ |
&& !$release |
219 |
+ |
&& !$lumiSummaryName |
220 |
+ |
&& !$xSection |
221 |
+ |
&& !$ySection; |
222 |
+ |
|
223 |
+ |
my $user = $userAndHost; |
224 |
+ |
$user =~ s/@.*$//g; |
225 |
|
|
226 |
|
my $fileList; |
227 |
|
my $pset; |
290 |
|
close (LUMI_SUMMARY); |
291 |
|
$lumiSummary = join ("", @lumiSummary); |
292 |
|
} |
293 |
< |
if ($release) |
294 |
< |
{ |
247 |
< |
my $query = "select id from ntupleRelease where name='$release'"; |
248 |
< |
$db->selectdb ("ntuple"); |
249 |
< |
my $results = $db->query ($query); |
250 |
< |
if ($results->numrows () != 1) |
251 |
< |
{ |
252 |
< |
print "Ntuple release \"$release\" not found!\n"; |
253 |
< |
exit; |
254 |
< |
} |
255 |
< |
} |
256 |
< |
($nFiles, $size) = sizeOfDataset ($dataset, $location, $fileList); |
293 |
> |
$release .= ".$configName" if $configName; |
294 |
> |
($nFiles, $size) = sizeOfDataset ($location, $fileList); |
295 |
|
my $fullLocation = $location; |
296 |
|
$fullLocation = "$ENV{'PWD'}/$location" if !($location =~ m/^\//); |
297 |
|
|
303 |
|
$jsonFile = addSlashes ($jsonFile); |
304 |
|
$lumiSummary = addSlashes ($lumiSummary); |
305 |
|
$fullLocation = addSlashes ($fullLocation); |
306 |
+ |
$name = addSlashes ($name); |
307 |
|
$fileList = addSlashes ($fileList); |
308 |
|
$status = addSlashes ($status); |
309 |
|
$comment = addSlashes ($comment); |
310 |
|
$release = addSlashes ($release); |
311 |
+ |
$globalTag = addSlashes ($globalTag); |
312 |
|
|
313 |
|
my $results; |
314 |
|
my $query; |
315 |
|
if ($id < 0) |
316 |
|
{ |
317 |
+ |
$query = "select id from ntuple where dataset='$dataset'"; |
318 |
+ |
$db->selectdb ("ntuple"); |
319 |
+ |
$results = $db->query ($query); |
320 |
+ |
if ($results->numrows ()) |
321 |
+ |
{ |
322 |
+ |
print "This dataset already exists in the database. Create anyway? (y/N): "; |
323 |
+ |
my $response = <STDIN>; |
324 |
+ |
$response =~ s/\n//g; |
325 |
+ |
$response = "n" if !$response; |
326 |
+ |
exit if substr (lc ($response), 0, 1) ne 'y'; |
327 |
+ |
} |
328 |
+ |
|
329 |
|
$query = "select max(id) from ntuple"; |
330 |
|
$db->selectdb ("ntuple"); |
331 |
|
$results = $db->query ($query); |
333 |
|
my $id = 1; |
334 |
|
$id = $row[0] + 1 if $results->numrows (); |
335 |
|
|
336 |
< |
$query = "insert into ntuple (id, dataset, creationTime, lastUpdateTime, lastUpdateUser, user, format, location, fileList, nFiles, sizeInGB, status, comment, pset, crabCfg, jsonFile, lumiSummary, version) values ($id, '$dataset', now(), now(), '$user', '$user', '$format', '$fullLocation', '$fileList', $nFiles, $size, '$status', '$comment', '$pset', '$crabCfg', '$jsonFile', '$lumiSummary', '$release')"; |
336 |
> |
my $columns = "(id, dataset, creationTime, lastUpdateTime, lastUpdateUser, user, format, location, fileList, nFiles, sizeInGB, status, comment, pset, crabCfg, jsonFile, lumiSummary, version, globalTag"; |
337 |
> |
$columns .= ", crossSectionInPicobarn" if $xSection; |
338 |
> |
$columns .= ", higherOrderCrossSectionInPicobarn" if $ySection; |
339 |
> |
$columns .= ")"; |
340 |
> |
my $values = "($id, '$dataset', now(), now(), '$userAndHost', '$user', '$format', '$fullLocation', '$fileList', $nFiles, $size, '$status', '$comment', '$pset', '$crabCfg', '$jsonFile', '$lumiSummary', '$release', '$globalTag'"; |
341 |
> |
$values .= ", $xSection" if $xSection; |
342 |
> |
$values .= ", $ySection" if $ySection; |
343 |
> |
$values .= ")"; |
344 |
> |
$query = "insert into ntuple $columns values $values"; |
345 |
|
} |
346 |
|
if ($id > 0) |
347 |
|
{ |
348 |
|
my $fields; |
349 |
|
my $values; |
350 |
|
|
351 |
< |
$values .= ", dataset='$dataset'" if $dataset; |
351 |
> |
if ($name) |
352 |
> |
{ |
353 |
> |
$query = "select id from ntuple where dataset='$name'"; |
354 |
> |
$db->selectdb ("ntuple"); |
355 |
> |
$results = $db->query ($query); |
356 |
> |
if ($results->numrows ()) |
357 |
> |
{ |
358 |
> |
print "This dataset already exists in the database. Use this name anyway? (y/N): "; |
359 |
> |
my $response = <STDIN>; |
360 |
> |
$response =~ s/\n//g; |
361 |
> |
$response = "n" if !$response; |
362 |
> |
exit if substr (lc ($response), 0, 1) ne 'y'; |
363 |
> |
} |
364 |
> |
$values .= ", dataset='$name'"; |
365 |
> |
} |
366 |
> |
|
367 |
|
$values .= ", lastUpdateTime=now()"; |
368 |
|
$values .= ", lastUpdateUser='$user'"; |
369 |
|
$values .= ", format='$format'" if $format; |
378 |
|
$values .= ", jsonFile='$jsonFile'" if $jsonFile; |
379 |
|
$values .= ", lumiSummary='$lumiSummary'" if $lumiSummary; |
380 |
|
$values .= ", version='$release'" if $release; |
381 |
+ |
$values .= ", globalTag='$globalTag'" if $globalTag; |
382 |
+ |
$values .= ", crossSectionInPicobarn=$xSection" if $xSection; |
383 |
+ |
$values .= ", higherOrderCrossSectionInPicobarn=$ySection" if $ySection; |
384 |
|
|
385 |
|
$values =~ s/^, //; |
386 |
|
$query = "update ntuple set $values where id=$id"; |
444 |
|
printf "%-29s%s\n", " -b, --crabCfg FILE", "CRAB config used to submit ntuple jobs"; |
445 |
|
printf "%-29s%s\n", " -c, --comment COMMENT", "comment for the database entry"; |
446 |
|
printf "%-29s%s\n", " -f, --format FORMAT", "ntuple format (default: BEAN)"; |
447 |
+ |
printf "%-29s%s\n", " -g, --globalTag TAG", "global tag"; |
448 |
+ |
printf "%-29s%s\n", " -i, --configName NAME", "name of config used to produce ntuples"; |
449 |
|
printf "%-29s%s\n", " -j, --jsonFile FILE", "JSON file used for this dataset"; |
450 |
|
printf "%-29s%s\n", " -l, --location DIRECTORY", "directory containing the ntuples"; |
451 |
|
printf "%-29s%s\n", " -p, --pyConfig FILE", "Python config used to produce ntuples"; |
452 |
|
printf "%-29s%s\n", " -r, --release NAME", "ntuple release used to produce ntuples"; |
453 |
|
printf "%-29s%s\n", " -s, --lumiSummary FILE", "lumiSummary.json reported by CRAB"; |
454 |
+ |
printf "%-29s%s\n", " -x, --xSection XSEC", "cross section in picobarns from PREP"; |
455 |
+ |
printf "%-29s%s\n", " -y, --higherOrderXSec XSEC", "higher-order cross section in picobarns"; |
456 |
|
} |
457 |
|
elsif ($command eq "createOther") |
458 |
|
{ |
465 |
|
elsif ($command eq "update") |
466 |
|
{ |
467 |
|
print "Usage: $exeName [OPTION]... update NAME\n"; |
468 |
< |
print "Updates an existing database entry for dataset NAME.\n"; |
468 |
> |
print "Updates an existing database entry for dataset NAME. If no options are given,\n"; |
469 |
> |
print "updates the number of files and the size on disk of the dataset using the\n"; |
470 |
> |
print "location in the database.\n"; |
471 |
|
print "\n"; |
472 |
|
print "Mandatory arguments to long options are mandatory for short options too.\n"; |
473 |
|
printf "%-29s%s\n", " -b, --crabCfg FILE", "CRAB config used to submit ntuple jobs"; |
474 |
|
printf "%-29s%s\n", " -c, --comment COMMENT", "comment for the database entry"; |
475 |
|
printf "%-29s%s\n", " -f, --format FORMAT", "ntuple format"; |
476 |
+ |
printf "%-29s%s\n", " -g, --globalTag TAG", "global tag"; |
477 |
+ |
printf "%-29s%s\n", " -i, --configName NAME", "name of config used to produce ntuples"; |
478 |
|
printf "%-29s%s\n", " -j, --jsonFile FILE", "JSON file used for this dataset"; |
479 |
|
printf "%-29s%s\n", " -l, --location DIRECTORY", "directory containing the ntuples"; |
480 |
+ |
printf "%-29s%s\n", " -n, --name NAME", "rename the entry"; |
481 |
|
printf "%-29s%s\n", " -o, --other", "update an entry in the non-ntuple database"; |
482 |
|
printf "%-29s%s\n", " -p, --pyConfig FILE", "Python config used to produce ntuples"; |
483 |
|
printf "%-29s%s\n", " -r, --release NAME", "ntuple release used to produce ntuples"; |
484 |
|
printf "%-29s%s\n", " -s, --lumiSummary FILE", "lumiSummary.json reported by CRAB"; |
485 |
+ |
printf "%-29s%s\n", " -x, --xSection XSEC", "cross section in picobarns from PREP"; |
486 |
+ |
printf "%-29s%s\n", " -y, --higherOrderXSec XSEC", "higher-order cross section in picobarns"; |
487 |
|
} |
488 |
|
elsif ($command eq "finish") |
489 |
|
{ |
490 |
|
print "Usage: $exeName -l DIRECTORY finish NAME\n"; |
402 |
– |
|
491 |
|
print "Finalizes the database entry for dataset NAME, changing its status to\n"; |
492 |
|
print "\"present\". This is intended to be the final step in command-line based ntuple\n"; |
493 |
|
print "production.\n"; |
535 |
|
print "Mandatory arguments to long options are mandatory for short options too.\n"; |
536 |
|
printf "%-29s%s\n", " -p, --pyConfig FILE", "Python configuration file name"; |
537 |
|
} |
538 |
+ |
elsif ($command eq "uploadConfig") |
539 |
+ |
{ |
540 |
+ |
print "Usage: $exeName -p FILE -r RELEASE [OPTION]... uploadConfig NAME\n"; |
541 |
+ |
print "Creates an entry in the database for a customized Python configuration file.\n"; |
542 |
+ |
print "\n"; |
543 |
+ |
print "Mandatory arguments to long options are mandatory for short options too.\n"; |
544 |
+ |
printf "%-29s%s\n", " -c, --comment COMMENT", "comment for the database entry"; |
545 |
+ |
printf "%-29s%s\n", " -p, --pyConfig FILE", "Python config file"; |
546 |
+ |
printf "%-29s%s\n", " -r, --release NAME", "ntuple release with which to use this config"; |
547 |
+ |
} |
548 |
|
else |
549 |
|
{ |
550 |
|
print "Usage: $exeName [OPTION]... COMMAND NAME\n"; |
563 |
|
printf "%-29s%s\n", " deprecate", "marks the dataset for deletion"; |
564 |
|
printf "%-29s%s\n", " uploadRelease", "upload an ntuple release"; |
565 |
|
printf "%-29s%s\n", " downloadRelease", "download an ntuple release"; |
566 |
+ |
printf "%-29s%s\n", " uploadConfig", "upload an ntuple config"; |
567 |
|
} |
568 |
|
|
569 |
|
exit; |
572 |
|
sub |
573 |
|
sizeOfDataset |
574 |
|
{ |
476 |
– |
my $dataset = shift; |
575 |
|
my $location = shift; |
576 |
|
my $fileList = shift; |
577 |
|
|
628 |
|
print "$recipeName does not exist!\n"; |
629 |
|
exit; |
630 |
|
} |
631 |
< |
move ($release, "/home/hart/public_html/releases/$name.tar.gz") or die "Ntuple releases may only be uploaded on the Tier 3, stopped"; |
631 |
> |
move ($release, "/home/osucms/public_html/releases/$name.tar.gz") or die "Ntuple releases may only be uploaded on the Tier 3, stopped"; |
632 |
|
open (PY_CONFIG, "<$psetName"); |
633 |
|
my @pset = <PY_CONFIG>; |
634 |
|
close (PY_CONFIG); |
636 |
|
open (RECIPE, "<$recipeName"); |
637 |
|
my @recipe = <RECIPE>; |
638 |
|
close (RECIPE); |
639 |
< |
my $recipe = join ("\n", @recipe); |
639 |
> |
my $recipe = join ("", @recipe); |
640 |
|
|
641 |
|
my $query = "select max(id) from ntupleRelease"; |
642 |
|
$db->selectdb ("ntuple"); |
672 |
|
print "Ntuple release \"$release\" not found!\n"; |
673 |
|
exit; |
674 |
|
} |
577 |
– |
if (!(-e "/home/hart/public_html/releases/$release.tar.gz")) |
578 |
– |
{ |
579 |
– |
print "Release is in the database but no package exists!\n"; |
580 |
– |
exit; |
581 |
– |
} |
675 |
|
if ($pyConfigName) |
676 |
|
{ |
677 |
|
my @row = $results->fetchrow (); |
679 |
|
print PY_CONFIG $row[1]; |
680 |
|
close (PY_CONFIG); |
681 |
|
} |
682 |
< |
copy ("/home/hart/public_html/releases/$release.tar.gz", "$release.tar.gz"); |
682 |
> |
`wget "http://cmshead.mps.ohio-state.edu/~osucms/releases/$release.tar.gz"`; |
683 |
|
} |
684 |
|
|
685 |
|
sub |
686 |
|
dbOtherCreate |
687 |
|
{ |
688 |
< |
my $user = shift; |
688 |
> |
my $userAndHost = shift; |
689 |
|
my $listOfFiles = shift; |
690 |
|
my $comment = shift; |
691 |
|
|
692 |
+ |
my $user = $userAndHost; |
693 |
+ |
$user =~ s/@.*$//g; |
694 |
+ |
|
695 |
|
my $size = 0.0; |
696 |
|
my $nFiles = 0.0; |
697 |
|
for (my $i = 0; $i < @$listOfFiles; $i++) |
722 |
|
$location = addSlashes ($location); |
723 |
|
$comment = addSlashes ($comment); |
724 |
|
|
725 |
< |
my $query = "insert into other (id, creationTime, lastUpdateTime, lastUpdateUser, user, location, nFiles, sizeInGB, comment) values ($id, now(), now(), '$user', '$user', '$location', $nFiles, $size, '$comment')"; |
725 |
> |
$query = "insert into other (id, creationTime, lastUpdateTime, lastUpdateUser, user, location, nFiles, sizeInGB, comment) values ($id, now(), now(), '$userAndHost', '$user', '$location', $nFiles, $size, '$comment')"; |
726 |
|
$db->selectdb ("ntuple"); |
727 |
< |
my $results = $db->query ($query); |
727 |
> |
$results = $db->query ($query); |
728 |
|
|
729 |
|
print "ID $id\n"; |
730 |
|
} |
731 |
+ |
|
732 |
+ |
sub |
733 |
+ |
uploadConfig |
734 |
+ |
{ |
735 |
+ |
my $name = shift; |
736 |
+ |
my $user = shift; |
737 |
+ |
my $psetName = shift; |
738 |
+ |
my $release = shift; |
739 |
+ |
my $comment = shift; |
740 |
+ |
|
741 |
+ |
if (!(-e $psetName)) |
742 |
+ |
{ |
743 |
+ |
print "$psetName does not exist!\n"; |
744 |
+ |
exit; |
745 |
+ |
} |
746 |
+ |
if ($release) |
747 |
+ |
{ |
748 |
+ |
my $query = "select id from ntupleRelease where name='$release'"; |
749 |
+ |
$db->selectdb ("ntuple"); |
750 |
+ |
my $results = $db->query ($query); |
751 |
+ |
if ($results->numrows () != 1) |
752 |
+ |
{ |
753 |
+ |
print "Ntuple release \"$release\" not found!\n"; |
754 |
+ |
exit; |
755 |
+ |
} |
756 |
+ |
} |
757 |
+ |
open (PSET, "<$psetName"); |
758 |
+ |
my @pset = <PSET>; |
759 |
+ |
close (PSET); |
760 |
+ |
my $pset = join ("", @pset); |
761 |
+ |
|
762 |
+ |
my $query = "select max(id) from ntupleConfig"; |
763 |
+ |
$db->selectdb ("ntuple"); |
764 |
+ |
my $results = $db->query ($query); |
765 |
+ |
my @row = $results->fetchrow (); |
766 |
+ |
my $id = 1; |
767 |
+ |
$id = $row[0] + 1 if $results->numrows (); |
768 |
+ |
|
769 |
+ |
$name = addSlashes ($name); |
770 |
+ |
$user = addSlashes ($user); |
771 |
+ |
$pset = addSlashes ($pset); |
772 |
+ |
$release = addSlashes ($release); |
773 |
+ |
$comment = addSlashes ($comment); |
774 |
+ |
|
775 |
+ |
my $query = "insert into ntupleConfig (id, name, pset, user, pending, ntupleRelease, comment) values ($id, '$name', '$pset', '$user', 1, '$release', '$comment')"; |
776 |
+ |
$db->selectdb ("ntuple"); |
777 |
+ |
$results = $db->query ($query); |
778 |
+ |
} |
779 |
+ |
|
780 |
+ |
sub |
781 |
+ |
locationExists |
782 |
+ |
{ |
783 |
+ |
my $id = shift; |
784 |
+ |
my $location = shift; |
785 |
+ |
|
786 |
+ |
$location =~ s/^(.*)\/+$/$1/; |
787 |
+ |
my $query = "select id from ntuple where location like '$location%' and id!=$id"; |
788 |
+ |
$db->selectdb ("ntuple"); |
789 |
+ |
my $results = $db->query ($query); |
790 |
+ |
return 1 if $results->numrows (); |
791 |
+ |
|
792 |
+ |
if ($location =~ m/^\/store\/.*$/) |
793 |
+ |
{ |
794 |
+ |
$location =~ s/^\/store\/(.*)$/\/data\/se\/store\/$1/; |
795 |
+ |
} |
796 |
+ |
elsif ($location =~ m/^\/data\/se\/store\/.*$/) |
797 |
+ |
{ |
798 |
+ |
$location =~ s/^\/data\/se\/store\/(.*)$/\/store\/$1/; |
799 |
+ |
} |
800 |
+ |
|
801 |
+ |
my $query = "select id from ntuple where location like '$location%' and id!=$id"; |
802 |
+ |
$db->selectdb ("ntuple"); |
803 |
+ |
my $results = $db->query ($query); |
804 |
+ |
return 1 if $results->numrows (); |
805 |
+ |
|
806 |
+ |
return 0; |
807 |
+ |
} |
808 |
+ |
|
809 |
+ |
sub |
810 |
+ |
getLocation |
811 |
+ |
{ |
812 |
+ |
my $id = shift; |
813 |
+ |
|
814 |
+ |
my $query = "select location from ntuple where id=$id"; |
815 |
+ |
$db->selectdb ("ntuple"); |
816 |
+ |
my $results = $db->query ($query); |
817 |
+ |
my @row = $results->fetchrow (); |
818 |
+ |
|
819 |
+ |
return $row[0]; |
820 |
+ |
} |