- don't show lastHistory

 - implement 2. query according to 1.
 - not tested 3. query using IS-only way (will need index on WorkFlow:successor)

diff --git a/org.glite.jp.index/examples/pch06/query1.pl b/org.glite.jp.index/examples/pch06/query1.pl
index 50b8a5a..7bc938e 100644 (file)
--- a/org.glite.jp.index/examples/pch06/query1.pl
+++ b/org.glite.jp.index/examples/pch06/query1.pl
@@ -8,7 +8,7 @@
 # the averaged atlas was generated, the warping performed etc.
 #
 # call:
-#   ./query2.pl OUTPUT_FILE_NAME 2>/dev/null
+#   ./query1.pl OUTPUT_FILE_NAME 2>/dev/null
 #
 
 use strict;
@@ -99,7 +99,7 @@ foreach my $jobid (sort { $according_jobs{$b} <=> $according_jobs{$a} } keys %ac
        print "jobid $jobid:\n";
 
        # query & output all desired atributes
-       foreach my $attr ("$pch::jplbtag:IPAW_STAGE", "$pch::jplbtag:IPAW_PROGRAM", "$pch::jplbtag:IPAW_PARAM", "$pch::jplbtag:IPAW_INPUT", "$pch::jplbtag:IPAW_OUTPUT", "$pch::lbattr:CE", "$pch::lbattr:lastStatusHistory") {
+       foreach my $attr ("$pch::jplbtag:IPAW_STAGE", "$pch::jplbtag:IPAW_PROGRAM", "$pch::jplbtag:IPAW_PARAM", "$pch::jplbtag:IPAW_INPUT", "$pch::jplbtag:IPAW_OUTPUT", "$pch::lbattr:CE") {
                my @attrs;
                my $attr_name = $attr; $attr_name =~ s/.*://;
 

diff --git a/org.glite.jp.index/examples/pch06/query2.pl b/org.glite.jp.index/examples/pch06/query2.pl
new file mode 100644 (file)
index 0000000..7143434
--- /dev/null
+++ b/org.glite.jp.index/examples/pch06/query2.pl
@@ -0,0 +1,120 @@
+#! /usr/bin/perl
+
+#
+# 2. query:
+#
+# Find the process that led to Atlas X Graphic, excluding everything prior to
+# the averaging of images with softmean.
+#
+# call:
+#   ./query2.pl OUTPUT_FILE_NAME 2>/dev/null
+#
+
+use strict;
+use pch;
+use Data::Dumper;
+
+my $ps='https://skurut1.cesnet.cz:8901';
+my $is='https://skurut1.cesnet.cz:8902';
+my $program_name = "softmean";
+
+my @according_jobs = (); # sequencially jobid list
+my %according_jobs = (); # hash jobid list
+my $according_count = 0;
+my $output;
+
+
+if ($#ARGV + 1 != 1) {
+       print STDERR "Usage: $0 OUTPUT_FILE\n";
+       exit 1
+}
+$output = $ARGV[0];
+
+# debug calls
+$pch::debug = 0;
+my $debug = 0;
+
+#
+# find out processes with given output
+#
+my @jobs = pch::isquery($is, [
+       ["$pch::jplbtag:IPAW_OUTPUT", ['EQUAL', "<string>$output</string>"]],
+], ["$pch::jpsys:jobId", "$pch::jpwf:ancestor"]);
+print Dumper(@jobs) if ($debug);
+die "...so exit on error" if ($pch::err);
+
+#
+# initial set from index server
+#
+foreach my $job (@jobs) {
+       my %job = %$job;
+       my %attributes = %{$job{attributes}};
+
+       if (!exists $according_jobs{$job{jobid}}) {
+               push @according_jobs, $job{jobid};
+               $according_jobs{$job{jobid}} = 1;
+       }
+}
+undef @jobs;
+
+
+#
+# collect all jobids (tree browsing), stop on softmean program
+#
+# note, the browsing tree is really needed here since we explore the workflow
+#
+$according_count = 0;
+foreach my $jobid (@according_jobs) {
+       my (@attrs, @program);
+
+       print "Handling $jobid (position $according_count)\n" if ($debug);
+
+       # stop on given program name
+       @program = pch::psquery($ps, $jobid, "$pch::jplbtag:IPAW_PROGRAM");
+       die "More program names of $jobid?" if ($#program > 0);
+       if ($program[0] eq $program_name) { 
+               print "$jobid is $program_name, stop here\n";
+               next;
+       }
+
+       # else browse up
+       @attrs = pch::psquery($ps, $jobid, "$pch::jpwf:ancestor");
+       for my $anc_jobid (@attrs) {
+               print "Considered: $anc_jobid\n" if ($debug);
+               if (!exists $according_jobs{$anc_jobid}) {
+                       $according_jobs{$anc_jobid} = 1;
+                       push @according_jobs, $anc_jobid;
+                       print "Added $anc_jobid to $#according_jobs\n" if ($debug);
+               }
+               else {
+                       print "Already existing $anc_jobid\n" if ($debug);
+               }
+       }
+       $according_count++;
+}
+
+foreach my $jobid (@according_jobs) {
+       my @attrs2 = pch::psquery($ps, $jobid, "$pch::jplbtag:IPAW_STAGE");
+       $according_jobs{$jobid} = $attrs2[0];
+}
+
+#
+# queries on result set
+#
+print "Results\n";
+print "=======\n";
+print "\n";
+foreach my $jobid (sort { $according_jobs{$b} <=> $according_jobs{$a} } keys %according_jobs) {
+       print "jobid $jobid:\n";
+
+       # query & output all desired atributes
+       foreach my $attr ("$pch::jplbtag:IPAW_STAGE", "$pch::jplbtag:IPAW_PROGRAM", "$pch::jplbtag:IPAW_PARAM", "$pch::jplbtag:IPAW_INPUT", "$pch::jplbtag:IPAW_OUTPUT", "$pch::lbattr:CE") {
+               my @attrs;
+               my $attr_name = $attr; $attr_name =~ s/.*://;
+
+               @attrs = pch::psquery($ps, $jobid, $attr);
+               print "  attr $attr_name: "; print join(", ", @attrs); print "\n";
+       }
+
+       print "\n";
+}

diff --git a/org.glite.jp.index/examples/pch06/query3.pl b/org.glite.jp.index/examples/pch06/query3.pl
new file mode 100644 (file)
index 0000000..a9ac5ca
--- /dev/null
+++ b/org.glite.jp.index/examples/pch06/query3.pl
@@ -0,0 +1,114 @@
+#! /usr/bin/perl
+
+#
+# 3. query:
+# 
+# Find the Stage 3, 4 and 5 details of the process that led to Atlas X Graphic.
+#
+# call:
+#   ./query3.pl OUTPUT_FILE_NAME 2>/dev/null
+#
+
+use strict;
+use pch;
+use Data::Dumper;
+
+my $ps='https://skurut1.cesnet.cz:8901';
+my $is='https://skurut1.cesnet.cz:8902';
+my @view_attributes = ("$pch::jplbtag:IPAW_STAGE", "$pch::jplbtag:IPAW_PROGRAM", "$pch::jplbtag:IPAW_PARAM", "$pch::jplbtag:IPAW_INPUT", "$pch::jplbtag:IPAW_OUTPUT", "$pch::lbattr:CE");
+my @attributes = ("$pch::jpsys:jobId", "$pch::jpwf:ancestor", @view_attributes);
+
+my @according_jobs = (); # sequencially jobid list
+my %according_jobs = (); # hash jobid list
+my $according_count = 0;
+my $output;
+
+
+if ($#ARGV + 1 != 1) {
+       print STDERR "Usage: $0 OUTPUT_FILE\n";
+       exit 1
+}
+$output = $ARGV[0];
+
+# debug calls
+$pch::debug = 0;
+my $debug = 0;
+
+#
+# find out processes with given output
+#
+my @jobs = pch::isquery($is, [
+       ["$pch::jplbtag:IPAW_OUTPUT", ['EQUAL', "<string>$output</string>"]],
+], \@attributes);
+print Dumper(@jobs) if ($debug);
+die "...so exit on error" if ($pch::err);
+
+#
+# initial set from index server
+#
+foreach my $job (@jobs) {
+       my %job = %$job;
+       my %attributes = %{$job{attributes}};
+
+       if (!exists $according_jobs{$job{jobid}}) {
+               push @according_jobs, $job{jobid};
+               $according_jobs{$job{jobid}} = \%job;
+       }
+}
+undef @jobs;
+
+
+#
+# collect all jobs (tree browsing)
+#
+$according_count = 0;
+foreach my $jobid (@according_jobs) {
+       my @ancs;
+
+       print "Handling $jobid (position $according_count)\n" if ($debug);
+       @ancs = pch::isquery($is, [["$pch::jpwf:successor", ['EQUAL', "<string>$jobid</string>"]]], \@attributes);
+       die "...so exit on error" if ($pch::err);
+
+       for my $anc (@ancs) {
+               my %anc = %$anc;
+               print "Considered: $anc{jobid}\n" if ($debug);
+               if (!exists $according_jobs{$anc{jobid}}) {
+                       $according_jobs{$anc{jobid}} = \%anc;
+                       push @according_jobs, $anc{jobid};
+                       print "Added $anc{jobid} to $#according_jobs\n" if ($debug);
+               }
+               else {
+                       print "Already existing $anc{jobid}\n" if ($debug);
+               }
+       }
+       $according_count++;
+}
+
+
+#
+# queries on result set
+#
+print "Results\n";
+print "=======\n";
+print "\n";
+foreach my $jobid (sort { $according_jobs{$b}{attributes}{"$pch::jplbtag:IPAW_STAGE"}[0] <=> $according_jobs{$a}{attributes}{"$pch::jplbtag:IPAW_STAGE"}[0] } keys %according_jobs) {
+       my %job = %{$according_jobs{jobid}};
+       my %attributes = %{$job{attributes}};
+       my $stage = $attributes{"$pch::jplbtag:IPAW_STAGE"}{value}[0];
+
+       if ( $stage == 3 || $stage == 4 || $stage == 5) {
+               print "jobid $jobid:\n";
+
+               # query & output all desired atributes
+               foreach my $attr (@view_attributes) {
+                       my %attr = %{$attributes{$attr}};
+                       my $attr_name = $attr; $attr_name =~ s/.*://;
+
+                       print "  attr $attr_name: "; print join(", ", @{$attr{value}}); print "\n";
+               }
+
+               print "\n";
+       } else {
+               print "(ignored $jobid with stage $stage)\n" if $debug;
+       }
+}