Struct oxidized_mdf::MdfDatabase

pub struct MdfDatabase { /* fields omitted */ }

Implementations

impl MdfDatabase

pub async fn open<P>(p: P) -> Result<Self, Error> where
    P: AsRef<Path>, 

pub async fn from_read(read: Box<dyn Read + Unpin>) -> Result<Self, Error>

pub fn database_name(&self) -> &str

pub fn table_names(&self) -> Vec<String>

Returns the table names of this database file.

let db = MdfDatabase::open("data/AWLT2005.mdf").await.unwrap();
let table_names = db.table_names();
assert!(table_names.contains(&String::from("Customer")));

pub fn column_names(&self, table_name: &str) -> Option<Vec<String>>

Returns the column names of the given table name.

let db = MdfDatabase::open("data/AWLT2005.mdf").await.unwrap();

let column_names = db.column_names("Address").unwrap();
assert!(column_names.contains(&String::from("City")));

pub fn rows<'a, 'b: 'a>(
    &'b mut self,
    table_name: &str
) -> Option<impl Stream<Item = Row> + 'a>

Returns a stream of the rows in the given table.

use oxidized_mdf::{MdfDatabase, Value};
use async_std::stream::StreamExt;

let mut db = MdfDatabase::open("data/AWLT2005.mdf").await.unwrap();
let mut rows = db.rows("Address").unwrap();
let first_row = rows.next().await.unwrap();

assert_eq!(
    first_row.value("AddressLine1").cloned(),
    Some(Value::String(String::from("8713 Yosemite Ct.")))
);