Struct ODBCConnectionManager 

pub struct ODBCConnectionManager { /* private fields */ }

Implementations

impl ODBCConnectionManager

pub fn new<S: Into<String>>(connection_string: S) -> ODBCConnectionManager

Creates a new ODBCConnectionManager.

Examples found in repository

examples/execute_query.rs (line 20)

fn connect() -> Result<(), Box<dyn Error>> {
    // TODO: Update with your actual database connection details
    let manager = ODBCConnectionManager::new("DRIVER={IBM DB2 ODBC DRIVER};DATABASE=SAMPLE;HOSTNAME=db.example.com;PORT=50000;UID=db_user;PWD=YourPassword123");
    let pool = r2d2::Pool::new(manager).unwrap();
    let pool = pool.clone();
    let pool_conn = pool.get().unwrap();
    let conn = pool_conn.raw();
    execute_statement(&conn)
}

examples/connect_pool.rs (line 8)

fn main() {
    // TODO: Update with your actual database connection details
    let manager = ODBCConnectionManager::new("DRIVER={IBM DB2 ODBC DRIVER};DATABASE=SAMPLE;HOSTNAME=db.example.com;PORT=50000;UID=db_user;PWD=YourPassword123");
    let pool = r2d2::Pool::new(manager).unwrap();

    let mut children = vec![];
    for i in 0..10i32 {
        let pool = pool.clone();
        let pool_conn = pool.get().unwrap();
        children.push(thread::spawn(move || {
            let conn = pool_conn.raw();
            let stmt = Statement::with_parent(&conn).unwrap();
            if let Data(mut stmt) = stmt.exec_direct("select * from dbtest.GLWTACT").unwrap() {
                while let Some(mut cursor) = stmt.fetch().unwrap() {
                    if let Some(val) = cursor.get_data::<&str>(1).unwrap() {
                        println!("THREAD {} {}", i, val);
                    }
                }
            }
        }));
    }

    for child in children {
        let _ = child.join();
    }
}

Trait Implementations

impl Debug for ODBCConnectionManager

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

Formats the value using the given formatter.

impl ManageConnection for ODBCConnectionManager

type Connection = ODBCConnection<'static, AutocommitOn>

The connection type this manager deals with.

type Error = ODBCError

The error type returned by Connections.

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

Attempts to create a new connection.

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

Quickly determines if the connection is no longer usable.