Struct SqlHostState 

pub struct SqlHostState { /* private fields */ }

Implementations

impl SqlHostState

pub fn new(db: Arc<SqlDB>) -> Self

Trait Implementations

impl HasData for SqlHostState

type Data<'a> = &'a mut SqlHostState where Self: 'a

The data associated with this trait implementation, chiefly used as a generic associated type to allow plumbing the 'a lifetime into the definition here.

impl Host for SqlHostState

async fn get_pool_state(&mut self) -> PoolState

Returns current pool state

impl Host for SqlHostState

fn push_int16( &mut self, value: Option<i16>, to: Resource<SqlArguments>, ) -> PushResult

Encodes a 16-bit signed integer (SMALLINT).

fn get_int16( &mut self, result: Resource<QueryResults>, position: ValuePosition, ) -> Result<Option<i16>, Error>

Decodes a 16-bit signed integer (SMALLINT) from results.

fn push_int32( &mut self, value: Option<i32>, to: Resource<SqlArguments>, ) -> PushResult

Encodes a 32-bit signed integer (INTEGER).

fn get_int32( &mut self, result: Resource<QueryResults>, position: ValuePosition, ) -> Result<Option<i32>, Error>

Decodes a 32-bit signed integer (INTEGER) from results.

fn push_int64( &mut self, value: Option<i64>, to: Resource<SqlArguments>, ) -> PushResult

Encodes a 64-bit signed integer (BIGINT).

fn get_int64( &mut self, result: Resource<QueryResults>, position: ValuePosition, ) -> Result<Option<i64>, Error>

Decodes a 64-bit signed integer (BIGINT) from results.

fn push_float32( &mut self, value: Option<f32>, to: Resource<SqlArguments>, ) -> PushResult

Encodes a 32-bit float (REAL).

fn get_float32( &mut self, result: Resource<QueryResults>, position: ValuePosition, ) -> Result<Option<f32>, Error>

Decodes a 32-bit float (REAL) from results.

fn push_float64( &mut self, value: Option<f64>, to: Resource<SqlArguments>, ) -> PushResult

Encodes a 64-bit float (DOUBLE PRECISION).

fn get_float64( &mut self, result: Resource<QueryResults>, position: ValuePosition, ) -> Result<Option<f64>, Error>

Decodes a 64-bit float (DOUBLE PRECISION) from results.

fn push_string( &mut self, value: Option<String>, to: Resource<SqlArguments>, ) -> PushResult

Encodes a string (TEXT, VARCHAR, CHAR).

fn get_string( &mut self, result: Resource<QueryResults>, position: ValuePosition, ) -> Result<Option<String>, Error>

Decodes a string (TEXT, VARCHAR, CHAR) from results.

fn push_bool( &mut self, value: Option<bool>, to: Resource<SqlArguments>, ) -> PushResult

Encodes a boolean (BOOLEAN).

fn get_bool( &mut self, result: Resource<QueryResults>, position: ValuePosition, ) -> Result<Option<bool>, Error>

Decodes a boolean (BOOLEAN) from results.

fn push_json( &mut self, value: Option<String>, to: Resource<SqlArguments>, ) -> PushResult

Encodes a JSON value as string (JSON, JSONB).

fn get_json( &mut self, result: Resource<QueryResults>, position: ValuePosition, ) -> Result<Option<String>, Error>

Decodes a JSON value as string (JSON, JSONB) from results.

fn push_uuid( &mut self, value: Option<Uuid>, to: Resource<SqlArguments>, ) -> PushResult

Encodes a UUID.

fn get_uuid( &mut self, result: Resource<QueryResults>, position: ValuePosition, ) -> Result<Option<Uuid>, Error>

Decodes a UUID from results.

fn push_hstore( &mut self, value: Option<Hstore>, to: Resource<SqlArguments>, ) -> PushResult

Encodes an HSTORE value.

fn get_hstore( &mut self, result: Resource<QueryResults>, position: ValuePosition, ) -> Result<Option<Hstore>, Error>

Decodes an HSTORE value from results.

fn push_date( &mut self, value: Option<Date>, to: Resource<SqlArguments>, ) -> PushResult

Encodes a DATE value.

fn get_date( &mut self, result: Resource<QueryResults>, position: ValuePosition, ) -> Result<Option<Date>, Error>

Decodes a DATE value from results.

fn push_time( &mut self, value: Option<Time>, to: Resource<SqlArguments>, ) -> PushResult

Encodes a TIME value.

fn get_time( &mut self, result: Resource<QueryResults>, position: ValuePosition, ) -> Result<Option<Time>, Error>

Decodes a TIME value from results.

fn push_timestamp( &mut self, value: Option<Timestamp>, to: Resource<SqlArguments>, ) -> PushResult

Encodes a TIMESTAMP value.

fn get_timestamp( &mut self, result: Resource<QueryResults>, position: ValuePosition, ) -> Result<Option<Timestamp>, Error>

Decodes a TIMESTAMP value from results.

fn push_timestamptz( &mut self, value: Option<Timestamptz>, to: Resource<SqlArguments>, ) -> PushResult

Encodes a TIMESTAMPTZ value.

fn get_timestamptz( &mut self, result: Resource<QueryResults>, position: ValuePosition, ) -> Result<Option<Timestamptz>, Error>

Decodes a TIMESTAMPTZ value from results.

fn push_interval( &mut self, value: Option<PgInterval>, to: Resource<SqlArguments>, ) -> PushResult

Encodes an INTERVAL value.

fn get_interval( &mut self, result: Resource<QueryResults>, position: ValuePosition, ) -> Result<Option<PgInterval>, Error>

Decodes an INTERVAL value from results.

fn push_inet( &mut self, value: Option<Inet>, to: Resource<SqlArguments>, ) -> PushResult

Encodes an INET value.

fn get_inet( &mut self, result: Resource<QueryResults>, position: ValuePosition, ) -> Result<Option<Inet>, Error>

Decodes an INET value from results.

fn push_cidr( &mut self, value: Option<Inet>, to: Resource<SqlArguments>, ) -> PushResult

Encodes a CIDR value.

fn get_cidr( &mut self, result: Resource<QueryResults>, position: ValuePosition, ) -> Result<Option<Inet>, Error>

Decodes a CIDR value from results.

fn push_macaddr( &mut self, value: Option<Macaddr>, to: Resource<SqlArguments>, ) -> PushResult

Encodes a MACADDR value.

fn get_macaddr( &mut self, result: Resource<QueryResults>, position: ValuePosition, ) -> Result<Option<Macaddr>, Error>

Decodes a MACADDR value from results.

fn push_numeric( &mut self, value: Option<Numeric>, to: Resource<SqlArguments>, ) -> PushResult

Encodes a NUMERIC value.

fn get_numeric( &mut self, result: Resource<QueryResults>, position: ValuePosition, ) -> Result<Option<Numeric>, Error>

Decodes a NUMERIC value from results.

impl HostConnection for SqlHostState

async fn drop(&mut self, rep: Resource<Connection>) -> Result<()>

async fn release(&mut self, _this: Resource<Connection>)

Explicitly releases the connection back to the pool. Consumes the connection resource.

impl HostConnectionWithStore for SqlHostState

async fn begin_transaction<T>( accessor: &Accessor<T, Self>, self_: Resource<Connection>, ) -> Result<Resource<Transaction>, Error>

Begins a new transaction on this connection. If dropped without explicit commit or rollback, the transaction is automatically rolled back.

impl HostQueryResults for SqlHostState

fn row_count(&mut self, self_: Resource<QueryResults>) -> Result<u64, Error>

Returns the number of rows in the result set.

fn drop(&mut self, rep: Resource<QueryResults>) -> Result<()>

impl HostSqlArguments for SqlHostState

fn new(&mut self) -> Result<Resource<SqlArgumentsImpl>, Error>

Creates a new empty arguments container.

fn drop(&mut self, rep: Resource<SqlArguments>) -> Result<()>

impl HostTransaction for SqlHostState

async fn drop(&mut self, rep: Resource<Transaction>) -> Result<()>

impl HostTransactionWithStore for SqlHostState

async fn commit<T>( accessor: &Accessor<T, Self>, this: Resource<Transaction>, ) -> Result<(), Error>

Commits all changes made within this transaction. Consumes the transaction resource.

async fn rollback<T>( accessor: &Accessor<T, Self>, this: Resource<Transaction>, ) -> Result<(), Error>

Rolls back all changes made within this transaction. Consumes the transaction resource.

impl HostWithStore for SqlHostState

async fn begin_transaction<T>( accessor: &Accessor<T, Self>, ) -> Result<Resource<Transaction>, Error>

Begins a new transaction from the pool. If dropped without explicit commit or rollback, the transaction is automatically rolled back.

async fn acquire_connection<T>( accessor: &Accessor<T, Self>, ) -> Result<Resource<Connection>, Error>

Acquires a dedicated connection from the pool. Use this when you need multiple operations on the same connection.

impl HostWithStore for SqlHostState

async fn fetch_all<T>( accessor: &Accessor<T, Self>, query: SqlQuery, executor: QueryExecutor, ) -> Result<Resource<QueryResults>, Error>

Executes a SELECT query and returns all rows. Use database-specific codecs to extract values from results.

async fn execute<T>( accessor: &Accessor<T, Self>, query: SqlQuery, executor: QueryExecutor, ) -> Result<u64, Error>

Executes an INSERT, UPDATE, or DELETE query. Returns the number of affected rows.

async fn execute_raw<T>( accessor: &Accessor<T, Self>, query: SqlString, executor: QueryExecutor, ) -> Result<(), Error>

Executes a raw SQL string without parameters. Use for DDL statements or when parameters are not needed.

impl Host for SqlHostState

impl Host for SqlHostState

impl Host for SqlHostState

impl Host for SqlHostState

impl Host for SqlHostState

impl Host for SqlHostState