datasources 0.1.5

Async datasource interfaces, middleware, registry, and test doubles
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19

use crate::i_where::IWhere;
use crate::statement::Statement;

pub trait ReadInput: Send + Sync {
    fn as_statement(&self) -> Option<&dyn Statement> {
        None
    }

    fn as_where(&self) -> Option<&dyn IWhere> {
        None
    }
}

pub fn where_of<'a>(query: Option<&'a dyn ReadInput>) -> Option<&'a dyn IWhere> {
    let input = query?;
    input
        .as_where()
        .or_else(|| input.as_statement().and_then(Statement::predicate))
}