()
| 158 | } |
| 159 | |
| 160 | func (s *IoTDBRpcDataSet) Close() (err error) { |
| 161 | if s.isClosed { |
| 162 | return nil |
| 163 | } |
| 164 | closeRequest := &rpc.TSCloseOperationReq{ |
| 165 | SessionId: s.sessionId, |
| 166 | StatementId: &s.statementId, |
| 167 | QueryId: &s.queryId, |
| 168 | } |
| 169 | |
| 170 | var status *common.TSStatus |
| 171 | status, err = s.client.CloseOperation(context.Background(), closeRequest) |
| 172 | if err == nil { |
| 173 | err = VerifySuccess(status) |
| 174 | } |
| 175 | s.client = nil |
| 176 | s.isClosed = true |
| 177 | return err |
| 178 | } |
| 179 | |
| 180 | func (s *IoTDBRpcDataSet) Next() (result bool, err error) { |
| 181 | if s.hasCachedBlock() { |
no test coverage detected