Function intersect

datafusion/optimizer/tests/optimizer_integration.rs:270–291

()

#[test]
fn intersect() -> Result<()> {
    let sql = "SELECT col_int32, col_utf8 FROM test \
    INTERSECT SELECT col_int32, col_utf8 FROM test \
    INTERSECT SELECT col_int32, col_utf8 FROM test";
    let plan = test_sql(sql)?;

    assert_snapshot!(
    format!("{plan}"),
    @r"
    LeftSemi Join: left.col_int32 = test.col_int32, left.col_utf8 = test.col_utf8
      Aggregate: groupBy=[[left.col_int32, left.col_utf8]], aggr=[[]]
        LeftSemi Join: left.col_int32 = right.col_int32, left.col_utf8 = right.col_utf8
          Aggregate: groupBy=[[left.col_int32, left.col_utf8]], aggr=[[]]
            SubqueryAlias: left
              TableScan: test projection=[col_int32, col_utf8]
          SubqueryAlias: right
            TableScan: test projection=[col_int32, col_utf8]
      TableScan: test projection=[col_int32, col_utf8]
    "
    );
    Ok(())
}

#[test]
fn between_date32_plus_interval() -> Result<()> {