Golang пакет для работы с ClickHouse

github.com/ClickHouse/clickhouse-go

Этот пакет — официальный драйвер для ClickHouse, разработанный командой ClickHouse. Он хорошо поддерживается и используется во многих проектах.

• Особенности:
  • Поддержка большинства функций ClickHouse.
  • Высокая производительность и низкий уровень запросов.
  • Подходит как для простых, так и для сложных запросов.
  • Поддержка репликации и распределенных запросов.
• Установка:
  
  Shell

  go get github.com/ClickHouse/clickhouse-go

  1 2	go get github.com/ClickHouse/clickhouse-go

   
• Пример использования:
  
  Go

  package main import ( "database/sql" _ "github.com/ClickHouse/clickhouse-go" "fmt" ) func main() { dsn := "tcp://host:port?username=your_username&password=your_password&database=your_database" db, err := sql.Open("clickhouse", dsn) if err != nil { fmt.Println("Error:", err) return } defer db.Close() // Пример запроса rows, err := db.Query("SELECT * FROM your_table LIMIT 10") if err != nil { fmt.Println("Query error:", err) return } defer rows.Close() var column1 string var column2 int for rows.Next() { if err := rows.Scan(&column1, &column2); err != nil { fmt.Println("Scan error:", err) return } fmt.Println(column1, column2) } }

  1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36

  package main   import (     "database/sql"     _ "github.com/ClickHouse/clickhouse-go"     "fmt" )   func main() {     dsn := "tcp://host:port?username=your_username&password=your_password&database=your_database"     db, err := sql.Open("clickhouse", dsn)     if err != nil {         fmt.Println("Error:", err)         return     }     defer db.Close()       // Пример запроса     rows, err := db.Query("SELECT * FROM your_table LIMIT 10")     if err != nil {         fmt.Println("Query error:", err)         return     }     defer rows.Close()       var column1 string     var column2 int     for rows.Next() {         if err := rows.Scan(&column1, &column2); err != nil {             fmt.Println("Scan error:", err)             return         }         fmt.Println(column1, column2)     } }