Changeset 9605 for trunk/MagicSoft/Mars/datacenter/scripts/sourcefile

Timestamp:

07/02/10 12:54:37 (14 years ago)

Author:

Daniela Dorner

Message:

*** empty log message ***

File:

• trunk/MagicSoft/Mars/datacenter/scripts/sourcefile (modified) (6 diffs)

trunk/MagicSoft/Mars/datacenter/scripts/sourcefile

@@ -254 +254 @@
 
 # function to get the join of a step 
-#  (normal join but using different primaries)
 #  from the dependencies-file steps.rc
+# $1 gives the step
+# $2 gives the type of join
 function getjoin()
 {
    getdbsetup
-   grep $@"[.]Join:" $steps | grep -v '#' | sed -e "s/$@[.]Join://"
-}
-
-# function to get the special join of a step 
-#  (i.e. join with a different table) 
-#  from the dependencies-file steps.rc
-function getspecialjoin()
-{
-   getdbsetup
-   grep $@"[.]SpecialJoin:" $steps | grep -v '#' | sed -e "s/$@[.]SpecialJoin://"
+   grep $1"[.]"$2"Join:" $steps | grep -v '#' | sed -e "s/$1[.]$2Join://"
 }
 
@@ -276 +268 @@
    getdbsetup
    grep $@"[.]Needs:" $steps | sed -e "s/$@[.]Needs://"
+}
+
+# subquery which is needed to check the 
+#   status of the steps with different primaries
+function subquerypart()
+{
+   query=$query" SELECT COUNT(*) FROM "$need"Status "
+   query=$query" "`getjoin $need "SpecialInfluence"`" "
+   query=$query" WHERE "$step"Status."`echo ${prims[0]} | sed -e 's/,//g'`"="$step"Status."`echo ${prims[0]} | sed -e 's/,//g'`
+   for (( j=1 ; j < ${#prims[@]} ; j++ ))
+   do
+      query=$query" AND "$step"Status."`echo ${prims[$j]} | sed -e 's/,//g'`"="$step"Status."`echo ${prims[$j]} | sed -e 's/,//g'`
+   done
 }
 
@@ -289 +294 @@
       needprims=( `getprimary $need` )
       # make sure that the correct joins are used
-      # in case the primaries of the step and the need are 
-      #   the same, the tables are join with these primaries
-      # otherwise it is checked whether there has to be a 
-      #   join with different primaries (indicated as 'Join'
-      #   in the steps.rc
-      # 'SpecialJoins' do not have to be taken into account here
-      if [ "`echo ${needprims[@]}`" == "`echo ${prims[@]}`" ]
-      then 
-         query=$query" LEFT JOIN "$need"Status USING (${prims[@]}) "
-      else 
-         stdjoin=`getjoin $need`
-         if ! [ "$stdjoin" = "" ]
-         then
-            query=$query" "$stdjoin" "
-         fi
+      specialneedjoin=`getjoin $need "SpecialNeed"`
+      if [ "$specialneedjoin" = "" ]
+      then
+         query=$query" LEFT JOIN "$need"Status USING (${needprims[@]}) "
+      else
+         query=$query" "$specialneedjoin" "
+         query=$query" LEFT JOIN "$need"Status USING (${needprims[@]}) "
+         break
       fi
    done
@@ -310 +308 @@
    # add condition for the status of the peceding steps
    counter=0
+   specialneedjoin=
    for need in $needs
    do
@@ -316 +315 @@
          query=$query" AND "
       fi
-      needprims=( `getprimary $need` )
-      # in case the primaries of the tables agree
-      #   or there is just a normal 'Join' needed
-      #   only the condition is added to the query
-      # for tables which need a join with a different
-      #   table, a special query is added using the
-      #   'SpecialJoin' from the steps.rc
-      if [ "`echo ${needprims[@]}`" == "`echo ${prims[@]}`" ] || ! [ "$stdjoin" = "" ]
+      specialneedjoin=$specialneedjoin" "`getjoin $need "SpecialNeed"`
+      if [ "$specialneedjoin" = " " ]
       then 
+         # condition for step with same primaries
          query=$query" NOT ISNULL("$need"Status.fStartTime) AND "
          query=$query" NOT ISNULL("$need"Status.fStopTime) AND "
          query=$query" ISNULL("$need"Status.fReturnCode) "
+         specialneedjoin=
       else 
-         query=$query" (SELECT COUNT(*) FROM "$need"Status "
-         query=$query" "`getspecialjoin $need`" "
-         query=$query" WHERE "$step"Status."`echo ${prims[0]} | sed -e 's/,//g'`"="$step"Status."`echo ${prims[0]} | sed -e 's/,//g'`
-         for (( j=1 ; j < ${#prims[@]} ; j++ ))
-         do
-            query=$query" AND "$step"Status."`echo ${prims[$j]} | sed -e 's/,//g'`"="$step"Status."`echo ${prims[$j]} | sed -e 's/,//g'`
-         done
-         query=$query") = (SELECT COUNT(*) FROM "$need"Status "
-         query=$query" "`getspecialjoin $need`" "
-         query=$query" WHERE "$step"Status."`echo ${prims[0]} | sed -e 's/,//g'`"="$step"Status."`echo ${prims[0]} | sed -e 's/,//g'`
-         for (( j=1 ; j < ${#prims[@]} ; j++ ))
-         do
-            query=$query" AND "$step"Status."`echo ${prims[$j]} | sed -e 's/,//g'`"="$step"Status."`echo ${prims[$j]} | sed -e 's/,//g'`
-         done
+         # special query to check steps which 
+         #   do not have the same primaries
+         # comparison of 
+         #     number of rows
+         #   with
+         #     number of rows which are done
+         query=$query" ( "
+         subquerypart
+         query=$query" ) = ( "
+         subquerypart
          query=$query" AND NOT ISNULL(fStartTime) "
          query=$query" AND NOT ISNULL(fStopTime) "
@@ -500 +491 @@
    query=" UPDATE "$step"Status "
    # add joins to the influenced tables
-   stepspecialjoin=""
+   specialinfljoin=`getjoin $step "SpecialInfluence"`
+   if ! [ "$specialinfljoin" = "" ]
+   then
+      query=$query" "$specialinfljoin
+   fi
    for influence in $influences
    do
-      inflprims=( `getprimary $influence` )
-      # make sure that the correct joins are used
-      # in case the primaries of the step and the influence are 
-      #   the same, the tables are join with these primaries
-      # otherwise they are joined with the primaries of the influence
-      if [ "`echo ${inflprims[@]}`" == "`echo ${prims[@]}`" ]
-      then 
-         query=$query" LEFT JOIN "$influence"Status USING (${prims[@]}) "
+      infljoin=`getjoin $influence "Influence"`
+      if [ "$infljoin" = "" ]
+      then
+         inflprims=( `getprimary $influence` )
+         query=$query" LEFT JOIN "$influence"Status USING (${inflprims[@]}) "
       else 
-         prims2=`getprimary $step | sed -e "s/\ //g"`
-         primstest=`echo ${inflprims[@]} | sed -e "s/\ //g" | sed -e "s/$prims2//g"`
-         if [ "$primstest" == "`echo ${inflprims[@]} | sed -e "s/\ //g"`" ]
-         then
-            if [ "$stepspecialjoin" == "" ]
-            then
-               stepspecialjoin=`getspecialjoin $step`
-               query=$query" "$stepspecialjoin" "
-            fi
-            query=$query" LEFT JOIN "$influence"Status USING (${inflprims[@]}) "
-         else
-            infljoin=`getjoin $influence`
-            if [ "$infljoin" = "" ]
-            then
-               query=$query" LEFT JOIN "$influence"Status USING (${prims[@]}) "
-            else
-               query=$query" "$infljoin
-               # warning: this is a workaround
-               #  it has to be checked whether it works for all steps
-               stepspecialjoin="not empty"
-            fi
-         fi
+         query=$query" "$infljoin
       fi
    done