fix clickhouse package to enable secure connection to clickhouse cloud

prismelabs · Jan 23, 2024 · 7bdffdb · 7bdffdb
1 parent 2b65bfd
commit 7bdffdb
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 0 deletions.
diff --git a/internal/clickhouse/connect.go b/internal/clickhouse/connect.go
@@ -96,14 +96,19 @@ func connectSql(logger log.Logger, cfg config.Clickhouse, maxRetry int) *sql.DB
 			cfg.User.ExposeSecret(),
 			cfg.Password.ExposeSecret(),
 		)
+		if cfg.TlsEnabled {
+			connectionString += "&secure=true"
+		}
 
 		db, err = sql.Open("clickhouse", connectionString)
 		if err != nil {
+			println(err.Error())
 			continue
 		}
 
 		err = db.Ping()
 		if err != nil {
+			println(err.Error())
 			continue
 		}
 

diff --git a/internal/clickhouse/migrate.go b/internal/clickhouse/migrate.go
@@ -19,6 +19,7 @@ func migrate(logger log.Logger, db *sql.DB) {
 
 	driver, err := clickhouse.WithInstance(db, &clickhouse.Config{
 		MigrationsTable:       "migrations",
+		MigrationsTableEngine: "MergeTree",
 		MultiStatementEnabled: true,
 	})
 	if err != nil {