Golang Thrift Hive

package main


import (
    hive "github.com/araddon/hive"
    "log"
    "fmt"
)


func init() {
    hive.MakePool("localhost:10000")
}


func main() {


    conn, err := hive.GetHiveConn()
    if err == nil {


        er, err := conn.Client.Execute("select * from tb where date='2016-09-09' limit 10")
        if er == nil && err == nil {
            for {
                row, _, _ := conn.Client.FetchOne()
                if len(row) > 0 { 
                    fmt.Println(row)
                } else {
                    return
                }   
            }   
        } else {
            log.Println(er, err)
        }   
    }   
    if conn != nil {
        // make sure to check connection back into pool
        conn.Checkin()
    }   
}

有疑问加站长微信联系（非本文作者）