- All working locally with repeats.

Author: general-kroll-4-life

internal/stackql/drm/drm_cfg.go

@@ -558,7 +558,7 @@ func (dc *staticDRMConfig) GenerateInsertDML(
 	}
 	priorParameters := tabAnnotated.GetParameters()
 	// TODO: fix this for dependent table where dependency has `IN` clause!!!
-	transformedParams, paramErr := util.TransformSQLRawParameters(priorParameters, true)
+	transformedParams, paramErr := util.TransformSQLRawParameters(priorParameters, false)
 	if paramErr != nil {
 		return nil, paramErr
 	}

internal/stackql/router/parameter_router.go

@@ -250,11 +250,12 @@ func (sp *standardParamSplitter) assembleSplitParams(
 	combinations := combinationComposerObj.getCombinations()
 	_, isAnythingSplit := len(combinations), combinationComposerObj.getIsAnythingSplit()
 	for _, paramCombination := range combinations {
+		com := paramCombination
 		splitAnnotationCtx := taxonomy.NewStaticStandardAnnotationCtx(
 			rawAnnotationCtx.GetSchema(),
 			rawAnnotationCtx.GetHIDs(),
 			rawAnnotationCtx.GetTableMeta().Clone(),
-			paramCombination,
+			com,
 		)
 		sp.splitAnnotationContextMap.Put(rawAnnotationCtx, splitAnnotationCtx)
 		// TODO: this has gotta replace the original and also be duplicated
@@ -310,6 +311,8 @@ func (pr *standardParameterRouter) GetOnConditionDataFlows() (dataflow.Collectio
 		}
 		var dependencyTable sqlparser.TableExpr
 		var dependencies []taxonomy.AnnotationCtx
+		var destinations []taxonomy.AnnotationCtx
+
 		var destColumn *sqlparser.ColName
 		var srcExpr sqlparser.Expr
 		switch l := k.Left.(type) {
@@ -329,6 +332,12 @@ func (pr *standardParameterRouter) GetOnConditionDataFlows() (dataflow.Collectio
 				} else {
 					dependencies = append(dependencies, lhr)
 				}
+				splitDestinations, isDestinationSplit := splitAnnotationContextMap.Get(destHierarchy)
+				if isDestinationSplit {
+					destinations = append(destinations, splitDestinations...)
+				} else {
+					destinations = append(destinations, destHierarchy)
+				}
 				dependencyTable = candidateTable
 				srcExpr = k.Left
 			}
@@ -343,6 +352,12 @@ func (pr *standardParameterRouter) GetOnConditionDataFlows() (dataflow.Collectio
 			} else {
 				dependencies = append(dependencies, annCtx)
 			}
+			splitDestinations, isDestinationSplit := splitAnnotationContextMap.Get(destHierarchy)
+			if isDestinationSplit {
+				destinations = append(destinations, splitDestinations...)
+			} else {
+				destinations = append(destinations, destHierarchy)
+			}
 			dependencyTable = te
 		}
 		switch r := k.Right.(type) {
@@ -368,6 +383,12 @@ func (pr *standardParameterRouter) GetOnConditionDataFlows() (dataflow.Collectio
 				} else {
 					dependencies = append(dependencies, rhr)
 				}
+				splitDestinations, isDestinationSplit := splitAnnotationContextMap.Get(destHierarchy)
+				if isDestinationSplit {
+					destinations = append(destinations, splitDestinations...)
+				} else {
+					destinations = append(destinations, destHierarchy)
+				}
 				dependencyTable = candidateTable
 			}
 		case *sqlparser.FuncExpr:
@@ -381,16 +402,25 @@ func (pr *standardParameterRouter) GetOnConditionDataFlows() (dataflow.Collectio
 			} else {
 				dependencies = append(dependencies, annCtx)
 			}
+			splitDestinations, isDestinationSplit := splitAnnotationContextMap.Get(destHierarchy)
+			if isDestinationSplit {
+				destinations = append(destinations, splitDestinations...)
+			} else {
+				destinations = append(destinations, destHierarchy)
+			}
 			dependencyTable = te
 		}
 		if !selfTableCited {
 			return nil, fmt.Errorf("table join ON comparison '%s' referencing incomplete", sqlparser.String(k))
 		}
-		// rv[dependencies] = destHierarchy
 
-		for _, dependency := range dependencies {
+		for i, dependency := range dependencies {
 			srcVertex := rv.UpsertStandardDataFlowVertex(dependency, dependencyTable)
-			destVertex := rv.UpsertStandardDataFlowVertex(destHierarchy, destinationTable)
+			destination := destHierarchy
+			if i < len(destinations) {
+				destination = destinations[i]
+			}
+			destVertex := rv.UpsertStandardDataFlowVertex(destination, destinationTable)
 
 			err := rv.AddOrUpdateEdge(
 				srcVertex,

test/robot/functional/stackql_mocked_from_cmd_line.robot

@@ -7382,6 +7382,6 @@ View Tuple Replacement Working As Exemplified by AWS EC2 Instances List and Deta
     ...    ${inputStr}
     ...    ${outputStr}
     ...    ${EMPTY}
-    ...    stackql_approot=${TEST_TMP_EXEC_APP_ROOT}
     ...    stdout=${CURDIR}/tmp/View-Tuple-Replacement-Working-As-Exemplified-by-AWS-EC2-Instances-List-and-Detail.tmp
     ...    stderr=${CURDIR}/tmp/View-Tuple-Replacement-Working-As-Exemplified-by-AWS-EC2-Instances-List-and-Detail-stderr.tmp
+    ...    repeat_count=20

test/robot/lib/StackQLInterfaces.py

@@ -822,19 +822,21 @@ def should_stackql_exec_inline_equal_both_streams(
     *args,
     **cfg
   ):
-    result = self._run_stackql_exec_command(
-      stackql_exe, 
-      okta_secret_str,
-      github_secret_str,
-      k8s_secret_str,
-      registry_cfg, 
-      auth_cfg_str, 
-      sql_backend_cfg_str,
-      query,
-      *args,
-      **cfg
-    )
-    return self._verify_both_streams(result, expected_output, expected_stderr_output)
+    repeat_count = int(cfg.pop('repeat_count', 1))
+    for _ in range(repeat_count):
+      result = self._run_stackql_exec_command(
+        stackql_exe, 
+        okta_secret_str,
+        github_secret_str,
+        k8s_secret_str,
+        registry_cfg, 
+        auth_cfg_str, 
+        sql_backend_cfg_str,
+        query,
+        *args,
+        **cfg
+      )
+      return self._verify_both_streams(result, expected_output, expected_stderr_output)
 
 
   @keyword