@@ -17,6 +17,7 @@ import (
17
17
"os"
18
18
)
19
19
20
+ // Various errors the driver might return. Can change between driver versions.
20
21
var (
21
22
ErrInvalidConn = errors .New ("Invalid Connection" )
22
23
ErrMalformPkt = errors .New ("Malformed Packet" )
@@ -27,17 +28,17 @@ var (
27
28
ErrPktSyncMul = errors .New ("Commands out of sync. Did you run multiple statements at once?" )
28
29
ErrPktTooLarge = errors .New ("Packet for query is too large. You can change this value on the server by adjusting the 'max_allowed_packet' variable." )
29
30
ErrBusyBuffer = errors .New ("Busy buffer" )
30
-
31
- errLog Logger = log .New (os .Stderr , "[MySQL] " , log .Ldate | log .Ltime | log .Lshortfile )
32
31
)
33
32
33
+ var errLog Logger = log .New (os .Stderr , "[MySQL] " , log .Ldate | log .Ltime | log .Lshortfile )
34
+
34
35
// Logger is used to log critical error messages.
35
36
type Logger interface {
36
37
Print (v ... interface {})
37
38
}
38
39
39
40
// SetLogger is used to set the logger for critical errors.
40
- // The initial logger is stderr .
41
+ // The initial logger is os.Stderr .
41
42
func SetLogger (logger Logger ) error {
42
43
if logger == nil {
43
44
return errors .New ("logger is nil" )
@@ -85,35 +86,31 @@ type MysqlWarning struct {
85
86
}
86
87
87
88
func (mc * mysqlConn ) getWarnings () (err error ) {
88
- rows , err := mc .Query ("SHOW WARNINGS" , []driver. Value {} )
89
+ rows , err := mc .Query ("SHOW WARNINGS" , nil )
89
90
if err != nil {
90
91
return
91
92
}
92
93
93
94
var warnings = MySQLWarnings {}
94
95
var values = make ([]driver.Value , 3 )
95
96
96
- var warning MysqlWarning
97
- var raw []byte
98
- var ok bool
99
-
100
97
for {
101
98
err = rows .Next (values )
102
99
switch err {
103
100
case nil :
104
- warning = MysqlWarning {}
101
+ warning : = MysqlWarning {}
105
102
106
- if raw , ok = values [0 ].([]byte ); ok {
103
+ if raw , ok : = values [0 ].([]byte ); ok {
107
104
warning .Level = string (raw )
108
105
} else {
109
106
warning .Level = fmt .Sprintf ("%s" , values [0 ])
110
107
}
111
- if raw , ok = values [1 ].([]byte ); ok {
108
+ if raw , ok : = values [1 ].([]byte ); ok {
112
109
warning .Code = string (raw )
113
110
} else {
114
111
warning .Code = fmt .Sprintf ("%s" , values [1 ])
115
112
}
116
- if raw , ok = values [2 ].([]byte ); ok {
113
+ if raw , ok : = values [2 ].([]byte ); ok {
117
114
warning .Message = string (raw )
118
115
} else {
119
116
warning .Message = fmt .Sprintf ("%s" , values [0 ])
0 commit comments