MCPcopy Create free account
hub / github.com/apache/iotdb-client-go / query

Function query

example/table/table_session_example.go:142–159  ·  view source on GitHub ↗
(session client.ITableSession)

Source from the content-addressed store, hash-verified

140}
141
142func query(session client.ITableSession) {
143 timeout := int64(2000)
144 dataSet, err := session.ExecuteQueryStatement("select * from t1", &timeout)
145 defer dataSet.Close()
146 if err != nil {
147 log.Fatal(err)
148 }
149 for {
150 hasNext, err := dataSet.Next()
151 if err != nil {
152 log.Fatal(err)
153 }
154 if !hasNext {
155 break
156 }
157 log.Printf("%v %v %v %v", getTextValueFromDataSet(dataSet, "tag1"), getTextValueFromDataSet(dataSet, "tag2"), getTextValueFromDataSet(dataSet, "s1"), getTextValueFromDataSet(dataSet, "s2"))
158 }
159}
160
161func checkError(err error) {
162 if err != nil {

Callers 1

mainFunction · 0.85

Calls 4

getTextValueFromDataSetFunction · 0.85
ExecuteQueryStatementMethod · 0.65
CloseMethod · 0.65
NextMethod · 0.45

Tested by

no test coverage detected

Used in the wild real call sites across dependent graphs

searching dependent graphs…