Golang migrate.New как указывать параметры для Clickhouse если базы еще нет и ее создаем в миграции

Если база данных ClickHouse ещё не существует и вы хотите создать её в миграции, есть несколько способов корректно настроить процесс с использованием библиотеки migrate. Проблема в том, что migrate.New ожидает, что база данных, указанная в строке подключения, уже существует.

Подходы к решению

1. Использовать отдельное подключение для создания базы данных Создайте базу данных перед запуском миграций с помощью отдельного подключения. Для этого укажите строку подключения без имени базы данных.

   Пример:

   Go

   package main import ( "context" "log" "github.com/golang-migrate/migrate/v4" _ "github.com/golang-migrate/migrate/v4/database/clickhouse" _ "github.com/golang-migrate/migrate/v4/source/file" "github.com/ClickHouse/clickhouse-go/v2" ) func main() { // Подключение без имени базы данных dsn := "clickhouse://default:@localhost:9000" // Создание базы данных перед миграцией conn, err := clickhouse.Open(&clickhouse.Options{ Addr: []string{"localhost:9000"}, }) if err != nil { log.Fatalf("Failed to connect to ClickHouse: %v", err) } ctx := context.Background() _, err = conn.Exec(ctx, "CREATE DATABASE IF NOT EXISTS my_database") if err != nil { log.Fatalf("Failed to create database: %v", err) } log.Println("Database created successfully!") // Путь к миграциям migrationsPath := "file:///path/to/your/migrations" // Подключение с именем базы данных dsnWithDatabase := "clickhouse://default:@localhost:9000/my_database" // Создание миграции m, err := migrate.New(migrationsPath, dsnWithDatabase) if err != nil { log.Fatalf("Failed to create migration instance: %v", err) } // Применение миграций if err := m.Up(); err != nil && err != migrate.ErrNoChange { log.Fatalf("Failed to apply migrations: %v", err) } log.Println("Migrations applied successfully!") }

   1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51

   package main   import (     "context"     "log"       "github.com/golang-migrate/migrate/v4"     _ "github.com/golang-migrate/migrate/v4/database/clickhouse"     _ "github.com/golang-migrate/migrate/v4/source/file"     "github.com/ClickHouse/clickhouse-go/v2" )   func main() {     // Подключение без имени базы данных     dsn := "clickhouse://default:@localhost:9000"       // Создание базы данных перед миграцией     conn, err := clickhouse.Open(&clickhouse.Options{         Addr: []string{"localhost:9000"},     })     if err != nil {         log.Fatalf("Failed to connect to ClickHouse: %v", err)     }       ctx := context.Background()     _, err = conn.Exec(ctx, "CREATE DATABASE IF NOT EXISTS my_database")     if err != nil {         log.Fatalf("Failed to create database: %v", err)     }     log.Println("Database created successfully!")       // Путь к миграциям     migrationsPath := "file:///path/to/your/migrations"       // Подключение с именем базы данных     dsnWithDatabase := "clickhouse://default:@localhost:9000/my_database"       // Создание миграции     m, err := migrate.New(migrationsPath, dsnWithDatabase)     if err != nil {         log.Fatalf("Failed to create migration instance: %v", err)     }       // Применение миграций     if err := m.Up(); err != nil && err != migrate.ErrNoChange {         log.Fatalf("Failed to apply migrations: %v", err)     }       log.Println("Migrations applied successfully!") }

    

2. Указать пустую базу в строке подключения В некоторых случаях можно использовать default или другую системную базу ClickHouse как временное подключение для выполнения миграций.

   Пример строки подключения:

   Default

   dsn := "clickhouse://default:@localhost:9000/default"

   1 2	dsn := "clickhouse://default:@localhost:9000/default"

   Затем в первой миграции создаётся нужная база данных, например:

   Миграция 0001_create_database.up.sql:

   PgSQL

   CREATE DATABASE IF NOT EXISTS my_database;

   1 2	CREATE DATABASE IF NOT EXISTS my_database;

   Миграция 0001_create_database.down.sql:

   PgSQL

   DROP DATABASE IF EXISTS my_database;

   1 2	DROP DATABASE IF EXISTS my_database;

    

3. Создание базы в первой миграции Вы можете указать default как базу в строке подключения, а саму базу создать в первой миграции. При этом путь к миграциям остаётся неизменным:
   Go

   migrationsPath := "file:///path/to/your/migrations" dsn := "clickhouse://default:@localhost:9000/default"

   1 2 3

   migrationsPath := "file:///path/to/your/migrations" dsn := "clickhouse://default:@localhost:9000/default"

   Тогда ваша первая миграция создаёт базу данных и таблицы.

Примечания

• Лучший подход: Обычно базы данных создаются вручную или с помощью CI/CD процессов перед запуском приложения, а миграции отвечают только за структуру таблиц и данных.
• Безопасность: При создании базы в коде убедитесь, что права доступа пользователя позволяют это сделать.
• Тестирование: Проверьте миграции на тестовом окружении, чтобы убедиться, что создаваемая база корректно подключается.

Выберите подход, который лучше всего соответствует вашим требованиям.