Function test_explain_timestamp_table

src/environmentd/tests/sql.rs:1265–1299

()

#[mz_ore::test]
#[allow(clippy::disallowed_methods)]
fn test_explain_timestamp_table() {
    let server = test_util::TestHarness::default().start_blocking();
    let mut client = server.connect(postgres::NoTls).unwrap();
    let timestamp_re = Regex::new(r"\s*(\d+) \(\d+-\d\d-\d\d \d\d:\d\d:\d\d.\d\d\d\)").unwrap();

    client.batch_execute("CREATE TABLE t1 (i1 int)").unwrap();

    let expect = "                query timestamp:<TIMESTAMP>
          oracle read timestamp:<TIMESTAMP>
largest not in advance of upper:<TIMESTAMP>
                          upper:[<TIMESTAMP>]
                          since:[<TIMESTAMP>]
        can respond immediately: true
                       timeline: Some(EpochMilliseconds)
              session wall time:<TIMESTAMP>

source materialize.public.t1 (u1, storage):
                  read frontier:[<TIMESTAMP>]
                 write frontier:[<TIMESTAMP>]

binding constraints:
lower:
  (Isolation level: StrictSerializable): [<TIMESTAMP>]\n";

    let row = client
        .query_one("EXPLAIN TIMESTAMP FOR SELECT * FROM t1;", &[])
        .unwrap();
    let explain: String = row.get(0);
    let explain = timestamp_re.replace_all(&explain, "<TIMESTAMP>");
    // The storage inputs constraint appears non-deterministically depending on
    // whether the storage frontier has advanced before the query runs.
    let storage_inputs_re = Regex::new(r"  \(Storage inputs: \[.*\]\): \[<TIMESTAMP>\]\n").unwrap();
    let explain = storage_inputs_re.replace_all(&explain, "");
    assert_eq!(explain, expect, "{explain}\n\n{expect}");
}

// Test `EXPLAIN TIMESTAMP AS JSON`
#[mz_ore::test]