fixup! fixup! Remove redundant tests for sql integrations

Author: mkleen

datafusion/sql/tests/sql_integration.rs

@@ -4860,6 +4860,38 @@ fn test_using_join_wildcard_schema() {
     );
 }
 
+#[test]
+fn test_2_nested_lateral_join_with_the_deepest_join_referencing_the_outer_most_relation()
+{
+    let sql = "SELECT * FROM j1 j1_outer, LATERAL (
+    SELECT * FROM j1 j1_inner, LATERAL (
+        SELECT * FROM j2 WHERE j1_inner.j1_id = j2_id and j1_outer.j1_id=j2_id
+    ) as j2
+) as j2";
+
+    let plan = logical_plan(sql).unwrap();
+    assert_snapshot!(
+         plan,
+         @r#"
+Projection: j1_outer.j1_id, j1_outer.j1_string, j2.j1_id, j2.j1_string, j2.j2_id, j2.j2_string
+  Cross Join:
+    SubqueryAlias: j1_outer
+      TableScan: j1
+    SubqueryAlias: j2
+      Subquery:
+        Projection: j1_inner.j1_id, j1_inner.j1_string, j2.j2_id, j2.j2_string
+          Cross Join:
+            SubqueryAlias: j1_inner
+              TableScan: j1
+            SubqueryAlias: j2
+              Subquery:
+                Projection: j2.j2_id, j2.j2_string
+                  Filter: outer_ref(j1_inner.j1_id) = j2.j2_id AND outer_ref(j1_outer.j1_id) = j2.j2_id
+                    TableScan: j2
+"#
+    );
+}
+
 #[test]
 fn test_correlated_recursive_scalar_subquery_with_level_3_scalar_subquery_referencing_level1_relation()
  {

datafusion/sqllogictest/test_files/joins.slt

@@ -57,15 +57,15 @@ statement ok
 CREATE TABLE join_t3(s3 struct<id INT>)
   AS VALUES
   (NULL),
-    ({id: 1}),
-    ({id: 2});
+  (struct(1)),
+  (struct(2));
 
 statement ok
 CREATE TABLE join_t4(s4 struct<id INT>)
   AS VALUES
   (NULL),
-    ({id: 2}),
-    ({id: 3});
+  (struct(2)),
+  (struct(3));
 
 # Left semi anti join
 
@@ -4646,29 +4646,6 @@ logical_plan
 08)----------TableScan: j3 projection=[j3_string, j3_id]
 physical_plan_error This feature is not implemented: Physical plan does not support logical expression OuterReferenceColumn(Field { name: "j1_id", data_type: Int32, nullable: true }, Column { relation: Some(Bare { table: "j1" }), name: "j1_id" })
 
-# 2 nested lateral join with the deepest join referencing the outer most relation
-query TT
-explain SELECT * FROM j1 j1_outer, LATERAL (
-    SELECT * FROM j1 j1_inner, LATERAL (
-        SELECT * FROM j2 WHERE j1_inner.j1_id = j2_id and j1_outer.j1_id=j2_id
-    ) as j2
-) as j2;
-----
-logical_plan
-01)Cross Join: 
-02)--SubqueryAlias: j1_outer
-03)----TableScan: j1 projection=[j1_string, j1_id]
-04)--SubqueryAlias: j2
-05)----Subquery:
-06)------Cross Join: 
-07)--------SubqueryAlias: j1_inner
-08)----------TableScan: j1 projection=[j1_string, j1_id]
-09)--------SubqueryAlias: j2
-10)----------Subquery:
-11)------------Filter: outer_ref(j1_inner.j1_id) = j2.j2_id AND outer_ref(j1_outer.j1_id) = j2.j2_id
-12)--------------TableScan: j2 projection=[j2_string, j2_id]
-physical_plan_error This feature is not implemented: Physical plan does not support logical expression OuterReferenceColumn(Field { name: "j1_id", data_type: Int32, nullable: true }, Column { relation: Some(Bare { table: "j1_inner" }), name: "j1_id" })
-
 query TT
 explain SELECT * FROM j1, LATERAL (SELECT 1) AS j2;
 ----
@@ -5072,10 +5049,9 @@ WHERE k1 < 0
 ----
 physical_plan
 01)HashJoinExec: mode=CollectLeft, join_type=RightAnti, on=[(k2@0, k1@0)]
-02)--FilterExec: k2@0 < 0
-03)----DataSourceExec: partitions=1, partition_sizes=[0]
-04)--FilterExec: k1@0 < 0
-05)----DataSourceExec: partitions=1, partition_sizes=[10000]
+02)--DataSourceExec: partitions=1, partition_sizes=[0]
+03)--FilterExec: k1@0 < 0
+04)----DataSourceExec: partitions=1, partition_sizes=[10000]
 
 query II
 SELECT *