fix(query): interval total microseconds add overflow check (#17215)

src/common/column/Cargo.toml

@@ -33,6 +33,7 @@ either = { workspace = true }
 ethnum = { workspace = true }
 foreign_vec = { workspace = true }
 hex = { workspace = true }
+log = { workspace = true }
 match-template = { workspace = true }
 num-traits = { workspace = true }
 serde = { workspace = true, features = ["rc"], optional = true }

src/common/column/src/types/native.rs

@@ -25,6 +25,7 @@ use borsh::BorshSerialize;
 use bytemuck::Pod;
 use bytemuck::Zeroable;
 use databend_common_base::base::OrderedFloat;
+use log::error;
 use serde_derive::Deserialize;
 use serde_derive::Serialize;
 
@@ -319,9 +320,21 @@ impl months_days_micros {
     }
 
     pub fn total_micros(&self) -> i64 {
-        (self.months() as i64 * MICROS_PER_MONTH)
-            + (self.days() as i64 * MICROS_PER_DAY)
-            + self.microseconds()
+        let months_micros = (self.months() as i64).checked_mul(MICROS_PER_MONTH);
+        let days_micros = (self.days() as i64).checked_mul(MICROS_PER_DAY);
+
+        months_micros
+            .and_then(|months_micros| days_micros.map(|days_micros| months_micros + days_micros))
+            .and_then(|total_micros| total_micros.checked_add(self.microseconds()))
+            .unwrap_or_else(|| {
+                error!(
+                    "interval is out of range: months={}, days={}, micros={}",
+                    self.months(),
+                    self.days(),
+                    self.microseconds()
+                );
+                0
+            })
     }
 }
 

tests/sqllogictests/suites/query/functions/02_0079_function_interval.test

@@ -142,3 +142,15 @@ query T
 SELECT to_years(10);
 ----
 10 years
+
+onlyif http
+query T
+select to_interval('1200000000 months');
+----
+100000000 years
+
+onlyif http
+query T
+select to_interval('120000000000 months');
+----
+00:00:00