Struct c3p0_pg_async::pg_async::PgC3p0Json

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

Methods

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

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

pub async fn fetch_one_by_id<'a, '_, ID: Into<&'a IdType>>(
    &'a self,
    conn: &'_ mut PgConnection,
    id: ID
) -> Result<Model<DATA>, C3p0Error>

pub async fn fetch_one_by_id_for_update<'a, '_, '_, ID: Into<&'a IdType>>(
    &'a self,
    conn: &'_ mut PgConnection,
    id: ID,
    for_update: &'_ ForUpdate
) -> Result<Model<DATA>, C3p0Error>

pub async fn create_table_if_not_exists<'_, '_>(
    &'_ self,
    conn: &'_ mut PgConnection
) -> Result<(), C3p0Error>

pub async fn drop_table_if_exists<'_, '_>(
    &'_ self,
    conn: &'_ mut PgConnection,
    cascade: bool
) -> Result<(), C3p0Error>

pub async fn count_all<'_, '_>(
    &'_ self,
    conn: &'_ mut PgConnection
) -> Result<u64, C3p0Error>

pub async fn exists_by_id<'a, '_, '_, ID: Into<&'a IdType>>(
    &'_ self,
    conn: &'_ mut PgConnection,
    id: ID
) -> Result<bool, C3p0Error>

pub async fn fetch_all<'_, '_>(
    &'_ self,
    conn: &'_ mut PgConnection
) -> Result<Vec<Model<DATA>>, C3p0Error>

pub async fn fetch_all_for_update<'_, '_, '_>(
    &'_ self,
    conn: &'_ mut PgConnection,
    for_update: &'_ ForUpdate
) -> Result<Vec<Model<DATA>>, C3p0Error>

pub async fn fetch_one_optional_by_id<'a, '_, '_, ID: Into<&'a IdType>>(
    &'_ self,
    conn: &'_ mut PgConnection,
    id: ID
) -> Result<Option<Model<DATA>>, C3p0Error>

pub async fn fetch_one_optional_by_id_for_update<'a, '_, '_, ID: Into<&'a IdType>>(
    &'a self,
    conn: &'_ mut PgConnection,
    id: ID,
    for_update: &'_ ForUpdate
) -> Result<Option<Model<DATA>>, C3p0Error>

pub async fn delete<'_, '_>(
    &'_ self,
    conn: &'_ mut PgConnection,
    obj: Model<DATA>
) -> Result<Model<DATA>, C3p0Error>

pub async fn delete_all<'_, '_>(
    &'_ self,
    conn: &'_ mut PgConnection
) -> Result<u64, C3p0Error>

pub async fn delete_by_id<'a, '_, '_, ID: Into<&'a IdType>>(
    &'_ self,
    conn: &'_ mut PgConnection,
    id: ID
) -> Result<u64, C3p0Error>

pub async fn save<'_, '_>(
    &'_ self,
    conn: &'_ mut PgConnection,
    obj: NewModel<DATA>
) -> Result<Model<DATA>, C3p0Error>

pub async fn update<'_, '_>(
    &'_ self,
    conn: &'_ mut PgConnection,
    obj: Model<DATA>
) -> Result<Model<DATA>, C3p0Error>

Trait Implementations

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

type CONN = PgConnection

fn codec(&self) -> &CODEC

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

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

Returns a copy of the value.

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

Performs copy-assignment from source.