@@ -550,7 +550,7 @@ func (s *Session) ExecuteGroupByQueryIntervalQuery(database *string, device, mea
550
550
Timeout : timeoutMs , IsAligned : isAligned }
551
551
if resp , err := s .client .ExecuteGroupByQueryIntervalQuery (context .Background (), & request ); err == nil {
552
552
if statusErr := VerifySuccess (resp .Status ); statusErr == nil {
553
- return NewSessionDataSet ("" , resp .Columns , resp .DataTypeList , resp .ColumnNameIndexMap , * resp .QueryId , s .client , s .sessionId , resp .QueryDataSet , resp .IgnoreTimeStamp != nil && * resp .IgnoreTimeStamp , s .config .FetchSize , timeoutMs ), err
553
+ return NewSessionDataSet ("" , resp .Columns , resp .DataTypeList , resp .ColumnNameIndexMap , * resp .QueryId , s .requestStatementId , s . client , s .sessionId , resp .QueryResult_ , resp .IgnoreTimeStamp != nil && * resp .IgnoreTimeStamp , timeoutMs , * resp . MoreData , s .config .FetchSize )
554
554
} else {
555
555
return nil , statusErr
556
556
}
@@ -559,7 +559,7 @@ func (s *Session) ExecuteGroupByQueryIntervalQuery(database *string, device, mea
559
559
request .SessionId = s .sessionId
560
560
resp , err = s .client .ExecuteGroupByQueryIntervalQuery (context .Background (), & request )
561
561
if statusErr := VerifySuccess (resp .Status ); statusErr == nil {
562
- return NewSessionDataSet ("" , resp .Columns , resp .DataTypeList , resp .ColumnNameIndexMap , * resp .QueryId , s .client , s .sessionId , resp .QueryDataSet , resp .IgnoreTimeStamp != nil && * resp .IgnoreTimeStamp , s .config .FetchSize , timeoutMs ), err
562
+ return NewSessionDataSet ("" , resp .Columns , resp .DataTypeList , resp .ColumnNameIndexMap , * resp .QueryId , s .requestStatementId , s . client , s .sessionId , resp .QueryResult_ , resp .IgnoreTimeStamp != nil && * resp .IgnoreTimeStamp , timeoutMs , * resp . MoreData , s .config .FetchSize )
563
563
} else {
564
564
return nil , statusErr
565
565
}
0 commit comments