db.go

package main

import (
	"context"

	"github.com/ClickHouse/clickhouse-go/v2"
	"github.com/ClickHouse/clickhouse-go/v2/lib/driver"
)

func Connect() (driver.Conn, error) {
	conn, err := clickhouse.Open(&clickhouse.Options{
		Addr: []string{"localhost:9000"}, // Menggunakan port TCP native
		Auth: clickhouse.Auth{
			Database: "iot_analytics",
			Username: "admin",
			Password: "securepassword123",
		},
		ClientInfo: clickhouse.ClientInfo{
			Products: []struct {
				Name    string
				Version string
			}{
				{Name: "iot_analytics-app", Version: "0.1"},
			},
		},
		Debug: true, // Aktifkan untuk melihat log query
	})

	if err != nil {
		return nil, err
	}

	// Ping untuk memastikan koneksi berhasil
	if err := conn.Ping(context.Background()); err != nil {
		return nil, err
	}

	return conn, nil
}