1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
|
--- a/job.go
+++ b/job.go
@@ -8,7 +8,6 @@ import (
"strings"
"time"
- _ "github.com/ClickHouse/clickhouse-go/v2" // register the ClickHouse driver
"github.com/cenkalti/backoff"
_ "github.com/denisenkom/go-mssqldb" // register the MS-SQL driver
"github.com/go-kit/log"
@@ -259,8 +258,6 @@ func (c *connection) connect(job *Job) e
switch c.driver {
case "mysql":
dsn = strings.TrimPrefix(dsn, "mysql://")
- case "clickhouse":
- dsn = "tcp://" + strings.TrimPrefix(dsn, "clickhouse://")
}
conn, err := sqlx.Connect(c.driver, dsn)
if err != nil {
|
