Skip to content

Commit fabc38a

Browse files
committed
fixed some golangci-lint checking errors
Signed-off-by: axfor <aixiaoxiang2009@hotmail.com>
1 parent 1b71baa commit fabc38a

File tree

2 files changed

+20
-17
lines changed

2 files changed

+20
-17
lines changed

client/resp.go

Lines changed: 11 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -336,15 +336,15 @@ func (c *Conn) readResultsetStreaming(data []byte, binary bool, result *Result,
336336
return nil
337337
}
338338

339-
func (c *Conn) readResultColumns(result *Result) (err error) {
339+
func (c *Conn) readResultColumns(result *Result) error {
340340
var i = 0
341341
var data []byte
342-
342+
var err error
343343
for {
344344
rawPkgLen := len(result.RawPkg)
345345
result.RawPkg, err = c.ReadPacketReuseMem(result.RawPkg)
346346
if err != nil {
347-
return
347+
return err
348348
}
349349
data = result.RawPkg[rawPkgLen:]
350350

@@ -361,15 +361,15 @@ func (c *Conn) readResultColumns(result *Result) (err error) {
361361
err = ErrMalformPacket
362362
}
363363

364-
return
364+
return err
365365
}
366366

367367
if result.Fields[i] == nil {
368368
result.Fields[i] = &Field{}
369369
}
370370
err = result.Fields[i].Parse(data)
371371
if err != nil {
372-
return
372+
return err
373373
}
374374

375375
result.FieldNames[hack.String(result.Fields[i].Name)] = i
@@ -378,14 +378,15 @@ func (c *Conn) readResultColumns(result *Result) (err error) {
378378
}
379379
}
380380

381-
func (c *Conn) readResultRows(result *Result, isBinary bool) (err error) {
381+
func (c *Conn) readResultRows(result *Result, isBinary bool) error {
382382
var data []byte
383+
var err error
383384

384385
for {
385386
rawPkgLen := len(result.RawPkg)
386387
result.RawPkg, err = c.ReadPacketReuseMem(result.RawPkg)
387388
if err != nil {
388-
return
389+
return err
389390
}
390391
data = result.RawPkg[rawPkgLen:]
391392

@@ -425,16 +426,17 @@ func (c *Conn) readResultRows(result *Result, isBinary bool) (err error) {
425426
return nil
426427
}
427428

428-
func (c *Conn) readResultRowsStreaming(result *Result, isBinary bool, perRowCb SelectPerRowCallback) (err error) {
429+
func (c *Conn) readResultRowsStreaming(result *Result, isBinary bool, perRowCb SelectPerRowCallback) error {
429430
var (
430431
data []byte
431432
row []FieldValue
433+
err error
432434
)
433435

434436
for {
435437
data, err = c.ReadPacketReuseMem(data[:0])
436438
if err != nil {
437-
return
439+
return err
438440
}
439441

440442
// EOF Packet

mysql/field.go

Lines changed: 9 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -41,50 +41,51 @@ const (
4141
FieldValueTypeString
4242
)
4343

44-
func (f *Field) Parse(p FieldData) (err error) {
44+
func (f *Field) Parse(p FieldData) error {
4545
f.Data = p
4646

4747
var n int
48+
var err error
4849
pos := 0
4950
//skip catelog, always def
5051
n, err = SkipLengthEncodedString(p)
5152
if err != nil {
52-
return
53+
return err
5354
}
5455
pos += n
5556

5657
//schema
5758
f.Schema, _, n, err = LengthEncodedString(p[pos:])
5859
if err != nil {
59-
return
60+
return err
6061
}
6162
pos += n
6263

6364
//table
6465
f.Table, _, n, err = LengthEncodedString(p[pos:])
6566
if err != nil {
66-
return
67+
return err
6768
}
6869
pos += n
6970

7071
//org_table
7172
f.OrgTable, _, n, err = LengthEncodedString(p[pos:])
7273
if err != nil {
73-
return
74+
return err
7475
}
7576
pos += n
7677

7778
//name
7879
f.Name, _, n, err = LengthEncodedString(p[pos:])
7980
if err != nil {
80-
return
81+
return err
8182
}
8283
pos += n
8384

8485
//org_name
8586
f.OrgName, _, n, err = LengthEncodedString(p[pos:])
8687
if err != nil {
87-
return
88+
return err
8889
}
8990
pos += n
9091

@@ -123,7 +124,7 @@ func (f *Field) Parse(p FieldData) (err error) {
123124

124125
if pos+int(f.DefaultValueLength) > len(p) {
125126
err = ErrMalformPacket
126-
return
127+
return err
127128
}
128129

129130
//default value string[$len]

0 commit comments

Comments
 (0)