datasources 0.1.40

Async datasource interfaces, middleware, registry, and test doubles
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

use datasources::*;
use datasources_memory::MemoryDriver;
use std::collections::HashMap;

fn record(pairs: &[(&str, Value)]) -> Row {
    pairs
        .iter()
        .map(|(key, value)| ((*key).to_string(), value.clone()))
        .collect()
}

#[tokio::test]
async fn update_keeps_explicit_empty_string_on_nullable() {
    let connection = MemoryDriver.connection(None);
    let mut options = CRUDRepositoryOptions::default();
    options.schema = Schema::new(HashMap::from([
        ("id".into(), SchemaColumn::new("integer")),
        (
            "note".into(),
            SchemaColumn {
                type_name: "string".into(),
                nullable: true,
                has_default: false,
                is_id: false,
            },
        ),
    ]));
    options.update_properties = Some(vec!["note".into()]);
    let repo = CRUDRepository::<Row>::new(connection, options).unwrap();
    repo.create(record(&[("id", Value::Int(1)), ("note", Value::from("side"))]))
        .await
        .expect("create");
    repo.update(record(&[("id", Value::Int(1)), ("note", Value::from(""))]))
        .await
        .expect("update");
    assert_eq!(
        repo.read_single(&()).await.unwrap().unwrap()["note"],
        Value::from("")
    );
}