tesseract implementation

Author: waralexrom

packages/cubejs-schema-compiler/src/adapter/BaseQuery.js

@@ -3916,6 +3916,7 @@ export class BaseQuery {
         like_escape: '{{ like_expr }} ESCAPE {{ escape_char }}',
         within_group: '{{ fun_sql }} WITHIN GROUP (ORDER BY {{ within_group_concat }})',
         concat_strings: '{{ strings | join(\' || \' ) }}',
+        rolling_window_expr_timestamp_cast: '{{ value }}'
       },
       tesseract: {
         ilike: '{{ expr }} {% if negated %}NOT {% endif %}ILIKE {{ pattern }}', // May require different overloads in Tesseract than the ilike from expressions used in SQLAPI.

packages/cubejs-schema-compiler/src/adapter/BigqueryQuery.ts

@@ -348,6 +348,7 @@ export class BigqueryQuery extends BaseQuery {
     templates.expressions.interval = 'INTERVAL {{ interval }}';
     templates.expressions.extract = 'EXTRACT({% if date_part == \'DOW\' %}DAYOFWEEK{% elif date_part == \'DOY\' %}DAYOFYEAR{% else %}{{ date_part }}{% endif %} FROM {{ expr }})';
     templates.expressions.timestamp_literal = 'TIMESTAMP(\'{{ value }}\')';
+    templates.expressions.rolling_window_expr_timestamp_cast = 'TIMESTAMP({{ value }})';
     delete templates.expressions.ilike;
     delete templates.expressions.like_escape;
     templates.filters.like_pattern = 'CONCAT({% if start_wild %}\'%\'{% else %}\'\'{% endif %}, LOWER({{ value }}), {% if end_wild %}\'%\'{% else %}\'\'{% endif %})';

rust/cubesqlplanner/cubesqlplanner/src/plan/join.rs

@@ -57,6 +57,7 @@ impl RegularRollingWindowJoinCondition {
                 start_date
             };
 
+            let trailing_start = templates.rolling_window_expr_timestamp_cast(&trailing_start)?;
             let sign = if self.offset == "start" { ">=" } else { ">" };
 
             conditions.push(format!("{date_column} {sign} {trailing_start}"));
@@ -75,6 +76,7 @@ impl RegularRollingWindowJoinCondition {
                 end_date
             };
 
+            let leading_end = templates.rolling_window_expr_timestamp_cast(&leading_end)?;
             let sign = if self.offset == "end" { "<=" } else { "<" };
 
             conditions.push(format!("{date_column} {sign} {leading_end}"));
@@ -109,6 +111,7 @@ impl RollingTotalJoinCondition {
         let date_column = self.time_dimension.to_sql(templates, context)?;
         let date_to =
             templates.column_reference(&Some(self.time_series_source.clone()), "date_to")?;
+        let date_to = templates.rolling_window_expr_timestamp_cast(&date_to)?;
         let result = format!("{date_column} <= {date_to}");
         Ok(result)
     }
@@ -146,6 +149,8 @@ impl ToDateRollingWindowJoinCondition {
             templates.column_reference(&Some(self.time_series_source.clone()), "date_to")?;
         let date_to =
             templates.column_reference(&Some(self.time_series_source.clone()), "date_from")?;
+        let date_from = templates.rolling_window_expr_timestamp_cast(&date_from)?;
+        let date_to = templates.rolling_window_expr_timestamp_cast(&date_to)?;
         let grouped_from = templates.time_grouped_column(self.granularity.clone(), date_from)?;
         let result = format!("{date_column} >= {grouped_from} and {date_column} <= {date_to}");
         Ok(result)

rust/cubesqlplanner/cubesqlplanner/src/planner/filter/base_filter.rs

@@ -397,6 +397,8 @@ impl BaseFilter {
     ) -> Result<(String, String), CubeError> {
         let from_expr = format!("min({})", plan_templates.quote_identifier("date_from")?);
         let to_expr = format!("max({})", plan_templates.quote_identifier("date_to")?);
+        let from_expr = plan_templates.time_stamp_cast(from_expr)?;
+        let to_expr = plan_templates.time_stamp_cast(to_expr)?;
         let alias = format!("value");
         let time_series_cte_name = format!("time_series"); // FIXME May be should be passed as parameter
 

rust/cubesqlplanner/cubesqlplanner/src/planner/sql_templates/plan.rs

@@ -702,4 +702,13 @@ impl PlanSqlTemplates {
             },
         )
     }
+    pub fn rolling_window_expr_timestamp_cast(&self, value: &str) -> Result<String, CubeError> {
+        self.render.render_template(
+            &"expressions/rolling_window_expr_timestamp_cast",
+            context! {
+                value => value
+
+            },
+        )
+    }
 }