Function test_view_join_table

crates/core/src/sql/execute.rs:973–1030

()

    #[tokio::test]
    async fn test_view_join_table() -> anyhow::Result<()> {
        let db = TestDB::in_memory()?;

        let schema = [("a", AlgebraicType::U8), ("b", AlgebraicType::U8)];
        let (_, v_id) = tests_utils::create_view_for_test(&db, "v", &schema, false)?;

        let schema = [("c", AlgebraicType::U8), ("d", AlgebraicType::U8)];
        let t_id = db.create_table_for_test("t", &schema, &[0.into()])?;

        with_auto_commit(&db, |tx| -> Result<_, DBError> {
            db.insert(tx, t_id, &product![0u8, 3u8].to_bsatn_vec().unwrap())?;
            db.insert(tx, t_id, &product![1u8, 4u8].to_bsatn_vec().unwrap())?;
            tests_utils::insert_into_view(&db, tx, v_id, Some(identity_from_u8(1)), product![0u8, 1u8])?;
            tests_utils::insert_into_view(&db, tx, v_id, Some(identity_from_u8(2)), product![1u8, 2u8])?;
            Ok(())
        })?;

        let id = identity_from_u8(2);
        let auth = AuthCtx::new(Identity::ZERO, id);

        assert_query_results(
            db.clone(),
            "select t.* from v join t on v.a = t.c",
            auth.clone(),
            [product![1u8, 4u8]],
        )
        .await;
        assert_query_results(
            db.clone(),
            "select v.* from v join t on v.a = t.c",
            auth.clone(),
            [product![1u8, 2u8]],
        )
        .await;
        assert_query_results(
            db.clone(),
            "select v.* from v join t where v.a = t.c",
            auth.clone(),
            [product![1u8, 2u8]],
        )
        .await;
        assert_query_results(
            db.clone(),
            "select v.b as b, t.d as d from v join t on v.a = t.c",
            auth.clone(),
            [product![2u8, 4u8]],
        )
        .await;
        assert_query_results(
            db.clone(),
            "select v.b as b, t.d as d from v join t where v.a = t.c",
            auth.clone(),
            [product![2u8, 4u8]],
        )
        .await;

        Ok(())
    }