add clickhouse migrations and small example of migration

Author: danuiachimovschi

.env

@@ -45,3 +45,8 @@ DATABASE_URL="postgresql://user:password@db:5432/app_db?serverVersion=16&charset
 # SCHEMA SCHEMA REGISTRY URL FOR AVRO SCHEMA REGISTRY
 # SCHEMA_REGISTRY_URL=http://localhost:8081
 SCHEMA_REGISTRY_URL=schema-registry:8081
+
+CLICKHOUSE_HOST=clickhouse
+CLICKHOUSE_PORT=8123
+CLICKHOUSE_USERNAME=default
+CLICKHOUSE_PASSWORD=

.env.dev

@@ -24,3 +24,10 @@ DATABASE_URL="postgresql://user:password@localhost:5432/app_db_dev?serverVersion
 # Use a local schema registry for development
 SCHEMA_REGISTRY_URL=schema-registry:8081
 ###< Avro Schema Registry ###
+
+###> ClickHouse ###
+# Use a local ClickHouse for development
+CLICKHOUSE_HOST=clickhouse
+CLICKHOUSE_PORT=8123
+CLICKHOUSE_USERNAME=default
+CLICKHOUSE_PASSWORD=

clickhousetest.php

@@ -20,6 +20,7 @@
         "jobcloud/avro-validator": "^2.1",
         "jobcloud/php-kafka-lib": "^2.0",
         "league/csv": "^9.21.0",
+        "mavlitov98/clickhouse-migrations": "^1.0",
         "php-amqplib/php-amqplib": "^3.7",
         "predis/predis": "^2.3",
         "promphp/prometheus_client_php": "^2.13.1",

composer.json

@@ -5,4 +5,5 @@
     Symfony\Bundle\MakerBundle\MakerBundle::class => ['dev' => true],
     Doctrine\Bundle\DoctrineBundle\DoctrineBundle::class => ['all' => true],
     Doctrine\Bundle\MigrationsBundle\DoctrineMigrationsBundle::class => ['all' => true],
+    ClickhouseMigrations\ClickhouseMigrationsBundle::class => ['all' => true],
 ];

composer.lock

@@ -0,0 +1,9 @@
+clickhouse_migrations:
+  connection:
+    host: '%env(CLICKHOUSE_HOST)%'
+    port: '%env(CLICKHOUSE_PORT)%'
+    username: '%env(CLICKHOUSE_USERNAME)%'
+    password: '%env(CLICKHOUSE_PASSWORD)%'
+  clickhouse_migrations_version_table: 'ch_migrations'
+  clickhouse_migrations_path: '%kernel.project_dir%/src/Migrations/Clickhouse'
+  clickhouse_migrations_namespace: 'App\Migrations\Clickhouse'

config/bundles.php

@@ -0,0 +1,28 @@
+<?php
+
+declare(strict_types=1);
+
+namespace App\Migrations\Clickhouse;
+
+use ClickHouseDB\Client;
+use ClickhouseMigrations\AbstractClickhouseMigration;
+
+final class Version20250207193422 extends AbstractClickhouseMigration
+{
+    public function up(Client $client): void
+    {
+        $client->write(
+            <<<CLICKHOUSE
+            CREATE TABLE IF NOT EXISTS events
+            (
+                id UUID,
+                event_name String,
+                event_data String,
+                created_at DateTime
+            ) 
+            ENGINE = MergeTree()
+            ORDER BY (created_at)
+            CLICKHOUSE,
+        );
+    }
+}

config/packages/clickhouse_migrations.yaml

@@ -47,6 +47,9 @@
             ".php-cs-fixer.dist.php"
         ]
     },
+    "mavlitov98/clickhouse-migrations": {
+        "version": "v1.0.0"
+    },
     "php-cs-fixer/shim": {
         "version": "3.9",
         "recipe": {