(session client.ITableSession)
| 140 | } |
| 141 | |
| 142 | func 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 | |
| 161 | func checkError(err error) { |
| 162 | if err != nil { |
no test coverage detected
searching dependent graphs…