File tree Expand file tree Collapse file tree 1 file changed +8
-8
lines changed Expand file tree Collapse file tree 1 file changed +8
-8
lines changed Original file line number Diff line number Diff line change @@ -643,10 +643,10 @@ func (this *Applier) ApplyIterationInsertQuery() (chunkSize int64, rowsAffected
643
643
fmt .Sprintf ("failed to get connection" )
644
644
return nil , err
645
645
}
646
- if _ , err := conn .ExecContext (context .Background (), "SET @@SESSION.sql_log_bin=0" ); err != nil {
647
- fmt .Sprintf ("failed to disable binary logs" )
648
- return nil , err
649
- }
646
+ // if _, err := conn.ExecContext(context.Background(), "SET @@SESSION.sql_log_bin=0"); err != nil {
647
+ // fmt.Sprintf("failed to disable binary logs")
648
+ // return nil, err
649
+ // }
650
650
tx , err := conn .BeginTx (context .Background (), nil )
651
651
if err != nil {
652
652
return nil , err
@@ -666,10 +666,10 @@ func (this *Applier) ApplyIterationInsertQuery() (chunkSize int64, rowsAffected
666
666
if err := tx .Commit (); err != nil {
667
667
return nil , err
668
668
}
669
- if _ , err := conn .ExecContext (context .Background (), "SET @@SESSION.sql_log_bin=1" ); err != nil {
670
- fmt .Sprintf ("failed to enable binary logs" )
671
- return nil , err
672
- }
669
+ // if _, err := conn.ExecContext(context.Background(), "SET @@SESSION.sql_log_bin=1"); err != nil {
670
+ // fmt.Sprintf("failed to enable binary logs")
671
+ // return nil, err
672
+ // }
673
673
conn .Close ()
674
674
return result , nil
675
675
}()
You can’t perform that action at this time.
0 commit comments