Struct c3p0_postgres::PgC3p0Json

pub struct PgC3p0Json<DATA, CODEC: JsonCodec<DATA>>where
    DATA: Clone + Serialize + DeserializeOwned + Send + Sync,{ /* private fields */ }

Implementations

impl<DATA, CODEC: JsonCodec<DATA>> PgC3p0Json<DATA, CODEC>where DATA: Clone + Serialize + DeserializeOwned + Send + Sync,

pub fn queries(&self) -> &Queries

pub fn to_model(&self, row: &Row) -> Result<Model<DATA>, Box<dyn Error>>

pub async fn fetch_one_optional_with_sql( &self, conn: &mut PgConnection, sql: &str, params: &[&(dyn ToSql + Sync)] ) -> Result<Option<Model<DATA>>, C3p0Error>

Allows the execution of a custom sql query and returns the first entry in the result set. For this to work, the sql query:

• must be a SELECT
• must declare the ID, VERSION and DATA fields in this exact order

pub async fn fetch_one_with_sql( &self, conn: &mut PgConnection, sql: &str, params: &[&(dyn ToSql + Sync)] ) -> Result<Model<DATA>, C3p0Error>

Allows the execution of a custom sql query and returns the first entry in the result set. For this to work, the sql query:

• must be a SELECT
• must declare the ID, VERSION and DATA fields in this exact order

pub async fn fetch_all_with_sql( &self, conn: &mut PgConnection, sql: &str, params: &[&(dyn ToSql + Sync)] ) -> Result<Vec<Model<DATA>>, C3p0Error>

Allows the execution of a custom sql query and returns all the entries in the result set. For this to work, the sql query:

• must be a SELECT
• must declare the ID, VERSION and DATA fields in this exact order

Trait Implementations

impl<DATA, CODEC: JsonCodec<DATA>> C3p0Json<DATA, CODEC> for PgC3p0Json<DATA, CODEC>where DATA: Clone + Serialize + DeserializeOwned + Send + Sync,

type Conn = PgConnection

fn codec(&self) -> &CODEC

fn create_table_if_not_exists<'life0, 'life1, 'async_trait>( &'life0 self, conn: &'life1 mut PgConnection ) -> Pin<Box<dyn Future<Output = Result<(), C3p0Error>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

fn drop_table_if_exists<'life0, 'life1, 'async_trait>( &'life0 self, conn: &'life1 mut PgConnection, cascade: bool ) -> Pin<Box<dyn Future<Output = Result<(), C3p0Error>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

fn count_all<'life0, 'life1, 'async_trait>( &'life0 self, conn: &'life1 mut PgConnection ) -> Pin<Box<dyn Future<Output = Result<u64, C3p0Error>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

fn exists_by_id<'a, 'life0, 'async_trait, ID>( &'a self, conn: &'life0 mut PgConnection, id: ID ) -> Pin<Box<dyn Future<Output = Result<bool, C3p0Error>> + Send + 'async_trait>>where ID: 'async_trait + Into<&'a IdType> + Send, Self: 'async_trait, 'a: 'async_trait, 'life0: 'async_trait,

fn fetch_all<'life0, 'life1, 'async_trait>( &'life0 self, conn: &'life1 mut PgConnection ) -> Pin<Box<dyn Future<Output = Result<Vec<Model<DATA>>, C3p0Error>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

fn fetch_all_for_update<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, conn: &'life1 mut PgConnection, for_update: &'life2 ForUpdate ) -> Pin<Box<dyn Future<Output = Result<Vec<Model<DATA>>, C3p0Error>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

fn fetch_one_optional_by_id<'a, 'life0, 'async_trait, ID>( &'a self, conn: &'life0 mut PgConnection, id: ID ) -> Pin<Box<dyn Future<Output = Result<Option<Model<DATA>>, C3p0Error>> + Send + 'async_trait>>where ID: 'async_trait + Into<&'a IdType> + Send, Self: 'async_trait, 'a: 'async_trait, 'life0: 'async_trait,

fn fetch_one_optional_by_id_for_update<'a, 'life0, 'life1, 'async_trait, ID>( &'a self, conn: &'life0 mut PgConnection, id: ID, for_update: &'life1 ForUpdate ) -> Pin<Box<dyn Future<Output = Result<Option<Model<DATA>>, C3p0Error>> + Send + 'async_trait>>where ID: 'async_trait + Into<&'a IdType> + Send, Self: 'async_trait, 'a: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

fn fetch_one_by_id<'a, 'life0, 'async_trait, ID>( &'a self, conn: &'life0 mut PgConnection, id: ID ) -> Pin<Box<dyn Future<Output = Result<Model<DATA>, C3p0Error>> + Send + 'async_trait>>where ID: 'async_trait + Into<&'a IdType> + Send, Self: 'async_trait, 'a: 'async_trait, 'life0: 'async_trait,

fn fetch_one_by_id_for_update<'a, 'life0, 'life1, 'async_trait, ID>( &'a self, conn: &'life0 mut PgConnection, id: ID, for_update: &'life1 ForUpdate ) -> Pin<Box<dyn Future<Output = Result<Model<DATA>, C3p0Error>> + Send + 'async_trait>>where ID: 'async_trait + Into<&'a IdType> + Send, Self: 'async_trait, 'a: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

fn delete<'life0, 'life1, 'async_trait>( &'life0 self, conn: &'life1 mut PgConnection, obj: Model<DATA> ) -> Pin<Box<dyn Future<Output = Result<Model<DATA>, C3p0Error>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

fn delete_all<'life0, 'life1, 'async_trait>( &'life0 self, conn: &'life1 mut PgConnection ) -> Pin<Box<dyn Future<Output = Result<u64, C3p0Error>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

fn delete_by_id<'a, 'life0, 'async_trait, ID>( &'a self, conn: &'life0 mut PgConnection, id: ID ) -> Pin<Box<dyn Future<Output = Result<u64, C3p0Error>> + Send + 'async_trait>>where ID: 'async_trait + Into<&'a IdType> + Send, Self: 'async_trait, 'a: 'async_trait, 'life0: 'async_trait,

fn save<'life0, 'life1, 'async_trait>( &'life0 self, conn: &'life1 mut PgConnection, obj: NewModel<DATA> ) -> Pin<Box<dyn Future<Output = Result<Model<DATA>, C3p0Error>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

fn update<'life0, 'life1, 'async_trait>( &'life0 self, conn: &'life1 mut PgConnection, obj: Model<DATA> ) -> Pin<Box<dyn Future<Output = Result<Model<DATA>, C3p0Error>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

impl<DATA, CODEC: Clone + JsonCodec<DATA>> Clone for PgC3p0Json<DATA, CODEC>where DATA: Clone + Serialize + DeserializeOwned + Send + Sync + Clone,

fn clone(&self) -> PgC3p0Json<DATA, CODEC>

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.