Add Protocol support for ConnectionConfig

Author: sholokhov

adapters/clickhouse_adapter.go

@@ -1,4 +1,4 @@
-// Copyright 2025 The DBQ Authors
+// Copyright 2026 The DBQ Authors
 //
 // Licensed under the Apache License, Version 2.0 (the "License");
 // you may not use this file except in compliance with the License.

adapters/mysql_adapter.go

@@ -1,4 +1,4 @@
-// Copyright 2025 The DBQ Authors
+// Copyright 2026 The DBQ Authors
 //
 // Licensed under the Apache License, Version 2.0 (the "License");
 // you may not use this file except in compliance with the License.

adapters/postgresql_adapter.go

@@ -1,4 +1,4 @@
-// Copyright 2025 The DBQ Authors
+// Copyright 2026 The DBQ Authors
 //
 // Licensed under the Apache License, Version 2.0 (the "License");
 // you may not use this file except in compliance with the License.

check_parser.go

@@ -1,4 +1,4 @@
-// Copyright 2025 The DBQ Authors
+// Copyright 2026 The DBQ Authors
 //
 // Licensed under the Apache License, Version 2.0 (the "License");
 // you may not use this file except in compliance with the License.

checks_cfg.go

@@ -1,4 +1,4 @@
-// Copyright 2025 The DBQ Authors
+// Copyright 2026 The DBQ Authors
 //
 // Licensed under the Apache License, Version 2.0 (the "License");
 // you may not use this file except in compliance with the License.

cnn/clickhouse_cnn.go

@@ -1,4 +1,4 @@
-// Copyright 2025 The DBQ Authors
+// Copyright 2026 The DBQ Authors
 //
 // Licensed under the Apache License, Version 2.0 (the "License");
 // you may not use this file except in compliance with the License.
@@ -15,24 +15,41 @@
 package cnn
 
 import (
+	"crypto/tls"
+
 	"github.com/ClickHouse/clickhouse-go/v2"
 	"github.com/ClickHouse/clickhouse-go/v2/lib/driver"
 	"github.com/DataBridgeTech/dbqcore"
 )
 
 func NewClickhouseConnection(connectionCfg dbqcore.ConnectionConfig, poolSize int) (driver.Conn, error) {
+	proto, tlsCfg := clickhouseProtocol(connectionCfg.Protocol)
+
 	cnn, err := clickhouse.Open(&clickhouse.Options{
 		Addr: []string{connectionCfg.Host},
 		Auth: clickhouse.Auth{
 			Database: connectionCfg.Database,
 			Username: connectionCfg.Username,
 			Password: connectionCfg.Password,
 		},
+		Protocol:     proto,
+		TLS:          tlsCfg,
 		MaxOpenConns: poolSize,
 		MaxIdleConns: poolSize,
-		//TLS: &tls.Config{
-		//	InsecureSkipVerify: true,
-		//},
 	})
 	return cnn, err
 }
+
+func clickhouseProtocol(protocol string) (clickhouse.Protocol, *tls.Config) {
+	switch protocol {
+	case "http":
+		return clickhouse.HTTP, nil
+	case "https":
+		return clickhouse.HTTP, &tls.Config{}
+	case "clickhouse-secure":
+		return clickhouse.Native, &tls.Config{}
+	default:
+		// "clickhouse", "" or any unrecognised value → native TCP, no TLS
+		return clickhouse.Native, nil
+	}
+}

cnn/mysql_cnn.go

@@ -1,4 +1,4 @@
-// Copyright 2025 The DBQ Authors
+// Copyright 2026 The DBQ Authors
 //
 // Licensed under the Apache License, Version 2.0 (the "License");
 // you may not use this file except in compliance with the License.

cnn/postgresql_cnn.go

@@ -1,4 +1,4 @@
-// Copyright 2025 The DBQ Authors
+// Copyright 2026 The DBQ Authors
 //
 // Licensed under the Apache License, Version 2.0 (the "License");
 // you may not use this file except in compliance with the License.

connectors/clickhouse_connector.go

@@ -1,4 +1,4 @@
-// Copyright 2025 The DBQ Authors
+// Copyright 2026 The DBQ Authors
 //
 // Licensed under the Apache License, Version 2.0 (the "License");
 // you may not use this file except in compliance with the License.

connectors/mysql_connector.go

@@ -1,4 +1,4 @@
-// Copyright 2025 The DBQ Authors
+// Copyright 2026 The DBQ Authors
 //
 // Licensed under the Apache License, Version 2.0 (the "License");
 // you may not use this file except in compliance with the License.