Struct HanaPoolForRocket

pub struct HanaPoolForRocket { /* private fields */ }

Available on crate feature rocket_pool only.

An implementation of rocket’s Pool trait.

Example

use hdbconnect_async::{
    ConnectParams, ConnectionConfiguration, HanaPoolForRocket, IntoConnectParamsBuilder
};
use rocket_db_pools::Pool;

let pool = HanaPoolForRocket::with_configuration(
    "hdbsql://abcd123:2222"
        .into_connect_params_builder()?
        .with_dbuser("MEIER")
        .with_password("schlau"),
    ConnectionConfiguration::default()
        .with_auto_commit(false),
)?;

let conn = pool.get().await.unwrap();
conn.query("select 1 from dummy").await.unwrap();

Implementations

impl HanaPoolForRocket

pub fn new<P: IntoConnectParams>(p: P) -> HdbResult<Self>

Creates a new HanaPoolForRocket with default configuration.

Errors

HdbError::Usage if not enough or inconsistent information was provided

pub fn with_configuration<P: IntoConnectParams>( p: P, c: ConnectionConfiguration, ) -> HdbResult<Self>

Creates a new HanaPoolForRocket with provided configuration.

Errors

HdbError::Usage if not enough or inconsistent information was provided

Trait Implementations

impl Clone for HanaPoolForRocket

fn clone(&self) -> HanaPoolForRocket

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for HanaPoolForRocket

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Pool for HanaPoolForRocket

type Connection = Connection

The connection type managed by this pool, returned by Self::get().

type Error = HdbError

The error type returned by Self::init() and Self::get().

fn init<'life0, 'async_trait>( figment: &'life0 Figment, ) -> Pin<Box<dyn Future<Output = HdbResult<Self>> + Send + 'async_trait>>

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

Constructs a pool from a Value.

fn get<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = HdbResult<Connection>> + Send + 'async_trait>>

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

Asynchronously retrieves a connection from the factory or pool.

fn close<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

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

Shutdown the connection pool, disallowing any new connections from being retrieved and waking up any tasks with active connections.