Function refresh_applies_join

nodedb/tests/sql_materialized_view_refresh.rs:153–197

()

/// joined rows, not copies of one source's raw docs.
#[tokio::test(flavor = "multi_thread", worker_threads = 4)]
async fn refresh_applies_join() {
    let server = TestServer::start().await;

    server.exec("CREATE COLLECTION mv_join_left").await.unwrap();
    server
        .exec("CREATE COLLECTION mv_join_right")
        .await
        .unwrap();
    server
        .exec("INSERT INTO mv_join_left { id: 'l1', rid: 'r1', name: 'alice' }")
        .await
        .unwrap();
    server
        .exec("INSERT INTO mv_join_left { id: 'l2', rid: 'r2', name: 'bob' }")
        .await
        .unwrap();
    server
        .exec("INSERT INTO mv_join_right { id: 'r1', tag: 'vip' }")
        .await
        .unwrap();
    // Deliberately no match for l2 — an INNER JOIN must drop it.

    server
        .exec(
            "CREATE MATERIALIZED VIEW mv_join ON mv_join_left AS \
             SELECT l.id AS id, r.tag AS tag \
             FROM mv_join_left l JOIN mv_join_right r ON l.rid = r.id",
        )
        .await
        .unwrap();
    server
        .exec("REFRESH MATERIALIZED VIEW mv_join")
        .await
        .unwrap();

    let rows = server
        .query_named_rows("SELECT * FROM mv_join")
        .await
        .unwrap();
    assert_eq!(
        rows.len(),
        1,
        "INNER JOIN view must materialize only the matched pair, got {rows:?}"
    );
}

/// When the view's WHERE predicate narrows the source, a subsequent refresh
/// must remove view rows that no longer match.