charybdis 1.1.0

High-Performance ORM for ScyllaDB
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
83
84
85
86
87
88
89
90
91
92
93
94
95

use crate::model::BaseModel;
use crate::query::{CharybdisQuery, ModelPaged, ModelRow, ModelStream, OptionalModelRow, QueryValue};
use scylla::response::PagingState;
use scylla::serialize::row::SerializeRow;

/// Configurable Find Queries
pub trait Find: BaseModel
where
    Self: 'static,
{
    fn find<'a, Val: SerializeRow>(query: &'static str, values: Val) -> CharybdisQuery<'a, Val, Self, ModelStream> {
        CharybdisQuery::new(query, QueryValue::Owned(values))
    }

    fn find_paged<Val: SerializeRow>(
        query: &'static str,
        values: Val,
        paging_state: PagingState,
    ) -> CharybdisQuery<'static, Val, Self, ModelPaged> {
        CharybdisQuery::new(query, QueryValue::Owned(values)).paging_state(paging_state)
    }

    fn find_paged_model<Val: SerializeRow>(
        query: &'static str,
        values: Val,
    ) -> CharybdisQuery<'static, Val, Self, ModelPaged> {
        CharybdisQuery::new(query, QueryValue::Owned(values))
    }

    fn find_first<'a, Val: SerializeRow>(query: &'static str, values: Val) -> CharybdisQuery<'a, Val, Self, ModelRow> {
        CharybdisQuery::new(query, QueryValue::Owned(values))
    }

    fn maybe_find_first<'a, Val: SerializeRow>(
        query: &'static str,
        values: Val,
    ) -> CharybdisQuery<'a, Val, Self, OptionalModelRow> {
        CharybdisQuery::new(query, QueryValue::Owned(values))
    }

    fn find_all<'a>() -> CharybdisQuery<'a, (), Self, ModelStream> {
        CharybdisQuery::new(Self::FIND_ALL_QUERY, QueryValue::Empty)
    }

    fn find_by_primary_key_value<'a>(value: Self::PrimaryKey) -> CharybdisQuery<'a, Self::PrimaryKey, Self, ModelRow> {
        CharybdisQuery::new(Self::FIND_BY_PRIMARY_KEY_QUERY, QueryValue::Owned(value))
    }

    fn maybe_find_by_primary_key_value<'a>(
        value: Self::PrimaryKey,
    ) -> CharybdisQuery<'a, Self::PrimaryKey, Self, OptionalModelRow> {
        CharybdisQuery::new(Self::FIND_BY_PRIMARY_KEY_QUERY, QueryValue::Owned(value))
    }

    fn find_by_partition_key_value<'a>(
        value: Self::PartitionKey,
    ) -> CharybdisQuery<'a, Self::PartitionKey, Self, ModelStream> {
        CharybdisQuery::new(Self::FIND_BY_PARTITION_KEY_QUERY, QueryValue::Owned(value))
    }

    fn find_first_by_partition_key_value<'a>(
        value: Self::PartitionKey,
    ) -> CharybdisQuery<'a, Self::PartitionKey, Self, ModelRow> {
        CharybdisQuery::new(Self::FIND_FIRST_BY_PARTITION_KEY_QUERY, QueryValue::Owned(value))
    }

    fn find_by_partition_key_value_paged<'a>(
        value: Self::PartitionKey,
    ) -> CharybdisQuery<'a, Self::PartitionKey, Self, ModelPaged> {
        CharybdisQuery::new(Self::FIND_BY_PARTITION_KEY_QUERY, QueryValue::Owned(value))
    }

    fn find_by_primary_key(&self) -> CharybdisQuery<'_, Self::PrimaryKey, Self, ModelRow> {
        CharybdisQuery::new(
            Self::FIND_BY_PRIMARY_KEY_QUERY,
            QueryValue::Owned(self.primary_key_values()),
        )
    }

    fn maybe_find_by_primary_key(&self) -> CharybdisQuery<'_, Self::PrimaryKey, Self, OptionalModelRow> {
        CharybdisQuery::new(
            Self::FIND_BY_PRIMARY_KEY_QUERY,
            QueryValue::Owned(self.primary_key_values()),
        )
    }

    fn find_by_partition_key(&self) -> CharybdisQuery<'_, Self::PartitionKey, Self, ModelStream> {
        CharybdisQuery::new(
            Self::FIND_BY_PARTITION_KEY_QUERY,
            QueryValue::Owned(self.partition_key_values()),
        )
    }
}

impl<M: BaseModel + 'static> Find for M {}