2016-02-26 01:44:53 +08:00
|
|
|
extern crate time;
|
|
|
|
|
2016-12-31 13:35:47 +08:00
|
|
|
use Result;
|
|
|
|
use types::{FromSql, FromSqlError, FromSqlResult, ToSql, ToSqlOutput, ValueRef};
|
2016-02-26 01:44:53 +08:00
|
|
|
|
|
|
|
const SQLITE_DATETIME_FMT: &'static str = "%Y-%m-%d %H:%M:%S";
|
|
|
|
|
|
|
|
impl ToSql for time::Timespec {
|
2016-05-26 10:57:43 +08:00
|
|
|
fn to_sql(&self) -> Result<ToSqlOutput> {
|
|
|
|
let time_string = time::at_utc(*self).strftime(SQLITE_DATETIME_FMT).unwrap().to_string();
|
|
|
|
Ok(ToSqlOutput::from(time_string))
|
2016-02-26 01:44:53 +08:00
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
impl FromSql for time::Timespec {
|
2016-12-31 13:35:47 +08:00
|
|
|
fn column_result(value: ValueRef) -> FromSqlResult<Self> {
|
2016-05-31 02:35:56 +08:00
|
|
|
value.as_str().and_then(|s| match time::strptime(s, SQLITE_DATETIME_FMT) {
|
2016-05-16 11:30:11 +08:00
|
|
|
Ok(tm) => Ok(tm.to_timespec()),
|
2016-06-03 03:03:25 +08:00
|
|
|
Err(err) => Err(FromSqlError::Other(Box::new(err))),
|
2016-05-24 09:49:54 +08:00
|
|
|
})
|
2016-05-16 11:30:11 +08:00
|
|
|
}
|
2016-02-26 01:44:53 +08:00
|
|
|
}
|
|
|
|
|
|
|
|
#[cfg(test)]
|
|
|
|
mod test {
|
|
|
|
use Connection;
|
|
|
|
use super::time;
|
|
|
|
|
|
|
|
fn checked_memory_handle() -> Connection {
|
|
|
|
let db = Connection::open_in_memory().unwrap();
|
|
|
|
db.execute_batch("CREATE TABLE foo (t TEXT, i INTEGER, f FLOAT)").unwrap();
|
|
|
|
db
|
|
|
|
}
|
|
|
|
|
|
|
|
#[test]
|
|
|
|
fn test_timespec() {
|
|
|
|
let db = checked_memory_handle();
|
|
|
|
|
|
|
|
let ts = time::Timespec {
|
|
|
|
sec: 10_000,
|
|
|
|
nsec: 0,
|
|
|
|
};
|
2016-05-16 11:30:11 +08:00
|
|
|
db.execute("INSERT INTO foo(t) VALUES (?)", &[&ts]).unwrap();
|
2016-02-26 01:44:53 +08:00
|
|
|
|
|
|
|
let from: time::Timespec = db.query_row("SELECT t FROM foo", &[], |r| r.get(0)).unwrap();
|
|
|
|
assert_eq!(from, ts);
|
|
|
|
}
|
|
|
|
}
|