Struct Cursor

pub struct Cursor<'s, 'a: 's, 'b: 's, S: 's, AC: AutocommitMode> { /* private fields */ }

Used to retrieve data from the fields of a query result

Implementations

impl<'a, 'b, 'c, S, AC: AutocommitMode> Cursor<'a, 'b, 'c, S, AC>

pub fn get_data<'d, T>(&'d mut self, col_or_param_num: u16) -> Result<Option<T>>

where T: Output<'d>,

Retrieves data for a single column in the result set

Panics

If you try to convert to &str but the data can’t be converted without allocating an intermediate buffer.

Examples found in repository

examples/list_tables.rs (line 38)

fn list_tables(conn: &Connection<AutocommitOn>) -> Result<(), Box<dyn Error>> {
    let stmt = Statement::with_parent(conn)?;
    // Create the table
    let mut table = Table::new();
    // Add a row per time
    table.add_row(row!["CATALOG_NAME","SCHEMA_NAME", "TABLE_NAME","TYPE"]);
    // Print the table to stdout
    table.printstd();

    let mut rs = stmt.tables_str("%", "%", "%", "TABLE")?;
    let cols = rs.num_result_cols()?;
    while let Some(mut cursor) = rs.fetch()? {

        for i in 1..(cols + 1) {
            match cursor.get_data::<&str>(i as u16)? {
                Some(val) => print!(" {},", val),
                None => print!(" NULL,"),
            }
        }
        //table.add_row(row![val_temp[1],val_temp[2],val_temp[3],val_temp[4],val_temp[5]]);
        println!();
    }
    Ok(())
}

examples/execute_query.rs (line 39)

fn execute_statement(conn: &Connection<AutocommitOn>) -> Result<(), Box<dyn Error>> {
    let stmt = Statement::with_parent(conn)?;

    let mut sql_text = String::new();
    println!("Please enter SQL statement string: ");
    io::stdin().read_line(&mut sql_text).unwrap();

    match stmt.exec_direct(&sql_text)? {
        Data(mut stmt) => {
            let cols = stmt.num_result_cols()?;
            while let Some(mut cursor) = stmt.fetch()? {
                for i in 1..(cols + 1) {
                    match cursor.get_data::<&str>(i as u16)? {
                        Some(val) => print!(" {}", val),
                        None => print!(" NULL"),
                    }
                }
                println!();
            }
        }
        NoData(_) => println!("Query executed, no data returned"),
    }

    Ok(())
}

examples/connect.rs (line 42)

fn execute_statement<'env>(conn: &Connection<'env, AutocommitOn>) -> Result<(),Box<dyn Error>> {
    let stmt = Statement::with_parent(conn)?;

    let mut sql_text = String::new();
    println!("Please enter SQL statement string: ");
    io::stdin().read_line(&mut sql_text).unwrap();

    match stmt.exec_direct(&sql_text)? {
        Data(mut stmt) => {
            let cols = stmt.num_result_cols()?;
            while let Some(mut cursor) = stmt.fetch()? {
                for i in 1..(cols + 1) {
                    match cursor.get_data::<&str>(i as u16)? {
                        Some(val) => print!(" {}", val),
                        None => print!(" NULL"),
                    }
                }
                println!();
            }
        }
        NoData(_) => println!("Query executed, no data returned"),
    }

    Ok(())
}

examples/connect_pool.rs (line 19)

fn main() {
    let manager = ODBCConnectionManager::new("DSN=dashdb;DATABASE=FOO;hostname=test@test.com;PORT=0000;UID=admin;PWD=admin;");
    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();
    }
}

examples/bind_params.rs (line 24)

fn test_me() -> std::result::Result<(), Box<dyn Error>> {
    let env = create_environment_v3().expect("Can't create ODBC environment");
    let conn = env.connect("dashdb", "admin", "admin")?;
    let stmt = Statement::with_parent(&conn)?.prepare(
        "select * from test where COL3 = ?",
    )?;

    let param = "Binit";

    let stmt = stmt.bind_parameter(1, &param)?;
    /*let stmt = stmt.bind_parameter(2, &param)?;
    let stmt = stmt.bind_parameter(3, &param)?;
    let stmt = stmt.bind_parameter(4, &param)?;*/

    let stmt = if let Data(mut stmt) = stmt.execute()? {
        if let Some(mut cursor) = stmt.fetch()? {
            println!("{}", cursor.get_data::<String>(1)?.unwrap());
        }
        stmt.close_cursor()?
    } else {
        panic!("SELECT statement returned no result set");
    };

    let stmt = stmt.reset_parameters()?;

    let param = 128u8;

    let stmt = stmt.bind_parameter(1, &param)?;
    let stmt = stmt.bind_parameter(2, &param)?;

    let stmt = if let Data(mut stmt) = stmt.execute()? {
        if let Some(mut cursor) = stmt.fetch()? {
            println!("{}", cursor.get_data::<String>(1)?.unwrap());
        }
        stmt.close_cursor()?
    } else {
        panic!("SELECT statement returned no result set");
    };
    stmt.reset_parameters().unwrap();

    Ok(())
}