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

use crate::errors::CharybdisError;
use crate::scylla::PagingState;
use scylla::client::caching_session::CachingSession;
use scylla::client::pager::QueryPager;
use scylla::response::query_result::QueryResult;
use scylla::response::PagingStateResponse;
use scylla::serialize::row::SerializeRow;

pub async fn execute_unpaged(
    session: &CachingSession,
    query: &'static str,
    values: impl SerializeRow,
) -> Result<QueryResult, CharybdisError> {
    let res = session
        .execute_unpaged(query, values)
        .await
        .map_err(|e| CharybdisError::ExecutionError(query, e))?;

    Ok(res)
}

pub async fn execute_iter(
    session: &CachingSession,
    query: &'static str,
    values: impl SerializeRow,
) -> Result<QueryPager, CharybdisError> {
    let res = session
        .execute_iter(query, values)
        .await
        .map_err(|e| CharybdisError::PagerExecutionError(query, e))?;

    Ok(res)
}

pub async fn execute_single_page(
    session: &CachingSession,
    query: &'static str,
    values: impl SerializeRow,
    paging_state: PagingState,
) -> Result<(QueryResult, PagingStateResponse), CharybdisError> {
    let res = session
        .execute_single_page(query, values, paging_state)
        .await
        .map_err(|e| CharybdisError::ExecutionError(query, e))?;

    Ok(res)
}