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

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

#[tokio::test]
async fn delete() -> Result<()> {
    init().await;
    let c = make_client().await;

    batch_write!(
        c;
        writes:
            Task {
                task_id: Some("aaa".to_string()),
                project: Some("bbb".to_string()),
                employee: Some("ccc".to_string()),
                ..Default::default()
            },
            Task {
                task_id: Some("aaa".to_string()),
                project: Some("hhh".to_string()),
                employee: Some("iii".to_string()),
                ..Default::default()
            };
        deletes:
    )?;

    ////////////////////////////////////////////////////////////////////////////

    remove!(c; Task {
        task_id: Some("aaa".to_string()),
        project: Some("hhh".to_string()),
        employee: Some("iii".to_string()),
        ..Default::default()
    })?;

    ////////////////////////////////////////////////////////////////////////////

    let keys = Task {
        task_id: Some("aaa".to_string()),
        ..Default::default()
    }
    .primary_keys();

    let q = vec_from_query!(
        c
            .query()
            .table_name(Task::table_name())
            .key_condition_expression("#pk = :pk")
            .set_expression_attribute_names(Some(HashMap::from([(
                "#pk".to_string(),
                keys.hash.field(),
            )])))
            .set_expression_attribute_values(Some(HashMap::from([(
                ":pk".to_string(),
                keys.hash.av(),
            )])))
            .send()
            .await?

        => TaskItems
    );

    // println!("{:#?}", q);
    assert_eq!(q.len(), 1);

    Ok(())
}