deez 0.3.0

abstraction for DynamoDB
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82

use crate::schemas::{
    foo::{init, Task, TaskItems},
    make_client,
};
use anyhow::Result;
use aws_sdk_dynamodb::types::AttributeValue;
use deez::*;
use std::collections::HashMap;

#[tokio::test]
async fn update() -> Result<()> {
    init().await;

    let c = make_client().await;

    create!(c; Task {
        task_id: Some("aaa".to_string()),
        project: Some("bbb".to_string()),
        employee: Some("ccc".to_string()),
        description: "ddd".to_string(),
        ..Default::default()
    })?;

    let k = Task {
        task_id: Some("aaa".to_string()),
        project: Some("bbb".to_string()),
        employee: Some("ccc".to_string()),
        ..Default::default()
    }
    .primary_keys();

    let u: HashMap<String, AttributeValue> = Task {
        description: "lol".to_string(),
        ..Default::default()
    }
    .into();

    c.update_item()
        .table_name(Task::table_name())
        .set_key(Some(HashMap::from([
            (k.hash.field(), k.hash.av()),
            (k.range.field(), k.range.av()),
        ])))
        .update_expression("SET #u = :u")
        .set_expression_attribute_names(Some(HashMap::from([(
            "#u".to_string(),
            "description".to_string(),
        )])))
        .set_expression_attribute_values(Some(HashMap::from([(
            ":u".to_string(),
            u["description"].clone(),
        )])))
        .send()
        .await?;

    let r = vec_from_query!(
        c
            .query()
            .table_name(Task::table_name())
            .key_condition_expression("#pk = :pk and begins_with(#sk, :sk)")
            .set_expression_attribute_names(Some(HashMap::from([
                ("#pk".to_string(), k.hash.field()),
                ("#sk".to_string(), k.range.field()),
            ])))
            .set_expression_attribute_values(Some(HashMap::from([
                (":pk".to_string(), k.hash.av()),
                (":sk".to_string(), k.range.av()),
            ])))
            .send()
            .await?

        => TaskItems
    );

    // println!("{:#?}", r);

    let f = r.first().unwrap();

    assert_eq!(f.description, "lol".to_string());

    Ok(())
}