Struct ODBCConnection

Source

pub struct ODBCConnection<'a, AC: AutocommitMode>(/* private fields */);

Implementations§

Source §

impl<'a, AC: AutocommitMode> ODBCConnection<'a, AC>

Source

pub fn raw(&self) -> &Connection<'a, AC>

Examples found in repository ?

examples/execute_query.rs (line 24)

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

More examples

Hide additional examples

examples/connect_pool.rs (line 16)

6fn main() {
7    // TODO: Update with your actual database connection details
8    let manager = ODBCConnectionManager::new("DRIVER={IBM DB2 ODBC DRIVER};DATABASE=SAMPLE;HOSTNAME=db.example.com;PORT=50000;UID=db_user;PWD=YourPassword123");
9    let pool = r2d2::Pool::new(manager).unwrap();
10
11    let mut children = vec![];
12    for i in 0..10i32 {
13        let pool = pool.clone();
14        let pool_conn = pool.get().unwrap();
15        children.push(thread::spawn(move || {
16            let conn = pool_conn.raw();
17            let stmt = Statement::with_parent(&conn).unwrap();
18            if let Data(mut stmt) = stmt.exec_direct("select * from dbtest.GLWTACT").unwrap() {
19                while let Some(mut cursor) = stmt.fetch().unwrap() {
20                    if let Some(val) = cursor.get_data::<&str>(1).unwrap() {
21                        println!("THREAD {} {}", i, val);
22                    }
23                }
24            }
25        }));
26    }
27
28    for child in children {
29        let _ = child.join();
30    }
31}