OpenDB is not declared

[nrbackback]

gorm.io/driver/clickhouse version is v0.5.0

[huangliu]

It declared in "github.com/ClickHouse/clickhouse-go/v2"

[nrbackback]

https://github.com/go-gorm/clickhouse
in readme

is this wrong?

[edhemphill]

Yeah, the advanced README example seems to be a bit messed up.

This code worked for me:

var dsn = "clickhouse://default:@127.0.0.1:9000/db?dial_timeout=200ms&max_execution_time=60"

if _, err = gorm.Open(clickhouse.Open(dsn), &gorm.Config{}); err != nil {
   fmt.Printf("failed to connect database, got error %v", err)
   os.Exit(1)
}

fmt.Printf("No error. Connectivity ok.\n")

Assuming db is created already.

In the advanced example click is also not defined / imported.

[edhemphill]

Here is an advanced example:

package main

import (
	"context"
	"fmt"
	"os"
	"time"

	chapi "github.com/ClickHouse/clickhouse-go/v2"
	"github.com/tlalocweb/hulation/config"
	"gorm.io/driver/clickhouse"
	"gorm.io/gorm"
)


func main() {

	var confpath string

	if len(os.Args) > 1 {
		confpath = os.Args[1]
	}
	if len(confpath) < 1 {
		fmt.Printf("Error: config file path not provided.\n")
		os.Exit(1)
	}
	myconf, err := config.LoadConfig(confpath)

	if err != nil {
		fmt.Printf("Error loading config: (%s) %s", confpath, err.Error())
		os.Exit(1)
	}

	dsn := config.GetDSNFromConfig(myconf)
	fmt.Printf("Connecting to %s\n", dsn)
        // or ... whatver ...
	//	var dsn = "clickhouse://default:@127.0.0.1:9000/db?dial_timeout=200ms&max_execution_time=60"

	fmt.Printf("testing clickhouse-go library...\n")

	conn := chapi.OpenDB(&chapi.Options{
		Addr: []string{fmt.Sprintf("%s:%d", myconf.DBConfig.Host, myconf.DBConfig.Port)},
		Auth: chapi.Auth{
			Database: myconf.DBConfig.DBName,
			Username: myconf.DBConfig.Username,
			Password: myconf.DBConfig.Password,
		},
		Settings: chapi.Settings{
			"max_execution_time": 60,
		},
		DialTimeout: 5 * time.Second,
		Compression: &chapi.Compression{
			Method: chapi.CompressionLZ4,
		},
	})

	conn.SetMaxIdleConns(5)
	conn.SetMaxOpenConns(10)
	conn.SetConnMaxLifetime(time.Hour)
	ctx := chapi.Context(context.Background(), chapi.WithSettings(chapi.Settings{
		"max_block_size": 10,
	}), chapi.WithProgress(func(p *chapi.Progress) {
		fmt.Println("progress: ", p)
	}))
	if err := conn.PingContext(ctx); err != nil {
		if exception, ok := err.(*chapi.Exception); ok {
			fmt.Printf("Catch exception [%d] %s \n%s\n", exception.Code, exception.Message, exception.StackTrace)
		} else {
	                fmt.Printf("Error: %s\n", err.Error())
                }
		os.Exit(1)
	} else {
		fmt.Println("Ping OK")
	}
	//	conn.Close()
	fmt.Printf("testing gorm w/ clickhouse driver...\n")

	if _, err = gorm.Open(clickhouse.New(clickhouse.Config{
		Conn: conn,
	}), &gorm.Config{}); err != nil {
		fmt.Printf("failed to connect database, got error %v", err)
		os.Exit(1)
	}

	fmt.Printf("No error. Connectivity ok.\n")