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
|
|
|
|
2017-07-11 23:01:25 +08:00
|
|
|
const SQLITE_DATETIME_FMT: &'static str = "%Y-%m-%d %H:%M:%f %z";
|
2016-02-26 01:44:53 +08:00
|
|
|
|
|
|
|
impl ToSql for time::Timespec {
|
2016-05-26 10:57:43 +08:00
|
|
|
fn to_sql(&self) -> Result<ToSqlOutput> {
|
2017-04-08 01:43:24 +08:00
|
|
|
let time_string = time::at_utc(*self)
|
|
|
|
.strftime(SQLITE_DATETIME_FMT)
|
|
|
|
.unwrap()
|
|
|
|
.to_string();
|
2016-05-26 10:57:43 +08:00
|
|
|
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> {
|
2017-04-08 01:43:24 +08:00
|
|
|
value
|
|
|
|
.as_str()
|
|
|
|
.and_then(|s| match time::strptime(s, SQLITE_DATETIME_FMT) {
|
|
|
|
Ok(tm) => Ok(tm.to_timespec()),
|
|
|
|
Err(err) => Err(FromSqlError::Other(Box::new(err))),
|
|
|
|
})
|
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();
|
2017-04-08 01:43:24 +08:00
|
|
|
db.execute_batch("CREATE TABLE foo (t TEXT, i INTEGER, f FLOAT)")
|
|
|
|
.unwrap();
|
2016-02-26 01:44:53 +08:00
|
|
|
db
|
|
|
|
}
|
|
|
|
|
|
|
|
#[test]
|
|
|
|
fn test_timespec() {
|
|
|
|
let db = checked_memory_handle();
|
|
|
|
|
|
|
|
let ts = time::Timespec {
|
|
|
|
sec: 10_000,
|
|
|
|
nsec: 0,
|
|
|
|
};
|
2017-04-08 01:43:24 +08:00
|
|
|
db.execute("INSERT INTO foo(t) VALUES (?)", &[&ts])
|
|
|
|
.unwrap();
|
2016-02-26 01:44:53 +08:00
|
|
|
|
2017-04-08 01:43:24 +08:00
|
|
|
let from: time::Timespec = db.query_row("SELECT t FROM foo", &[], |r| r.get(0))
|
|
|
|
.unwrap();
|
2016-02-26 01:44:53 +08:00
|
|
|
assert_eq!(from, ts);
|
|
|
|
}
|
|
|
|
}
|