dbqcore v0.0.8

Author: sholokhov

go.mod

@@ -3,7 +3,7 @@ module github.com/DataBridgeTech/dbqctl
 go 1.24.5
 
 require (
-	github.com/DataBridgeTech/dbqcore v0.0.6
+	github.com/DataBridgeTech/dbqcore v0.0.8
 	github.com/spf13/cobra v1.9.1
 	github.com/spf13/pflag v1.0.7
 	github.com/spf13/viper v1.20.1

internal/app.go

@@ -18,7 +18,6 @@ import (
 	"fmt"
 	"log/slog"
 	"os"
-	"strings"
 
 	"github.com/DataBridgeTech/dbqcore"
 
@@ -157,12 +156,11 @@ func initConfig(dbqConfigPath string) (*dbqcore.DbqConfig, string) {
 }
 
 func getDbqConnector(ds dbqcore.DataSource, logLevel slog.Level) (dbqcore.DbqConnector, error) {
-	dsType := strings.ToLower(ds.Type)
 	logHandler := slog.NewTextHandler(os.Stdout, &slog.HandlerOptions{Level: logLevel})
-	switch dsType {
-	case "clickhouse":
+	switch ds.Type {
+	case dbqcore.DataSourceTypeClickhouse:
 		return dbqcore.NewClickhouseDbqConnector(ds, slog.New(logHandler))
 	default:
-		return nil, fmt.Errorf("data source type '%s' is not supported", dsType)
+		return nil, fmt.Errorf("data source type '%s' is not supported", ds.Type)
 	}
 }