Function test_view_join_view

crates/core/src/sql/execute.rs:1033–1090

()

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

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

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

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

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

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

        Ok(())
    }