連接

func NewCkConn(ckInfo config.CkConfig) (*dbr.Connection, error) {conn, err := dbr.Open("clickhouse", "http://"+ckInfo.Username+":"+ckInfo.Password+"@"+ckInfo.Host+":"+ckInfo.Port+"/"+ckInfo.Database, nil)if err != nil {return nil, err}return conn, nil }

查詢

rows.next是從內存中一條一條的取出 rows.Scan是進行賦值 記住next與scan組合進行賦值的 func (m *Metric) TotalAmount(sql string) (TotalAmount, error) {rows, err := ck.Query(sql)if err != nil {return TotalAmount{}, err}var res TotalAmountfor rows.Next() {err = rows.Scan(&res.CpuUseds, &res.CpuTotals, &res.MemUseds, &res.MemTotals)if err != nil {return TotalAmount{}, err}}return res, nil }

總結

以上是生活随笔為你收集整理的Go使用go-clickhouse库的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。