Merge pull request #86 from Hubbitus/issue71-clickhouse-http-support

issue 71: add clickhouse http support
justwatchcom · Jun 19, 2023 · 63eed6d · 63eed6d
2 parents f0a38d7 + 5819c4a
commit 63eed6d
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/job.go b/job.go
@@ -259,7 +259,10 @@ func (c *connection) connect(job *Job) error {
 	switch c.driver {
 	case "mysql":
 		dsn = strings.TrimPrefix(dsn, "mysql://")
-	case "clickhouse":
+	case "clickhouse+tcp", "clickhouse+http": // Support both http and tcp connections
+		dsn = strings.TrimPrefix(dsn, "clickhouse+")
+		c.driver = "clickhouse"
+	case "clickhouse": // Backward compatible alias
 		dsn = "tcp://" + strings.TrimPrefix(dsn, "clickhouse://")
 	}
 	conn, err := sqlx.Connect(c.driver, dsn)