@@ -46,19 +46,19 @@ type serverSettings struct {
46
46
}
47
47
48
48
// Handles parameters set in DSN
49
- func (mc * mysqlConn ) handleParams () (e error ) {
49
+ func (mc * mysqlConn ) handleParams () (err error ) {
50
50
for param , val := range mc .cfg .params {
51
51
switch param {
52
52
// Charset
53
53
case "charset" :
54
54
charsets := strings .Split (val , "," )
55
55
for _ , charset := range charsets {
56
- e = mc .exec ("SET NAMES " + charset )
57
- if e == nil {
56
+ err = mc .exec ("SET NAMES " + charset )
57
+ if err == nil {
58
58
break
59
59
}
60
60
}
61
- if e != nil {
61
+ if err != nil {
62
62
return
63
63
}
64
64
@@ -72,8 +72,8 @@ func (mc *mysqlConn) handleParams() (e error) {
72
72
73
73
// System Vars
74
74
default :
75
- e = mc .exec ("SET " + param + "=" + val + "" )
76
- if e != nil {
75
+ err = mc .exec ("SET " + param + "=" + val + "" )
76
+ if err != nil {
77
77
return
78
78
}
79
79
}
@@ -83,15 +83,15 @@ func (mc *mysqlConn) handleParams() (e error) {
83
83
}
84
84
85
85
func (mc * mysqlConn ) Begin () (driver.Tx , error ) {
86
- e := mc .exec ("START TRANSACTION" )
87
- if e != nil {
88
- return nil , e
86
+ err := mc .exec ("START TRANSACTION" )
87
+ if err != nil {
88
+ return nil , err
89
89
}
90
90
91
- return & mysqlTx {mc }, e
91
+ return & mysqlTx {mc }, err
92
92
}
93
93
94
- func (mc * mysqlConn ) Close () (e error ) {
94
+ func (mc * mysqlConn ) Close () (err error ) {
95
95
mc .writeCommandPacket (COM_QUIT )
96
96
mc .bufReader = nil
97
97
mc .netConn .Close ()
@@ -101,36 +101,36 @@ func (mc *mysqlConn) Close() (e error) {
101
101
102
102
func (mc * mysqlConn ) Prepare (query string ) (driver.Stmt , error ) {
103
103
// Send command
104
- e := mc .writeCommandPacket (COM_STMT_PREPARE , query )
105
- if e != nil {
106
- return nil , e
104
+ err := mc .writeCommandPacket (COM_STMT_PREPARE , query )
105
+ if err != nil {
106
+ return nil , err
107
107
}
108
108
109
109
stmt := mysqlStmt {new (stmtContent )}
110
110
stmt .mc = mc
111
111
112
112
// Read Result
113
113
var columnCount uint16
114
- columnCount , e = stmt .readPrepareResultPacket ()
115
- if e != nil {
116
- return nil , e
114
+ columnCount , err = stmt .readPrepareResultPacket ()
115
+ if err != nil {
116
+ return nil , err
117
117
}
118
118
119
119
if stmt .paramCount > 0 {
120
- stmt .params , e = stmt .mc .readColumns (stmt .paramCount )
121
- if e != nil {
122
- return nil , e
120
+ stmt .params , err = stmt .mc .readColumns (stmt .paramCount )
121
+ if err != nil {
122
+ return nil , err
123
123
}
124
124
}
125
125
126
126
if columnCount > 0 {
127
- _ , e = stmt .mc .readUntilEOF ()
128
- if e != nil {
129
- return nil , e
127
+ _ , err = stmt .mc .readUntilEOF ()
128
+ if err != nil {
129
+ return nil , err
130
130
}
131
131
}
132
132
133
- return stmt , e
133
+ return stmt , err
134
134
}
135
135
136
136
func (mc * mysqlConn ) Exec (query string , args []driver.Value ) (driver.Result , error ) {
@@ -141,40 +141,40 @@ func (mc *mysqlConn) Exec(query string, args []driver.Value) (driver.Result, err
141
141
mc .affectedRows = 0
142
142
mc .insertId = 0
143
143
144
- e := mc .exec (query )
145
- if e != nil {
146
- return nil , e
144
+ err := mc .exec (query )
145
+ if err != nil {
146
+ return nil , err
147
147
}
148
148
149
149
return & mysqlResult {
150
150
affectedRows : int64 (mc .affectedRows ),
151
151
insertId : int64 (mc .insertId )},
152
- e
152
+ err
153
153
}
154
154
155
155
// Internal function to execute commands
156
- func (mc * mysqlConn ) exec (query string ) (e error ) {
156
+ func (mc * mysqlConn ) exec (query string ) (err error ) {
157
157
// Send command
158
- e = mc .writeCommandPacket (COM_QUERY , query )
159
- if e != nil {
158
+ err = mc .writeCommandPacket (COM_QUERY , query )
159
+ if err != nil {
160
160
return
161
161
}
162
162
163
163
// Read Result
164
164
var resLen int
165
- resLen , e = mc .readResultSetHeaderPacket ()
166
- if e != nil {
165
+ resLen , err = mc .readResultSetHeaderPacket ()
166
+ if err != nil {
167
167
return
168
168
}
169
169
170
170
if resLen > 0 {
171
- _ , e = mc .readUntilEOF ()
172
- if e != nil {
171
+ _ , err = mc .readUntilEOF ()
172
+ if err != nil {
173
173
return
174
174
}
175
175
176
- mc .affectedRows , e = mc .readUntilEOF ()
177
- if e != nil {
176
+ mc .affectedRows , err = mc .readUntilEOF ()
177
+ if err != nil {
178
178
return
179
179
}
180
180
}
@@ -188,27 +188,27 @@ func (mc *mysqlConn) Query(query string, args []driver.Value) (driver.Rows, erro
188
188
}
189
189
190
190
// Send command
191
- e := mc .writeCommandPacket (COM_QUERY , query )
192
- if e != nil {
193
- return nil , e
191
+ err := mc .writeCommandPacket (COM_QUERY , query )
192
+ if err != nil {
193
+ return nil , err
194
194
}
195
195
196
196
// Read Result
197
197
var resLen int
198
- resLen , e = mc .readResultSetHeaderPacket ()
199
- if e != nil {
200
- return nil , e
198
+ resLen , err = mc .readResultSetHeaderPacket ()
199
+ if err != nil {
200
+ return nil , err
201
201
}
202
202
203
203
rows := mysqlRows {& rowsContent {mc , false , nil , false }}
204
204
205
205
if resLen > 0 {
206
206
// Columns
207
- rows .content .columns , e = mc .readColumns (resLen )
208
- if e != nil {
209
- return nil , e
207
+ rows .content .columns , err = mc .readColumns (resLen )
208
+ if err != nil {
209
+ return nil , err
210
210
}
211
211
}
212
212
213
- return rows , e
213
+ return rows , err
214
214
}
0 commit comments