@@ -359,6 +359,7 @@ func (mc *mysqlConn) Exec(query string, args []driver.Value) (driver.Result, err
359
359
// try to interpolate the parameters to save extra roundtrips for preparing and closing a statement
360
360
prepared , err := mc .interpolateParams (query , args )
361
361
if err != nil {
362
+ mc .log (err .Error ())
362
363
return nil , err
363
364
}
364
365
query = prepared
@@ -369,6 +370,7 @@ func (mc *mysqlConn) Exec(query string, args []driver.Value) (driver.Result, err
369
370
copied := mc .result
370
371
return & copied , err
371
372
}
373
+ mc .log (err .Error ())
372
374
return nil , mc .markBadConn (err )
373
375
}
374
376
@@ -377,23 +379,27 @@ func (mc *mysqlConn) exec(query string) error {
377
379
handleOk := mc .clearResult ()
378
380
// Send command
379
381
if err := mc .writeCommandPacketStr (comQuery , query ); err != nil {
382
+ mc .log (err .Error ())
380
383
return mc .markBadConn (err )
381
384
}
382
385
383
386
// Read Result
384
387
resLen , _ , err := handleOk .readResultSetHeaderPacket ()
385
388
if err != nil {
389
+ mc .log (err .Error ())
386
390
return err
387
391
}
388
392
389
393
if resLen > 0 {
390
394
// columns
391
395
if err := mc .skipColumns (resLen ); err != nil {
396
+ mc .log (err .Error ())
392
397
return err
393
398
}
394
399
395
400
// rows
396
401
if err := mc .skipRows (); err != nil {
402
+ mc .log (err .Error ())
397
403
return err
398
404
}
399
405
}
@@ -418,20 +424,23 @@ func (mc *mysqlConn) query(query string, args []driver.Value) (*textRows, error)
418
424
// try client-side prepare to reduce roundtrip
419
425
prepared , err := mc .interpolateParams (query , args )
420
426
if err != nil {
427
+ mc .log (err .Error ())
421
428
return nil , err
422
429
}
423
430
query = prepared
424
431
}
425
432
// Send command
426
433
err := mc .writeCommandPacketStr (comQuery , query )
427
434
if err != nil {
435
+ mc .log (err .Error ())
428
436
return nil , mc .markBadConn (err )
429
437
}
430
438
431
439
// Read Result
432
440
var resLen int
433
441
resLen , _ , err = handleOk .readResultSetHeaderPacket ()
434
442
if err != nil {
443
+ mc .log (err .Error ())
435
444
return nil , err
436
445
}
437
446
@@ -505,7 +514,6 @@ func (mc *mysqlConn) finish() {
505
514
506
515
// Ping implements driver.Pinger interface
507
516
func (mc * mysqlConn ) Ping (ctx context.Context ) (err error ) {
508
- mc .log ("Ping mysql connection" )
509
517
if mc .closed .Load () {
510
518
return driver .ErrBadConn
511
519
}
@@ -572,10 +580,12 @@ func (mc *mysqlConn) QueryContext(ctx context.Context, query string, args []driv
572
580
func (mc * mysqlConn ) ExecContext (ctx context.Context , query string , args []driver.NamedValue ) (driver.Result , error ) {
573
581
dargs , err := namedValueToValue (args )
574
582
if err != nil {
583
+ mc .log (err .Error ())
575
584
return nil , err
576
585
}
577
586
578
587
if err := mc .watchCancel (ctx ); err != nil {
588
+ mc .log (err .Error ())
579
589
return nil , err
580
590
}
581
591
defer mc .finish ()
0 commit comments