in client/rpcdataset.go [473:508]
func (s *IoTDBRpcDataSet) Close() (err error) {
if s.IsClosed() {
return nil
}
if s.client != nil {
closeRequest := &rpc.TSCloseOperationReq{
SessionId: s.sessionId,
QueryId: &s.queryId,
}
var status *rpc.TSStatus
status, err = s.client.CloseOperation(context.Background(), closeRequest)
if err == nil {
err = VerifySuccess(status)
}
}
s.columnCount = 0
s.sessionId = -1
s.queryId = -1
s.rowsIndex = -1
s.queryDataSet = nil
s.sql = ""
s.fetchSize = 0
s.columnNameList = nil
s.columnTypeList = nil
s.columnOrdinalMap = nil
s.columnTypeDeduplicatedList = nil
s.currentBitmap = nil
s.time = nil
s.values = nil
s.client = nil
s.emptyResultSet = true
s.closed = true
return err
}