Struct ModelRepository 

pub struct ModelRepository<'a, T, ID>
where
    T: Model,
{ /* private fields */ }

Available on crate features model-mysql or model-postgres or model-sqlite only.

Repository tied to a model type and a pool.

Implementations

impl<'a, T, ID> ModelRepository<'a, T, ID>

where T: Model,

pub fn new(pool: &'a DbPool) -> ModelRepository<'a, T, ID>

impl<'a, T, ID> ModelRepository<'a, T, ID>

where T: Model, ID: PrimaryKey,

pub async fn insert(&self, entity: &T) -> Result<T, DbError>

Insert entity (never an update, unlike Repository::save) and answer the row as stored — with the generated key, timestamps and version. A key that exists already is the database’s unique-key error.

pub async fn find_by_id_with_deleted( &self, id: ID, ) -> Result<Option<T>, DbError>

The row with key id, soft-deleted or not.

pub async fn restore(&self, id: ID) -> Result<bool, DbError>

Clear the soft-delete column of row id: true when it was deleted, false when it wasn’t (or doesn’t exist). An error for a model without one.

pub async fn force_delete_by_id(&self, id: ID) -> Result<(), DbError>

Delete row id for real (DELETE), soft-delete column or not.

pub fn query(&self) -> QueryBuilder<'a, T>

A QueryBuilder over the same table and pool.

Trait Implementations

impl<'a, T> Repository<T, String> for ModelRepository<'a, T, String>

where T: Model,

async fn find_by_id(&self, id: String) -> Result<Option<T>, DbError>

async fn find_all(&self) -> Result<Vec<T>, DbError>

async fn save(&self, entity: &T) -> Result<T, DbError>

async fn save_all(&self, entities: &[T]) -> Result<Vec<T>, DbError>

async fn delete_by_id(&self, id: String) -> Result<(), DbError>

async fn delete_all_by_id(&self, ids: &[String]) -> Result<(), DbError>

async fn count(&self) -> Result<i64, DbError>

async fn exists_by_id(&self, id: String) -> Result<bool, DbError>

impl<'a, T> Repository<T, Uuid> for ModelRepository<'a, T, Uuid>

where T: Model,

async fn find_by_id(&self, id: Uuid) -> Result<Option<T>, DbError>

async fn find_all(&self) -> Result<Vec<T>, DbError>

async fn save(&self, entity: &T) -> Result<T, DbError>

async fn save_all(&self, entities: &[T]) -> Result<Vec<T>, DbError>

async fn delete_by_id(&self, id: Uuid) -> Result<(), DbError>

async fn delete_all_by_id(&self, ids: &[Uuid]) -> Result<(), DbError>

async fn count(&self) -> Result<i64, DbError>

async fn exists_by_id(&self, id: Uuid) -> Result<bool, DbError>

impl<'a, T> Repository<T, i32> for ModelRepository<'a, T, i32>

where T: Model,

async fn find_by_id(&self, id: i32) -> Result<Option<T>, DbError>

async fn find_all(&self) -> Result<Vec<T>, DbError>

async fn save(&self, entity: &T) -> Result<T, DbError>

async fn save_all(&self, entities: &[T]) -> Result<Vec<T>, DbError>

async fn delete_by_id(&self, id: i32) -> Result<(), DbError>

async fn delete_all_by_id(&self, ids: &[i32]) -> Result<(), DbError>

async fn count(&self) -> Result<i64, DbError>

async fn exists_by_id(&self, id: i32) -> Result<bool, DbError>

impl<'a, T> Repository<T, i64> for ModelRepository<'a, T, i64>

where T: Model,

async fn find_by_id(&self, id: i64) -> Result<Option<T>, DbError>

async fn find_all(&self) -> Result<Vec<T>, DbError>

async fn save(&self, entity: &T) -> Result<T, DbError>

async fn save_all(&self, entities: &[T]) -> Result<Vec<T>, DbError>

async fn delete_by_id(&self, id: i64) -> Result<(), DbError>

async fn delete_all_by_id(&self, ids: &[i64]) -> Result<(), DbError>

async fn count(&self) -> Result<i64, DbError>

async fn exists_by_id(&self, id: i64) -> Result<bool, DbError>