rustling-data 0.1.0

Core data access layer for Rustling, supporting PostgreSQL and MongoDB
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

#[cfg(feature = "postgres")]
use sqlx::{Encode, Postgres, Type};
#[cfg(feature = "mongo")]
pub type MongoError = mongodb::error::Error;
use thiserror::Error;

#[derive(Error, Debug)]
pub enum RepositoryError<DB> {
    #[error("entity not found")]
    NotFound,
    #[error("database connection error: {0}")]
    ConnectionError(DB),
    #[error("constraint violation: {0}")]
    ConstraintViolation(String),
    #[error("unknown error: {0}")]
    Other(String),
}

#[async_trait::async_trait]
pub trait CrudRepository<T, ID, DB> {
    async fn find_all(&self) -> Result<Vec<T>, RepositoryError<DB>>;
    async fn find_one(&self, id: &ID) -> Result<Option<T>, RepositoryError<DB>>;
    async fn insert_one(&self, entity: &T) -> Result<ID, RepositoryError<DB>>;
    async fn update_one(&self, id: &ID, entity: &T) -> Result<Option<T>, RepositoryError<DB>>;
    async fn delete_one(&self, id: &ID) -> Result<u64, RepositoryError<DB>>;
}

#[cfg(feature = "postgres")]
pub trait PostgresEntity {
    type Id;
    fn columns() -> &'static [&'static str];
    fn values<'e>(&'e self) -> Vec<&'e (impl Encode<'e, Postgres> + Type<Postgres>)>;
}