|
|
@@ -70,44 +70,3 @@ func (qgar *QueryGroupAsyncResult) Await() ([]*QueryResult, error) {
|
|
|
|
|
|
return result.Results, nil
|
|
|
}
|
|
|
-
|
|
|
-/*
|
|
|
-type QueryResultCollection []*QueryResults
|
|
|
-
|
|
|
-func (qrc *QueryResultCollection) HasErrors() bool {
|
|
|
- for _, qr := range *qrc {
|
|
|
- if qr.Error != nil {
|
|
|
- return true
|
|
|
- }
|
|
|
- }
|
|
|
- return false
|
|
|
-}
|
|
|
-
|
|
|
-func (qrc *QueryResultCollection) Error() error {
|
|
|
- var errCollection QueryErrorCollector
|
|
|
-
|
|
|
- for _, qr := range *qrc {
|
|
|
- q := qr.Query
|
|
|
- e := qr.Error
|
|
|
-
|
|
|
- if e != nil {
|
|
|
- if IsErrorCollection(e) {
|
|
|
- if errs, ok := e.(QueryErrorCollection); ok {
|
|
|
- for _, qErr := range errs.Errors() {
|
|
|
- errCollection.AppendError(qErr)
|
|
|
- }
|
|
|
- for _, qWarn := range errs.Warnings() {
|
|
|
- errCollection.AppendWarning(qWarn)
|
|
|
- }
|
|
|
- } else {
|
|
|
- errCollection.AppendError(&QueryError{Query: q, Error: e})
|
|
|
- }
|
|
|
- } else {
|
|
|
- errCollection.AppendError(&QueryError{Query: q, Error: e})
|
|
|
- }
|
|
|
- }
|
|
|
- }
|
|
|
-
|
|
|
- return &errCollection
|
|
|
-}
|
|
|
-*/
|