Struct OracleConnectionManager

pub struct OracleConnectionManager { /* private fields */ }

A bb8::ManageConnection for oracle::Connections.

Example

use std::thread;
use bb8_oracle::OracleConnectionManager;

let manager = OracleConnectionManager::new("user", "password", "localhost");
let pool = bb8::Pool::builder()
     .max_size(15)
     .build(manager).await
     .unwrap();

for _ in 0..20 {
    let pool = pool.clone();
    thread::spawn(move || {
        let conn = pool.get().unwrap();
        // use the connection
        // it will be returned to the pool when it falls out of scope.
    });
}

Implementations

impl OracleConnectionManager

pub fn new<U: Into<String>, P: Into<String>, C: Into<String>>( username: U, password: P, connect_string: C, ) -> OracleConnectionManager

Initialise the connection manager with the data needed to create new connections. Refer to the documentation of oracle::Connection for further details on the parameters.

Example

let manager = OracleConnectionManager::new("user", "password", "localhost");

pub fn from_connector(connector: Connector) -> OracleConnectionManager

Initialise the connection manager with the data needed to create new connections using oracle::Connector. This allows setting additional connection data.

If a connection can be established only with a username, password and connect string, use new instead.

Example

// connect system/manager as sysdba
let mut connector = oracle::Connector::new("system", "manager", "");
connector.privilege(oracle::Privilege::Sysdba);
let manager = OracleConnectionManager::from_connector(connector);

Trait Implementations

impl Debug for OracleConnectionManager

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

Formats the value using the given formatter.

impl ManageConnection for OracleConnectionManager

type Connection = Arc<Connection>

The connection type this manager deals with.

type Error = Error

The error type returned by Connections.

async fn connect(&self) -> Result<Self::Connection, Self::Error>

Attempts to create a new connection.

async fn is_valid(&self, conn: &mut Self::Connection) -> Result<(), Self::Error>

Determines if the connection is still connected to the database.

fn has_broken(&self, conn: &mut Self::Connection) -> bool

Synchronously determine if the connection is no longer usable, if possible.