semilattice-database

Example

use semilattice_database::prelude::*;

let dir="./sl-test/";

if std::path::Path::new(dir).exists(){
    std::fs::remove_dir_all(dir).unwrap();
    std::fs::create_dir_all(dir).unwrap();
}else{
    std::fs::create_dir_all(dir).unwrap();
}
let mut database=Database::new(dir).unwrap();

let collection_person=database.collection_id_or_create("person").unwrap();
let collection_history=database.collection_id_or_create("history").unwrap();

if let Ok(mut sess)=database.session("test"){
    sess.update(vec![
        Record::New{
            collection_id:collection_person
            ,activity:Activity::Active
            ,term_begin:Term::Defalut
            ,term_end:Term::Defalut
            ,fields:vec![
                KeyValue::new("name","Joe")
                ,KeyValue::new("birthday","1972-08-02")
            ]
            ,depends:Depends::Overwrite(vec![])
            ,pends:vec![Pend::new("history",vec![
                Record::New{
                    collection_id:collection_history
                    ,activity:Activity::Active
                    ,term_begin:Term::Defalut
                    ,term_end:Term::Defalut
                    ,fields:vec![
                        KeyValue::new("date","1972-08-02")
                        ,KeyValue::new("event","Birth")
                    ]
                    ,depends:Depends::Default
                    ,pends:vec![]
                }
                ,Record::New{
                    collection_id:collection_history
                    ,activity:Activity::Active
                    ,term_begin:Term::Defalut
                    ,term_end:Term::Defalut
                    ,fields:vec![
                        KeyValue::new("date","1999-12-31")
                        ,KeyValue::new("event","Mariage")
                    ]
                    ,depends:Depends::Default
                    ,pends:vec![]
                }
            ])]
        }
        ,Record::New{
            collection_id:collection_person
            ,activity:Activity::Active
            ,term_begin:Term::Defalut
            ,term_end:Term::Defalut
            ,fields:vec![
                KeyValue::new("name","Tom")
                ,KeyValue::new("birthday","2000-12-12")
            ]
            ,depends:Depends::Default
            ,pends:vec![Pend::new("history",vec![
                Record::New{
                    collection_id:collection_history
                    ,activity:Activity::Active
                    ,term_begin:Term::Defalut
                    ,term_end:Term::Defalut
                    ,fields:vec![
                        KeyValue::new("date","2000-12-12")
                        ,KeyValue::new("event","Birth")
                    ]
                    ,depends:Depends::Default
                    ,pends:vec![]
                }
            ])]
        }
        ,Record::New{
            collection_id:collection_person
            ,activity:Activity::Active
            ,term_begin:Term::Defalut
            ,term_end:Term::Defalut
            ,fields:vec![
                KeyValue::new("name","Billy")
                ,KeyValue::new("birthday","1982-03-03")
            ]
            ,depends:Depends::Default
            ,pends:vec![]
        }
    ]);
    sess.commit();
}

if let (
    Some(person)
    ,Some(history)
)=(
    database.collection(collection_person)
    ,database.collection(collection_history)
){
    for i in database.begin_search(person).result(){
        println!(
            "{},{}"
            ,person.field_str(i,"name")
            ,person.field_str(i,"birthday")
        );
        for h in database.begin_search(history).depend(vec![
            Depend::new("history",CollectionRow::new(collection_person,i))
        ]).result(){
            println!(
                " {} : {}"
                ,history.field_str(h,"date")
                ,history.field_str(h,"event")
            );
        }
    }
}
if let Ok(mut sess)=database.session("test"){
    sess.update(vec![
        Record::Update{
            collection_id:collection_person
            ,row:1
            ,activity:Activity::Active
            ,term_begin:Term::Defalut
            ,term_end:Term::Defalut
            ,fields:vec![KeyValue::new("name","Renamed Joe")]
            ,depends:Depends::Default
            ,pends:vec![]
        }
    ]);
}
if let Ok(mut sess)=database.session("test"){
    let search=sess.begin_search(collection_person).search_activity(Activity::Active);
    for r in search.result(){
        println!(
            "{},{}"
            ,sess.field_str(collection_person,r,"name")
            ,sess.field_str(collection_person,r,"birthday")
        );
    }
    sess.commit();
}

let test1=database.collection_id_or_create("test1").unwrap();
let range=1..=10;
if let Ok(mut sess)=database.session("test"){
    for i in range.clone(){
        sess.update(vec![
            Record::New{
                collection_id:test1
                ,activity:Activity::Active
                ,term_begin:Term::Defalut
                ,term_end:Term::Defalut
                ,fields:vec![
                    KeyValue::new("num",i.to_string())
                    ,KeyValue::new("num_by3",(i*3).to_string())
                ]
                ,depends:Depends::Overwrite(vec![])
                ,pends:vec![]
            }
        ]);
    }
    sess.commit();
}

if let Ok(mut sess)=database.session("test"){
    sess.update(vec![
        Record::Update{
            collection_id:test1
            ,row:3
            ,activity:Activity::Inactive
            ,term_begin:Term::Defalut
            ,term_end:Term::Defalut
            ,fields:vec![]
            ,depends:Depends::Overwrite(vec![])
            ,pends:vec![]
        }
    ]);
    sess.commit();
}

if let Some(t1)=database.collection(test1){
    let mut sum=0.0;
    for i in range.clone(){
        sum+=t1.field_num(i,"num");
        println!(
            "{},{},{},{},{},{},{},{}"
            ,t1.serial(i)
            ,if t1.activity(i)==Activity::Active{
                "Active"
            }else{
                "Inactive"
            }
            ,t1.uuid_str(i)
            ,t1.last_updated(i)
            ,t1.term_begin(i)
            ,t1.term_end(i)
            ,t1.field_str(i,"num")
            ,t1.field_str(i,"num_by3")
        );
    }
    assert_eq!(sum,55.0);
}