diff --git a/app/storage/clickhouse/client.go b/app/storage/clickhouse/client.go index d1a9961..a14f871 100644 --- a/app/storage/clickhouse/client.go +++ b/app/storage/clickhouse/client.go @@ -53,7 +53,11 @@ func connect() (*driver.Conn, error) { } func Migrate() error { - rows, err := Connection.Query( + rows, err := Connection.Query(context.TODO(), "SELECT 1") + if err != nil { + log.Fatal("Query failed:", err) + } + rows, err = Connection.Query( context.TODO(), `CREATE TABLE IF NOT EXISTS endpoints ( timestamp DateTime,