@@ -106,7 +106,6 @@ func (data *Data) Dump() error {
106
106
DumpVersion : version ,
107
107
}
108
108
109
- // Get server version
110
109
if err := meta .updateServerVersion (data .Connection ); err != nil {
111
110
return err
112
111
}
@@ -119,13 +118,11 @@ func (data *Data) Dump() error {
119
118
return err
120
119
}
121
120
122
- // Get tables
123
121
tables , err := data .getTables ()
124
122
if err != nil {
125
123
return err
126
124
}
127
125
128
- // Get sql for each table
129
126
data .wg .Add (len (tables ))
130
127
for _ , name := range tables {
131
128
if err := data .dumpTable (name ); err != nil {
@@ -137,7 +134,6 @@ func (data *Data) Dump() error {
137
134
return data .err
138
135
}
139
136
140
- // Set complete time
141
137
meta .CompleteTime = time .Now ().String ()
142
138
return data .footerTmpl .Execute (data .Out , meta )
143
139
}
@@ -168,8 +164,8 @@ func (data *Data) writeTable(table *table) {
168
164
169
165
// MARK: get methods
170
166
167
+ // getTemplates initilaizes the templates on data from the constants in this file
171
168
func (data * Data ) getTemplates () (err error ) {
172
- // Write dump to file
173
169
data .headerTmpl , err = template .New ("mysqldumpHeader" ).Parse (headerTmpl )
174
170
if err != nil {
175
171
return
@@ -190,14 +186,12 @@ func (data *Data) getTemplates() (err error) {
190
186
func (data * Data ) getTables () ([]string , error ) {
191
187
tables := make ([]string , 0 )
192
188
193
- // Get table list
194
189
rows , err := data .Connection .Query ("SHOW TABLES" )
195
190
if err != nil {
196
191
return tables , err
197
192
}
198
193
defer rows .Close ()
199
194
200
- // Read result
201
195
for rows .Next () {
202
196
var table sql.NullString
203
197
if err := rows .Scan (& table ); err != nil {
@@ -244,7 +238,6 @@ func (data *Data) createTable(name string) (*table, error) {
244
238
}
245
239
246
240
func (data * Data ) createTableSQL (name string ) (string , error ) {
247
- // Get table creation SQL
248
241
var tableReturn , tableSQL sql.NullString
249
242
err := data .Connection .QueryRow ("SHOW CREATE TABLE " + name ).Scan (& tableReturn , & tableSQL )
250
243
@@ -259,14 +252,12 @@ func (data *Data) createTableSQL(name string) (string, error) {
259
252
}
260
253
261
254
func (data * Data ) createTableValues (name string ) (string , error ) {
262
- // Get Data
263
255
rows , err := data .Connection .Query ("SELECT * FROM " + name )
264
256
if err != nil {
265
257
return "" , err
266
258
}
267
259
defer rows .Close ()
268
260
269
- // Get columns
270
261
columns , err := rows .Columns ()
271
262
if err != nil {
272
263
return "" , err
@@ -275,7 +266,6 @@ func (data *Data) createTableValues(name string) (string, error) {
275
266
return "" , errors .New ("No columns in table " + name + "." )
276
267
}
277
268
278
- // Read data
279
269
dataText := make ([]string , 0 )
280
270
tt , err := rows .ColumnTypes ()
281
271
if err != nil {
@@ -302,7 +292,6 @@ func (data *Data) createTableValues(name string) (string, error) {
302
292
values [i ] = reflect .New (types [i ]).Interface ()
303
293
}
304
294
for rows .Next () {
305
- // Read data
306
295
if err := rows .Scan (values ... ); err != nil {
307
296
return "" , err
308
297
}
@@ -311,7 +300,7 @@ func (data *Data) createTableValues(name string) (string, error) {
311
300
312
301
for key , value := range values {
313
302
if value == nil {
314
- dataStrings [key ] = "null "
303
+ dataStrings [key ] = "NULL "
315
304
} else if s , ok := value .(* sql.NullString ); ok {
316
305
if s .Valid {
317
306
dataStrings [key ] = "'" + sanitize (s .String ) + "'"
0 commit comments