scyllax 0.1.10-alpha

A SQLx and Discord inspired query system for Scylla
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
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111

//! ScyllaX error types

use tokio::sync::oneshot::error::RecvError;

/// An error from ScyllaX
#[derive(thiserror::Error, Clone, Debug)]
pub enum ScyllaxError {
    /// A query error from Scylla
    #[error("Scylla Query error: {0}")]
    Scylla(#[from] scylla::transport::errors::QueryError),

    /// An error thrown when trying to parse a single row
    #[error("Scylla single row typed error: {0}")]
    SingleRowTyped(#[from] scylla::transport::query_result::SingleRowTypedError),

    /// No rows were found when trying to parse a single row
    #[error("No rows found")]
    NoRowsFound,

    /// There was an error when building an upsert query.
    #[error("Failed to build query: {0}")]
    BuildUpsertQueryError(#[from] BuildUpsertQueryError),

    /// An error when serializing values
    #[error("Failed to serialize values: {0}")]
    SerializedValues(#[from] scylla::frame::value::SerializeValuesError),

    /// An error when using receivers
    #[error("Receiver error: {0}")]
    ReceiverError(#[from] RecvError),
}

/// An error when building an upsert query
#[derive(thiserror::Error, Clone, Debug)]
pub enum BuildUpsertQueryError {
    /// There were too many values (usually ignored since we don't set a capacity on [`scylla::frame::value::SerializedValues`]])
    #[error("Too many values when adding {field}")]
    TooManyValues {
        /// The field being added when the error was thrown
        field: String,
    },

    /// You cant mix named and unnamed values (trating SerializedValues as both a HashMap and a Vec).
    /// This is only added for `scylla`-error parity
    #[error("Can't mix named and unnamed values")]
    MixingNamedAndNotNamedValues,

    /// The value for a field was too big
    #[error("Value for {field} is too big")]
    ValueTooBig {
        /// The field being added when the error was thrown
        field: String,
    },

    /// Failed to parse a value
    #[error("Failed to serialize value for {field}")]
    ParseError {
        /// The field being added when the error was thrown
        field: String,
    },
}

#[cfg(test)]
mod test {
    use super::*;

    #[test]
    fn test_build_upsert_query_error() {
        assert_eq!(
            "Value for foo is too big",
            BuildUpsertQueryError::ValueTooBig {
                field: "foo".to_string()
            }
            .to_string()
        );

        assert_eq!(
            "Failed to serialize value for foo",
            BuildUpsertQueryError::ParseError {
                field: "foo".to_string()
            }
            .to_string()
        );

        assert_eq!(
            "Too many values when adding foo",
            BuildUpsertQueryError::TooManyValues {
                field: "foo".to_string()
            }
            .to_string()
        );

        assert_eq!(
            "Can't mix named and unnamed values",
            BuildUpsertQueryError::MixingNamedAndNotNamedValues.to_string()
        );
    }

    #[test]
    fn test_scyllax_error() {
        assert_eq!("No rows found", ScyllaxError::NoRowsFound.to_string());

        assert_eq!(
            "Failed to build query: Value for foo is too big",
            ScyllaxError::BuildUpsertQueryError(BuildUpsertQueryError::ValueTooBig {
                field: "foo".to_string()
            })
            .to_string()
        );
    }
}