Implement TTL column definition

Author: davimi

dbt/adapters/clickhouse/impl.py

@@ -541,12 +541,13 @@ def get_credentials(self, connection_overrides) -> Dict:
         return credentials
 
     @classmethod
-    def render_raw_columns_constraints(cls, raw_columns: Dict[str, Dict[str, Any]]) -> List:
+    def render_raw_columns_constraints(cls, raw_columns: Dict[str, Dict[str, Any]]) -> List[str]:
         rendered_columns = []
         for v in raw_columns.values():
             codec = f"CODEC({_codec})" if (_codec := v.get('codec')) else ""
+            ttl = f"TTL {_ttl}" if (_ttl := v.get('ttl')) else ""
             rendered_columns.append(
-                f"{quote_identifier(v['name'])} {v['data_type']} {codec}".rstrip()
+                f"{quote_identifier(v['name'])} {v['data_type']} {codec} {ttl}".rstrip()
             )
             if v.get("constraints"):
                 warn_or_error(ConstraintNotSupported(constraint='column', adapter='clickhouse'))

tests/integration/adapter/column_ttl/fixtures_column_ttl.py

@@ -0,0 +1,27 @@
+column_ttl_model_yml = """
+version: 2
+models:
+  - name: column_ttl_model
+    config:
+      contract:
+        enforced: true
+    columns:
+      - name: datetime_col
+        data_type: DateTime
+      - name: id
+        data_type: UInt32
+        ttl: toStartOfDay(datetime_col) + INTERVAL 1 DAY
+"""
+
+
+column_ttl_model_sql = """
+{{
+  config(
+    materialized = "table"
+  )
+}}
+
+select
+  now() as datetime_col,
+  1::UInt32 as id
+"""

tests/integration/adapter/column_ttl/test_column_ttl.py

@@ -0,0 +1,24 @@
+import pytest
+from dbt.tests.util import get_manifest, run_dbt
+from fixtures_column_ttl import (
+    column_ttl_model_yml,
+    column_ttl_model_sql
+)
+
+
+class TestTtlColumn:
+    @pytest.fixture(scope="class")
+    def models(self):
+        return {
+            "column_ttl_model.yml": column_ttl_model_yml,
+            "column_ttl_model.sql": column_ttl_model_sql
+        }
+
+    def test_ttl_column(self, project):
+        run_dbt(["run", "-s", "column_ttl_model"], expect_pass=True)
+        manifest = get_manifest(project.project_root)
+        model_id = "model.test.column_ttl_model"
+        id_column_config = manifest.nodes[model_id].columns.get("id")
+        assert id_column_config._extra.get("ttl") == "toStartOfDay(datetime_col) + INTERVAL 1 DAY"
+
+