diff options
| author | Paul Buetow <pbuetow@mimecast.com> | 2024-02-23 15:01:41 +0200 |
|---|---|---|
| committer | Paul Buetow <pbuetow@mimecast.com> | 2024-02-23 15:01:41 +0200 |
| commit | a3e10757a52fa47a0608afd88986162ca5eb22cc (patch) | |
| tree | dce61c6695bc3badd455a64767252e6947b32711 /internal/mapr/groupsetresult.go | |
| parent | 85780654df870dc4170b93a8ed5a5dbfa917fe5d (diff) | |
lint warnings
Diffstat (limited to 'internal/mapr/groupsetresult.go')
| -rw-r--r-- | internal/mapr/groupsetresult.go | 36 |
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 } |
