This is the GoLang client of Apache IoTDB.
Apache IoTDB website: https://iotdb.apache.org Apache IoTDB Github: https://github.com/apache/iotdb
golang >= 1.13
With go mod
export GO111MODULE=on export GOPROXY=https://goproxy.io mkdir session_example && cd session_example curl -o session_example.go -L https://github.com/apache/iotdb-client-go/raw/main/example/session_example.go go mod init session_example go run session_example.go
Without go mod
# get thrift 0.15.0 go get github.com/apache/thrift cd $GOPATH/src/github.com/apache/thrift git checkout 0.15.0 mkdir -p $GOPATH/src/iotdb-client-go-example/session_example cd $GOPATH/src/iotdb-client-go-example/session_example curl -o session_example.go -L https://github.com/apache/iotdb-client-go/raw/main/example/session_example.go go run session_example.go
SessionPool is a wrapper of a Session Set. Using SessionPool, the user do not need to consider how to reuse a session connection. If there is no available connections and the pool reaches its max size, the all methods will hang until there is a available connection. The PutBack method must be called after use
standalone
config := &client.PoolConfig{ Host: host, Port: port, UserName: user, Password: password, } sessionPool = client.NewSessionPool(config, 3, 60000, 60000, false)
cluster or doubleLive
config := &client.PoolConfig{ UserName: user, Password: password, NodeUrls: strings.Split("127.0.0.1:6667,127.0.0.1:6668", ","), } sessionPool = client.NewSessionPool(config, 3, 60000, 60000, false)
set storage group
session, err := sessionPool.GetSession() defer sessionPool.PutBack(session) if err == nil { session.SetStorageGroup(sg) }
query statement
var timeout int64 = 1000 session, err := sessionPool.GetSession() defer sessionPool.PutBack(session) if err != nil { log.Print(err) return } sessionDataSet, err := session.ExecuteQueryStatement(sql, &timeout) if err == nil { defer sessionDataSet.Close() printDataSet1(sessionDataSet) } else { log.Println(err) }
In the branch rel/0.13
and earlier versions, the version of apache/thrift is v0.14.1
. In the latest version, apache/thrift has been upgraded to v0.15.0
.
The two versions are not compatible on some interfaces. Using mismatched version will cause compilation errors.
The interfaces changed in the two versions are as follows:
NewTSocketConf
. This function returns two values in the version v0.14.1
and only one value in the version v0.15.0
.NewTFramedTransport
has been deprecated, use NewTFramedTransportConf
instead.For more details, please take a look at this PR: update thrift to 0.15.0 to fit IoTDB 0.13.0
The implementation of the function client/session.go/Open()
is mismatched with the description. The parameter connectionTimeoutInMs
represents connection timeout in milliseconds. However, in the older version, this function did not implement correctly, regarding it as nanosecond instead. The bug is now fixed. Positive value of this parameter means connection timeout in milliseconds. Set 0 for no timeout.