rqlite_client 0.1.0

rqlite database client with optional extra convenience
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

#![allow(missing_docs, unused_crate_dependencies)]

use std::sync::OnceLock;

use rqlite_client::{response, state, Connection, Error, Query, RequestBuilder};

struct ImplRequestTest {}

impl<T> RequestBuilder<T> for ImplRequestTest
where
    T: state::State,
{
    fn run(&self, query: &Query<T>) -> response::Result {
        Err(Error::ResultError(format!(
            "ImplRequestTest is dummy impl: {query}"
        )))
    }
}

const TEST_CONNECTION_URL: &str = "http://localhost:4001/";

static TEST_CONNECTION: OnceLock<Connection> = OnceLock::new();

fn test_connection() -> &'static Connection {
    TEST_CONNECTION.get_or_init(|| {
        #[cfg(feature = "url")]
        let c = Connection::new(TEST_CONNECTION_URL).unwrap();
        #[cfg(not(feature = "url"))]
        let c = Connection::new(TEST_CONNECTION_URL);

        c
    })
}

#[test]
fn request_test() {
    let q = test_connection().query();
    let r = ImplRequestTest {}.run(&q.set_sql_str("SELECT 1"));

    assert!(r.is_err());
    #[cfg(any(feature = "url", feature = "percent_encoding"))]
    {
        assert_eq!(
        &format!("{:?}", r.unwrap_err()),
        "ResultError(\"ImplRequestTest is dummy impl: http://localhost:4001/db/query?q=SELECT%201\")"
    );
    }
    #[cfg(not(any(feature = "url", feature = "percent_encoding")))]
    {
        assert_eq!(
            &format!("{:?}", r.unwrap_err()),
            "ResultError(\"ImplRequestTest is dummy impl: http://localhost:4001/db/query?q=SELECT 1\")"
        );
    }
}