summaryrefslogtreecommitdiff
path: root/internal/mapr/groupsetresult.go
diff options
context:
space:
mode:
authorPaul Buetow <pbuetow@mimecast.com>2024-02-23 15:01:41 +0200
committerPaul Buetow <pbuetow@mimecast.com>2024-02-23 15:01:41 +0200
commita3e10757a52fa47a0608afd88986162ca5eb22cc (patch)
treedce61c6695bc3badd455a64767252e6947b32711 /internal/mapr/groupsetresult.go
parent85780654df870dc4170b93a8ed5a5dbfa917fe5d (diff)
lint warnings
Diffstat (limited to 'internal/mapr/groupsetresult.go')
-rw-r--r--internal/mapr/groupsetresult.go36
1 files changed, 25 insertions, 11 deletions
diff --git a/internal/mapr/groupsetresult.go b/internal/mapr/groupsetresult.go
index d01a3c9..58663b8 100644
--- a/internal/mapr/groupsetresult.go
+++ b/internal/mapr/groupsetresult.go
@@ -169,9 +169,10 @@ func (*GroupSet) writeQueryFile(query *Query) error {
}
defer fd.Close()
- fd.WriteString(query.RawQuery)
- os.Rename(tmpQueryFile, queryFile)
- return nil
+ if _, err := fd.WriteString(query.RawQuery); err != nil {
+ return err
+ }
+ return os.Rename(tmpQueryFile, queryFile)
}
// WriteResult writes the result to an CSV outfile.
@@ -221,7 +222,9 @@ func (g *GroupSet) resultWriteUnformatted(query *Query, rows []result, fd *os.Fi
lastColumn := len(query.Select) - 1
if writeHeader {
- g.resultWriteUnformattedHeader(query, fd, lastColumn)
+ if err := g.resultWriteUnformattedHeader(query, fd, lastColumn); err != nil {
+ return err
+ }
}
// And now write the data
@@ -230,13 +233,19 @@ func (g *GroupSet) resultWriteUnformatted(query *Query, rows []result, fd *os.Fi
break
}
for j, value := range r.values {
- fd.WriteString(value)
+ if _, err := fd.WriteString(value); err != nil {
+ return err
+ }
if j == lastColumn {
continue
}
- fd.WriteString(protocol.CSVDelimiter)
+ if _, err := fd.WriteString(protocol.CSVDelimiter); err != nil {
+ return err
+ }
+ }
+ if _, err := fd.WriteString("\n"); err != nil {
+ return err
}
- fd.WriteString("\n")
}
if !query.Outfile.AppendMode {
@@ -250,13 +259,18 @@ func (g *GroupSet) resultWriteUnformatted(query *Query, rows []result, fd *os.Fi
return nil
}
-func (g *GroupSet) resultWriteUnformattedHeader(query *Query, fd *os.File, lastColumn int) {
+func (g *GroupSet) resultWriteUnformattedHeader(query *Query, fd *os.File, lastColumn int) (err error) {
for i, sc := range query.Select {
- fd.WriteString(sc.FieldStorage)
+ if _, err = fd.WriteString(sc.FieldStorage); err != nil {
+ return
+ }
if i == lastColumn {
continue
}
- fd.WriteString(protocol.CSVDelimiter)
+ if _, err = fd.WriteString(protocol.CSVDelimiter); err != nil {
+ return
+ }
}
- fd.WriteString("\n")
+ _, err = fd.WriteString("\n")
+ return
}