[DOP-28169] MySQL database name is optional

Author: dolfinus

syncmaster/dto/connections.py

@@ -1,6 +1,6 @@
 # SPDX-FileCopyrightText: 2023-2024 MTS PJSC
 # SPDX-License-Identifier: Apache-2.0
-from dataclasses import dataclass
+from dataclasses import dataclass, field
 from typing import ClassVar, Literal
 
 
@@ -15,8 +15,8 @@ class PostgresConnectionDTO(ConnectionDTO):
     port: int
     user: str
     password: str
-    additional_params: dict
     database_name: str
+    additional_params: dict = field(default_factory=dict)
     type: ClassVar[str] = "postgres"
 
 
@@ -26,8 +26,8 @@ class ClickhouseConnectionDTO(ConnectionDTO):
     port: int
     user: str
     password: str
-    database_name: str
-    additional_params: dict
+    database_name: str | None = None
+    additional_params: dict = field(default_factory=dict)
     type: ClassVar[str] = "clickhouse"
 
 
@@ -38,7 +38,7 @@ class MSSQLConnectionDTO(ConnectionDTO):
     user: str
     password: str
     database_name: str
-    additional_params: dict
+    additional_params: dict = field(default_factory=dict)
     type: ClassVar[str] = "mssql"
 
 
@@ -48,8 +48,8 @@ class MySQLConnectionDTO(ConnectionDTO):
     port: int
     user: str
     password: str
-    database_name: str
-    additional_params: dict
+    database_name: str | None = None
+    additional_params: dict = field(default_factory=dict)
     type: ClassVar[str] = "mysql"
 
 
@@ -59,7 +59,7 @@ class OracleConnectionDTO(ConnectionDTO):
     port: int
     user: str
     password: str
-    additional_params: dict
+    additional_params: dict = field(default_factory=dict)
     sid: str | None = None
     service_name: str | None = None
     type: ClassVar[str] = "oracle"
@@ -91,7 +91,7 @@ class IcebergRESTCatalogS3DirectConnectionBaseDTO(IcebergConnectionBaseDTO):
     s3_secret_key: str
     s3_port: int | None
     s3_protocol: str
-    s3_additional_params: dict
+    s3_additional_params: dict = field(default_factory=dict)
     implementation: ClassVar[str] = "iceberg_rest_s3_direct"
 
 
@@ -175,7 +175,7 @@ class S3ConnectionDTO(ConnectionDTO):
     secret_key: str
     bucket: str
     bucket_style: Literal["domain", "path"]
-    additional_params: dict
+    additional_params: dict = field(default_factory=dict)
     region: str | None = None
     protocol: str = "https"
     type: ClassVar[str] = "s3"
@@ -212,9 +212,9 @@ class FTPSConnectionDTO(ConnectionDTO):
 class SambaConnectionDTO(ConnectionDTO):
     host: str
     share: str
-    protocol: Literal["SMB", "NetBIOS"]
     user: str
     password: str
+    protocol: Literal["SMB", "NetBIOS"] = "SMB"
     auth_type: Literal["NTLMv1", "NTLMv2"] = "NTLMv2"
     domain: str = ""
     port: int | None = None

syncmaster/schemas/v1/connections/mysql.py

@@ -17,7 +17,7 @@
 class MySQLConnectionDataSchema(BaseModel):
     host: str
     port: int = Field(default=3306, gt=0, le=65535)  # noqa: WPS432
-    database_name: str
+    database_name: str | None = None
     additional_params: dict = Field(default_factory=dict)
 
 

syncmaster/schemas/v1/transfers/resources.py

@@ -2,16 +2,13 @@
 # SPDX-License-Identifier: Apache-2.0
 from pydantic import BaseModel, ByteSize, Field
 
-ONE_MB = 2**20  # noqa: WPS432
-ONE_GB = 2**30  # noqa: WPS432
-
 
 class Resources(BaseModel):
     max_parallel_tasks: int = Field(default=1, ge=1, le=100, description="Parallel executors")
     cpu_cores_per_task: int = Field(default=1, ge=1, le=32, description="Cores per executor")  # noqa: WPS432
     ram_bytes_per_task: ByteSize = Field(  # type: ignore[arg-type]
-        default=ONE_GB,
-        ge=512 * ONE_MB,  # noqa: WPS432
-        le=64 * ONE_GB,  # noqa: WPS432
+        default="1GiB",
+        ge="512MiB",  # noqa: WPS432
+        le="64GiB",  # noqa: WPS432
         description="RAM per executor",
     )

tests/settings.py

@@ -50,7 +50,7 @@ class TestSettings(BaseSettings):
     TEST_MYSQL_PORT_FOR_WORKER: int
     TEST_MYSQL_USER: str
     TEST_MYSQL_PASSWORD: str
-    TEST_MYSQL_DB: str
+    TEST_MYSQL_DB: str | None = None
     TEST_MYSQL_ADDITIONAL_PARAMS: dict = {}
 
     TEST_HIVE_CLUSTER: str