summaryrefslogtreecommitdiffstats
path: root/sqlglot/dialects/doris.py
diff options
context:
space:
mode:
Diffstat (limited to 'sqlglot/dialects/doris.py')
-rw-r--r--sqlglot/dialects/doris.py65
1 files changed, 65 insertions, 0 deletions
diff --git a/sqlglot/dialects/doris.py b/sqlglot/dialects/doris.py
new file mode 100644
index 0000000..160c23c
--- /dev/null
+++ b/sqlglot/dialects/doris.py
@@ -0,0 +1,65 @@
+from __future__ import annotations
+
+from sqlglot import exp
+from sqlglot.dialects.dialect import (
+ approx_count_distinct_sql,
+ arrow_json_extract_sql,
+ parse_timestamp_trunc,
+ rename_func,
+ time_format,
+)
+from sqlglot.dialects.mysql import MySQL
+
+
+class Doris(MySQL):
+ DATE_FORMAT = "'yyyy-MM-dd'"
+ DATEINT_FORMAT = "'yyyyMMdd'"
+ TIME_FORMAT = "'yyyy-MM-dd HH:mm:ss'"
+
+ class Parser(MySQL.Parser):
+ FUNCTIONS = {
+ **MySQL.Parser.FUNCTIONS,
+ "DATE_TRUNC": parse_timestamp_trunc,
+ "REGEXP": exp.RegexpLike.from_arg_list,
+ }
+
+ class Generator(MySQL.Generator):
+ CAST_MAPPING = {}
+
+ TYPE_MAPPING = {
+ **MySQL.Generator.TYPE_MAPPING,
+ exp.DataType.Type.TEXT: "STRING",
+ exp.DataType.Type.TIMESTAMP: "DATETIME",
+ exp.DataType.Type.TIMESTAMPTZ: "DATETIME",
+ }
+
+ TRANSFORMS = {
+ **MySQL.Generator.TRANSFORMS,
+ exp.ApproxDistinct: approx_count_distinct_sql,
+ exp.ArrayAgg: rename_func("COLLECT_LIST"),
+ exp.Coalesce: rename_func("NVL"),
+ exp.CurrentTimestamp: lambda *_: "NOW()",
+ exp.DateTrunc: lambda self, e: self.func(
+ "DATE_TRUNC", e.this, "'" + e.text("unit") + "'"
+ ),
+ exp.JSONExtractScalar: arrow_json_extract_sql,
+ exp.JSONExtract: arrow_json_extract_sql,
+ exp.RegexpLike: rename_func("REGEXP"),
+ exp.RegexpSplit: rename_func("SPLIT_BY_STRING"),
+ exp.SetAgg: rename_func("COLLECT_SET"),
+ exp.StrToUnix: lambda self, e: f"UNIX_TIMESTAMP({self.sql(e, 'this')}, {self.format_time(e)})",
+ exp.Split: rename_func("SPLIT_BY_STRING"),
+ exp.TimeStrToDate: rename_func("TO_DATE"),
+ exp.ToChar: lambda self, e: f"DATE_FORMAT({self.sql(e, 'this')}, {self.format_time(e)})",
+ exp.TsOrDsAdd: lambda self, e: f"DATE_ADD({self.sql(e, 'this')}, {self.sql(e, 'expression')})", # Only for day level
+ exp.TsOrDsToDate: lambda self, e: self.func("TO_DATE", e.this),
+ exp.TimeToUnix: rename_func("UNIX_TIMESTAMP"),
+ exp.TimestampTrunc: lambda self, e: self.func(
+ "DATE_TRUNC", e.this, "'" + e.text("unit") + "'"
+ ),
+ exp.UnixToStr: lambda self, e: self.func(
+ "FROM_UNIXTIME", e.this, time_format("doris")(self, e)
+ ),
+ exp.UnixToTime: rename_func("FROM_UNIXTIME"),
+ exp.Map: rename_func("ARRAY_MAP"),
+ }