Struct TenantRepository 

pub struct TenantRepository<E, R> { /* private fields */ }

租户感知 Repository 装饰器

包装任意 Repository<E>，在查询/保存/删除时自动注入 tenant_id 条件。

自动注入行为

操作	注入逻辑
find_by	追加 AND tenant_id = current
find_one_by	追加 AND tenant_id = current
save	校验/填充 entity.tenant_id = current
delete	先按主键查找，校验 tenant_id 后删除
delete_by	追加 AND tenant_id = current
count_by	追加 AND tenant_id = current

Implementations

impl<E: TenantAware, R> TenantRepository<E, R>

pub fn new(inner: Arc<R>) -> Self

用底层 Repository 创建 TenantRepository

Trait Implementations

impl<E, R> Repository<E> for TenantRepository<E, R>

where E: TenantAware + EntityAttributes, R: Repository<E>,

type Key = <R as Repository<E>>::Key

主键类型

fn key_of(&self, entity: &E) -> Self::Key

提取实体的主键

fn find_by_id(&self, key: &Self::Key) -> RepositoryResult<Option<E>>

按主键查找

fn find_all(&self) -> RepositoryResult<Vec<E>>

查询所有

fn find_by(&self, conditions: &[WhereCondition]) -> RepositoryResult<Vec<E>>

按条件查询

fn find_one_by( &self, conditions: &[WhereCondition], ) -> RepositoryResult<Option<E>>

按条件查询单条

fn save(&self, entity: E) -> RepositoryResult<E>

保存（INSERT 或 UPDATE）

fn save_many(&self, entities: Vec<E>) -> RepositoryResult<Vec<E>>

批量保存

fn delete(&self, key: &Self::Key) -> RepositoryResult<usize>

按主键删除

fn delete_by(&self, conditions: &[WhereCondition]) -> RepositoryResult<usize>

按条件删除

fn count(&self) -> RepositoryResult<u64>

总数

fn count_by(&self, conditions: &[WhereCondition]) -> RepositoryResult<u64>

按条件计数

fn batch_update( &self, entities: Vec<E>, ) -> Result<BatchUpdateResult<E>, RepositoryError>

批量更新（S-1：SeaORM 对标短板补全）

fn exists(&self, key: &Self::Key) -> Result<bool, RepositoryError>

主键是否存在

fn paginate( &self, page: u64, page_size: u64, ) -> Result<PageResult<E>, RepositoryError>

where E: Clone,

分页查询

fn paginate_by( &self, conditions: &[WhereCondition], page: u64, page_size: u64, ) -> Result<PageResult<E>, RepositoryError>

where E: Clone,

按条件分页查询

fn find_by_with_or_filter( &self, and: &[WhereCondition], or_filter: &[WhereCondition], ) -> Result<Vec<E>, RepositoryError>

where E: Clone + EntityAttributes,

按 AND 条件查询，并对结果应用额外的 OR 过滤组