diff --git a/sqlx-core/src/mysql/types/chrono.rs b/sqlx-core/src/mysql/types/chrono.rs index da84c4ea..c14411df 100644 --- a/sqlx-core/src/mysql/types/chrono.rs +++ b/sqlx-core/src/mysql/types/chrono.rs @@ -78,6 +78,13 @@ impl<'r> Decode<'r, MySql> for NaiveTime { // data length, expecting 8 or 12 (fractional seconds) let len = buf.get_u8(); + // MySQL specifies that if all of hours, minutes, seconds, microseconds + // are 0 then the length is 0 and no further data is send + // https://dev.mysql.com/doc/internals/en/binary-protocol-value.html + if len == 0 { + return Ok(NaiveTime::from_hms_micro(0, 0, 0, 0)); + } + // is negative : int<1> let is_negative = buf.get_u8(); debug_assert_eq!(is_negative, 0, "Negative dates/times are not supported"); diff --git a/sqlx-core/src/mysql/types/time.rs b/sqlx-core/src/mysql/types/time.rs index 7ce89174..26b1b328 100644 --- a/sqlx-core/src/mysql/types/time.rs +++ b/sqlx-core/src/mysql/types/time.rs @@ -83,6 +83,13 @@ impl<'r> Decode<'r, MySql> for Time { // data length, expecting 8 or 12 (fractional seconds) let len = buf.get_u8(); + // MySQL specifies that if all of hours, minutes, seconds, microseconds + // are 0 then the length is 0 and no further data is send + // https://dev.mysql.com/doc/internals/en/binary-protocol-value.html + if len == 0 { + return Ok(Time::try_from_hms_micro(0, 0, 0, 0).unwrap()); + } + // is negative : int<1> let is_negative = buf.get_u8(); assert_eq!(is_negative, 0, "Negative dates/times are not supported"); diff --git a/tests/mysql/types.rs b/tests/mysql/types.rs index 3219c45d..bebe6e89 100644 --- a/tests/mysql/types.rs +++ b/tests/mysql/types.rs @@ -49,6 +49,11 @@ mod chrono { "DATE '2050-11-23'" == NaiveDate::from_ymd(2050, 11, 23) )); + test_type!(chrono_time_zero( + MySql, + "TIME '00:00:00.000000'" == NaiveTime::from_hms_micro(0, 0, 0, 0) + )); + test_type!(chrono_time( MySql, "TIME '05:10:20.115100'" == NaiveTime::from_hms_micro(5, 10, 20, 115100) @@ -81,6 +86,11 @@ mod time_tests { "DATE '2050-11-23'" == date!(2050 - 11 - 23) )); + test_type!(time_time_zero