only ping a connection if immediately necessary

ClickHouse · Feb 28, 2025 · 523d6ff · 523d6ff
1 parent 7e57e27
commit 523d6ff
Showing 1 changed file with 5 additions and 6 deletions.
diff --git a/pkg/sinks/clickhouse.go b/pkg/sinks/clickhouse.go
@@ -163,14 +163,13 @@ func NewClickHouse(cfg *ClickHouseConfig) (*ClickHouse, error) {
 		db.SetConnMaxIdleTime(time.Duration(*cfg.ConnMaxIdleTimeMs) * time.Millisecond)
 	}
 
-	err := db.Ping()
-	if err != nil {
-		return nil, err
-	}
-
 	if cfg.CreateTable {
+		err := db.Ping()
+		if err != nil {
+			return nil, err
+		}
 		var exists int
-		err := db.QueryRow(fmt.Sprintf("EXISTS %s", cfg.TableName)).Scan(&exists)
+		err = db.QueryRow(fmt.Sprintf("EXISTS %s", cfg.TableName)).Scan(&exists)
 		if err != nil {
 			return nil, err
 		}