Function query_gsi_basic

tests/rust/src/gsi.rs:9–39

()

#[tokio::test]
async fn query_gsi_basic() {
    let c = client();
    let t = tables().await;
    let table = &t.simple_key_string_gsi;
    let gsi_hash = format!("gsi_qb_{}", ts());

    let mut item = create_item(table);
    item.insert(GSI_HASH_KEY.into(), s(&gsi_hash));
    item.insert(GSI_RANGE_KEY.into(), s("r1"));
    c.put_item()
        .table_name(table)
        .set_item(Some(item.clone()))
        .send()
        .await
        .unwrap();

    tokio::time::sleep(std::time::Duration::from_secs(2)).await;

    let resp = c
        .query()
        .table_name(table)
        .index_name(GSI_NAME)
        .key_condition_expression("#h = :hv")
        .expression_attribute_names("#h", GSI_HASH_KEY)
        .expression_attribute_values(":hv", s(&gsi_hash))
        .send()
        .await
        .unwrap();

    assert_eq!(resp.count(), 1);
}

#[tokio::test]
async fn query_gsi_multiple_items() {