Struct PostgresService 

pub struct PostgresService { /* private fields */ }

Postgres Service

Implementations

impl PostgresService

pub fn new( db: Arc<DatabaseConnection>, table: impl Into<String>, ) -> Result<Self, CoolError>

创建 Postgres Service，校验后端类型

Trait Implementations

impl BaseService for PostgresService

fn db(&self) -> &DatabaseConnection

获取数据库连接

fn table_name(&self) -> &str

获取表名

fn add<'life0, 'async_trait>( &'life0 self, data: Value, ) -> Pin<Box<dyn Future<Output = CoolResult<Value>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

新增

fn delete<'life0, 'async_trait>( &'life0 self, param: DeleteParam, ) -> Pin<Box<dyn Future<Output = CoolResult<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

删除

fn soft_delete<'life0, 'async_trait>( &'life0 self, ids: Vec<Id>, ) -> Pin<Box<dyn Future<Output = CoolResult<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

软删除

fn update<'life0, 'async_trait>( &'life0 self, data: Value, ) -> Pin<Box<dyn Future<Output = CoolResult<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

修改

fn info<'life0, 'async_trait>( &'life0 self, id: Id, _ignore_fields: Option<Vec<String>>, ) -> Pin<Box<dyn Future<Output = CoolResult<Option<Value>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

查询单条记录

fn page<'life0, 'async_trait>( &'life0 self, query: PageQuery, option: QueryOption, ) -> Pin<Box<dyn Future<Output = CoolResult<PageResult<Value>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

分页查询

fn page_with_filters<'life0, 'life1, 'async_trait>( &'life0 self, query: PageQuery, filters: &'life1 Value, option: QueryOption, ) -> Pin<Box<dyn Future<Output = CoolResult<PageResult<Value>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

分页查询（带过滤参数）

fn list<'life0, 'async_trait>( &'life0 self, query: ListQuery, option: QueryOption, ) -> Pin<Box<dyn Future<Output = CoolResult<Vec<Value>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

列表查询（不分页）

fn native_query<'life0, 'life1, 'async_trait>( &'life0 self, sql: &'life1 str, params: Vec<Value>, ) -> Pin<Box<dyn Future<Output = CoolResult<Vec<Value>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

原生 SQL 查询

fn execute<'life0, 'life1, 'async_trait>( &'life0 self, sql: &'life1 str, ) -> Pin<Box<dyn Future<Output = CoolResult<u64>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

执行 SQL

fn modify_before<'life0, 'async_trait>( &'life0 self, data: Value, _modify_type: ModifyType, ) -> Pin<Box<dyn Future<Output = CoolResult<Value>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

修改前置钩子

fn modify_after<'life0, 'async_trait>( &'life0 self, _data: Value, _modify_type: ModifyType, ) -> Pin<Box<dyn Future<Output = CoolResult<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

修改后置钩子

fn map_row(&self, row: QueryResult) -> Value

行数据映射