[DOP-19896] Add Clickhouse API schema

Author: Ilyas Gasanov

syncmaster/backend/api/v1/connections.py

@@ -18,6 +18,7 @@
 from syncmaster.exceptions.credentials import AuthDataNotFoundError
 from syncmaster.exceptions.group import GroupNotFoundError
 from syncmaster.schemas.v1.connection_types import (
+    CLICKHOUSE_TYPE,
     HDFS_TYPE,
     HIVE_TYPE,
     ORACLE_TYPE,
@@ -37,7 +38,7 @@
 
 router = APIRouter(tags=["Connections"], responses=get_error_responses())
 
-CONNECTION_TYPES = ORACLE_TYPE, POSTGRES_TYPE, HIVE_TYPE, S3_TYPE, HDFS_TYPE
+CONNECTION_TYPES = ORACLE_TYPE, POSTGRES_TYPE, CLICKHOUSE_TYPE, HIVE_TYPE, S3_TYPE, HDFS_TYPE
 
 
 @router.get("/connections")

tests/test_unit/test_connections/test_create_connection.py

@@ -282,7 +282,7 @@ async def test_check_fields_validation_on_create_connection(
                     "context": {
                         "discriminator": "'type'",
                         "tag": "POSTGRESQL",
-                        "expected_tags": "'hive', 'oracle', 'postgres', 'hdfs', 's3'",
+                        "expected_tags": "'hive', 'oracle', 'postgres', 'clickhouse', 'hdfs', 's3'",
                     },
                     "input": {
                         "type": "POSTGRESQL",
@@ -292,7 +292,7 @@ async def test_check_fields_validation_on_create_connection(
                         "database_name": "postgres",
                     },
                     "location": ["body", "connection_data"],
-                    "message": "Input tag 'POSTGRESQL' found using 'type' does not match any of the expected tags: 'hive', 'oracle', 'postgres', 'hdfs', 's3'",
+                    "message": "Input tag 'POSTGRESQL' found using 'type' does not match any of the expected tags: 'hive', 'oracle', 'postgres', 'clickhouse', 'hdfs', 's3'",
                     "code": "union_tag_invalid",
                 },
             ],

tests/test_unit/test_transfers/transfer_fixtures/transfers_fixture.py

@@ -76,7 +76,12 @@ async def group_transfers(
             source_params["directory_path"] = "/path/to/source"
             target_params.update(common_params)
             target_params["directory_path"] = "/path/to/target"
-        elif connection_type in [ConnectionType.HIVE, ConnectionType.POSTGRES, ConnectionType.ORACLE]:
+        elif connection_type in [
+            ConnectionType.HIVE,
+            ConnectionType.POSTGRES,
+            ConnectionType.ORACLE,
+            ConnectionType.CLICKHOUSE,
+        ]:
             source_params["table_name"] = "source_table"
             target_params["table_name"] = "target_table"