Can no longer easily join duplicate schemas as of version 43 #14112

use arrow::array::{ArrayRef, Int32Array, RecordBatch};

use datafusion::prelude::*;
use std::sync::Arc;

#[tokio::main]
async fn main() {
    let ctx = SessionContext::new();

    let id: ArrayRef = Arc::new(Int32Array::from(vec![0, 1, 2]));
    let value: ArrayRef = Arc::new(Int32Array::from(vec![0, 1, 2]));
    let batch = RecordBatch::try_from_iter(vec![("id", id), ("value", value)]).unwrap();

    ctx.register_batch("tes", batch).unwrap();

    let id: ArrayRef = Arc::new(Int32Array::from(vec![1, 2, 3]));
    let value: ArrayRef = Arc::new(Int32Array::from(vec![1, 2, 3]));
    let batch = RecordBatch::try_from_iter(vec![("id", id), ("value", value)]).unwrap();

    ctx.register_batch("tes2", batch).unwrap();

    let tes = ctx.table("tes").await.unwrap();
    let tes2 = ctx.table("tes2").await.unwrap();

    // This succeeds (the two tables have different names and so the qualified names of the columns differ)
    let joined = tes
        .clone()
        .join(tes2, JoinType::Full, &["id"], &["id"], None)
        .unwrap();

    joined.show().await.unwrap();

    // This fails with the error:
    //
    // SchemaError(DuplicateQualifiedField { qualifier: Bare { table: "tes" }, name: "id" }, Some(""))
    let tes_clone = tes.clone();
    let joined = tes
        .join(tes_clone, JoinType::Full, &["id"], &["id"], None)
        .unwrap();

    joined.show().await.unwrap();
}

CREATE TABLE tes (id int, val int);
INSERT INTO tes (id, val) VALUES (0, 0), (1, 1), (2, 2);
CREATE TABLE tes2 (id int, val int);
INSERT INTO tes2 (id, val) VALUES (1, 1), (2, 2), (3, 3);
SELECT * FROM tes FULL OUTER JOIN tes2 ON tes.id = tes2.id;
SELECT * FROM tes as t1 FULL OUTER JOIN tes as t2 ON t1.id = t2.id;