ByteHouse Go Driver

本文介绍如何通过 ByteHouse Go Driver 连接并访问 ByteHouse 云数仓。
请访问 github 项目主页，获取 ByteHouse Go 驱动最新的文档和发布版本。

连接到 ByteHouse

请参考通过驱动连接到 ByteHouse，了解如何通过API Token 或用户名+密码的方式连接到 ByteHouse 。

基本使用

创建一个数据库和数据表。

package main
import (
    "context"
    "fmt"
    "github.com/bytehouse-cloud/driver-go/sdk"
)
func main() {
    dsn := fmt.Sprintf("tcp://host:port?secure=true&token=%v",
       "Your-API-Token",
    )

    ctx := context.Background()

    g, err := sdk.Open(ctx, dsn)
    if err != nil {
       panic(err)
    }

    if err := g.Ping(); err != nil {
       panic(err)
    }

    if qs, err := g.QueryContext(ctx, "CREATE DATABASE my_db"); err != nil || qs.Exception() != nil {
       if err != nil {
          panic(err)
       }
       if qs.Exception() != nil {
          panic(qs.Exception())
       }
    }

    if qs, err := g.QueryContext(ctx,
       `CREATE TABLE my_db.animal 
                (
                    dog Int64,
                    cat Int64
                )
                ENGINE=CnchMergeTree ORDER BY dog`); err != nil || qs.Exception() != nil {
       if err != nil {
          panic(err)
       }
       if qs.Exception() != nil {
          panic(qs.Exception())
       }
    }
}

插入数据

将值插入到新建的表中。

package main
import (
    "context"
    "fmt"
    "github.com/bytehouse-cloud/driver-go/sdk"
)
func main() {
    dsn := fmt.Sprintf("tcp://host:port?secure=true&token=%v",
       "Your-API-Token",
    )

    ctx := context.Background()

    g, err := sdk.Open(ctx, dsn)
    if err != nil {
       panic(err)
    }

    if err := g.Ping(); err != nil {
       panic(err)
    }

    if err := g.SendInsertQuery(ctx, "INSERT INTO my_db.animal VALUES (1,2), (3,4)"); err != nil {
       panic(err)
    }

}

数据查询

package main
import (
    "context"
    "fmt"
    "github.com/bytehouse-cloud/driver-go/sdk"
)
func main() {
    dsn := fmt.Sprintf("tcp://host:port?secure=true&token=%v",
       "Your-API-Token",
    )

    ctx := context.Background()

    g, err := sdk.Open(ctx, dsn)
    if err != nil {
       panic(err)
    }

    if err := g.Ping(); err != nil {
       panic(err)
    }

    qs, err := g.QueryContext(ctx, "SELECT * FROM my_db.animal")
    if err != nil || qs.Exception() != nil {
       if err != nil {
          panic(err)
       }
       if qs.Exception() != nil {
          panic(qs.Exception())
       }
    }

    for {
       rows, ok := qs.NextRow()
       if !ok {
          break
       }
       fmt.Printf("%+v", rows)
    }

}