| //! Convert most of the [Time Strings](http://sqlite.org/lang_datefunc.html) to chrono types. |
| |
| use std::borrow::Cow; |
| |
| use chrono::{DateTime, Local, NaiveDate, NaiveDateTime, NaiveTime, TimeZone, Utc}; |
| |
| use crate::types::{FromSql, FromSqlError, FromSqlResult, ToSql, ToSqlOutput, ValueRef}; |
| use crate::Result; |
| |
| /// ISO 8601 calendar date without timezone => "YYYY-MM-DD" |
| impl ToSql for NaiveDate { |
| fn to_sql(&self) -> Result<ToSqlOutput<'_>> { |
| let date_str = self.format("%Y-%m-%d").to_string(); |
| Ok(ToSqlOutput::from(date_str)) |
| } |
| } |
| |
| /// "YYYY-MM-DD" => ISO 8601 calendar date without timezone. |
| impl FromSql for NaiveDate { |
| fn column_result(value: ValueRef<'_>) -> FromSqlResult<Self> { |
| value |
| .as_str() |
| .and_then(|s| match NaiveDate::parse_from_str(s, "%Y-%m-%d") { |
| Ok(dt) => Ok(dt), |
| Err(err) => Err(FromSqlError::Other(Box::new(err))), |
| }) |
| } |
| } |
| |
| /// ISO 8601 time without timezone => "HH:MM:SS.SSS" |
| impl ToSql for NaiveTime { |
| fn to_sql(&self) -> Result<ToSqlOutput<'_>> { |
| let date_str = self.format("%H:%M:%S%.f").to_string(); |
| Ok(ToSqlOutput::from(date_str)) |
| } |
| } |
| |
| /// "HH:MM"/"HH:MM:SS"/"HH:MM:SS.SSS" => ISO 8601 time without timezone. |
| impl FromSql for NaiveTime { |
| fn column_result(value: ValueRef<'_>) -> FromSqlResult<Self> { |
| value.as_str().and_then(|s| { |
| let fmt = match s.len() { |
| 5 => "%H:%M", |
| 8 => "%H:%M:%S", |
| _ => "%H:%M:%S%.f", |
| }; |
| match NaiveTime::parse_from_str(s, fmt) { |
| Ok(dt) => Ok(dt), |
| Err(err) => Err(FromSqlError::Other(Box::new(err))), |
| } |
| }) |
| } |
| } |
| |
| /// ISO 8601 combined date and time without timezone => |
| /// "YYYY-MM-DDTHH:MM:SS.SSS" |
| impl ToSql for NaiveDateTime { |
| fn to_sql(&self) -> Result<ToSqlOutput<'_>> { |
| let date_str = self.format("%Y-%m-%dT%H:%M:%S%.f").to_string(); |
| Ok(ToSqlOutput::from(date_str)) |
| } |
| } |
| |
| /// "YYYY-MM-DD HH:MM:SS"/"YYYY-MM-DD HH:MM:SS.SSS" => ISO 8601 combined date |
| /// and time without timezone. ("YYYY-MM-DDTHH:MM:SS"/"YYYY-MM-DDTHH:MM:SS.SSS" |
| /// also supported) |
| impl FromSql for NaiveDateTime { |
| fn column_result(value: ValueRef<'_>) -> FromSqlResult<Self> { |
| value.as_str().and_then(|s| { |
| let fmt = if s.len() >= 11 && s.as_bytes()[10] == b'T' { |
| "%Y-%m-%dT%H:%M:%S%.f" |
| } else { |
| "%Y-%m-%d %H:%M:%S%.f" |
| }; |
| |
| match NaiveDateTime::parse_from_str(s, fmt) { |
| Ok(dt) => Ok(dt), |
| Err(err) => Err(FromSqlError::Other(Box::new(err))), |
| } |
| }) |
| } |
| } |
| |
| /// Date and time with time zone => UTC RFC3339 timestamp |
| /// ("YYYY-MM-DDTHH:MM:SS.SSS+00:00"). |
| impl<Tz: TimeZone> ToSql for DateTime<Tz> { |
| fn to_sql(&self) -> Result<ToSqlOutput<'_>> { |
| Ok(ToSqlOutput::from(self.with_timezone(&Utc).to_rfc3339())) |
| } |
| } |
| |
| /// RFC3339 ("YYYY-MM-DDTHH:MM:SS.SSS[+-]HH:MM") into `DateTime<Utc>`. |
| impl FromSql for DateTime<Utc> { |
| fn column_result(value: ValueRef<'_>) -> FromSqlResult<Self> { |
| { |
| // Try to parse value as rfc3339 first. |
| let s = value.as_str()?; |
| |
| // If timestamp looks space-separated, make a copy and replace it with 'T'. |
| let s = if s.len() >= 11 && s.as_bytes()[10] == b' ' { |
| let mut s = s.to_string(); |
| unsafe { |
| let sbytes = s.as_mut_vec(); |
| sbytes[10] = b'T'; |
| } |
| Cow::Owned(s) |
| } else { |
| Cow::Borrowed(s) |
| }; |
| |
| if let Ok(dt) = DateTime::parse_from_rfc3339(&s) { |
| return Ok(dt.with_timezone(&Utc)); |
| } |
| } |
| |
| // Couldn't parse as rfc3339 - fall back to NaiveDateTime. |
| NaiveDateTime::column_result(value).map(|dt| Utc.from_utc_datetime(&dt)) |
| } |
| } |
| |
| /// RFC3339 ("YYYY-MM-DDTHH:MM:SS.SSS[+-]HH:MM") into `DateTime<Local>`. |
| impl FromSql for DateTime<Local> { |
| fn column_result(value: ValueRef<'_>) -> FromSqlResult<Self> { |
| let utc_dt = DateTime::<Utc>::column_result(value)?; |
| Ok(utc_dt.with_timezone(&Local)) |
| } |
| } |
| |
| #[cfg(test)] |
| mod test { |
| use crate::{Connection, Result, NO_PARAMS}; |
| use chrono::{DateTime, Duration, Local, NaiveDate, NaiveDateTime, NaiveTime, TimeZone, Utc}; |
| |
| fn checked_memory_handle() -> Connection { |
| let db = Connection::open_in_memory().unwrap(); |
| db.execute_batch("CREATE TABLE foo (t TEXT, i INTEGER, f FLOAT, b BLOB)") |
| .unwrap(); |
| db |
| } |
| |
| #[test] |
| fn test_naive_date() { |
| let db = checked_memory_handle(); |
| let date = NaiveDate::from_ymd(2016, 2, 23); |
| db.execute("INSERT INTO foo (t) VALUES (?)", &[&date]) |
| .unwrap(); |
| |
| let s: String = db |
| .query_row("SELECT t FROM foo", NO_PARAMS, |r| r.get(0)) |
| .unwrap(); |
| assert_eq!("2016-02-23", s); |
| let t: NaiveDate = db |
| .query_row("SELECT t FROM foo", NO_PARAMS, |r| r.get(0)) |
| .unwrap(); |
| assert_eq!(date, t); |
| } |
| |
| #[test] |
| fn test_naive_time() { |
| let db = checked_memory_handle(); |
| let time = NaiveTime::from_hms(23, 56, 4); |
| db.execute("INSERT INTO foo (t) VALUES (?)", &[&time]) |
| .unwrap(); |
| |
| let s: String = db |
| .query_row("SELECT t FROM foo", NO_PARAMS, |r| r.get(0)) |
| .unwrap(); |
| assert_eq!("23:56:04", s); |
| let v: NaiveTime = db |
| .query_row("SELECT t FROM foo", NO_PARAMS, |r| r.get(0)) |
| .unwrap(); |
| assert_eq!(time, v); |
| } |
| |
| #[test] |
| fn test_naive_date_time() { |
| let db = checked_memory_handle(); |
| let date = NaiveDate::from_ymd(2016, 2, 23); |
| let time = NaiveTime::from_hms(23, 56, 4); |
| let dt = NaiveDateTime::new(date, time); |
| |
| db.execute("INSERT INTO foo (t) VALUES (?)", &[&dt]) |
| .unwrap(); |
| |
| let s: String = db |
| .query_row("SELECT t FROM foo", NO_PARAMS, |r| r.get(0)) |
| .unwrap(); |
| assert_eq!("2016-02-23T23:56:04", s); |
| let v: NaiveDateTime = db |
| .query_row("SELECT t FROM foo", NO_PARAMS, |r| r.get(0)) |
| .unwrap(); |
| assert_eq!(dt, v); |
| |
| db.execute("UPDATE foo set b = datetime(t)", NO_PARAMS) |
| .unwrap(); // "YYYY-MM-DD HH:MM:SS" |
| let hms: NaiveDateTime = db |
| .query_row("SELECT b FROM foo", NO_PARAMS, |r| r.get(0)) |
| .unwrap(); |
| assert_eq!(dt, hms); |
| } |
| |
| #[test] |
| fn test_date_time_utc() { |
| let db = checked_memory_handle(); |
| let date = NaiveDate::from_ymd(2016, 2, 23); |
| let time = NaiveTime::from_hms_milli(23, 56, 4, 789); |
| let dt = NaiveDateTime::new(date, time); |
| let utc = Utc.from_utc_datetime(&dt); |
| |
| db.execute("INSERT INTO foo (t) VALUES (?)", &[&utc]) |
| .unwrap(); |
| |
| let s: String = db |
| .query_row("SELECT t FROM foo", NO_PARAMS, |r| r.get(0)) |
| .unwrap(); |
| assert_eq!("2016-02-23T23:56:04.789+00:00", s); |
| |
| let v1: DateTime<Utc> = db |
| .query_row("SELECT t FROM foo", NO_PARAMS, |r| r.get(0)) |
| .unwrap(); |
| assert_eq!(utc, v1); |
| |
| let v2: DateTime<Utc> = db |
| .query_row("SELECT '2016-02-23 23:56:04.789'", NO_PARAMS, |r| r.get(0)) |
| .unwrap(); |
| assert_eq!(utc, v2); |
| |
| let v3: DateTime<Utc> = db |
| .query_row("SELECT '2016-02-23 23:56:04'", NO_PARAMS, |r| r.get(0)) |
| .unwrap(); |
| assert_eq!(utc - Duration::milliseconds(789), v3); |
| |
| let v4: DateTime<Utc> = db |
| .query_row("SELECT '2016-02-23 23:56:04.789+00:00'", NO_PARAMS, |r| { |
| r.get(0) |
| }) |
| .unwrap(); |
| assert_eq!(utc, v4); |
| } |
| |
| #[test] |
| fn test_date_time_local() { |
| let db = checked_memory_handle(); |
| let date = NaiveDate::from_ymd(2016, 2, 23); |
| let time = NaiveTime::from_hms_milli(23, 56, 4, 789); |
| let dt = NaiveDateTime::new(date, time); |
| let local = Local.from_local_datetime(&dt).single().unwrap(); |
| |
| db.execute("INSERT INTO foo (t) VALUES (?)", &[&local]) |
| .unwrap(); |
| |
| // Stored string should be in UTC |
| let s: String = db |
| .query_row("SELECT t FROM foo", NO_PARAMS, |r| r.get(0)) |
| .unwrap(); |
| assert!(s.ends_with("+00:00")); |
| |
| let v: DateTime<Local> = db |
| .query_row("SELECT t FROM foo", NO_PARAMS, |r| r.get(0)) |
| .unwrap(); |
| assert_eq!(local, v); |
| } |
| |
| #[test] |
| fn test_sqlite_functions() { |
| let db = checked_memory_handle(); |
| let result: Result<NaiveTime> = |
| db.query_row("SELECT CURRENT_TIME", NO_PARAMS, |r| r.get(0)); |
| assert!(result.is_ok()); |
| let result: Result<NaiveDate> = |
| db.query_row("SELECT CURRENT_DATE", NO_PARAMS, |r| r.get(0)); |
| assert!(result.is_ok()); |
| let result: Result<NaiveDateTime> = |
| db.query_row("SELECT CURRENT_TIMESTAMP", NO_PARAMS, |r| r.get(0)); |
| assert!(result.is_ok()); |
| let result: Result<DateTime<Utc>> = |
| db.query_row("SELECT CURRENT_TIMESTAMP", NO_PARAMS, |r| r.get(0)); |
| assert!(result.is_ok()); |
| } |
| } |